Spring中的事务和事务的传播机制

事务是一组操作的集合,不可以被分割。事务会把所有的操作作为一个整体,这组操作要么全部成功,要么全部失败。

事务有三种操作:

  1. 开启事务;
  2. 提交事务;
  3. 回滚事务。

如果代码的执行逻辑是这样:

开启事务业务A回滚事务

此时A当中的所有操作都不会生效

开启事务业务A提交事务

开启事务后只有这种情况下A中的逻辑才生效

Spring中事务的实现有两种

编程式(手动操作事务)

Spring Boot对于事务操作内置了两个类,我们在使用时可以选择直接注入:

  • DataSourceTransactionManager:事务管理器,里面包含了事务的操作和获取;
  • TransactionDefinition:事务的属性。在获取事务时需要充当参数。

提交事务

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {//获取事务管理器@Autowiredprivate DataSourceTransactionManager dataSourceTransactionManager;//获取事务属性@Autowiredprivate TransactionDefinition definition;@Autowiredprivate UserMapper userMapper;@RequestMapping("/fun1")public void fun1() {//获取并开启事务TransactionStatus transaction = dataSourceTransactionManager.getTransaction(definition);//业务操作//向数据库中插入一条数据userMapper.userInsert("zhangsan","man");//打印日志log.info("数据插入完成");//提交事务dataSourceTransactionManager.commit(transaction);}
}
@Mapper
public interface UserMapper {@Insert("insert into userinfo(username,gender) values (#{userName},#{gender});")void userInsert(String userName, String gender);
}

这是数据库的初始状态

代码执行后数据成功插入

回滚事务

@RequestMapping("/fun1")
public void fun1() {//获取并开启事务TransactionStatus transaction = dataSourceTransactionManager.getTransaction(definition);//业务操作userMapper.userInsert("zhangsan","man");log.info("数据插入完成");//提交事务
//        dataSourceTransactionManager.commit(transaction);//回滚事务dataSourceTransactionManager.rollback(transaction);
}

当代码执行成功后,数据库中的数据并没有变多。

注解式(利用注解自动实现事务)

使用注解实现事务是非常简单的只需要给需要添加事务的方法加上@Transactional注解。添加该注解后程序会自动的在方法开始前开启事务,在方法结束后提交事务;如果在方法执行中发生了没有处理的异常会自动进行回滚事务

@Transactional既可以修饰方法也可以修饰类:

  1. 修饰方法时该方法必须是被public修饰的方法,否则既不会生效也不会报错;
  2. 当修饰类时,会对该类中的所有被public修饰的方法生效。

当方法正常执行完毕后会自动提交事务 :

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {@Autowiredprivate UserMapper userMapper;@Transactional@RequestMapping("/fun2")public void fun2() {userMapper.userInsert("lisi","man");log.info("数据插入完成");}
}

当方法执行过程中发生异常时自动回滚事务 (该注解默认只回滚运行时异常<RuntimeException
>和错误<error>):

