Function setupMysql

packages/client/src/utils/setupMysql.ts:11–31

(options: SetupParams)

}

export async function setupMysql(options: SetupParams): Promise<void> {
  const { connectionString } = options
  const { dirname } = options
  const schema = fs.readFileSync(path.join(dirname, 'setup.sql'), 'utf-8')

  await createDatabase(connectionString).catch((e) => console.error(e))

  const credentials = uriToCredentials(connectionString)
  const db = await mariadb.createConnection({
    host: credentials.host,
    port: credentials.port,
    database: credentials.database,
    user: credentials.user,
    password: credentials.password,
    multipleStatements: true,
    allowPublicKeyRetrieval: true,
  })

  await db.query(schema)
  await db.end()
}

export async function tearDownMysql(connectionString: string) {
  const credentials = uriToCredentials(connectionString)