query-builder.cjs 3.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114
  1. "use strict";
  2. var __defProp = Object.defineProperty;
  3. var __getOwnPropDesc = Object.getOwnPropertyDescriptor;
  4. var __getOwnPropNames = Object.getOwnPropertyNames;
  5. var __hasOwnProp = Object.prototype.hasOwnProperty;
  6. var __export = (target, all) => {
  7. for (var name in all)
  8. __defProp(target, name, { get: all[name], enumerable: true });
  9. };
  10. var __copyProps = (to, from, except, desc) => {
  11. if (from && typeof from === "object" || typeof from === "function") {
  12. for (let key of __getOwnPropNames(from))
  13. if (!__hasOwnProp.call(to, key) && key !== except)
  14. __defProp(to, key, { get: () => from[key], enumerable: !(desc = __getOwnPropDesc(from, key)) || desc.enumerable });
  15. }
  16. return to;
  17. };
  18. var __toCommonJS = (mod) => __copyProps(__defProp({}, "__esModule", { value: true }), mod);
  19. var query_builder_exports = {};
  20. __export(query_builder_exports, {
  21. QueryBuilder: () => QueryBuilder
  22. });
  23. module.exports = __toCommonJS(query_builder_exports);
  24. var import_entity = require("../../entity.cjs");
  25. var import_dialect = require("../dialect.cjs");
  26. var import_selection_proxy = require("../../selection-proxy.cjs");
  27. var import_subquery = require("../../subquery.cjs");
  28. var import_select = require("./select.cjs");
  29. class QueryBuilder {
  30. static [import_entity.entityKind] = "GelQueryBuilder";
  31. dialect;
  32. dialectConfig;
  33. constructor(dialect) {
  34. this.dialect = (0, import_entity.is)(dialect, import_dialect.GelDialect) ? dialect : void 0;
  35. this.dialectConfig = (0, import_entity.is)(dialect, import_dialect.GelDialect) ? void 0 : dialect;
  36. }
  37. $with(alias) {
  38. const queryBuilder = this;
  39. return {
  40. as(qb) {
  41. if (typeof qb === "function") {
  42. qb = qb(queryBuilder);
  43. }
  44. return new Proxy(
  45. new import_subquery.WithSubquery(qb.getSQL(), qb.getSelectedFields(), alias, true),
  46. new import_selection_proxy.SelectionProxyHandler({ alias, sqlAliasedBehavior: "alias", sqlBehavior: "error" })
  47. );
  48. }
  49. };
  50. }
  51. with(...queries) {
  52. const self = this;
  53. function select(fields) {
  54. return new import_select.GelSelectBuilder({
  55. fields: fields ?? void 0,
  56. session: void 0,
  57. dialect: self.getDialect(),
  58. withList: queries
  59. });
  60. }
  61. function selectDistinct(fields) {
  62. return new import_select.GelSelectBuilder({
  63. fields: fields ?? void 0,
  64. session: void 0,
  65. dialect: self.getDialect(),
  66. distinct: true
  67. });
  68. }
  69. function selectDistinctOn(on, fields) {
  70. return new import_select.GelSelectBuilder({
  71. fields: fields ?? void 0,
  72. session: void 0,
  73. dialect: self.getDialect(),
  74. distinct: { on }
  75. });
  76. }
  77. return { select, selectDistinct, selectDistinctOn };
  78. }
  79. select(fields) {
  80. return new import_select.GelSelectBuilder({
  81. fields: fields ?? void 0,
  82. session: void 0,
  83. dialect: this.getDialect()
  84. });
  85. }
  86. selectDistinct(fields) {
  87. return new import_select.GelSelectBuilder({
  88. fields: fields ?? void 0,
  89. session: void 0,
  90. dialect: this.getDialect(),
  91. distinct: true
  92. });
  93. }
  94. selectDistinctOn(on, fields) {
  95. return new import_select.GelSelectBuilder({
  96. fields: fields ?? void 0,
  97. session: void 0,
  98. dialect: this.getDialect(),
  99. distinct: { on }
  100. });
  101. }
  102. // Lazy load dialect to avoid circular dependency
  103. getDialect() {
  104. if (!this.dialect) {
  105. this.dialect = new import_dialect.GelDialect(this.dialectConfig);
  106. }
  107. return this.dialect;
  108. }
  109. }
  110. // Annotate the CommonJS export names for ESM import in node:
  111. 0 && (module.exports = {
  112. QueryBuilder
  113. });
  114. //# sourceMappingURL=query-builder.cjs.map