diff --git a/src/db/adapters/DittoSQLite.ts b/src/db/adapters/DittoSQLite.ts index c78ab67..47c7ae8 100644 --- a/src/db/adapters/DittoSQLite.ts +++ b/src/db/adapters/DittoSQLite.ts @@ -1,7 +1,6 @@ import { Conf } from '@/config.ts'; import { DittoTables } from '@/db/DittoTables.ts'; -import { Kysely, PolySqliteDialect } from '@/deps.ts'; -import { setPragma } from '@/pragma.ts'; +import { Kysely, PolySqliteDialect, sql } from '@/deps.ts'; import SqliteWorker from '@/workers/sqlite.ts'; export class DittoSQLite { @@ -20,9 +19,9 @@ export class DittoSQLite { // Set PRAGMA values. await Promise.all([ - setPragma(this.db, 'synchronous', 'normal'), - setPragma(this.db, 'temp_store', 'memory'), - setPragma(this.db, 'mmap_size', Conf.sqlite.mmapSize), + sql`PRAGMA synchronous = normal`.execute(this.db), + sql`PRAGMA temp_store = memory`.execute(this.db), + sql.raw(`PRAGMA mmap_size = ${Conf.sqlite.mmapSize}`).execute(this.db), ]); } return this.db; diff --git a/src/pragma.ts b/src/pragma.ts deleted file mode 100644 index f5aa8e4..0000000 --- a/src/pragma.ts +++ /dev/null @@ -1,15 +0,0 @@ -import { type Kysely, sql } from '@/deps.ts'; - -/** Set the PRAGMA and then read back its value to confirm. */ -function setPragma(db: Kysely, pragma: string, value: string | number) { - return sql.raw(`PRAGMA ${pragma} = ${value}`).execute(db); -} - -/** Get value of PRAGMA from the database. */ -async function getPragma(db: Kysely, pragma: string) { - const result = await sql.raw(`PRAGMA ${pragma}`).execute(db); - const row = result.rows[0] as Record | undefined; - return row?.[pragma]; -} - -export { getPragma, setPragma };