[Bug] [connector-jdbc-v2] Fix transaction force commit when autoCommi…

…t is enabled (apache#2636)
MRYOG · Sep 15, 2022 · a642164 · a642164
1 parent af86ffb
commit a642164
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...e/seatunnel/connectors/seatunnel/jdbc/internal/executor/SimpleBatchStatementExecutor.java b/...e/seatunnel/connectors/seatunnel/jdbc/internal/executor/SimpleBatchStatementExecutor.java
@@ -68,7 +68,9 @@ public void executeBatch() throws SQLException {
             batch.clear();
 
             // cache commit
-            st.getConnection().commit();
+            if (!st.getConnection().getAutoCommit()) {
+                st.getConnection().commit();
+            }
             st.clearParameters();
             st.clearBatch();
 
@@ -78,6 +80,9 @@ public void executeBatch() throws SQLException {
     @Override
     public void closeStatements() throws SQLException {
         if (st != null) {
+            if (!st.getConnection().getAutoCommit()) {
+                st.getConnection().commit();
+            }
             st.close();
             st = null;
         }