Skip to content

Commit ba38d79

Browse files
authored
fix(qc-test-worker): adapt to upstream changes (#5727)
Change qc-test-worker to use the updated reusable `QueryInterpreter` API from <prisma/prisma#29016>.
1 parent 56fb1a4 commit ba38d79

1 file changed

Lines changed: 13 additions & 13 deletions

File tree

libs/driver-adapters/executor/src/qc-test-worker/worker-query.ts

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,7 @@ export function query(
4040
class QueryPipeline {
4141
private compiler: QueryCompiler
4242
private driverAdapter: SqlDriverAdapter
43+
private interpreter: QueryInterpreter
4344
private transactionManager: TransactionManager
4445

4546
constructor(
@@ -49,6 +50,14 @@ class QueryPipeline {
4950
this.compiler = state.compiler
5051
this.driverAdapter = state.driverAdapter
5152
this.transactionManager = state.transactionManager
53+
this.interpreter = QueryInterpreter.forSql({
54+
onQuery: (event) => {
55+
this.logs.push(safeJsonStringify(event))
56+
},
57+
tracingHelper: noopTracingHelper,
58+
provider: this.driverAdapter.provider,
59+
connectionInfo: this.driverAdapter.getConnectionInfo?.(),
60+
})
5261
}
5362

5463
async run(query: QueryParams['query'], txId: QueryParams['txId']) {
@@ -151,20 +160,11 @@ class QueryPipeline {
151160
: { enabled: false }
152161
) satisfies QueryInterpreterTransactionManager
153162

154-
const interpreterOpts = {
163+
return this.interpreter.run(queryPlan, {
164+
queryable,
155165
transactionManager: qiTransactionManager,
156-
placeholderValues: {},
157-
onQuery: (event: QueryEvent) => {
158-
this.logs.push(safeJsonStringify(event))
159-
},
160-
tracingHelper: noopTracingHelper,
161-
provider: this.driverAdapter.provider,
162-
connectionInfo: this.driverAdapter.getConnectionInfo?.(),
163-
}
164-
165-
const interpreter = QueryInterpreter.forSql(interpreterOpts)
166-
167-
return interpreter.run(queryPlan, queryable)
166+
scope: {},
167+
})
168168
}
169169

170170
private async executeIndependentBatch(

0 commit comments

Comments
 (0)