spring事务的使用
1. 未启用spring事务管理功能@EnableTransactionManagement
Spring事务的实现原理的往aop里面写入一个advisor，如果没有开启这个EnableTransactionManagement的话就不会注册advisor，也就是没有使用。
事务1截图
注：springboot框架下面不用手动开启，start里面已经自己开启了这个注释
~/org/springframework/boot/spring-boot-autoconfigure/2.3.0.RELEASE/spring-boot-autoconfigure-2.3.0.RELEASE.jar!/META-INF/spring.factories
org.springframework.boot.autoconfigure.transaction.TransactionAutoConfiguration
@Configuration(proxyBeanMethods = false)
@ConditionalOnClass(PlatformTransactionManager.class)
@AutoConfigureAfter({ JtaAutoConfiguration.class, HibernateJpaAutoConfiguration.class,
DataSourceTransactionManagerAutoConfiguration.class, Neo4jDataAutoConfiguration.class })
@EnableConfigurationProperties(TransactionProperties.class)
public class TransactionAutoConfiguration {
...
@Configuration(proxyBeanMethods = false)
@ConditionalOnBean(TransactionManager.class)
@ConditionalOnMissingBean(AbstractTransactionManagementConfiguration.class)
public static class EnableTransactionManagementConfiguration {
@Configuration(proxyBeanMethods = false)
//这边注入了
@EnableTransactionManagement(proxyTargetClass = false)
@ConditionalOnProperty(prefix = "spring.aop", name = "proxy-target-class", havingValue = "false",
matchIfMissing = false)
public static class JdkDynamicAutoProxyConfiguration {
}
@Configuration(proxyBeanMethods = false)
//这边注入了
@EnableTransactionManagement(proxyTargetClass = true)
@ConditionalOnProperty(prefix = "spring.aop", name = "proxy-target-class", havingValue = "true",
matchIfMissing = true)
public static class CglibAutoProxyConfiguration {
}
}
2. 方法不是public类型的
因为事务底层的实现原理是aop，aop增强的必须是public的，private的只能同一个方法内部调用
3. 数据源未配置事务管理器
这个很好理解，如果不是同一个事务管理器的话，连接池就不是同一个，就不存在事务的概念了，事务底层还是依赖mysql的事务去做的
4. 自身调用问题
因为spring事务是基于aop来实现的，必须调用的代理对象才行，直接调用的话就是方法内调用，没有加任何切面，所以也不会有事务
public void test() {
System.out.println("执行M1");
this.m1();
}
@Transactional
public void m1() {
jdbcTemplate.update(insertQuery1, 101, "Bob", 50000.00);
jdbcTemplate.update(badSql, 1, "A", 25);
System.out.println("数据1插入成功！");
}
5. 异常类型错误
他这边默认只会回滚RuntimeException,可以在注解上面配置rollbackFor
判断是否回滚代码
public boolean rollbackOn(Throwable ex) {
return (ex instanceof RuntimeException || ex instanceof Error);
}
这样自己指定异常类型的话，当抛出exception异常时都会处理，回滚
@Transactional(rollbackFor =Exception.class )
实例
如果不是runtimeException的话，不会回滚，第一条写入语句正常
@Transactional
public void t1() throws IOException{
jdbcTemplate.update(insertQuery1, 102, "Bob", 50000.00);
System.out.println("数据1插入成功！")
//这边抛出ZipException,非runtimeException，
throw new IOException("zip exception");
}
6. 异常被吞了
这边有2种情况，差别在于是否在方法中有抛出异常，如果有抛出异常，整一个大事务都会失效，如果在刚抛出的异常时catch了，就不会回滚其他，导致事务失败
(1)事务未执行，一半成功，一半失败，
@Transactional
public void insertData() {
String insertQuery1 = "INSERT INTO student (id, name, age) VALUES (?, ?, ?)";
jdbcTemplate.update(insertQuery1, 1, "A", 25);
System.out.println("数据1插入成功！");
dataService.insertData2();
}
@Transactional
public void insertData2() {
String insertQuery2 = "INSERT INTO student (id, name, salll) VALUES (?, ?, ?)";
try {
jdbcTemplate.update(insertQuery2, 101, "Bob", 50000.00);
} catch (Exception e) {
System.out.println("数据2插入失败 = " + e);
return;
}
System.out.println("数据2插入成功！");
}
(2)事务执行，全部失败(可通过配置修改)
这种情况下是全部回滚了，报错，可以配置这个参数，他就是只会滚一部分
transaction.UnexpectedRollbackException: Transaction rolled back because it has been marked as rollback-only
@Transactional
public void insertData() {
String insertQuery1 = "INSERT INTO student (id, name, age) VALUES (?, ?, ?)";
jdbcTemplate.update(insertQuery1, 1, "A", 25);
System.out.println("数据1插入成功！");
try {
dataService.insertData2();
} catch (Exception e) {
System.out.println("数据2插入失败 = " + e);
}
}
@Transactional
public void insertData2() {
String insertQuery2 = "INSERT INTO student (id, name, salll) VALUES (?, ?, ?)";
jdbcTemplate.update(insertQuery2, 101, "B", 50000.00);
System.out.println("数据2插入成功！");
}
7. 业务和spring事务代码必须在一个线程中
因为连接是保存在threadLocal里面的，如果不是同一个线程的话拿到的数据库连接就不是同一个，会导致事务失效
8. 多个方法调用时，事务传播机制不是同一个事务
badSql是错误的sql，insertQuery1是正常的sql，当隔离级别设置为REQUIRES_NEW时，insertData2正常执行，已经提交后insertData报错，这时候insertData2不会回滚，
@Transactional
public void insertData() {
dataService.insertData2();
jdbcTemplate.update(badSql, 1, "A", 25);
System.out.println("数据1插入成功！");
}
@Transactional(propagation = Propagation.REQUIRES_NEW)
public void insertData2() {
jdbcTemplate.update(insertQuery1, 101, "Bob", 50000.00);
System.out.println("数据2插入成功！");
}
