(
statement: D1PreparedStatement,
params: ReadonlyArray<unknown> = []
)
| 222 | }) |
| 223 | |
| 224 | const runStatement = ( |
| 225 | statement: D1PreparedStatement, |
| 226 | params: ReadonlyArray<unknown> = [] |
| 227 | ): Effect.Effect<ReadonlyArray<any>, SqlError, never> => |
| 228 | Effect.tryPromise({ |
| 229 | try: async () => { |
| 230 | const response = await statement.bind(...params).all() |
| 231 | if (response.error) { |
| 232 | throw response.error |
| 233 | } |
| 234 | return response.results || [] |
| 235 | }, |
| 236 | catch: (cause) => new SqlError({ reason: classifyError(cause, "Failed to execute statement", "execute") }) |
| 237 | }) |
| 238 | |
| 239 | const runRaw = ( |
| 240 | sql: string, |
no test coverage detected