Fix local transaction auto commit in jdbc adapter.

apache · Jan 25, 2024 · 416017a · 416017a
1 parent d6d1079
commit 416017a
Showing 1 changed file with 7 additions and 4 deletions.
diff --git a/.../java/org/apache/shardingsphere/driver/jdbc/core/connection/ShardingSphereConnection.java b/.../java/org/apache/shardingsphere/driver/jdbc/core/connection/ShardingSphereConnection.java
@@ -185,13 +185,16 @@ private void beginDistributedTransaction() throws SQLException {
 
     /**
      * Handle auto commit.
-     * 
+     *
      * @throws SQLException SQL exception
      */
     public void handleAutoCommit() throws SQLException {
-        if (!autoCommit && TransactionType.isDistributedTransaction(databaseConnectionManager.getConnectionTransaction().getTransactionType())
-                && !databaseConnectionManager.getConnectionTransaction().isInTransaction()) {
-            beginDistributedTransaction();
+        if (!autoCommit && !databaseConnectionManager.getConnectionTransaction().isInTransaction()) {
+            if (TransactionType.isDistributedTransaction(databaseConnectionManager.getConnectionTransaction().getTransactionType())) {
+                beginDistributedTransaction();
+            } else {
+                getConnectionContext().getTransactionContext().setInTransaction(true);
+            }
         }
     }