Function getWorkerDb

packages/db/src/client.ts:45–52

(connectionString: string, options: GetWorkerDbOptions = {})

 * Return a fresh wrapper per call so request/DO-bound I/O state never crosses contexts.
 */
export function getWorkerDb(connectionString: string, options: GetWorkerDbOptions = {}) {
  const pool = new pg.Pool({
    connectionString,
    max: 1,
    ...options,
  });
  return drizzle(pool, { schema });
}

export type WorkerDb = ReturnType<typeof getWorkerDb>;