Method createDriver

app/src/sqlite/dialect.ts:23–64

()

	}

	createDriver() {
		const load = this.database
		const waiter = mutex()

		let db: CRDatabase
		let connection: DatabaseConnection

		return {
			async init() {
				db = await load()
				connection = {
					async executeQuery<O>(query: CompiledQuery) {
						return {
							rows: (await db.execO(query.sql, query.parameters)) as O[],
						}
					},
					async *streamQuery() {
						throw new Error("Sqlite driver doesn't support streaming")
					},
				}
			},
			async acquireConnection() {
				await waiter.lock()
				return connection
			},
			async beginTransaction(connection: DatabaseConnection) {
				await connection.executeQuery(CompiledQuery.raw('begin'))
			},
			async commitTransaction(connection: DatabaseConnection) {
				await connection.executeQuery(CompiledQuery.raw('commit'))
			},
			async rollbackTransaction(connection: DatabaseConnection) {
				await connection.executeQuery(CompiledQuery.raw('rollback'))
			},
			async releaseConnection() {
				waiter.unlock()
			},
			async destroy() {
				db.close()
			},
		}
	}
}

function mutex() {