增加beforeCommit帮助方法

entropy-cloud · Jul 31, 2024 · a5b6f6b · a5b6f6b
1 parent fbdf2cd
commit a5b6f6b
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/nop-dao/src/main/java/io/nop/dao/txn/ITransactionTemplate.java b/nop-dao/src/main/java/io/nop/dao/txn/ITransactionTemplate.java
@@ -72,6 +72,15 @@ default void removeTransactionListener(String txnGroup, ITransactionListener lis
         }
     }
 
+    default void beforeCommit(String txnGroup, Runnable action) {
+        addTransactionListener(txnGroup, new ITransactionListener() {
+            @Override
+            public void onBeforeCommit(ITransaction txn) {
+                action.run();
+            }
+        });
+    }
+
     default void afterCommit(String txnGroup, Runnable action) {
         addTransactionListener(txnGroup, new ITransactionListener() {
             @Override