(
sql: string,
params: ReadonlyArray<unknown>,
transformRows: (<A extends object>(row: ReadonlyArray<A>) => ReadonlyArray<A>) | undefined
)
| 667 | return this.runWithClient<ReadonlyArray<any>>((client, resume) => { |
| 668 | client.query(query, params as any, (err, result) => { |
| 669 | if (err) { |
| 670 | resume( |
| 671 | Effect.fail(new SqlError({ reason: classifyError(err, "Failed to execute statement", "execute") })) |
| 672 | ) |
| 673 | } else { |
| 674 | // Multi-statement queries return an array of results |
| 675 | resume(Effect.succeed( |
| 676 | Array.isArray(result) |
| 677 | ? result.map((r) => r.rows ?? []) |
| 678 | : result.rows ?? [] |
| 679 | )) |
| 680 | } |