【Spring系列】- Spring事务底层原理

实验准备

配置文件

首先在配置文件中配置jdbcTemplate和事务管理器,并且需要开启事务的注解@EnableTransactionManagement以及@Configuration注解

@ComponentScan("com.lyd") @EnableTransactionManagement @Configuration public class ApplicationConfig { @Bean public JdbcTemplate jdbcTemplate() { return new JdbcTemplate(dataSource()); } @Bean public PlatformTransactionManager transactionManager() { DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(); transactionManager.setDataSource(dataSource()); return transactionManager; } @Bean public DataSource dataSource() { DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/eladmin?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true"); dataSource.setUsername("root"); dataSource.setPassword("12356"); return dataSource; } }

准备数据表

本次实验使用学生表,就简单几个字段。

image.png

1|3Spring事务的底层原理

       我们在需要加上事务的方法上添加@Transactional注解,然后在此方法中使用jdbcTemplate去执行SQL语句,再来执行此方法,观察可以看到,事务真的回滚了。

@Component public class UserService { @Autowired private JdbcTemplate jdbcTemplate; @Transactional public void test(){ jdbcTemplate.execute("insert into student values (1, 'lyd', 18, '20183033210')"); throw new NullPointerException(); } }

原理

       首先spring会调用代理对象,对于事务,代理对象会通过执行事务的切面逻辑。在这个切面逻辑,Spring会去判断是否含有@Transactional事务注解,如果有才会去开启事务。spring的事务管理器会新建一个数据库连接conn,紧接着会把conn.autocommit 设置为 false ,autocommit(自动提交),每次执行完SQL后就会立马提交,因此这里需要设置为false。spring默认是开启了自动提交,当SQL执行结束之后就会提交,当遇到异常的时候,由于前面的事务都已经提升,因此就没法回滚了,所以需要把自动提交给关闭了。后在通过次创建的对象(Spring个生命周期中通过构造方法创造的对象)去执行test方法。接着会去执行SQL语句,在此SQL执行完之后是不会进行提交的,在执行SQL语句之前,jdbcTemplate会去拿到事务管理器创建的这个数据库连接conn。当执行完test方法后,Spring事务会去判断是否有异常,没有异常就会提交事务(conn.commit()),否者就会事务回滚(conn.rollback());

image.png

Spring事务失效

       接下来实现一个案例,在test方法中调用本类的另一个方法Add,两个方法都是执行了插入的SQL语句。两个方法都加上了@Transactional注解,只是在第二个方法中的注解标上一个策略:propagation = Propagation.NEVER,这个的意思是:总是非事务地执行,如果存在一个活动事务,则抛出异常。按道理来说以下代码执行将会出现异常,并且会回滚事务。

@Component public class UserService { @Autowired private JdbcTemplate jdbcTemplate; @Transactional public void test(){ jdbcTemplate.execute("insert into student values (1, 'lyd', 18, '20183033210')"); doAdd(); } @Transactional(propagation = Propagation.NEVER) public void doAdd() { jdbcTemplate.execute("insert into student values (2, 'lyy', 18, '20183033211')"); } }

可是,后的结果却不是预期结果。

image.png

失效原理

       可见后还是将两条数据插入了,显然这个事务是不回滚的,那么这是为什么呢?从上面说事务的底层原理就可以知道,当spring创建了代理对象,在代理对象内部的test方法中的切面逻辑,会去创建数据库连接等等,后由普通对象(UserService.class通过构造方法去创建的对象)去执行test,也就是相当于是使用了普通对象去执行doAdd方法,普通对象就只是构造方法实例化的一个对象,执行doAdd并不会去检测这个@Transactional注解,因此这个事务就不会被执行到,也就不会回滚。然而spring应该是在执行代理类的test方法时候回去判断@Transactional注解,会有额外的逻辑去判断事务,也就是doAdd应该也要由代理对象去执行。

解决方案

那么有办法解决吗?办法肯定过有,接下来介绍一种解决方法

方案一

将add方法抽到另一个bean类里面

@Component public class UserBaseService { @Autowired private JdbcTemplate jdbcTemplate; @Transactional(propagation = Propagation.NEVER) public void doAdd() { jdbcTemplate.execute("insert into student values (2, 'lyy', 18, '20183033211')"); } }

再来通过bean对象来执行这个doAdd方法

@Component public class UserService { private JdbcTemplate jdbcTemplate; private UserBaseService userBaseService; jdbcTemplate.execute("insert into student values (1, 'lyd', 18, '20183033210')"); userBaseService.doAdd(); } }

然后把数据表清空,在此执行

image.png

这回就报错了,而且也是我们所期望的错误,在看一下数据表,发现数据没有保存进去。

方案二

