目录
?今日良言:生命只有一次,你要活的畅快淋漓
?一、Sping 事务
1.Spring 中事务的实现
2.Spring 中事务隔离级别
?二、Spring 事务传播机制
1.基本概念
2.详细介绍
?今日良言:生命只有一次,你要活的畅快淋漓
?一、Sping 事务
1.Spring 中事务的实现
在MySQL中也有事务,如下链接是博主之前写的关于MySQL事务的博客:
如何理解数据库事务?_程序猿小马的博客-CSDN博客
事务就是逻辑上的一组操作,组成这组操作的各个单元,要么全部成功,要么全部失败。
Spring 中的事务分为两类:
1).编程式事务(手动写代码)
代码如下:
@RestController @RequestMapping("/user") public class UserController { // 编程式事务 @Autowired private UserService userService; @Autowired private DataSourceTransactionManager transactionManager; @Autowired private TransactionDefinition definition; @RequestMapping("/del") public int del(Integer id) { if (id == null || id <= 0) { return 0; } // 开启事务 TransactionStatus status = transactionManager.getTransaction(definition); // 业务操作 删除用户 int result = userService.del(id); System.out.println("删除ID 操作已经执行成功"); // 2.提交事务 transactionManager.commit(status); return result; } }
Spring 手动操作事务和MySQL 操作事务类似,有三个重要操作:
开启事务 提交事务 回滚事务
SpringBoot 内置了两个对象,DataSourceTransactionManager 用来开启事务(获取事务)、提交或者回滚事务,TransactionDefinition 是事务的属性,在获取事务的时候需要将 TransactionDefinition 传递进去,从而获得一个事务 TransactionStatus。
文章来源地址https://uudwc.com/A/Z2y5
UserService 中代码:
@Service public class UserService { @Autowired private UserMapper userMapper; public int del(Integer id) { return userMapper.del(id); } }
UserMapper 中代码:
@Mapper public interface UserMapper { int del(@Param("id")Integer id); }
UserMapper.xml 中的代码:
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.example.demo.mapper.UserMapper"> <delete id="del"> delete from user where id = #{id} </delete> </mapper>
目录结构如下:
在进行操作之前,先查看数据库user表中的数据:
启动项目:
输入URL:
此时再次查看user表中数据,会发现 id为3的数据被删除了。
上述是提交事务,接下来查看回滚事务。
代码如下:
@RestController @RequestMapping("/user") public class UserController { // 编程式事务 @Autowired private UserService userService; @Autowired private DataSourceTransactionManager transactionManager; @Autowired private TransactionDefinition definition; @RequestMapping("/del") public int del(Integer id) { if (id == null || id <= 0) { return 0; } // 开启事务 TransactionStatus status = transactionManager.getTransaction(definition); // 业务操作 删除用户 int result = userService.del(id); System.out.println("删除ID 操作已经执行成功"); // 2.提交事务 // transactionManager.commit(status); // 回滚事务 transactionManager.rollback(status); return result; } }
启动项目:
输入URL:
此时查看user表中记录数据,会发现id为2的数据没有被删除:
查看IDEA控制台打印的信息:
数据已经被删除了,但是事务回滚了,所以删除的数据被恢复成初始状态。
2).声明式事务(使用注解)
声明式事务的实现很简单,只需要在需要的⽅法上添加 @Transactional 注解就可以实现了,⽆需⼿动 开启事务和提交事务,进⼊⽅法时⾃动开启事务,⽅法执⾏完会⾃动提交事务,如果中途发⽣了没有处 理的异常会⾃动回滚事务
代码如下:
@RestController @RequestMapping("/user") public class UserController { @Autowired private UserService userService; @Transactional @RequestMapping("/del") public int del(Integer id) { if (id == null || id <= 0) { return 0; } int result = userService.del(id); return result; } }
进行操作之前,先查看User表中数据:
此时启动项目,输入URL:
查看 user 表中数据:
id 为2 的数据被删除。
当加了 Transactional 注解以后,程序执行正常情况下,是不会回滚事务的,只有当发生异常以后才会回滚事务。
添加一行会发生异常的代码:
此时启动项目,输入URL:
状态码500表示 服务器内部出现错误,查看IDEA控制台打印的信息:
删除操作执行了,但是这里发生了除0的异常,此时查看user表中数据,会发现:
id 为1的数据并没有被删除,事务发生了回滚。
Transactional 注解的作用范围:
@Transactional 可以用来修饰方法或类
修饰方法时:需要注意只能应用到public方法上,否则不生效。
修饰类时,表明该注解对该类中所有的public 方法都生效。
Transactional 参数如下:
需要注意的是:@Transactional 在异常被捕获的情况下,不会进行事务回滚。
修改Usercontroller代码如下:
@RestController
@RequestMapping("/user")
public class UserController {
@Autowired
private UserService userService;
@Transactional
@RequestMapping("/del")
public int del(Integer id) {
if (id == null || id <= 0) {
return 0;
}
int result = 0;
try {
result = userService.del(id);
int num = 10 / 0;
} catch (Exception e) {
e.printStackTrace();
}
return result;
}
}
启动项目,输入URL:
此时查看 user 表中数据:
id 为1的数据被删除了。
查看IDEA控制台信息:
对于上述这种情况(try catch 捕获了异常,事务不会自动回滚),有两种方案可以解决:
1).将异常抛出去,让spring感知到异常,此时就会自动回滚异常
代码如下:
@RestController @RequestMapping("/user") public class UserController { @Autowired private UserService userService; @Transactional @RequestMapping("/del") public int del(Integer id) { if (id == null || id <= 0) { return 0; } int result = 0; try { result = userService.del(id); int num = 10 / 0; } catch (Exception e) { throw e; } return result; } }
查看user表中数据:
启动项目,输入URL:
服务器内部出现错误。
查看IDEA控制台打印信息:
查看user表中数据:
id 为5的数据并未被删除。
2).通过代码的方式手动回滚事务。
代码如下:
@RestController @RequestMapping("/user") public class UserController { @Autowired private UserService userService; @Transactional @RequestMapping("/del") public int del(Integer id) { if (id == null || id <= 0) { return 0; } int result = 0; try { result = userService.del(id); int num = 10 / 0; } catch (Exception e) { TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); } return result; } }
此时查看最终效果也是id为5的数据未被删除。
2.Spring 中事务隔离级别
在MySQL 中事务的隔离级别有四个,但是在Spring 中事务的隔离级别有五个:
1). Isolation.DEFAULT:以连接的数据库的事务隔离级别为主。
2). Isolation.READ_UNCOMMITTED:读未提交,可以读取到未提交的事务,存在脏读。
3). Isolation.READ_COMMITTED:读已提交,只能读取到已经提交的事务,解决了脏读,存在不可重复读。
4). Isolation.REPEATABLE_READ:可重复读,解决了不可重复读,但存在幻读(MySQL默认级别)。
5). Isolation.SERIALIZABLE:串⾏化,可以解决所有并发问题,但性能太低。
可以在添加@Transactional 注解的时候设置 参数,不同的参数对应不同的Spring 隔离级别:
?二、Spring 事务传播机制
1.基本概念
Spring 事务传播机制定义了多个包含事务的方法相互调用时,事务是如何在这些方法间进行传播的。
事务隔离级别是保证多个事务并发执行的可控性的(稳定性的),而事务传播机制是保证一个事务在多个调用方法间的可控性的(稳定性的)。
2.详细介绍
Spring 事务传播机制包含以下7种:
1).Propagation.REQUIRED:
默认的事务传播机制,表示如果当前存在事务,则加入当前事务;如果当前没有事务,就新建一个事务。
2).Propagation.SUPPORTS:表示如果当前存在事务,则加入当前事务;如果当前没有事务,就以非事务的方式继续运行。
3).Propagation.MANDATORY:表示如果当前存在事务,则加入当前事务;如果当前没有事务,就抛出异常。
4).Propagation.REQUIRES_NEW:表示创建一个新的事务,如果当前存在事务,则把当前事务挂起。
5).Propagation.NOT_SUPPORTED:表示当前方法以非事务方式执行,如果当前存在事务,则挂起该事务。
6).Propagation.NEVER:表示当前方法以非事务方式执行,如果当前存在事务,就抛出异常。
7).Propagation.NESTED:如果当前存在事务,则创建一个新的事务作为当前事务的嵌套事务来执行,如果当前没有事务,效果相当于REQUIRED.
可以根据是否支持当前事务将以上7种分为以下3类:
嵌套事务(NESTED)和 加入事务(REQUIRED) 的区别:
1).整个事务如果全部执行成功,二者的结果是一样的。
2).如果事务执行到一半失败了,那么加入事务整个事务会全部回滚;而嵌套事务会局部回滚,不会影响上一个方法中执行的结果。
嵌套事务之所以能够实现局部回滚,是因为事务中有一个保存点(savepoint)的概念,嵌套事务进入之后相当于新建了一个保存点,而回滚时只回滚到当前保存点,因此之前的事务是不会受到影响的。文章来源:https://uudwc.com/A/Z2y5