Fixed Connection auto-commit settings.

Signed-off-by: Tomáš Kraus <[email protected]>

dbclient/jdbc/src/main/java/io/helidon/dbclient/jdbc/JdbcStatement.java

@@ -108,7 +108,13 @@ protected PreparedStatement prepareStatement(DbClientServiceContext serviceConte
      * @return statement
      */
     protected PreparedStatement prepareStatement(String stmtName, String stmt) {
-        return prepareStatement(connectionPool.connection(), stmtName, stmt);
+        Connection connection = connectionPool.connection();
+        try {
+            connection.setAutoCommit(true);
+        } catch (SQLException e) {
+            throw new DbClientException("Failed to set autocommit to true", e);
+        }
+        return prepareStatement(connection, stmtName, stmt);
     }
 
     /**

dbclient/jdbc/src/main/java/io/helidon/dbclient/jdbc/JdbcTransactionStatement.java

@@ -15,8 +15,11 @@
  */
 package io.helidon.dbclient.jdbc;
 
+import java.sql.Connection;
 import java.sql.PreparedStatement;
+import java.sql.SQLException;
 
+import io.helidon.dbclient.DbClientException;
 import io.helidon.dbclient.DbStatement;
 
 /**
@@ -44,6 +47,14 @@ protected JdbcTransactionStatement(JdbcConnectionPool connectionPool,
 
     @Override
     protected PreparedStatement prepareStatement(String stmtName, String stmt) {
-        return prepareStatement(transactionContext.connection(), stmtName, stmt);
+        Connection connection = transactionContext.connection();
+        try {
+            connection.setAutoCommit(false);
+        } catch (SQLException e) {
+            throw new DbClientException("Failed to set autocommit to false", e);
+        }
+        return prepareStatement(connection, stmtName, stmt);
     }
+
 }
+

tests/integration/dbclient/common/src/main/java/io/helidon/tests/integration/dbclient/common/tests/ServerHealthCheckIT.java

@@ -75,8 +75,8 @@ public static void setup(DbClient dbClient, Config config) {
     }
 
     // Add 2 endpoints:
-    // - HealthCheck /observe/healthNoDetails with details turned off
-    // - HealthCheck /observe/healthDetails with details turned on
+    // - HealthCheck /noDetails/health with details turned off
+    // - HealthCheck /details/health with details turned on
     private static void routing(DbClient dbClient, Config config, HttpRouting.Builder router) {
         router.addFeature(
                 createObserveFeature(dbClient, config, "healthNoDetails", "noDetails", false));