Ensure database name on pipelined begin is handled appropriately (#1615)

neo4j · Feb 5, 2025 · 5306f43 · 5306f43
1 parent 31b8f96
commit 5306f43
Showing 1 changed file with 8 additions and 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
@@ -233,7 +233,14 @@ public CompletionStage<ResultCursor> 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))