刚开始使用spring@Transactional时碰过不少坑,比如:
例子一:
public boolean save(User user) {
return subSave();
}
@Transactional
public boolean subSave() {
jdbcTemplate.execute("insert into [User](name) values('alice2')");
String str = null;
String str2 = str.substring(1);//写一个错误
return true;
}
例子二:
@Transactional
public boolean saveCatchException(User user) {
try {
jdbcTemplate.execute("insert into [User](name) values('alice2')");
String str = null;
String str2 = str.substring(1);//写一个错误
return true;
} catch (Exception ex) {
ex.printStackTrace();
return false;
}
}
上面两个例子事务都不会生效,为什么呢?
@Transactional不生效原理分析
是spring的AOP实现的。错误示例1是因为方法subSave上面的注解不会走代理,所以不会走事物。错误示例二是因为会走catch里面,事物不会回滚。
例子一为什么不生效?
@Transactional注解实现事务是通过spring的AOP实现的。程序运行时,生成动态代理类,实际上是动态代理类去实现的。首先,把生成的动态代理类成成.class文件,
生成class文件方法(cglib):
System.setProperty(DebuggingClassWriter.DEBUG_LOCATION_PROPERTY, "D:\\class");
生成代理类:
其中,原始类是:UserRepository,动态生成的代理类是UserRepositoryEnhancerBySpringCGLIB$$9f0ede1
原save方法变为:
public final boolean save(User var1) {
try {
MethodInterceptor var10000 = this.CGLIB$CALLBACK_0;
if (this.CGLIB$CALLBACK_0 == null) {
CGLIB$BIND_CALLBACKS(this);
var10000 = this.CGLIB$CALLBACK_0;
}
if (var10000 != null) {
Object var4 = var10000.intercept(this, CGLIB$save$0$Method, new Object[]{var1}, CGLIB$save$0$Proxy);
return var4 == null ? false : (Boolean)var4;
} else {
return super.save(var1);//会走到这里,调用父类UserRepository类的save()方法
}
} catch (Error | RuntimeException var2) {
throw var2;
} catch (Throwable var3) {
throw new UndeclaredThrowableException(var3);
}
}
最终会走到super.save(var1)这里,调用UserRepository的save()方法,save方法调用UserRepository的subSave方法,而不是代理类的subSave方法。因此即使subSave方法加上了@Transactional标签,也走不到代理,事务也不会起着作用。
例子二为什么不起作用?
例子二中的代码对异常进行了处理,处理后导致AOP不能捕获到这个异常,所以事务也不会回滚。
这种情况可以有以下解决办法:
1)throw new RuntimeException(),抛异常,回滚事务
@Transactional(rollbackFor = Exception.class)
public boolean saveCatchException(User user) {
try {
jdbcTemplate.execute("insert into [User](name) values('alice2')");
String str = null;
String str2 = str.substring(1);
return true;
} catch (Exception ex) {
throw new RuntimeException();
}
}
AOP可以捕获到这个运行时异常,可以正常回滚。
2) 手动回滚
@Transactional(rollbackFor = Exception.class)
public boolean saveCatchException(User user) {
try {
jdbcTemplate.execute("insert into [User](name) values('alice2')");
String str = null;
String str2 = str.substring(1);
return true;
} catch (Exception ex) {
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
return false;
}
}