SpringBoot事务简单操作及手动回滚
本文内容纲要:
-一、引入依赖
-二、application.properties
-三、dao和service代码
-四、手动回滚事务
-五、回滚部分异常
-六、使用DataSourceTransactionManager
-七、springbootcontroller设置@Transactional不回滚的解决办法
本节部分内容摘自:https://blog.csdn.net/zzhongcy/article/details/102893309
一、引入依赖
<!--核心启动器,包括auto-configuration、loggingandYAML-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!--usingSpringDataJDBC,JdbcTemplate或NamedParameterJdbcTemplate都是由springjdbc提供的-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jdbc</artifactId>
</dependency>
<!--数据库操作需要的mysql驱动包-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.48</version>
</dependency>
<!--testingSpringBootapplicationswithlibrariesincludingJUnit,HamcrestandMockito-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
二、application.properties
spring.datasource.url=jdbc:mysql://192.168.178.5:12345/mydb?characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.driver-class-name=com.mysql.jdbc.Driver
spring.datasource.type=com.zaxxer.hikari.HikariDataSource
三、dao和service代码
1.dao
student接口
publicinterfaceStudentDao{
voidsaveStudent();
}
student实现类
@Repository
publicclassStudentDaoImplimplementsStudentDao{
@Autowired
privateJdbcTemplatejdbcTemplate;
publicvoidsaveStudent(){
Stringsql="insertintostudent(name,s_class)values(?,?";//这里会出现一个错误,少了右括号
List<Object>sqlParamList=newArrayList<Object>();
sqlParamList.add("stn-"+Math.random());
sqlParamList.add(20);
jdbcTemplate.update(sql,sqlParamList.toArray(newObject[sqlParamList.size()]));
}
}
user接口
publicinterfaceUserDao{
voidsaveUser();
}
user实现类
@Repository
publicclassUserDaoImplimplementsUserDao{
@Autowired
privateJdbcTemplatejdbcTemplate;
publicvoidsaveUser(){
Stringsql="insertintouser(name,age)values(?,?)";
List<Object>sqlParamList=newArrayList<Object>();
sqlParamList.add("sn-"+Math.random());
sqlParamList.add(20);
jdbcTemplate.update(sql,sqlParamList.toArray(newObject[sqlParamList.size()]));
}
}
2.service
接口:
publicinterfaceOperatorService{
voidsaveEntity()throwsException;
}
接口实现类
@Service
publicclassOperatorServiceImplimplementsOperatorService{
@Autowired
privateStudentDaostudentDao;
@Autowired
privateUserDaouserDao;
@Override
publicvoidsaveEntity()throwsException{
userDao.saveUser();
studentDao.saveStudent();
}
}
当执行以上saveEntity()代码时,因StudentDaoImpl插入语句的一个错误,会导致事务不一致,user表成功插入一条记录,student表没有。
为了使事务一致,在SpringBoot项目中,我们只需要在saveEntity()上添加@Transactional注解,,对@Transactional的注解可以查看对注解@Transactional的解读一节。
这里为了适应更多的异常,我们提升了事务捕获异常的范围:@Transactional(rollbackFor=Exception.class)
四、手动回滚事务
有时我们需要捕获一些错误信息,又需要进行事务回滚,这时我们就需要用到Spring提供的事务切面支持类TransactionAspectSupport。
@Transactional(rollbackFor=Exception.class)
@Override
publicvoidsaveEntity()throwsException{
try{
userDao.saveUser();
studentDao.saveStudent();
}catch(Exceptione){
System.out.println("异常了====="+e);
//手动强制回滚事务,这里一定要第一时间处理
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}
}
手动回滚事务一定要加上@Transactional,不然会报以下错误:
org.springframework.transaction.NoTransactionException:Notransactionaspect-managedTransactionStatusinscope
想想也是,不开启事务,何来手动回滚,所以@Transactional必不可少。
五、回滚部分异常
使用ObjectsavePoint=TransactionAspectSupport.currentTransactionStatus().createSavepoint();设置回滚点。
使用TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);回滚到savePoint。
@Transactional(rollbackFor=Exception.class)
@Override
publicvoidsaveEntity()throwsException{
ObjectsavePoint=null;
try{
userDao.saveUser();
//设置回滚点
savePoint=TransactionAspectSupport.currentTransactionStatus().createSavepoint();
studentDao.saveStudent();//执行成功
inta=10/0;//这里因为除数0会报异常,进入catch块
}catch(Exceptione){
System.out.println("异常了====="+e);
//手工回滚异常
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
}
}
六、使用DataSourceTransactionManager
springboot开启事务以及手动提交事务,可以在服务类上加上两个注解。
@Autowired
DataSourceTransactionManagerdataSourceTransactionManager;
@Autowired
TransactionDefinitiontransactionDefinition;
手动开启事务
TransactionStatustransactionStatus=dataSourceTransactionManager.getTransaction(transactionDefinition);
手动提交事务
dataSourceTransactionManager.commit(transactionStatus);//提交
手动回滚事务
dataSourceTransactionManager.rollback(transactionStatus);//最好是放在catch里面,防止程序异常而事务一直卡在哪里未提交
七、springbootcontroller设置@Transactional不回滚的解决办法
默认spring事务只在发生未被捕获的RuntimeException时才回滚。
springaop异常捕获原理:被拦截的方法需显式抛出异常,并不能经任何处理,这样aop代理才能捕获到方法的异常,才能进行回滚,默认情况下aop只捕获RuntimeException的异常,但可以通过配置来捕获特定的异常并回滚。
换句话说在service的方法中不使用trycatch或者在catch中最后加上thrownewRuntimeException(),这样程序异常时才能被aop捕获进而回滚。
解决方案:
方案1:例如service层处理事务,那么service中的方法中不做异常捕获,或者在catch语句中最后增加thrownewRuntimeException()语句,以便让aop捕获异常再去回滚,并且在service上层(webservice客户端,view层action)要继续捕获这个异常并处理。
方案2:在service层方法的catch语句中增加:TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();语句,手动回滚,这样上层就无需去处理异常。
注意:
-
默认地,如果使用的数据源不是SpringBoot的默认配置(即是由自己定义的配置信息,自己解析创建的数据源),则需要手动创建事务管理器,因为SpringBoot无法识别配置信息,无法完成自动注入。
//DynamicDataSource是自定义的数据源 @Bean publicPlatformTransactionManagertransactionManager(DynamicDataSourcedataSource){ returnnewDataSourceTransactionManager(dataSource); }
-
SpringBoot1.x需要在启动类上添加@EnableTransactionManagement,SpringBoot2.x则不需要。
本文内容总结:一、引入依赖,二、application.properties,三、dao和service代码,四、手动回滚事务,五、回滚部分异常,六、使用DataSourceTransactionManager,七、springbootcontroller设置@Transactional不回滚的解决办法,
原文链接:https://www.cnblogs.com/myitnews/p/12364455.html