Use same transaction manager in one transaction

apache · Dec 30, 2024 · 7632ea2 · 7632ea2
1 parent 8d6327f
commit 7632ea2
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/...he/shardingsphere/proxy/backend/connector/jdbc/transaction/BackendTransactionManager.java b/...he/shardingsphere/proxy/backend/connector/jdbc/transaction/BackendTransactionManager.java
@@ -60,9 +60,14 @@ public BackendTransactionManager(final ProxyDatabaseConnectionManager databaseCo
         connection = databaseConnectionManager;
         localTransactionManager = new LocalTransactionManager(databaseConnectionManager);
         TransactionRule transactionRule = ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData().getGlobalRuleMetaData().getSingleRule(TransactionRule.class);
+        TransactionConnectionContext transactionContext = getTransactionContext();
         transactionType = transactionRule.getDefaultType();
         ShardingSphereTransactionManagerEngine engine = transactionRule.getResource();
-        distributedTransactionManager = null == engine ? null : engine.getTransactionManager(transactionType);
+        if (transactionContext.getTransactionManager().isPresent()) {
+            distributedTransactionManager = (ShardingSphereDistributedTransactionManager) transactionContext.getTransactionManager().get();
+        } else {
+            distributedTransactionManager = null == engine ? null : engine.getTransactionManager(transactionType);
+        }
         transactionHooks = OrderedSPILoader.getServices(TransactionHook.class, ProxyContext.getInstance().getContextManager().getMetaDataContexts().getMetaData().getGlobalRuleMetaData().getRules());
     }