(
sql: string,
params: ReadonlyArray<unknown> = []
)
| 215 | catch: (cause) => new SqlError({ reason: classifyError(cause, "Failed to execute statement", "execute") }) |
| 216 | }) |
| 217 | |
| 218 | const runValues = ( |
| 219 | sql: string, |
| 220 | params: ReadonlyArray<unknown> = [] |
| 221 | ): Effect.Effect<ReadonlyArray<any>, SqlError, never> => |
| 222 | Effect.try({ |
| 223 | try: () => |
| 224 | Array.from(sqlStorage.exec(sql, ...params).raw(), (row) => { |
| 225 | for (let i = 0; i < row.length; i++) { |
| 226 | const value = row[i] |
| 227 | if (value instanceof ArrayBuffer) { |
| 228 | row[i] = new Uint8Array(value) as any |
| 229 | } |
| 230 | } |
| 231 | return row |
| 232 | }), |
| 233 | catch: (cause) => new SqlError({ reason: classifyError(cause, "Failed to execute statement", "execute") }) |
| 234 | }) |
| 235 | |
| 236 | return identity<Connection>({ |
no test coverage detected
searching dependent graphs…