ref #376 - fixing error where sql2o might throw an exception if autoC…

…ommit is set to false on data source level

core/pom.xml

@@ -63,12 +63,6 @@
             <version>${embedded-db-junit.version}</version>
             <scope>test</scope>
         </dependency>
-        <dependency>
-            <groupId>org.junit.jupiter</groupId>
-            <artifactId>junit-jupiter</artifactId>
-            <version>5.11.0</version>
-            <scope>test</scope>
-        </dependency>
 
         <dependency>
             <groupId>org.mockito</groupId>

core/src/main/java/org/sql2o/Connection.java

@@ -123,6 +123,14 @@ public Query createQueryWithParams(String queryText, Object... paramValues){
                 .withParams(paramValues);
     }
 
+    public void prepareForTransaction(int isolationLevel) throws SQLException {
+        if (!getJdbcConnection().getAutoCommit()) {
+            getJdbcConnection().setAutoCommit(true); // force autocommit to true to allow for transaction isolation level to be set
+        }
+        getJdbcConnection().setTransactionIsolation(isolationLevel);
+        getJdbcConnection().setAutoCommit(false);
+    }
+
     public Sql2o rollback(){
         return this.rollback(true).sql2o;
     }

core/src/main/java/org/sql2o/Sql2o.java

@@ -296,8 +296,7 @@ public Connection beginTransaction(ConnectionSource connectionSource, int isolat
 
         boolean success = false;
         try {
-            connection.getJdbcConnection().setAutoCommit(false);
-            connection.getJdbcConnection().setTransactionIsolation(isolationLevel);
+            connection.prepareForTransaction(isolationLevel);
             success = true;
         } catch (SQLException e) {
             throw new Sql2oException("Could not start the transaction - " + e.getMessage(), e);

extensions/postgres/pom.xml

@@ -36,6 +36,13 @@
             <version>42.7.2</version>
             <optional>true</optional>
         </dependency>
+
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <version>6.2.1</version>
+            <scope>test</scope>
+        </dependency>
     </dependencies>
 
 </project>

extensions/postgres/src/test/java/org/sql2o/extensions/postgres/DataSourceTest.java

@@ -0,0 +1,41 @@
+package org.sql2o.extensions.postgres;
+
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+import org.sql2o.Sql2o;
+
+public class DataSourceTest {
+
+    private Sql2o sql2o;
+
+    @BeforeEach
+    void setUp() {
+        var dsConfig = new HikariConfig();
+        dsConfig.setDataSourceClassName("org.postgresql.ds.PGSimpleDataSource");
+        dsConfig.addDataSourceProperty("serverName", "localhost");
+        dsConfig.addDataSourceProperty("portNumber", 15432);
+        dsConfig.addDataSourceProperty("databaseName", "postgres");
+        dsConfig.addDataSourceProperty("user", "testuser");
+        dsConfig.addDataSourceProperty("password", "testpassword");
+        dsConfig.setMaximumPoolSize(5);
+        dsConfig.setSchema("public");
+
+        // this is important to test, as it make the data source automatically open a connection when a connection is
+        // created. This might break some functionality of sql2o.
+        dsConfig.setAutoCommit(false);
+        dsConfig.setReadOnly(false);
+
+        var ds = new HikariDataSource(dsConfig);
+        sql2o = new Sql2o(ds);
+    }
+
+    @Test
+    void testQueryUsingHikariDataSource() {
+        try (var con = sql2o.beginTransaction()) {
+            var result = con.createQuery("SELECT 1").executeScalar(Integer.class);
+            System.out.println(result);
+        }
+    }
+}

pom.xml

@@ -108,6 +108,12 @@
             <version>${junit.version}</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.junit.jupiter</groupId>
+            <artifactId>junit-jupiter</artifactId>
+            <version>5.11.4</version>
+            <scope>test</scope>
+        </dependency>
 
         <!-- all projects use slf4j-simple when testing -->
         <dependency>