feat(worker-dialect): expose createSqliteExecutor

Author: subframe7536

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

@@ -23,7 +23,8 @@ export const defaultCreateDatabaseFn: CreateDatabaseFn
   = fileName => new Database(fileName, { create: true })
 
 /**
- * Handle worker message, support custom callback on initialization
+ * Handle worker message, support custom callback on initialization.
+ * Built-in: {@link defaultCreateDatabaseFn}
  * @example
  * // worker.ts
  * import { createOnMessageCallback } from 'kysely-bun-worker'
@@ -47,7 +48,7 @@ export function createOnMessageCallback(
   )
 }
 
-function createSqliteExecutor(db: Database, cache: boolean): IGenericSqlite<Database> {
+export function createSqliteExecutor(db: Database, cache: boolean): IGenericSqlite<Database> {
   const fn = cache ? 'query' : 'prepare'
   const getStmt = (sql: string, parameters?: any[]) => db[fn](sql, parameters)
 

packages/dialect-sqlite-worker/src/worker/utils.ts

@@ -14,7 +14,8 @@ export const defaultCreateDatabaseFn: CreateDatabaseFn
   = (fileName, options) => new Database(fileName, options)
 
 /**
- * Handle worker message, support custom message handler
+ * Handle worker message, support custom message handler,
+ * built-in: {@link defaultCreateDatabaseFn}
  * @example
  * in `worker.ts`
  * ```ts
@@ -48,7 +49,7 @@ export function createOnMessageCallback(
   )
 }
 
-function createSqliteExecutor(db: BetterSqlite3.Database): IGenericSqlite<BetterSqlite3.Database> {
+export function createSqliteExecutor(db: BetterSqlite3.Database): IGenericSqlite<BetterSqlite3.Database> {
   const getStmt = (sql: string) => db.prepare(sql)
 
   return {

packages/dialect-wasqlite-worker/src/worker/utils.ts

@@ -32,7 +32,7 @@ function createRowMapper(sqlite: SQLiteDBCore['sqlite'], stmt: number) {
   return (row: any[]) => Object.fromEntries(cols.map((key, i) => [key, row[i]]))
 }
 
-export async function queryData(
+async function queryData(
   core: SQLiteDBCore,
   sql: string,
   parameters?: readonly any[],
@@ -66,7 +66,7 @@ export async function queryData(
   return { rows: result }
 }
 
-export async function* iterateDate(
+async function* iterateDate(
   core: SQLiteDBCore,
   sql: string,
   parameters?: readonly any[],
@@ -105,7 +105,8 @@ export async function* iterateDate(
 }
 
 /**
- * Handle worker message, support custom message handler
+ * Handle worker message, support custom message handler,
+ * built-in: {@link defaultCreateDatabaseFn}
  * @example
  * in `worker.ts`
  * ```ts
@@ -139,7 +140,7 @@ export function createOnMessageCallback(
   )
 }
 
-function createSqliteExecutor(db: SQLiteDBCore): IGenericSqlite<SQLiteDBCore> {
+export function createSqliteExecutor(db: SQLiteDBCore): IGenericSqlite<SQLiteDBCore> {
   return {
     db,
     query: async (_isSelect, sql, parameters) => await queryData(db, sql, parameters),