SpringBoot事务简单操作及手动回滚

2026-06-01 4 花语

本文内容纲要：

-一、引入依赖 -二、application.properties -三、dao和service代码 -四、手动回滚事务 -五、回滚部分异常 -六、使用DataSourceTransactionManager -七、springbootcontroller设置@Transactional不回滚的解决办法

本节部分内容摘自：https://blog.csdn.net/zzhongcy/article/details/102893309

一、引入依赖

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency>  <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jdbc</artifactId> </dependency>  <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.48</version> </dependency>  <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