(
sql: string,
params: ReadonlyArray<unknown> = []
)
| 103 | }) |
| 104 | |
| 105 | const runValues = ( |
| 106 | sql: string, |
| 107 | params: ReadonlyArray<unknown> = [] |
| 108 | ): Effect.Effect<ReadonlyArray<any>, SqlError, never> => |
| 109 | Effect.try({ |
| 110 | try: () => |
| 111 | Array.from(db.exec(sql, ...params).raw(), (row) => { |
| 112 | for (let i = 0; i < row.length; i++) { |
| 113 | const value = row[i] |
| 114 | if (value instanceof ArrayBuffer) { |
| 115 | row[i] = new Uint8Array(value) as any |
| 116 | } |
| 117 | } |
| 118 | return row |
| 119 | }), |
| 120 | catch: (cause) => new SqlError({ cause, message: `Failed to execute statement` }) |
| 121 | }) |
| 122 | |
| 123 | return identity<Connection>({ |
| 124 | execute(sql, params, transformRows) { |
no test coverage detected
searching dependent graphs…