Function runStatement

repos/effect/packages/sql/d1/src/D1Client.ts:121–134

(
        statement: D1PreparedStatement,
        params: ReadonlyArray<unknown> = []
      )

type TransformRows = <A extends object>(rows: ReadonlyArray<A>) => ReadonlyArray<A>

type BatchResults<Statements extends ReadonlyArray<Statement.Statement<any>>> = {
  readonly [K in keyof Statements]: Effect.Success<Statements[K]>
}

interface StatementWithTransformRows extends Statement.Statement<any> {
  readonly transformRows: TransformRows | undefined
}

const makeBatch = (options: {
  readonly db: D1Database
  readonly prepareCache: Cache.Cache<string, D1PreparedStatement, SqlError>
  readonly spanAttributes: ReadonlyArray<readonly [string, unknown]>
  readonly getClient: () => D1Client
}): D1Client["batch"] =>
<const Statements extends ReadonlyArray<Statement.Statement<any>>>(
  statements: Statements