Function createDatabase

packages/internals/src/schemaEngineCommands.ts:108–141

(connectionString: string, cwd = process.cwd(), schemaEnginePath?: string)

// could be refactored with engines using JSON RPC instead and just passing the schema
export async function createDatabase(connectionString: string, cwd = process.cwd(), schemaEnginePath?: string) {
  const dbExists = await canConnectToDatabase(connectionString, cwd, schemaEnginePath)

  // If database is already created, stop here, don't create it
  if (dbExists === true) {
    return false
  }

  try {
    await execaCommand({
      connectionString,
      cwd,
      schemaEnginePath,
      engineCommandName: 'create-database',
    })

    return true
  } catch (_e) {
    const e = _e as ExecaError

    if (e.stderr) {
      const logs = parseJsonFromStderr(e.stderr)
      const error = logs.find((it) => it.level === 'ERROR' && it.target === 'schema_engine::logger')

      if (error && error.fields.error_code && error.fields.message) {
        throw new Error(`${error.fields.error_code}: ${error.fields.message}`)
      } else {
        throw new Error(`Schema engine error:\n${logs.map((log) => log.fields.message).join('\n')}`)
      }
    } else {
      throw new Error(`Schema engine exited. ${_e}`)
    }
  }
}

export async function dropDatabase(connectionString: string, cwd = process.cwd(), schemaEnginePath?: string) {
  try {