feat(dialect-bun-worker): add BunSqliteDialect

Author: subframe7536

packages/dialect-bun-worker/package.json

@@ -26,6 +26,10 @@
       "import": "./dist/index.mjs",
       "require": "./dist/index.js"
     },
+    "./normal": {
+      "import": "./dist/normal.mjs",
+      "require": "./dist/normal.js"
+    },
     "./worker": {
       "import": "./dist/worker.mjs",
       "require": "./dist/worker.js"
@@ -36,6 +40,9 @@
   "module": "./dist/index.mjs",
   "typesVersions": {
     "*": {
+      "normal": [
+        "./dist/normal.d.ts"
+      ],
       "worker": [
         "./dist/index.d.ts"
       ]

packages/dialect-bun-worker/src/normal.ts

@@ -0,0 +1,20 @@
+import type { BunSqliteDialectConfig } from './type'
+
+import Database from 'bun:sqlite'
+import { GenericSqliteDialect } from 'kysely-generic-sqlite'
+
+import { createSqliteExecutor } from './worker/utils'
+
+export class BunSqliteDialect extends GenericSqliteDialect {
+  constructor(config?: BunSqliteDialectConfig) {
+    const {
+      url = ':memory:',
+      cacheStatment = false,
+      onCreateConnection,
+    } = config || {}
+    super(
+      () => createSqliteExecutor(new Database(url), cacheStatment),
+      onCreateConnection,
+    )
+  }
+}

packages/dialect-bun-worker/src/type.ts

@@ -22,3 +22,17 @@ export type InitData = {
   fileName: string
   cache: boolean
 }
+
+export interface BunSqliteDialectConfig extends IBaseSqliteDialectConfig {
+  /**
+   * db file path
+   *
+   * @default ':memory:'
+   */
+  url?: string
+  /**
+   * use `bun:sqlite` built-in statment cache
+   * @see https://bun.sh/docs/api/sqlite#query
+   */
+  cacheStatment?: boolean
+}