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

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

事务有三种操作:

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

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

开启事务

业务A

回滚事务

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

开启事务

业务A

提交事务

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

Spring中事务的实现有两种

编程式(手动操作事务)

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

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

提交事务

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {
    //获取事务管理器
    @Autowired
    private DataSourceTransactionManager dataSourceTransactionManager;

    //获取事务属性
    @Autowired
    private TransactionDefinition definition;

    @Autowired
    private 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 {
    @Autowired
    private UserMapper userMapper;

    @Transactional
    @RequestMapping("/fun2")
    public void fun2() {
        userMapper.userInsert("lisi","man");
        log.info("数据插入完成");
    }
}

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

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

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {
    @Autowired
    private UserMapper userMapper;

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

编译时异常不会回滚:

@Slf4j
@RestController
@RequestMapping("/trans")
public class Test {
    @Autowired
    private 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 {
    @Autowired
    private 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 {

    @Autowired
    private 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 {

    @Autowired
    private 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() {}

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

NutUI + taro +vue 开发遇到的问题 使用popup组件 内部元素滚动遇到的的问题

1 popup 弹出内容时 弹出的框内元素数据很长需要滚动时 本地可以正常滚动 打包成小程序后无法滚动 如这样的免责条款内容 代码如下 解决办法 1 把2处的单位换成百分比 弹框能滚动但是 是popup 里面所有的元素都一起滚动 导致标题都滚走了 2 scroll-y 改成&#xff1a; :scrol…

Excel数据表定制分组排序

实例需求&#xff1a;某学校体育活动统计表如下图左侧表格所示&#xff0c;数据按照班级排列&#xff0c;现在需要根据如下规格对表格进行排序 “幼儿”班级排列在表格最后按照“次数”降序排列“幼儿”班级同样按“次数”降序排列 排序结果如下图中右侧表格所示。 示例代码…

GDB之(8)GDB-Server远程调试

GDB之(8)GDB-Server远程调试 Author&#xff1a;Once Day Date&#xff1a;2024年2月27日 漫漫长路&#xff0c;有人对你微笑过嘛… 全系列文章请查看专栏: Linux实践记录_Once-Day的博客-CSDN博客 参考文档: 用GDB调试程序 _CSDN博客 _陈皓GDB: The GNU Project Debugger…

UE4c++ ConvertActorsToStaticMesh ConvertProceduralMeshToStaticMesh

UE4c ConvertActorsToStaticMesh 创建Edior模块&#xff08;最好是放Editor模块毕竟是编辑器代码&#xff09;创建蓝图函数UBlueprintFunctionLibraryUTestFunctionLibrary.hUTestFunctionLibrary.cpp:.Build.cs 目标:为了大量生成模型&#xff0c;我们把虚幻带有的方法迁移成函…

【数据结构与算法】回溯法解题20240229

【数据结构与算法】回溯法解题20240229 一、46. 全排列1、以[1,2,3]为例&#xff0c;抽象成树形结构2、回溯三部曲 二、LCR 084. 全排列 II1、以[1,1,2]为例&#xff0c;抽象成树形结构 三、面试题 08.07. 无重复字符串的排列组合四、面试题 08.08. 有重复字符串的排列组合 一、…

基于视觉识别的自动采摘机器人设计与实现

一、前言 1.1 项目介绍 【1】项目功能介绍 随着科技的进步和农业现代化的发展&#xff0c;农业生产效率与质量的提升成为重要的研究对象。其中&#xff0c;果蔬采摘环节在很大程度上影响着整个产业链的效益。传统的手工采摘方式不仅劳动强度大、效率低下&#xff0c;而且在劳…

163邮箱SMTP端口号及服务器地址详细设置?

163邮箱SMTP端口号是什么&#xff1f;163邮件SMTP设置教程&#xff1f; 除了基本的邮箱账号和密码外&#xff0c;还需要了解SMTP服务器地址和端口号&#xff0c;以及相应的设置。这些设置对于确保邮件能够顺利发送至关重要。下面&#xff0c;蜂邮EDM将详细介绍163邮箱SMTP端口…

http和https的区别是什么?

–前言 传输信息安全性不同、连接方式不同、端口不同、证书申请方式不同 一、传输信息安全性不同 1、http协议&#xff1a;是超文本传输协议&#xff0c;信息是明文传输。如果攻击者截取了Web浏览器和网站服务器之间的传输报文&#xff0c;就可以直接读懂其中的信息。 2、h…

《Redis 设计与实现》读书概要

注&#xff1a; 《Redis 设计与实现》一书基于 Redis 2.9 版本编写&#xff0c;部分内容已过时&#xff0c;过时之处本文会有所说明。本文为读书笔记&#xff0c;部分简单和日常使用较少的知识点未记录。原书网页版地址 https://redisbook.com/ 一、底层数据结构 SDS(Simple Dy…

微信小程序固定头部-CSS实现

效果图 代码逻辑&#xff1a;设置头部的高度&#xff0c;浮动固定后&#xff0c;再加个这个高度的大小的外边距 .weui-navigation-bar {position: fixed;top: 0px;left: 0px;right: 0px;height:90px; } .weui-navigation-bar_bottom{height:90px; }

【React架构 - Scheduler中的MessageChannel】

前序 我们都知道JS代码是在浏览器5个进程(下面有介绍)中渲染进程中的Js引擎线程执行的&#xff0c;其他还有GUI渲染线程、定时器线程等&#xff0c;而页面的布局和绘制是在GUI线程中完成的&#xff0c;这些线程之间是互斥的&#xff0c;所以在执行Js的同时会阻塞页面的渲染绘制…

仿牛客网项目---社区首页的开发实现

从今天开始我们来写一个新项目&#xff0c;这个项目是一个完整的校园论坛的项目。主要功能模块&#xff1a;用户登录注册&#xff0c;帖子发布和热帖排行&#xff0c;点赞关注&#xff0c;发送私信&#xff0c;消息通知&#xff0c;社区搜索等。这篇文章我们先试着写一下用户的…

数据可视化之旅:电商销售看板的制作与心得

作为一名电商工作者&#xff0c;每天都需要与海量的销售数据打交道。在数据海洋中&#xff0c;如何快速准确地找到关键信息&#xff0c;优化销售策略&#xff0c;是摆在我面前的一大挑战。在了解市面上众多可视化产品后&#xff0c;我选择尝试了山海鲸可视化软件&#xff0c;这…

2024年小程序云开发CMS内容管理无法使用,无法同步内容模型到云开发数据库的解决方案,回退老版本CMS内容管理的最新方法

一&#xff0c;问题描述 最近越来越多的同学找石头哥&#xff0c;说cms用不了&#xff0c;其实是小程序官方最近又搞大动作了&#xff0c;偷偷的升级的云开发cms&#xff08;内容管理&#xff09;以下都称cms&#xff0c;不升级不要紧&#xff0c;这一升级&#xff0c;就导致我…

【架构之路】糟糕程序员的20个坏习惯,切记要改掉

文章目录 强烈推荐前言&#xff1a;坏习惯:总结&#xff1a;强烈推荐专栏集锦写在最后 强烈推荐 前些天发现了一个巨牛的人工智能学习网站&#xff0c;通俗易懂&#xff0c;风趣幽默&#xff0c;忍不住分享一下给大家。点击跳转到网站:人工智能 前言&#xff1a; 优秀的程序员…

matlab实现不同窗滤波器示例

1 汉明窗低通滤波器 &#xff1a; 在Matlab中使用汉明窗设计低通滤波器可以通过fir1函数实现。汉明窗通常用于设计滤波器&#xff0c;可以提供更突出的频率特性。 下面是一个示例代码&#xff0c;演示如何在Matlab中使用汉明窗设计低通滤波器&#xff1a; % 定义滤波器参数 fs …

Scrapy与分布式开发:框架原生去重机制源码解析与不足分析

框架原生去重机制源码解析与不足分析 导语 在网络爬虫和数据采集领域,去重机制是一个至关重要的环节。随着互联网的迅速发展,数据量呈爆炸式增长,如何在海量数据中高效地筛选出有价值且唯一的信息,成为了一个亟待解决的问题。去重机制正是为了解决这一问题而诞生的。 Sc…

docker中hyperf项目配置虚拟域名

在使用hyperf框架时&#xff0c;直接用了docker环境进行开发 下载镜像运行容器 docker run --name hyperf -v /data/project:/data/project -p 9501:9501 -itd -w /data/project --privileged -u root --entrypoint /bin/sh 镜像ID配置docker-compose.yml version: "3.…

东崎仪表案例-中国新能源汽车产业全面崛起

以下部分数据信息来源&#xff1a;澎湃新闻 1月9日&#xff0c;韩国研究机构SNE Research公布了全球动力电池市场的新一轮统计数据。2023年1—11月&#xff0c;全球登记的电动汽车&#xff08;EV、PHEV、HEV&#xff09;电池装车量约为624.4GWh&#xff0c;比2022年同期增长41.…

Qt SQLite的创建和使用

重点&#xff1a; 1.SQLite创建数据库内容方法 链接&#xff1a;SQLite Expert Personal的简单使用-CSDN博客 2.和数据库进行链接方法 QSqlDatabase DB; //数据库连接bool MainWindow::openDatabase(QString aFile) {DBQSqlDatabase::addDatabase("QSQLITE"); /…