Function getDatabase

db/cli.ts:177–228

* Creates a new Knex.js database connection.

(options?: { env?: string; schema?: string })

 * Creates a new Knex.js database connection.
 */
function getDatabase(options?: { env?: string; schema?: string }) {
  loadEnv(options?.env);
  let connector: Connector | undefined = undefined;
  const db = knex({
    client: "pg",
    async connection() {
      if (/^\S+:\S+:\S+$/.test(process.env.PGHOST ?? "")) {
        connector = new Connector();
        const options = await connector.getOptions({
          instanceConnectionName: process.env.PGHOST!,
          ipType: IpAddressTypes.PUBLIC,
        });
        return {
          ...options,
          user: process.env.PGUSER,
          password: process.env.PGPASSWORD,
          database: process.env.PGDATABASE,
        };
      }
      return {
        user: process.env.PGUSER,
        password: process.env.PGPASSWORD,
        host: process.env.PGHOST,
        port: parseInt(process.env.PGPORT!),
        database: process.env.PGDATABASE,
      };
    },
    migrations: {
      directory: relative(process.cwd(), migrationsDir),
      tableName: "migration",
      schemaName: options?.schema,
      extension: "ts",
    },
    seeds: {
      directory: relative(process.cwd(), seedsDir),
      extension: "ts",
    },
  });

  const destroy = db.destroy;
  Object.defineProperty(db, "destroy", {
    value: async () => {
      await destroy.call(db);
      connector?.close();
    },
    writable: false,
    enumerable: false,
    configurable: true,
  });

  return db;
}

async function version(options?: { env?: string; schema?: string }) {
  const db = getDatabase(options);