Issue helidon-io#4719 - Helidon DBClient does not trigger an Exceptio…

…n when no sane DB connection can be obtained Signed-off-by: Tomas Kraus <tomas.kraus@oracle.com>
Tomas-Kraus · Sep 28, 2022 · 81e6f52 · 81e6f52
1 parent 2599cc4
commit 81e6f52
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/dbclient/jdbc/src/main/java/io/helidon/dbclient/jdbc/JdbcStatementDml.java b/dbclient/jdbc/src/main/java/io/helidon/dbclient/jdbc/JdbcStatementDml.java
@@ -54,7 +54,13 @@ private Single<Long> doExecute(DbClientServiceContext dbContext,
                                    CompletableFuture<Long> queryFuture) {
 
         executorService().submit(() -> {
-            connection().thenAccept(conn -> callStatement(dbContext, conn, statementFuture, queryFuture));
+            connection()
+                    .thenAccept(conn -> callStatement(dbContext, conn, statementFuture, queryFuture))
+                    .exceptionally(t -> {
+                        statementFuture.completeExceptionally(t);
+                        queryFuture.completeExceptionally(t);
+                        return null;
+                    });
         });
 
         // the query future is reused, as it completes with the number of updated records