driver.js 1.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940
  1. import { entityKind } from "../entity.js";
  2. import { DefaultLogger } from "../logger.js";
  3. import { MySqlDatabase } from "../mysql-core/db.js";
  4. import { MySqlDialect } from "../mysql-core/dialect.js";
  5. import {
  6. createTableRelationsHelpers,
  7. extractTablesRelationalConfig
  8. } from "../relations.js";
  9. import { MySqlRemoteSession } from "./session.js";
  10. class MySqlRemoteDatabase extends MySqlDatabase {
  11. static [entityKind] = "MySqlRemoteDatabase";
  12. }
  13. function drizzle(callback, config = {}) {
  14. const dialect = new MySqlDialect({ casing: config.casing });
  15. let logger;
  16. if (config.logger === true) {
  17. logger = new DefaultLogger();
  18. } else if (config.logger !== false) {
  19. logger = config.logger;
  20. }
  21. let schema;
  22. if (config.schema) {
  23. const tablesConfig = extractTablesRelationalConfig(
  24. config.schema,
  25. createTableRelationsHelpers
  26. );
  27. schema = {
  28. fullSchema: config.schema,
  29. schema: tablesConfig.tables,
  30. tableNamesMap: tablesConfig.tableNamesMap
  31. };
  32. }
  33. const session = new MySqlRemoteSession(callback, dialect, schema, { logger });
  34. return new MySqlRemoteDatabase(dialect, session, schema, "default");
  35. }
  36. export {
  37. MySqlRemoteDatabase,
  38. drizzle
  39. };
  40. //# sourceMappingURL=driver.js.map