From 5306f431857bf5abfe4043e9c261befa4a07d5b9 Mon Sep 17 00:00:00 2001
From: Dmitriy Tverdiakov <11927660+injectives@users.noreply.github.com>
Date: Wed, 5 Feb 2025 18:37:20 +0000
Subject: [PATCH] Ensure database name on pipelined begin is handled
 appropriately (#1615)

---
 .../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 d1330ad7f..ccdca148a 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<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))