!243 修复非事务提交数据源因为提交报错问题

Merge pull request !243 from life/main

mybatis-flex-core/src/main/java/com/mybatisflex/core/datasource/FlexDataSource.java

@@ -224,15 +224,12 @@ public class FlexDataSource extends AbstractDataSource {
     }
 
     private static class ConnectionHandler implements InvocationHandler {
-
         private static final String[] proxyMethods = new String[]{"commit", "rollback", "close", "setAutoCommit"};
         private final Connection original;
         private final String xid;
 
         public ConnectionHandler(Connection original, String xid) {
-
             closeAutoCommit(original);
-
             this.original = original;
             this.xid = xid;
         }

mybatis-flex-spring/src/main/java/com/mybatisflex/spring/FlexSpringTransaction.java

@@ -16,6 +16,7 @@
 package com.mybatisflex.spring;
 
 import com.mybatisflex.core.datasource.FlexDataSource;
+import com.mybatisflex.core.transaction.TransactionContext;
 import java.sql.Connection;
 import java.sql.SQLException;
 import javax.sql.DataSource;
@@ -30,7 +31,7 @@ public class FlexSpringTransaction implements Transaction {
 
     DataSource dataSource;
 
-    boolean isTransaction;
+    boolean isTransaction =false;
 
     TransactionIsolationLevel level;
     boolean autoCommit;
@@ -46,6 +47,10 @@ public class FlexSpringTransaction implements Transaction {
     @Override
     public Connection getConnection() throws SQLException {
         if (dataSource instanceof FlexDataSource) {
+            this.autoCommit = this.dataSource.getConnection().getAutoCommit();
+            if ( TransactionContext.getXID() != null){
+                isTransaction = true;
+            }
             return  dataSource.getConnection();
         }else{
             throw new SQLException("The datasource must be FlextDataSource");
@@ -56,13 +61,18 @@ public class FlexSpringTransaction implements Transaction {
 
     @Override
     public void commit() throws SQLException {
+        if (!isTransaction && !autoCommit){
             getConnection().commit();
         }
 
+    }
+
     @Override
     public void rollback() throws SQLException {
+        if (!isTransaction && !autoCommit){
             getConnection().rollback();
         }
+    }
 
     @Override
     public void close() throws SQLException {