| 74 | } |
| 75 | |
| 76 | async batch<T extends BatchItem<class="st">'sqlite'>[] | readonly BatchItem<class="st">'sqlite'>[]>(queries: T) { |
| 77 | const preparedQueries: PreparedQuery[] = []; |
| 78 | const builtQueries: { sql: string; params: any[]; method: class="st">'run' | class="st">'all' | class="st">'values' | class="st">'get' }[] = []; |
| 79 | |
| 80 | for (const query of queries) { |
| 81 | const preparedQuery = query._prepare(); |
| 82 | const builtQuery = (preparedQuery as RemotePreparedQuery).getQuery(); |
| 83 | preparedQueries.push(preparedQuery); |
| 84 | builtQueries.push({ sql: builtQuery.sql, params: builtQuery.params, method: builtQuery.method }); |
| 85 | } |
| 86 | |
| 87 | const batchResults = await (this.batchCLient as AsyncBatchRemoteCallback)(builtQueries); |
| 88 | return batchResults.map((result, i) => preparedQueries[i]!.mapResult(result, true)); |
| 89 | } |
| 90 | |
| 91 | override async transaction<T>( |
| 92 | transaction: (tx: SQLiteProxyTransaction<TFullSchema, TSchema>) => Promise<T>, |