Function ensureDatabaseExists

packages/migrate/src/utils/ensureDatabaseExists.ts:131–169

(
  pathResolutionRoot: string,
  provider: ConnectorType,
  config: PrismaConfigWithDatasource,
)

type SuccessMessage = string

export async function ensureDatabaseExists(
  pathResolutionRoot: string,
  provider: ConnectorType,
  config: PrismaConfigWithDatasource,
): Promise<SuccessMessage | undefined> {
  const url = config.datasource.url

  const canConnect = await canConnectToDatabase(url, pathResolutionRoot)
  if (canConnect === true) {
    return
  }
  const { code, message } = canConnect

  // P1003 means we can connect but that the database doesn't exist
  if (code !== 'P1003') {
    throw new Error(`${code}: ${message}`)
  }

  if (await createDatabase(url, pathResolutionRoot)) {
    // URI parsing is not implemented for SQL server yet
    if (provider === 'sqlserver') {
      return `SQL Server database created.\n`
    }

    // parse the url
    const credentials = uriToCredentials(url)
    const prettyProvider = prettifyProvider(provider)

    let message = `${prettyProvider} database${credentials.database ? ` ${credentials.database} ` : ' '}created`
    const dbLocation = getDbLocation(credentials)
    if (dbLocation) {
      message += ` at ${bold(dbLocation)}`
    }

    return message
  }

  return undefined
}

// returns the "host" like localhost / 127.0.0.1 + default port
export function getDbLocation(credentials: DatabaseCredentials): string | undefined {