修正多数据源事务支持

entropy-cloud · Jul 27, 2023 · 86c4792 · 86c4792
1 parent 300840e
commit 86c4792
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/nop-dao/src/main/java/io/nop/dao/txn/impl/TransactionTemplateImpl.java b/nop-dao/src/main/java/io/nop/dao/txn/impl/TransactionTemplateImpl.java
@@ -126,6 +126,14 @@ private TxnState getTxnState(String txnGroup, boolean allowCreate) {
                     }
                     state.newlyCreated = true;
                 }
+            } else {
+                txn = transactionManager.getRegisteredTransaction(txnGroup);
+                if (txn == null && allowCreate) {
+                    // 只是新建事务对象，但是并没有调用open打开事务
+                    txn = transactionManager.newTransaction(txnGroup);
+                    state.newlyCreated = true;
+                    state.prevTxn = transactionManager.registerTransaction(txn);
+                }
             }
             state.txn = txn;
             state.groupTxn = groupTxn;