SpringBoot事务简单操作及⼿动回滚
<!-- 核⼼启动器, 包括auto-configuration、logging and YAML -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<!-- using Spring Data JDBC, JdbcTemplate或NamedParameterJdbcTemplate都是由spring jdbc提供的 --> <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>
<!-- testing Spring Boot applications with libraries including JUnit, Hamcrest and Mockito -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
</dependency>
spring.datasource.url=jdbc:mysql://192.168.178.5:12345/mydb?characterEncoding=UTF-8
spring.datasource.username=root
spring.datasource.password=123456
spring.datasource.sql.jdbc.Driver
pe=com.zaxxer.hikari.HikariDataSource
1. dao
student接⼝
public interface StudentDao {
void saveStudent();
}
student实现类
public class StudentDaoImpl implements StudentDao{
@Autowired
private JdbcTemplate jdbcTemplate;
public void saveStudent(){
String sql = "insert into student(name, s_class) values(?,?"; //这⾥会出现⼀个错误，少了右括号 List<Object> sqlParamList = new ArrayList<Object>();
sqlParamList.add("stn-"+Math.random());
sqlParamList.add(20);
jdbcTemplate.update(sql, Array(new Object[sqlParamList.size()]));
}
}
user接⼝
public interface UserDao {
void saveUser();
}
user实现类
@Repository
public class UserDaoImpl implements UserDao{
@Autowired
private JdbcTemplate jdbcTemplate;
public void saveUser(){
String sql = "insert into user(name, age) values(?,?)";
List<Object> sqlParamList = new ArrayList<Object>();
sqlParamList.add("sn-"+Math.random());
sqlParamList.add(20);
jdbcTemplate.update(sql, Array(new Object[sqlParamList.size()]));
}
}
2. service
接⼝：
public interface OperatorService {
void saveEntity() throws Exception;
}
接⼝实现类
public class OperatorServiceImpl implements OperatorService{
@Autowired
private StudentDao studentDao;
@Autowired
private UserDao userDao;
@Override
public void saveEntity() throws Exception{
userDao.saveUser();
studentDao.saveStudent();
}
}
当执⾏以上saveEntity()代码时，因StudentDaoImpl 插⼊语句的⼀个错误，会导致事务不⼀致，user表成功插⼊⼀条记录，student表没有。
为了使事务⼀致，在SpringBoot项⽬中，我们只需要在saveEntity()上添加@Transactional注解，，对@Transactional的注解可以查看⼀节。
这⾥为了适应更多的异常，我们提升了事务捕获异常的范围：@Transactional(rollbackFor = Exception.class)
有时我们需要捕获⼀些错误信息，⼜需要进⾏事务回滚，这时我们就需要⽤到Spring提供的事务切⾯⽀持类TransactionAspectSupport。
@Transactional(rollbackFor = Exception.class)
@Override
public void saveEntity() throws Exception{
try {
userDao.saveUser();
studentDao.saveStudent();
}catch (Exception e){
System.out.println("异常了=====" + e);
//⼿动强制回滚事务，这⾥⼀定要第⼀时间处理
TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
}
}
⼿动回滚事务⼀定要加上@Transactional，不然会报以下错误：
ansaction.NoTransactionException: No transaction aspect-managed TransactionStatus in scope
想想也是，不开启事务，何来⼿动回滚，所以@Transactional必不可少。
使⽤Object savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint(); 设置回滚点。
使⽤TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint); 回滚到savePoint。
@Transactional(rollbackFor = Exception.class)
@Override
public void saveEntity() throws Exception{
Object savePoint = null;
try {
userDao.saveUser();
//设置回滚点springframework事务
savePoint = TransactionAspectSupport.currentTransactionStatus().createSavepoint();
studentDao.saveStudent(); //执⾏成功
int a = 10/0; //这⾥因为除数0会报异常，进⼊catch块
}catch (Exception e){
System.out.println("异常了=====" + e);
//⼿⼯回滚异常
TransactionAspectSupport.currentTransactionStatus().rollbackToSavepoint(savePoint);
}
}
springboot 开启事务以及⼿动提交事务，可以在服务类上加上两个注解。
@Autowired
DataSourceTransactionManager dataSourceTransactionManager;
@Autowired
TransactionDefinition transactionDefinition;
⼿动开启事务
TransactionStatus transactionStatus = Transaction(transactionDefinition);
⼿动提交事务
dataSourceTransactionManagermit(transactionStatus);//提交
⼿动回滚事务
默认spring事务只在发⽣未被捕获的 RuntimeException 时才回滚。
spring aop 异常捕获原理：被拦截的⽅法需显式抛出异常，并不能经任何处理，这样aop代理才能捕获到⽅法的异常，才能进⾏回滚，默认情况下aop只捕获 RuntimeException 的异常，但可以通过配置来捕获特定的异常并回滚。
换句话说在service的⽅法中不使⽤try catch 或者在catch中最后加上throw new RuntimeException ()，这样程序异常时才能被aop捕获进⽽回滚。
解决⽅案：
⽅案1：例如service层处理事务，那么service中的⽅法中不做异常捕获，或者在catch语句中最后增加throw new RuntimeException()语句，以便让aop捕获异常再去回滚，并且在service上层（webservice客户端，view层action）要继续捕获这个异常并处理。
⽅案2：在service层⽅法的catch语句中增加：TransactionAspectSupport.currentTransactionStatus().setRollbackOnly()；语句，⼿动回滚，这样上层就⽆需去处理异常。
注意：
1. 默认地，如果使⽤的数据源不是SpringBoot的默认配置（即是由⾃⼰定义的配置信息，⾃⼰解析创建的数据源），则需要⼿动创建事务管理器，因为SpringBoot⽆法识别配置信息，⽆法完成⾃动注⼊。
//DynamicDataSource 是⾃定义的数据源
@Bean
public PlatformTransactionManager transactionManager(DynamicDataSource dataSource){
return new DataSourceTransactionManager(dataSource);
}
2. SpringBoot1.x需要在启动类上添加@EnableTransactionManagement，SpringBoot2.x则不需要。
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论