添加事务函数，支持定制事务行为

src/main/java/com/jfinal/plugin/activerecord/tx/Tx.java

@@ -31,12 +31,21 @@ import com.jfinal.plugin.activerecord.NestedTransactionHelpException;
  * Example: @Before(Tx.class)
  */
 public class Tx implements Interceptor {
-	
+
+	private static TxFun txFun = null;
+
+	public static void setTxFun(TxFun txFun) {
+		if (Tx.txFun != null) {
+			throw new IllegalStateException("txFun already set");
+		}
+		Tx.txFun = txFun;
+	}
+
 	public static Config getConfigWithTxConfig(Invocation inv) {
 		TxConfig txConfig = inv.getMethod().getAnnotation(TxConfig.class);
 		if (txConfig == null)
 			txConfig = inv.getTarget().getClass().getAnnotation(TxConfig.class);
-		
+
 		if (txConfig != null) {
 			Config config = DbKit.getConfig(txConfig.value());
 			if (config == null)
@@ -45,16 +54,16 @@ public class Tx implements Interceptor {
 		}
 		return null;
 	}
-	
+
 	protected int getTransactionLevel(Config config) {
 		return config.getTransactionLevel();
 	}
-	
+
 	public void intercept(Invocation inv) {
 		Config config = getConfigWithTxConfig(inv);
 		if (config == null)
 			config = DbKit.getConfig();
-		
+
 		Connection conn = config.getThreadLocalConnection();
 		if (conn != null) {	// Nested transaction support
 			try {
@@ -66,7 +75,7 @@ public class Tx implements Interceptor {
 				throw new ActiveRecordException(e);
 			}
 		}
-		
+
 		Boolean autoCommit = null;
 		try {
 			conn = config.getConnection();
@@ -74,14 +83,20 @@ public class Tx implements Interceptor {
 			config.setThreadLocalConnection(conn);
 			conn.setTransactionIsolation(getTransactionLevel(config));	// conn.setTransactionIsolation(transactionLevel);
 			conn.setAutoCommit(false);
-			inv.invoke();
-			conn.commit();
+
+			if (txFun == null) {
+				inv.invoke();
+				conn.commit();
+			} else {
+				txFun.call(inv, conn);
+			}
+
 		} catch (NestedTransactionHelpException e) {
 			if (conn != null) try {conn.rollback();} catch (Exception e1) {LogKit.error(e1.getMessage(), e1);}
 			LogKit.logNothing(e);
 		} catch (Throwable t) {
 			if (conn != null) try {conn.rollback();} catch (Exception e1) {LogKit.error(e1.getMessage(), e1);}
-			
+
 			// 支持在 controller 中 try catch 的 catch 块中使用 render(...) 并 throw e，实现灵活控制 render
 			if (inv.isActionInvocation() && inv.getController().getRender() != null) {
 				LogKit.error(t.getMessage(), t);

src/main/java/com/jfinal/plugin/activerecord/tx/TxFun.java

@@ -0,0 +1,30 @@
+/**
+ * Copyright (c) 2011-2023, James Zhan 詹波 (jfinal@126.com).
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package com.jfinal.plugin.activerecord.tx;
+
+import com.jfinal.aop.Invocation;
+import java.sql.Connection;
+
+/**
+ * 支持定制事务行为
+ */
+@FunctionalInterface
+public interface TxFun {
+    void call(Invocation inv, Connection conn);
+}
+
+