Merge pull request #159 from ebean-orm/fix/158

#158 - fastMode fails with MySQL and Hikari and AutoCommit=true

Author: rbygrave

ebean-migration/pom.xml

@@ -49,6 +49,13 @@
 
     <!-- test dependencies -->
 
+    <dependency>
+      <groupId>com.zaxxer</groupId>
+      <artifactId>HikariCP</artifactId>
+      <version>5.1.0</version>
+      <scope>test</scope>
+    </dependency>
+
     <dependency>
       <groupId>io.avaje</groupId>
       <artifactId>avaje-slf4j-jpl</artifactId>

ebean-migration/src/main/java/io/ebean/migration/runner/MigrationPlatform.java

@@ -87,7 +87,9 @@ List<MigrationMetaRow> fastReadMigrations(String sqlTable, Connection connection
         }
       }
     } finally {
-      connection.rollback();
+      if (!connection.getAutoCommit()) {
+        connection.rollback();
+      }
     }
     return rows;
   }

ebean-migration/src/test/java/io/ebean/migration/MigrationRunner_platform_Test.java

@@ -1,5 +1,7 @@
 package io.ebean.migration;
 
+import com.zaxxer.hikari.HikariConfig;
+import com.zaxxer.hikari.HikariDataSource;
 import io.ebean.ddlrunner.DdlRunner;
 import io.ebean.test.containers.*;
 import org.junit.jupiter.api.Disabled;
@@ -210,13 +212,23 @@ public void mysql_migration() throws SQLException {
 
     config.setMigrationPath("dbmig_basic");
 
-    MigrationRunner runner = new MigrationRunner(config);
-    runner.run();
+    HikariConfig hikariConfig = new HikariConfig();
+    hikariConfig.setJdbcUrl(mysqlContainer.jdbcUrl());
+    hikariConfig.setUsername("mig_test");
+    hikariConfig.setPassword("test");
 
-    try (Connection connection = mysqlContainer.createConnection()) {
-      readQuery(connection, "select * from m1");
-      readQuery(connection, "select * from m2");
-      readQuery(connection, "select * from m3");
+    try (HikariDataSource ds = new HikariDataSource(hikariConfig)) {
+      MigrationRunner runner = new MigrationRunner(config);
+      try (Connection connection1 = ds.getConnection()) {
+        // connection1.setAutoCommit(false);
+        runner.run(connection1);
+      }
+
+      try (Connection connection = mysqlContainer.createConnection()) {
+        readQuery(connection, "select * from m1");
+        readQuery(connection, "select * from m2");
+        readQuery(connection, "select * from m3");
+      }
     }
 
     mysqlContainer.stopRemove();