Issue #4719 - Helidon DB Client does not trigger an Exception when no…

… sane DB connection can be obtained (#4772) Signed-off-by: Tomas Kraus <tomas.kraus@oracle.com> Signed-off-by: Tomas Kraus <tomas.kraus@oracle.com>
helidon-io · Oct 4, 2022 · 625bbde · 625bbde
1 parent c1d3a5c
commit 625bbde
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