Function createDatabase

db/cli.ts:253–287

* Creates a new database if it does not exist.

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

 * Creates a new database if it does not exist.
 */
async function createDatabase(options: { env?: string; schema?: string } = {}) {
  let db = getDatabase(options);
  const dbName = process.env.PGDATABASE;
  const pgUser = process.env.PGUSER;

  if (!dbName) throw new Error("PGDATABASE is not set");
  if (!pgUser) throw new Error("PGUSER is not set");

  try {
    await db.select(db.raw("current_database()"));
  } catch (err) {
    // Error code 3D000 indicates that the database does not exist.
    if ((err as NodeJS.ErrnoException).code !== "3D000") {
      throw err;
    }

    await db.destroy();

    process.env.PGDATABASE = "template1";

    db = getDatabase(options);

    // Attempt to create a new database.
    await db.raw(`CREATE DATABASE ?? WITH OWNER ??`, [dbName, pgUser]);

    // Attempt to create a new database schema.
    await db.raw(`CREATE SCHEMA IF NOT EXISTS ?? AUTHORIZATION ??`, [
      options?.schema,
      pgUser,
    ]);
  } finally {
    process.env.PGDATABASE = dbName;
    await db.destroy();
  }
}

/**
 * Launches an interactive terminal with Knex.js.