Class MySqlDatabase

src/Databases/MySqlDatabase.ts:25–134

};

export default class MySqlDatabase implements DatabaseInterface {
	public readonly connection: Pool|PoolConnection;

	constructor(connection: PoolConfig|Pool|PoolConnection) {
		if (isPoolOrPoolConnection(connection)) {
			this.connection = <Pool|PoolConnection>connection;
		} else {
			this.connection = createPool(<PoolConfig>connection);
		}
	}

	async disconnect(): Promise<void> {
		if (isPool(this.connection)) {
			return new Promise((resolve, reject) => {
				this.connection.end(err => {
					if (err) {
						reject(err);
					} else {
						resolve();
					}
				});
			});
		}
	}

	indexToPlaceholder (i: number): string {
		return '?';
	}

	async query(query: SqlQuery): Promise<any[]> {
		return new Promise((resolve, reject) => {
			const compiledQuery = query.compile(this.indexToPlaceholder, formatIdentifier);

			this.connection.query(
				compiledQuery.sql,
				<any[]><any>compiledQuery.params,
				(error, rows) => {
					if (error) {
						reject(error);
					} else {
						resolve(rows);
					}
				},
			);
		});
	}

	async sequence<T>(
		sequence: (sequenceDb: MySqlDatabase) => Promise<T>,
	): Promise<T> {
		if (!isPool(this.connection)) {
			// Already in a sequence, so another call changes nothing but works for conveniency
			return sequence(this);
		}

		const client: PoolConnection = await new Promise((resolve, reject) => {
			(<Pool>this.connection).getConnection((error: MysqlError, connection: PoolConnection) => {
				if (error) {