Function createDatabase

tests/sandbox/src/steps/database.ts:11–100

(env: Env, logger: Logger)

 * Connection settings mirror directus setup
 */
export function createDatabase(env: Env, logger: Logger): Knex {
	const client = env.DB_CLIENT;

	const connection: Record<string, any> =
		client === 'sqlite3'
			? { filename: env.DB_FILENAME }
			: {
					host: env.DB_HOST,
					port: Number(env.DB_PORT),
					user: env.DB_USER,
					password: env.DB_PASSWORD,
					database: env.DB_DATABASE,
				};

	const poolConfig: Knex.PoolConfig = {};

	const knexConfig: Knex.Config = {
		client,
		connection,
		pool: poolConfig,
		log: {
			warn: (msg) => {
				// Ignore warnings about returning not being supported in some DBs
				if (msg.startsWith('.returning()')) return;
				if (msg.endsWith('does not currently support RETURNING clause')) return;

				// Ignore warning about MySQL not supporting TRX for DDL
				if (msg.startsWith('Transaction was implicitly committed, do not mix transactions and DDL with MySQL')) return;

				return logger.warn(msg);
			},
			error: (msg) => logger.error(msg),
			deprecate: (msg) => logger.info(msg),
			debug: (msg) => logger.debug(msg),
		},
	};

	if (client === 'sqlite3') {
		knexConfig.useNullAsDefault = true;

		poolConfig.afterCreate = (conn: any, callback: any) => {
			logger.info('Enabling SQLite Foreign Keys support...');

			conn.run('PRAGMA foreign_keys = ON');

			callback(null, conn);
		};
	}

	if (client === 'cockroachdb') {
		poolConfig.afterCreate = (conn: any, callback: any) => {
			logger.info('Setting CRDB serial_normalization and default_int_size');

			conn.query('SET serial_normalization = "sql_sequence"');
			conn.query('SET default_int_size = 4');

			callback(null, conn);
		};