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

… sane DB connection can be obtained Signed-off-by: Tomas Kraus <tomas.kraus@oracle.com>
helidon-io · Aug 30, 2022 · c7a58aa · c7a58aa
1 parent 3cfc643
commit c7a58aa
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/reactive/dbclient/jdbc/src/main/java/io/helidon/reactive/dbclient/jdbc/JdbcStatementDml.java b/reactive/dbclient/jdbc/src/main/java/io/helidon/reactive/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