driver.js 2.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687
  1. import { Client } from "@planetscale/database";
  2. import { entityKind } from "../entity.js";
  3. import { DefaultLogger } from "../logger.js";
  4. import { MySqlDatabase } from "../mysql-core/db.js";
  5. import { MySqlDialect } from "../mysql-core/dialect.js";
  6. import {
  7. createTableRelationsHelpers,
  8. extractTablesRelationalConfig
  9. } from "../relations.js";
  10. import { isConfig } from "../utils.js";
  11. import { PlanetscaleSession } from "./session.js";
  12. class PlanetScaleDatabase extends MySqlDatabase {
  13. static [entityKind] = "PlanetScaleDatabase";
  14. }
  15. function construct(client, config = {}) {
  16. if (!(client instanceof Client)) {
  17. throw new Error(`Warning: You need to pass an instance of Client:
  18. import { Client } from "@planetscale/database";
  19. const client = new Client({
  20. host: process.env["DATABASE_HOST"],
  21. username: process.env["DATABASE_USERNAME"],
  22. password: process.env["DATABASE_PASSWORD"],
  23. });
  24. const db = drizzle(client);
  25. `);
  26. }
  27. const dialect = new MySqlDialect({ casing: config.casing });
  28. let logger;
  29. if (config.logger === true) {
  30. logger = new DefaultLogger();
  31. } else if (config.logger !== false) {
  32. logger = config.logger;
  33. }
  34. let schema;
  35. if (config.schema) {
  36. const tablesConfig = extractTablesRelationalConfig(
  37. config.schema,
  38. createTableRelationsHelpers
  39. );
  40. schema = {
  41. fullSchema: config.schema,
  42. schema: tablesConfig.tables,
  43. tableNamesMap: tablesConfig.tableNamesMap
  44. };
  45. }
  46. const session = new PlanetscaleSession(client, dialect, void 0, schema, { logger, cache: config.cache });
  47. const db = new PlanetScaleDatabase(dialect, session, schema, "planetscale");
  48. db.$client = client;
  49. db.$cache = config.cache;
  50. if (db.$cache) {
  51. db.$cache["invalidate"] = config.cache?.onMutate;
  52. }
  53. return db;
  54. }
  55. function drizzle(...params) {
  56. if (typeof params[0] === "string") {
  57. const instance = new Client({
  58. url: params[0]
  59. });
  60. return construct(instance, params[1]);
  61. }
  62. if (isConfig(params[0])) {
  63. const { connection, client, ...drizzleConfig } = params[0];
  64. if (client) return construct(client, drizzleConfig);
  65. const instance = typeof connection === "string" ? new Client({
  66. url: connection
  67. }) : new Client(
  68. connection
  69. );
  70. return construct(instance, drizzleConfig);
  71. }
  72. return construct(params[0], params[1]);
  73. }
  74. ((drizzle2) => {
  75. function mock(config) {
  76. return construct({}, config);
  77. }
  78. drizzle2.mock = mock;
  79. })(drizzle || (drizzle = {}));
  80. export {
  81. PlanetScaleDatabase,
  82. drizzle
  83. };
  84. //# sourceMappingURL=driver.js.map