From 95d9b426d88c1e2a8936b685170b988db3c57dac Mon Sep 17 00:00:00 2001 From: Dmitriy Tverdiakov Date: Wed, 5 Feb 2025 15:21:11 +0000 Subject: [PATCH] Ensure database name on pipelined begin is handled appropriately --- .../driver/internal/async/UnmanagedTransaction.java | 9 ++++++++- 1 file changed, 8 insertions(+), 1 deletion(-) diff --git a/driver/src/main/java/org/neo4j/driver/internal/async/UnmanagedTransaction.java b/driver/src/main/java/org/neo4j/driver/internal/async/UnmanagedTransaction.java index d1330ad7fc..ccdca148a8 100644 --- a/driver/src/main/java/org/neo4j/driver/internal/async/UnmanagedTransaction.java +++ b/driver/src/main/java/org/neo4j/driver/internal/async/UnmanagedTransaction.java @@ -233,7 +233,14 @@ public CompletionStage runAsync(Query query) { ensureCanRunQueries(); var parameters = query.parameters().asMap(Values::value); var resultCursor = new ResultCursorImpl( - connection, query, fetchSize, (bookmark) -> {}, false, beginFuture, ignored -> {}, apiTelemetryWork); + connection, + query, + fetchSize, + (bookmark) -> {}, + false, + beginFuture, + databaseNameConsumer, + apiTelemetryWork); var flushStage = connection .run(query.text(), parameters) .thenCompose(ignored -> connection.pull(-1, fetchSize))