Class ConnectionBuilder

src/kysely.ts:834–858

}

export class ConnectionBuilder<DB> {
  readonly #props: ConnectionBuilderProps

  constructor(props: ConnectionBuilderProps) {
    this.#props = freeze(props)
  }

  async execute<T>(
    callback: (db: Kysely<DB>) => Promise<T>,
    options?: AbortableOperationOptions,
  ): Promise<T> {
    return this.#props.executor.provideConnection(
      async (connection) => {
        const executor = this.#props.executor.withConnectionProvider(
          new SingleConnectionProvider(connection),
        )

        const db = new Kysely<DB>({ ...this.#props, executor })

        return await callback(db)
      },
      freeze({ signal: options?.signal }),
    )
  }
}

interface ConnectionBuilderProps extends KyselyProps {}