|
@@ -74,7 +74,13 @@ public class Tx implements Interceptor {
|
|
|
try {
|
|
try {
|
|
|
if (conn.getTransactionIsolation() < getTransactionLevel(config))
|
|
if (conn.getTransactionIsolation() < getTransactionLevel(config))
|
|
|
conn.setTransactionIsolation(getTransactionLevel(config));
|
|
conn.setTransactionIsolation(getTransactionLevel(config));
|
|
|
- inv.invoke();
|
|
|
|
|
|
|
+
|
|
|
|
|
+ if (txFun == null) {
|
|
|
|
|
+ inv.invoke();
|
|
|
|
|
+ } else {
|
|
|
|
|
+ txFun.call(inv, conn);
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
return ;
|
|
return ;
|
|
|
} catch (SQLException e) {
|
|
} catch (SQLException e) {
|
|
|
throw new ActiveRecordException(e);
|
|
throw new ActiveRecordException(e);
|