(
statement: StatementSync,
params: ReadonlyArray<unknown>,
raw: boolean
)
| 162 | }) |
| 163 | |
| 164 | const runStatement = ( |
| 165 | statement: StatementSync, |
| 166 | params: ReadonlyArray<unknown>, |
| 167 | raw: boolean |
| 168 | ) => |
| 169 | Effect.withFiber<ReadonlyArray<any>, SqlError>((fiber) => { |
| 170 | const useSafeIntegers = Context.get(fiber.context, Client.SafeIntegers) |
| 171 | return Effect.try({ |
| 172 | try: () => { |
| 173 | statement.setReadBigInts(useSafeIntegers) |
| 174 | if (statement.columns().length > 0) { |
| 175 | return statement.all(...(params as Array<any>)) as ReadonlyArray<any> |
| 176 | } |
| 177 | const result = statement.run(...(params as Array<any>)) |
| 178 | return raw ? { changes: result.changes, lastInsertRowid: result.lastInsertRowid } as any : [] |
| 179 | }, |
| 180 | catch: (cause) => new SqlError({ reason: classifyError(cause, "Failed to execute statement", "execute") }) |
| 181 | }) |
| 182 | }) |
| 183 | |
| 184 | const runStatementValues = ( |
| 185 | statement: StatementSync, |
no test coverage detected