Function connectToMySQL

drizzle-kit/src/cli/connections.ts:741–879

(
	it: MysqlCredentials,
)

};

export const connectToMySQL = async (
	it: MysqlCredentials,
): Promise<{
	db: DB;
	packageName: 'mysql2' | '@planetscale/database';
	proxy: Proxy;
	transactionProxy: TransactionProxy;
	database: string;
	migrate: (config: MigrationConfig) => Promise<void>;
}> => {
	const result = parseMysqlCredentials(it);

	if (await checkPackage('mysql2')) {
		const { createConnection } = await import('mysql2/promise');
		const { drizzle } = await import('drizzle-orm/mysql2');
		const { migrate } = await import('drizzle-orm/mysql2/migrator');

		const connection = result.url
			? await createConnection(result.url)
			: await createConnection(result.credentials!); // needed for some reason!

		const db = drizzle(connection);
		const migrateFn = async (config: MigrationConfig) => {
			return migrate(db, config);
		};

		const typeCast = (field: any, next: any) => {
			if (field.type === 'TIMESTAMP' || field.type === 'DATETIME' || field.type === 'DATE') {
				return field.string();
			}
			return next();
		};

		await connection.connect();
		const query: DB['query'] = async <T>(
			sql: string,
			params?: any[],
		): Promise<T[]> => {
			const res = await connection.execute({
				sql,
				values: params,
				typeCast,
			});
			return res[0] as any;
		};

		const proxy: Proxy = async (params: ProxyParams) => {
			const result = await connection.query({
				sql: params.sql,
				values: params.params,
				rowsAsArray: params.mode === 'array',
				typeCast,
			});
			return result[0] as any[];
		};

		const transactionProxy: TransactionProxy = async (queries) => {
			const results: any[] = [];