       那如果我们还是想要在本类中去执行这个doAdd方法呢?其实也是可以,就是我们通过自己调用自己的方式,在本类中引用本类的bean对象,此时他就是一个代理对象,这样事务的策略也就能够实现了。

@Autowired private UserService userService; @Transactional public void test(){ jdbcTemplate.execute("insert into student values (1, 'lyd', 18, '20183033210')"); throw new NullPointerException(); userService.doAdd(); }

也能得到我们预期的实现效果,数据库中也没有相关数据。

image.png

1|4@Configuration底层原理

在上面我们提到了jdbcTemplate获得数据库连接,那么这个又是如何得到呢?我们来看一下一开始的配置。

@Bean public JdbcTemplate jdbcTemplate() { return new JdbcTemplate(dataSource()); } @Bean public PlatformTransactionManager transactionManager() { DataSourceTransactionManager transactionManager = new DataSourceTransactionManager(); transactionManager.setDataSource(dataSource()); return transactionManager; } @Bean public DataSource dataSource() { DriverManagerDataSource dataSource = new DriverManagerDataSource(); dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/eladmin?serverTimezone=Asia/Shanghai&characterEncoding=utf8&useSSL=false&useOldAliasMetadataBehavior=true"); dataSource.setUsername("root"); dataSource.setPassword("12356"); return dataSource; }

贯穿逻辑

       在创建 jdbcTemplate 的bean对象的时候,会去调用 dataSource ,在创建事务管理PlatformTransactionManager也会去调用一次dataSource方法,在这个方法中会创建新的dataSource,那么,所获得的事务不就不一样了吗,显然这是不行的。那么在spring中,他是如何实现单例的呢?就是通过 @Configuration 注解来实现。
       其实spring会通过ThreadLocal(线程变量,是一个以ThreadLocal对象为键、任意对象为值的存储结构),在spring中ThreadLocal<Map<DataSource, conn>>是根据 DataSource来存储连接conn,如果没有 @Configuration注解来实现,两次使用的DataSource就是不同的。 jdbcTemplate在获取 DataSource 对象的时候,会去ThreadLocal的map根据jdbcTemplate自己的DataSource去找连接,然而这时候DataSource对象不同,他就找不到,就会自己从新生成连接,当执行完SQL语句之后,就会去提交,这时候接下来再抛异常已经没用了。

@Configuration原理

       然而,@Configuration能够实现单例DataSource对象呢?这就是因为@Configuration也是采用了动态代理会创建ApplicationConfig的代理对象。spring会创建ApplicationConfig的代理对象,这个代理对象会去调用jdbcTemplate方法,而代理对象会执行super.jdbcTemplate(),在这个方法中需要执行dataSource()方法,他会首先去容器中找是否有dataSource的bean对象,如果有直接返回,没有就会创建,创建之后会将单例进行保存。接着transactionManager方法也是由代理对象去执行的,在他需要dataSource对象的时候,也是现去容器查找,这就能够实现他们两个的dataSource是一样的了。这样事务拿到的数据库连接就是相同了,如果是在使用dataSource这个bean对象的时候,使用的beanName是不同,那么后得到的连接也就不同。

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

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

相关文章

[入门]测试原则-ApiHug准备-测试篇-002

&#x1f917; ApiHug {Postman|Swagger|Api...} 快↑ 准√ 省↓ GitHub - apihug/apihug.com: All abou the Apihug apihug.com: 有爱&#xff0c;有温度&#xff0c;有质量&#xff0c;有信任ApiHug - API design Copilot - IntelliJ IDEs Plugin | Marketplace 写在前面…

低敏猫粮怎么选?看这一篇就够了!

亲爱的朋友们&#xff0c;你们是否曾经为了家中敏感肠胃的小猫咪而犯愁&#xff0c;不知道如何选择适合的猫粮呢&#xff1f;今天&#xff0c;就让我们一起聊聊低敏猫粮与普通猫粮的那些不同之处吧&#xff01;&#x1f431; 1️⃣ **成分差异**&#xff1a;首先&#xff0c;从…

Go 自定义14位时间类型 yyyyMMddHHmmss

目录 功能 代码 功能 数据库或者接口时间类型&#xff0c;经常会使用14位的时间格式。每次都转换有点麻烦。可以自定义一个时间类型。 自定义类型需要实现json接口中的MarshalJSON与UnmarshalJSON两个函数&#xff0c;这样在做json编码解码时就会自动转为14位的时间格式了。…

第四届大数据工程与教育国际会议(BDEE 2024)即将召开!

第四届大数据工程与教育国际会议&#xff08;BDEE 2024&#xff09;将于2024年8月9-11日在泰国清迈举行。数据驱动教育变革&#xff0c;智慧点亮未来课堂&#xff01;BDEE 2024是专注于大数据工程与教育领域的重要学术会议&#xff0c;全球大数据与教育精英齐聚&#xff0c;在数…

使用 Docker 部署 SurveyKing 调查问卷系统

1&#xff09;SurveyKing 介绍 SurveyKing 是一款功能强大、操作简便的开源问卷系统。它不仅满足了用户对问卷调查的基本需求&#xff0c;还提供了丰富的逻辑设置和灵活的问题设置&#xff0c;使得问卷制作更加智能化和个性化。此外&#xff0c;SurveyKing 还具有快速部署和安全…

构建鸿蒙ACE静态库

搭建开发环境 根据说明文档下载鸿蒙全部代码&#xff0c;一般采取第四种方式获取最新代码(请保证代码为最新) 源码获取Windows下载编译环境 MinGW GCC 7.3.0版本 请添加环境变量IDE 可以使用两种 CLion和Qt,CLion不带有环境需要安装MinGW才可以开发,Qt自带MinGW环境&#xff0…

认识一下RAG

1.RAG技术背景与挑战 2.RAG的核心概念 3.RAG的工作流程与架构 4.RAG的优化方法 RAG的提出 •Retrieval-Augmented Generation for Knowledge-Intensive NLP Tasks是一篇重要的论文(2020年5月) •REALM: Retrieval-Augmented Language Model Pre-Training (2020)就将BERT预训练模…

家居网购项目(三)

文章目录 1.后台管理—添加家居1.需求分析2.程序框架图3.修改FurnDao添加方法add 4.修改FurnDaoImpl添加方法add 5.单元测试FurnDaoTest.java 6.修改FurnService添加方法add 7.修改FurnServiceImpl添加方法add 8.单元测试FurnServiceTest.java 9.修改furn_add.jsp10.修改FurnSe…

【面试经典 150 | 数学】阶乘后的零

文章目录 写在前面Tag题目来源题目解读解题思路方法一&#xff1a;数学优化计算 写在最后 写在前面 本专栏专注于分析与讲解【面试经典150】算法&#xff0c;两到三天更新一篇文章&#xff0c;欢迎催更…… 专栏内容以分析题目为主&#xff0c;并附带一些对于本题涉及到的数据结…

人工智能——机器学习概述

1. 人工智能 1.1. 概念 人工智能(Artificial Intelligence&#xff0c;AI)&#xff0c;是新一轮科技革命和产业变革的重要驱动力量&#xff0c; [26]是研究、开发用于模拟、延伸和扩展人的智能的理论、方法、技术及应用系统的一门新的技术科学。 人工智能是智能学科重要的组…

【Ansible自动化运维】Ansible入门基础信息【安装配置、常用命令与模块】

介绍安装配置注意事项yum安装验证安装配置host配置主机清单配置主控端被控端 常用模块命令组成command模块shell模块copy模块script模块 日志信息最后 介绍 Ansible 是一个开源 IT 自动化引擎&#xff0c;可自动执行供应、配置管理、应用程序部署、编排和许多其他 IT 流程。它可…

YesPMP平台 | 活动有礼,现金奖励点击领取!

YesPMP众包平台在线发福利啦&#xff0c;活动火热开启&#xff0c;现金奖励等你来领&#xff0c;最高可领千元&#xff0c;赶快参与将奖励收入囊中&#xff0c;一起来了解活动细节吧&#xff01; 一、活动内容&#xff1a; 活动一&#xff1a;【项目征集令】活动&#xff0c;…

前端大文件上传 -- 上传文件到S3或本地服务器

特别提醒 大文件上传的文件切片逻辑, 包括如何将分片文件上传到本地服务器, 请查看之前的文章: 前端大文件上传 - 总结&#xff08;Vue3 hook Web Worker实现&#xff0c;通过多个Worker线程大大提高Hash计算的速度&#xff09;, 本篇仅实现如何将大文件分块上传到S3. 后面写…

关于Wordpress的操作问题1:如何点击菜单跳转新窗口

1.如果打开&#xff0c;外观-菜单-菜单结构内&#xff0c;没有打开新窗口属性&#xff0c;如图&#xff1a; 2.在页面的最上部&#xff0c;点开【显示选项】&#xff0c;没有这一步&#xff0c;不会出现新跳转窗口属性 3.回到菜单结构部分&#xff0c;就出现了

2024年工程师职称水平能力测试考试难吗?

大家现在都知道&#xff0c;现在湖北中级和高级职称评审&#xff0c;都必须要先报名一个水平能力测试考试&#xff0c;水测考过了之后才能参加评审&#xff0c;那么很多人都不知道水测到底难不难&#xff1f;能不能考过&#xff1f;水测主要是考什么呢&#xff1f; 职称水平能力…

Rust 语言 GUI 用户界面框架汇总(持续更新)

拜登&#xff1a;“一切非 Rust 项目均为非法”&#x1f60e; 什么是 GUI 图形用户界面&#xff08;Graphical User Interface&#xff0c;简称 GUI&#xff0c;又称图形用户接口&#xff09;是指采用图形方式显示的计算机操作用户界面。 现在的应用开发&#xff0c;是既要功…

【python】flask操作数据库工具SQLAlchemy,详细用法和应用实战

✨✨ 欢迎大家来到景天科技苑✨✨ &#x1f388;&#x1f388; 养成好习惯&#xff0c;先赞后看哦~&#x1f388;&#x1f388; &#x1f3c6; 作者简介&#xff1a;景天科技苑 &#x1f3c6;《头衔》&#xff1a;大厂架构师&#xff0c;华为云开发者社区专家博主&#xff0c;…

【Linux系统编程】第三弹---基本指令(一)

✨个人主页&#xff1a; 熬夜学编程的小林 &#x1f497;系列专栏&#xff1a; 【C语言详解】 【数据结构详解】【C详解】【Linux系统编程】 目录 1、touch指令 2、mkdir指令 3、ls 指令 4、pwd命令 3、cd 指令 6、rmdir指令 && rm 指令 7、man指令 7、cp指令 …

在 PyCharm 中使用系统安装的 Python 和 Anaconda 的 Python什么区别

virtualenv environment &#xff1a; virtualenv 是一个用于创建独立 Python 环境的工具。它可以在同一个系统上创建多个相互独立的 Python 环境&#xff0c;每个环境都有自己的 Python 解释器和包库&#xff0c;从而可以实现不同项目之间的依赖隔离和版本控制。coda environm…

[已解决]问题:root.users.hdfs is not a leaf queue

问题&#xff1a;root.users.hdfs is not a leaf queue CDH集群报错&#xff1a; Exception in thread “main” org.apache.hadoop.yarn.exceptions.YarnException: Failed to submit application_1713149630679_0005 to YARN : root.users.hdfs is not a leaf queue 思路 …