driver.cjs 3.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  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 driver_exports = {};
  20. __export(driver_exports, {
  21. BunSQLiteDatabase: () => BunSQLiteDatabase,
  22. drizzle: () => drizzle
  23. });
  24. module.exports = __toCommonJS(driver_exports);
  25. var import_bun_sqlite = require("bun:sqlite");
  26. var import_entity = require("../entity.cjs");
  27. var import_logger = require("../logger.cjs");
  28. var import_relations = require("../relations.cjs");
  29. var import_db = require("../sqlite-core/db.cjs");
  30. var import_dialect = require("../sqlite-core/dialect.cjs");
  31. var import_utils = require("../utils.cjs");
  32. var import_session = require("./session.cjs");
  33. class BunSQLiteDatabase extends import_db.BaseSQLiteDatabase {
  34. static [import_entity.entityKind] = "BunSQLiteDatabase";
  35. }
  36. function construct(client, config = {}) {
  37. const dialect = new import_dialect.SQLiteSyncDialect({ casing: config.casing });
  38. let logger;
  39. if (config.logger === true) {
  40. logger = new import_logger.DefaultLogger();
  41. } else if (config.logger !== false) {
  42. logger = config.logger;
  43. }
  44. let schema;
  45. if (config.schema) {
  46. const tablesConfig = (0, import_relations.extractTablesRelationalConfig)(
  47. config.schema,
  48. import_relations.createTableRelationsHelpers
  49. );
  50. schema = {
  51. fullSchema: config.schema,
  52. schema: tablesConfig.tables,
  53. tableNamesMap: tablesConfig.tableNamesMap
  54. };
  55. }
  56. const session = new import_session.SQLiteBunSession(client, dialect, schema, { logger });
  57. const db = new BunSQLiteDatabase("sync", dialect, session, schema);
  58. db.$client = client;
  59. return db;
  60. }
  61. function drizzle(...params) {
  62. if (params[0] === void 0 || typeof params[0] === "string") {
  63. const instance = params[0] === void 0 ? new import_bun_sqlite.Database() : new import_bun_sqlite.Database(params[0]);
  64. return construct(instance, params[1]);
  65. }
  66. if ((0, import_utils.isConfig)(params[0])) {
  67. const { connection, client, ...drizzleConfig } = params[0];
  68. if (client) return construct(client, drizzleConfig);
  69. if (typeof connection === "object") {
  70. const { source, ...opts } = connection;
  71. const options = Object.values(opts).filter((v) => v !== void 0).length ? opts : void 0;
  72. const instance2 = new import_bun_sqlite.Database(source, options);
  73. return construct(instance2, drizzleConfig);
  74. }
  75. const instance = new import_bun_sqlite.Database(connection);
  76. return construct(instance, drizzleConfig);
  77. }
  78. return construct(params[0], params[1]);
  79. }
  80. ((drizzle2) => {
  81. function mock(config) {
  82. return construct({}, config);
  83. }
  84. drizzle2.mock = mock;
  85. })(drizzle || (drizzle = {}));
  86. // Annotate the CommonJS export names for ESM import in node:
  87. 0 && (module.exports = {
  88. BunSQLiteDatabase,
  89. drizzle
  90. });
  91. //# sourceMappingURL=driver.cjs.map