发生运行时异常,事务回滚:

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {@Autowiredprivate UserMapper userMapper;@Transactional@RequestMapping("/fun2")public void fun2() {userMapper.userInsert("lisi111","man");log.info("数据插入完成");//发生运行时异常,事务回滚throw new RuntimeException();}
}

编译时异常不会回滚:

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {@Autowiredprivate UserMapper userMapper;@Transactional@RequestMapping("/fun2")public void fun2() throws IOException {userMapper.userInsert("lisi111","man");log.info("数据插入完成");//发生编译时异常,事务不会回滚throw new IOException();}
}

此时尽管程序已经报错了,可数据还是正常插入了。如何解决这个问题呢?

rollbackFor

可以通过配置 @Transactional 注解当中的 rollbackFor 属性,通过 rollbackFor 这个属性来指定出现何种异常类型时事务进行回滚。

这个属性的类型是数组需要注意

Class<? extends Throwable>[] rollbackFor() default {};
@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {@Autowiredprivate UserMapper userMapper;//此时会回滚所有的Exception类型的异常@Transactional(rollbackFor = {Exception.class})@RequestMapping("/fun2")public void fun2() throws IOException {userMapper.userInsert("lisi222","man");log.info("数据插入完成");//此时发生编译时异常,事务回滚throw new IOException();}
}

此时error类型的错误依然会进行回滚。

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {@Autowiredprivate UserMapper userMapper;@Transactional(rollbackFor = {Exception.class})@RequestMapping("/fun2")public void fun2() {userMapper.userInsert("lisi222","man");log.info("数据插入完成");//会发生栈溢出错误,仍然会回滚while(true) {fun2();}}
}

手动回滚事务

使用 TransactionAspectSupport.currentTransactionStatus() 得到当前的事务,并使用setRollbackOnly使事务进行回滚

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {@Autowiredprivate UserMapper userMapper;@Transactional(rollbackFor = {Exception.class})@RequestMapping("/fun2")public void fun2() {userMapper.userInsert("66666","man");log.info("数据插入完成");//手动设置回滚事务TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();}
}

事务隔离级别

SQL中的事务隔离级别:

  1. 读未提交(READ UNCOMMITTED):读未提交,也叫未提交读。该隔离级别的事务可以看到其他事务中未提交的数据(未提交的数据可能会发生回滚,但是该隔离级别却可以读到,这个问题称之为脏读)
  2. 读已提交(READ COMMITTED):也叫提交读,该隔离级别的事务能读取到已经提交事务的数据。(该隔离级别不会有脏读的问题。但由于在事务的执行中可以读取到其他事务提交的结果,所以在不同时间的相同SQL查询可能会得到不同的结果,这种现象叫做不可重复读)
  3. 可重复读(REPEATABLE READ):事务不会读到其他事务对已有数据的修改,即使其他事务已提交。可重复读,是MySQL的默认事务隔离级别。(虽然可以确保同一事务多次查询的结果一致,但是其他事务新插入的数据,是可以感知到A事务正在执行时,另⼀个事务成功的插入了某条数据,而此时A事务如果再查寻数据库就会导致两次查找到的“结果集”不同<数据变多了>,这个现象叫幻读。)
  4. 串行化(SERIALIZABLE):序列化,事务最高隔离级别。它会强制事务排序,使之不会发生冲突,从而解决了脏读,不可重复读和幻读问题,但因为执行效率低,所以真正使用的场景并不多。

Spring中的事务隔离级别:

  1. Isolation.DEFAULT :以连接的数据库的事务隔离级别为主;
  2. Isolation.READ_UNCOMMITTED :读未提交;
  3. Isolation.READ_COMMITTED :读已提交;
  4. Isolation.REPEATABLE_READ :可重复读;
  5. Isolation.SERIALIZABLE :串行化;

事务隔离级别可以通过 @Transactional 中的 isolation 属性进行设置

@Transactional(isolation = Isolation.DEFAULT)
@RequestMapping("/fun2")
public void fun2() {}

事务的传播机制

如果A方法中调用B方法那么B方法是使用A方法的事务还是自己的事务,事务的传播机制就是为了解决该问题。

@Transactional 注解支持事务传播机制的设置,通过 propagation 属性来设置。

Spring 事务传播机制有 7 种(在A方法中调用B(七种传播机制都设置在该方法上)方法):

  1. Propagation.REQUIRED:默认的事务传播级别。如果A存在事务,则B加入该事务。如果A没有事务,则B创建一个新的事务;
  2. Propagation.SUPPORTS:如果A存在事务,则B加入该事务。如果A没有事务,则B以非事务的方式继续运行;
  3. Propagation.MANDATORY:强制性。如果A存在事务,则B加入该事务。如果A没有事务,B抛出异常;
  4. Propagation.REQUIRES_NEW:创建一个新的事务。不管A是否开启事务,B都会重新创建一个事务,且创建的事务相互独立,互不干扰;
  5. Propagation.NOT_SUPPORTED:以非事务方式运行。无论A是否存在事务,B都以非事务运行;
  6. Propagation.NEVER:以非事务方式运行。如果A存在事务,则抛出异常;
  7. Propagation.NESTED :如果A存在事务,则B创建一个事务作为当前事务的嵌套事务来运行。如果A没有事务,B创建一个事务。
@Transactional(propagation = Propagation.MANDATORY)
@RequestMapping("/fun2")
public void fun2() {}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/496904.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

[C++][C++11][四] -- [lambda表达式]

目录 1.为什么要有lambda表达式&#xff1f;2.lambda表达式3.lambda表达式语法4.函数对象与lambda表达式 1.为什么要有lambda表达式&#xff1f; 在C98中&#xff0c;如果想要对一个数据集合中的元素进行排序&#xff0c;可以使用std::sort方法 如果待排序元素为自定义类型&am…

车牌识别-只用opencv的方式

项目简述 本文描述如何只使用opencv将车牌中的车牌号提取出来&#xff0c;整个过程大致分为三个过程&#xff1a;车牌定位&#xff0c;车牌号元素分割&#xff0c;模式匹配。 在做完这个实验后&#xff0c;我感触是&#xff0c;只用opencv的方式能使用的场景有限&#xff0c;不…

大模型(LLM)的token学习记录-I

文章目录 基本概念什么是token?如何理解token的长度&#xff1f;使用openai tokenizer 观察token的相关信息open ai的模型 token的特点token如何映射到数值&#xff1f;token级操作&#xff1a;精确地操作文本token 设计的局限性 tokenizationtoken 数量对LLM 的影响训练模型参…

【MySQL】DCL

DCL英文全称是Data Control Language(数据控制语言)&#xff0c;用来管理数据库用户、控制数据库的访问权限。 1. 管理用户 在MySQL数据库中&#xff0c;DCL&#xff08;数据控制语言&#xff09;是用来管理用户和权限的语句集合。通过DCL语句&#xff0c;可以创建、修改、删…

C# 打包nuget包

类库等项目开发好之后打开csproj&#xff0c;添加如下代码 <PropertyGroup><!--<TargetFramework>netstandard2.0</TargetFramework>--><PackageId>Test01</PackageId><Version>1.0.0</Version><Authors>wjl</Autho…

安防视频监控EasyCVR平台使用GB28181协议接入时,如何正确配置端口?

国标GB28181协议EasyCVR安防视频监控平台可以提供实时远程视频监控、视频录像、录像回放与存储、告警、语音对讲、云台控制、平台级联、磁盘阵列存储、视频集中存储、云存储等丰富的视频能力&#xff0c;平台支持7*24小时实时高清视频监控&#xff0c;能同时播放多路监控视频流…

05-Linux部署MySQL

Linux部署MySQL 在今后的使用过程中&#xff0c;需要频繁使用Linux系统&#xff0c;所以在Linux上安装软是必不可少的操作 。 前置要求 需要学习前四章知识&#xff0c;初识Linux、Linux基础命令、Linux权限管理、Linux高阶技巧这4个章节。需要开启多态虚拟机&#xff0c;电…

10 Redis之SB整合Redis

7. SB整合Redis Spring Boot 中可以直接使用 Jedis 实现对 Redis 的操作&#xff0c;但一般不这样用&#xff0c;而是使用 Redis操作模板 RedisTemplate 类的实例来操作 Redis。 RedisTemplate 类是一个对 Redis 进行操作的模板类。该模板类中具有很多方法&#xff0c;这些方…

多微信管理利器,让你高效社交,轻松管理!

随着工作和生活中微信号增加&#xff0c;管理多个微信账号也成了一项挑战。面对多个微信号&#xff0c;要应对各种消息、好友请求、群发等多重任务&#xff0c;往往会让我们不知所措。 这时&#xff0c;一款强大的微信管理系统将成为你的利器&#xff0c;帮你高效社交&#xf…

Redis的高性能之道

前言&#xff1a;做码农这么多年&#xff0c;我也读过很多开源软件或者框架的源码&#xff0c;在我看来&#xff0c;Redis是我看过写得最优美、最像一件艺术品的软件&#xff0c;正如Redis之父自己说的那样&#xff0c;他宁愿以一个糟糕的艺术家身份而不是一名好程序员被别人记…

【C++STL】快速排序算法(sort)的原理与使用

一、sort算法原理 std::sort 是 C 标准库中提供的排序算法&#xff0c;它使用的是一种经典的排序算法——快速排序&#xff08;Quicksort&#xff09;或者是其变种。 快速排序是一种基于比较的排序算法&#xff0c;通过不断地选择一个基准值&#xff08;pivot&#xff09;&am…

超声波手持气象站的工作原理

TH-CSQ5A超声波手持气象站是一种利用超声波技术进行气象要素测量的便携式设备。它集成了多种气象传感器&#xff0c;包括温度传感器、湿度传感器、风速传感器、风向传感器等&#xff0c;能够同时测量和记录多个气象参数。 超声波手持气象站的工作原理基于超声波的传播特性。它…