()
| 1332 | } |
| 1333 | span.attribute(ATTR_DB_OPERATION_NAME, "executeStream") |
| 1334 | span.attribute(ATTR_DB_QUERY_TEXT, sql) |
| 1335 | return Effect.map(self.acquirer, (_) => _.executeStream(sql, params, self.transformRows)) |
| 1336 | }) |
| 1337 | )) |
| 1338 | }, |
| 1339 | |
| 1340 | get values(): Effect.Effect< |
| 1341 | ReadonlyArray<ReadonlyArray<unknown>>, |
| 1342 | SqlError |
| 1343 | > { |
| 1344 | return this.withConnection("executeValues", (connection, sql, params) => connection.executeValues(sql, params)) |
| 1345 | }, |
| 1346 | |
| 1347 | get valuesUnprepared(): Effect.Effect< |
| 1348 | ReadonlyArray<ReadonlyArray<unknown>>, |
| 1349 | SqlError |
| 1350 | > { |
| 1351 | return this.withConnection( |
| 1352 | "executeValuesUnprepared", |
nothing calls this directly
no test coverage detected
searching dependent graphs…