Class SqliteDatabase

src/Databases/SqliteDatabase.ts:12–103

};

export default class SqliteDatabase implements DatabaseInterface {
	public readonly connection: Database;

	constructor(connection: SqliteConfig|Database) {
		if (connection instanceof Database) {
			this.connection = connection;
		} else {
			this.connection = new Database(
				connection.filename,
				connection.mode,
			);
		}
	}

	async disconnect(): Promise<void> {
		if (this.connection instanceof Database) {
			return new Promise((resolve, reject) => {
				this.connection.close(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.all(
				compiledQuery.sql,
				<any[]><any>compiledQuery.params,
				(error, rows) => {
					if (error) {
						reject(error);
					} else {
						resolve(rows);
					}
				},
			);
		});
	}

	async sequence<T>(
		sequence: (sequenceDb: SqliteDatabase) => Promise<T>,
	): Promise<T> {
		return new Promise((resolve, reject) => {
			this.connection.serialize(async () => {
				try {
					const result = await sequence(this);
					resolve(result);