Spring-4-掌握Spring事务传播机制

今日目标

能够掌握Spring事务配置

Spring事务管理

1 Spring事务简介【重点】

1.1 Spring事务作用

  • 事务作用：在数据层保障一系列的数据库操作同成功同失败

  • Spring事务作用：在数据层或业务层保障一系列的数据库操作同成功同失败

1.2 案例分析Spring事务

  • 需求：实现任意两个账户间转账操作

  • 需求微缩：A账户减钱，B账户加钱

  • 分析： ①：数据层提供基础操作，指定账户减钱（outMoney），指定账户加钱（inMoney） ②：业务层提供转账操作（transfer），调用减钱与加钱的操作 ③：提供2个账号和操作金额执行转账操作 ④：基于Spring整合MyBatis环境搭建上述操作

  • 结果分析： ①：程序正常执行时，账户金额A减B加，没有问题 ②：程序出现异常后，转账失败，但是异常之前操作成功，异常之后操作失败，整体业务失败

  • 结构：

1.3 代码实现

【前置工作】环境准备

创建数据库和表

CREATE DATABASE IF NOT EXISTS `spring_db2` DEFAULT CHARACTER SET utf8
USE `spring_db2`;DROP TABLE IF EXISTS `tbl_account`;
CREATE TABLE `tbl_account` (`id` INT(11) NOT NULL AUTO_INCREMENT,`name` VARCHAR(20) DEFAULT NULL,`money` DOUBLE DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;INSERT  INTO `tbl_account`(`id`,`name`,`money`) VALUES
(1,'Jack',1000),
(2,'Rose',1000);DROP TABLE IF EXISTS `tbl_log`;
CREATE TABLE `tbl_log` (`id` INT(11) NOT NULL AUTO_INCREMENT,`info` VARCHAR(255) DEFAULT NULL,`create_date` DATETIME DEFAULT NULL,PRIMARY KEY (`id`)
) ENGINE=INNODB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;INSERT  INTO `tbl_log`(`id`,`info`,`create_date`) VALUES
(2,'Jack向Rose转账520.0元','2021-11-04 17:19:18');

pom.xml添加依赖

    <dependencies><!--导入spring的坐标spring-context，对应版本是5.2.10.RELEASE--><dependency><groupId>org.springframework</groupId><artifactId>spring-context</artifactId><version>5.3.15</version></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>1.18.28</version></dependency><dependency><groupId>org.springframework</groupId><artifactId>spring-jdbc</artifactId><version>5.3.15</version></dependency>
<!--mysql--><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.27</version></dependency><!-- https://mvnrepository.com/artifact/org.mybatis/mybatis --><dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.5.13</version></dependency><dependency><groupId>org.mybatis</groupId><artifactId>mybatis-spring</artifactId><version>1.3.0</version></dependency><!-- https://mvnrepository.com/artifact/com.alibaba/druid --><dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.2.18</version></dependency><!--junit,spring对junit4的要求必须是4.12版本以上--><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>4.13</version><scope>test</scope></dependency><!--spring-test--><dependency><groupId>org.springframework</groupId><artifactId>spring-test</artifactId><version>5.3.22</version><scope>test</scope></dependency></dependencies>

Spring整合Mybatis相关代码(依赖、JdbcConfig、MybatisConfig、SpringConfig) JdbcConfig

package com.zbbmeta.config;import com.alibaba.druid.pool.DruidDataSource;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;import javax.sql.DataSource;public class JdbcConfig {@Value("${jdbc.driverClassName}")private String driverClassName;@Value("${jdbc.url}")private String url;@Value("${jdbc.username}")private String userName;@Value("${jdbc.password}")private String password;@Beanpublic DataSource dataSource(){DruidDataSource ds = new DruidDataSource();ds.setDriverClassName(driverClassName);ds.setUrl(url);ds.setUsername(userName);ds.setPassword(password);return ds;}//spring提供的事务切面类：里面增强了事务管理功能，里面有事务提交和事务回滚功能@Beanpublic PlatformTransactionManager transactionManager(DataSource dataSource){DataSourceTransactionManager ptm = new DataSourceTransactionManager();ptm.setDataSource(dataSource);return ptm;}
}

MybatisConfig

package com.zbbmeta.config;import org.apache.ibatis.logging.stdout.StdOutImpl;
import org.apache.ibatis.session.Configuration;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.mapper.MapperScannerConfigurer;
import org.springframework.context.annotation.Bean;import javax.sql.DataSource;public class MybatisConfig {@Bean  //不仅可以将返回值加入IOC容器，而且可以实现方法参数进行依赖注入，参数默认会根据类型从IOC容器中获取对象自动注入public SqlSessionFactoryBean sqlSessionFactoryBean(DataSource dataSource){SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean();ssfb.setTypeAliasesPackage("com.zbbmeta.entity"); //告诉mybatis，设置实体类包别名ssfb.setDataSource(dataSource); //将IOC容器中连接池给到Mybatis//注意：必须导入org.apache.ibatis.session.Configuration;Configuration configuration = new Configuration();//设置整合mybatis驼峰命名映射configuration.setMapUnderscoreToCamelCase(true);//设置打印日志configuration.setLogImpl(StdOutImpl.class);ssfb.setConfiguration(configuration);return ssfb;}
}

SpringConfig

@Configuration
@ComponentScan("com.zbbmeta")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
public class SpringConfig {
}

Account

@ToString
@Data
public class Account {private Integer id;private String name;private Double money;}

AccountDao

public interface AccountDao {@Update("update tbl_account set money = money + #{money} where name = #{name}")void inMoney(@Param("name") String name, @Param("money") Double money);@Update("update tbl_account set money = money - #{money} where name = #{name}")void outMoney(@Param("name") String name, @Param("money") Double money);
}

public interface AccountService {/*** 转账操作* @param out 传出方* @param in 转入方* @param money 金额*/void transfer(String out,String in,Double money) ;
}

AccountServiceImpl

@Service
public class AccountServiceImpl implements AccountService {@Autowiredprivate AccountDao accountDao;public void transfer(String out, String in, Double money) {//转出accountDao.outMoney(out, money);//模拟出现异常//System.out.println(1 / 0);//转入accountDao.inMoney(in, money);System.out.println("转账成功");}
}

【第一步】在业务层接口上添加Spring事务管理

在转账的方法上添加@Transactional注解

/*** 业务接口*/
public interface AccountService {/*** 转账操作* @param out 传出方* @param in 转入方* @param money 金额*/@Transactionalvoid transfer(String out,String in ,Double money) ;
}

注意事项

  1. Spring注解式事务通常添加在业务层接口中而不会添加到业务层实现类中，降低耦合

  2. 注解式事务可以添加到业务方法上表示当前方法开启事务，也可以添加到接口上表示当前接口所有方法开启事务

【第二步】设置事务管理器(将事务管理器添加到IOC容器中)

说明：可以在JdbcConfig中配置事务管理器

//配置事务管理器，mybatis使用的是jdbc事务
@Bean
public PlatformTransactionManager transactionManager(DataSource dataSource){DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();transactionManager.setDataSource(dataSource);return transactionManager;
}

注意事项

  1. 事务管理器要根据实现技术进行选择

  2. MyBatis框架使用的是JDBC事务

【第三步】开启注解式事务驱动

@EnableTransactionManagement

@Configuration
@ComponentScan("com.itheima")
@PropertySource("classpath:jdbc.properties")
@Import({JdbcConfig.class,MybatisConfig.class})
@EnableTransactionManagement //开启事务注解扫描
public class SpringConfig {
}

【第四步】运行测试类，查看结果

  1. 去掉@EnableTransactionManagement注解，即没有进行事务管理，当转账出现问题时结果

  1. 加上@EnableTransactionManagement注解，账户钱都恢复成1000

结果

  1. 转账成功的时候

结果：

@RunWith(SpringJUnit4ClassRunner.class)  //指定第三方的运行器
@ContextConfiguration(classes = SpringConfig.class)  //读取类配置文件
public class AccountDaoTest {@Autowired  //自动注入业务对象private AccountService accountService;@Testpublic void testFindById() throws IOException {//直接使用业务方法accountService.transfer("Jack","Rose", 100d);}
}

2 Spring事务角色【理解】

问题导入

什么是事务管理员，什么是事务协调员？

2.1 Spring事务角色

  • 事务管理员：发起事务方，在Spring中通常指代业务层开启事务的方法

  • 事务协调员：加入事务方，在Spring中通常指数据层方法，也可以是业务层方法

3 Spring事务相关配置

问题导入

什么样的异常，Spring事务默认是不进行回滚的？

3.1 @Transactional注解中与事务相关配置

属性作用示例
readOnly设置是否为只读事务readOnly=true 只读事务
timeout设置事务超时时间timeout = -1（永不超时）
rollbackFor设置事务回滚异常（class）rollbackFor = {FileNotFoundException.class}
rollbackForClassName设置事务回滚异常（String）同上格式为字符串
noRollbackFor设置事务不回滚异常（class）noRollbackFor = {FileNotFoundException.class}
noRollbackForClassName设置事务不回滚异常（String）同上格式为字符串
propagation设置事务传播行为……
属性作用示例
readOnly设置是否为只读事务readOnly=true 只读事务
timeout设置事务超时时间timeout = -1（永不超时）
rollbackFor设置事务回滚异常（class）rollbackFor = {FileNotFoundException.class}
rollbackForClassName设置事务回滚异常（String）同上格式为字符串
noRollbackFor设置事务不回滚异常（class）noRollbackFor = {FileNotFoundException.class}
noRollbackForClassName设置事务不回滚异常（String）同上格式为字符串
propagation设置事务传播行为……

说明：对于RuntimeException类型异常或者Error错误，Spring事务能够进行回滚操作。但是对于非运行时异常，Spring事务是不进行回滚的，所以需要使用rollbackFor来设置要回滚的异常。

3.2 案例：转账业务追加日志

需求和分析

  • 需求：实现任意两个账户间转账操作，并对每次转账操作在数据库进行记录

  • 需求微缩：A账户减钱，B账户加钱，数据库记录日志

  • 分析： ①：基于转账操作案例添加日志模块，实现数据库中记录日志 ②：业务层转账操作（transfer），调用减钱、加钱与记录日志功能

  • 实现效果预期： 无论转账操作是否成功，均进行转账操作的日志留痕

  • 存在的问题： 日志的记录与转账操作隶属同一个事务，同成功同失败

  • 实现效果预期改进： 无论转账操作是否成功，日志必须保留

  • 事务传播行为：事务协调员对事务管理员所携带事务的处理态度

【准备工作】环境整备

创建新的LogDao接口

public interface LogDao {@Insert("insert into tbl_log (info,create_date) values(#{info},now())")void log(String info);
}

创建业务接口使用事务

public interface LogService {/*** 记录日志* @param out 转出账户* @param in 转入账户* @param money 金额* 设置事务属性：传播行为设置为需要新事务*/@Transactionalvoid log(String out, String in, Double money);
}

实现类

@Service
public class LogServiceImpl implements LogService {@Autowiredprivate LogDao logDao;public void log(String out, String in, Double money) {logDao.log("转账操作由" + out + "到" + in + ",金额：" + money);}
}

【第一步】在AccountServiceImpl中调用logService中添加日志的方法

因为无论成功与否，都需要记录日志，所以日志放在finally语句块中，但异常不需要捕获，要抛出用来激活事务的处理

/*** 业务接口*/
public interface AccountService {/*** 转账操作* @param out 传出方* @param in 转入方* @param money 金额*/@Transactionalvoid transfer(String out,String in ,Double money) ;
}

@Service
public class AccountServiceImpl implements AccountService {@Autowiredprivate AccountDao accountDao;@Autowiredprivate LogService logService;public void transfer(String out,String in ,Double money) {try{accountDao.outMoney(out,money);//int i = 1/0;accountDao.inMoney(in,money);} finally {logService.log(out,in,money);}}
}

【第二步】在LogService的log()方法上设置事务的传播行为

需求：无论有没有异常日志都要记录下来，不能被回滚

  1. 先只设置@Transactional，查看运行结果

  2. 设置成当前操作需要新事务再查看运行结果

public interface LogService {//propagation设置事务属性：传播行为设置为当前操作需要新事务@Transactional(propagation = Propagation.REQUIRES_NEW)void log(String out, String in, Double money);
}

【第三步】运行测试类，查看结果

@RunWith(SpringJUnit4ClassRunner.class)  //指定第三方的运行器
@ContextConfiguration(classes = SpringConfig.class)  //读取类配置文件
public class AccountServiceTest {@Autowired  //自动注入业务对象private AccountService accountService;/*** 转账的测试*/@Testpublic void testTransfer() {accountService.transfer("Jack", "Rose", 10d);}
}

思考:为什么 在LogService的方法上设置propagation = Propagation.REQUIRES_NEW接可以创建新的事务?

这就是事务传播行为(经常会面试提问)

3.3 事务传播行为

传播属性Method1Method2
REQUIRED开启TI事务加入T1事务
无新建T2事务
REQUIRES_NEW开启TI事务新建T2事务
无新建T2事务
SUPPORTS开启TI事务加入T1事务
无无
NOT_SUPPORTED开启TI事务无
无无
MANDATORY开启TI事务加入T1事务
无ERROR
NEVER开启TI事务ERROR
无无
NESTED

思考:事务会一直生效？有没有事务失效的情况？为什么会失效，大家可以思考一下，这也是一个长问面试题

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

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

相关文章

STM32--TIM定时器（2）

STM32--TIM定时器（2）

文章目录 输出比较PWM输出比较通道参数计算舵机简介直流电机简介TB6612 PWM基本结构PWM驱动呼吸灯PWM驱动舵机PWM控制电机 输出比较 输出比较&#xff0c;简称OC&#xff08;Output Compare&#xff09;。 输出比较的原理是&#xff0c;当定时器计数值与比较值相等或者满足某种…
阅读更多...
【数据结构OJ题】有效的括号

【数据结构OJ题】有效的括号

原题链接&#xff1a;https://leetcode.cn/problems/valid-parentheses/ 目录 1. 题目描述 2. 思路分析 3. 代码实现 1. 题目描述 2. 思路分析 这道题目主要考查了栈的特性&#xff1a; 题目的意思主要是要做到3点匹配&#xff1a;类型、顺序、数量。 题目给的例子是比较…
阅读更多...
【Hibench 】完成 HDP-Spark 性能测试

【Hibench 】完成 HDP-Spark 性能测试

&#x1f341; 博主 "开着拖拉机回家"带您 Go to New World.✨&#x1f341; &#x1f984; 个人主页——&#x1f390;开着拖拉机回家_Linux,Java基础学习,大数据运维-CSDN博客 &#x1f390;✨&#x1f341; &#x1fa81;&#x1f341; 希望本文能够给您带来一定的…
阅读更多...
单片机实训报告

单片机实训报告

这周我们进行了单片机实训&#xff0c;一周中我们通过七个项目1&#xff1a;P1 口输入/输出 2&#xff1a;继电器控制 3 音频控制 4&#xff1a;子程序设计 5&#xff1a;字符碰头程序设计 6&#xff1a;外部中断 7&#xff1a; 急救车与交通信号灯&#xff0c;练习编写了子程…
阅读更多...
mysql 设置 mysql 日志时间与系统时间保持一致

mysql 设置 mysql 日志时间与系统时间保持一致

临时设置 mysql> show variables like %log_timestamps%;-----------------------| Variable_name | Value |-----------------------| log_timestamps | UTC |-----------------------1 row in set (0.00 sec)系统是 CST &#xff0c; nysql 是 UTC当UTC时间为0点时&am…
阅读更多...
docker的使用方法总结

docker的使用方法总结

Docker是一个非常强大的工具&#xff0c;它可以用于创建、部署和运行应用程序。以下是一些docker相关的常用指令&#xff0c; 1、查看docker版本 docker version 2、查看正在运行的Docker容器 docker ps 3、查看所有的docker容器&#xff08;包括没有运行的容器&#xff0…
阅读更多...
Python 之 Http 获取网页的 html 数据，并去掉 html 格式等相关信息

Python 之 Http 获取网页的 html 数据，并去掉 html 格式等相关信息

Python之 Http 获取网页的 html 数据，并去掉 html 格式等相关信息 目录 Python之 Http 获取网页的 html 数据，并去掉 html 格式等相关信息
阅读更多...
SCF金融公链新加坡启动会 创新驱动未来

SCF金融公链新加坡启动会 创新驱动未来

新加坡迎来一场引人瞩目的金融科技盛会&#xff0c;SCF金融公链启动会于2023年8月13日盛大举行。这一受瞩目的活动将为金融科技领域注入新的活力&#xff0c;并为广大投资者、合作伙伴以及关注区块链发展的人士提供一个难得的交流平台。 在SCF金融公链启动会上&#xff0c; Wil…
阅读更多...
级联（数据字典）

级联（数据字典）

二级级联&#xff1a; 一&#xff1a;新建两个Bean 父级&#xff1a; /*** Description 数据字典* Author WangKun* Date 2023/7/25 10:15* Version*/ Data AllArgsConstructor NoArgsConstructor TableName("HW_DICT_KEY") public class DictKey implements Seri…
阅读更多...
excel快速选择数据、选择性粘贴、冻结单元格

excel快速选择数据、选择性粘贴、冻结单元格

一、如何快速选择数据 在excel中&#xff0c;希望选择全部数据&#xff0c;通常使用鼠标选择数据然后往下拉&#xff0c;当数据很多时&#xff0c;也可单击单元格使用ctrl A选中全部数据&#xff0c;此外&#xff0c;具体介绍另一种方法。 操作&#xff1a;ctrl shift 方向…
阅读更多...
【C++】STL---list

【C++】STL---list

STL---list 一、list 的介绍二、list 的模拟实现1. list 节点类2. list 迭代器类&#xff08;1&#xff09;前置&#xff08;2&#xff09;后置&#xff08;3&#xff09;前置- -、后置- -&#xff08;4&#xff09;! 和 运算符重载&#xff08;5&#xff09;* 解引用重载 和 …
阅读更多...
css3新增属性

css3新增属性

文章目录 css3新增属性box-shadowborder-radius设置椭圆 position: sticky;渐变背景线性渐变可重复的渐变背景 径向渐变可重复的渐变背景 过渡分属性 动画关键帧与transition的关系demo 变形平移使用 旋转使用 其他使用立体效果perspective元素位于3D空间还是平面中 缩放变形的…
阅读更多...
tornado在模板中遍历二维数组

tornado在模板中遍历二维数组

要在Tornado模板中遍历一个二维数组&#xff0c;你可以使用Tornado的模板语法来实现迭代和显示数组中的每个元素。 以下是一个示例&#xff0c;演示如何在Tornado模板中遍历和显示二维数组的内容&#xff1a; template.html: <!DOCTYPE html> <html> <head&g…
阅读更多...
小米分享 | 解密面试题：网易面试如何回答“创建线程有哪几种方式？”

小米分享 | 解密面试题：网易面试如何回答“创建线程有哪几种方式？”

大家好&#xff0c;我是你们的小米&#xff01;今天要和大家一起探讨一个在技术面试中常见的问题&#xff1a;创建线程有哪几种方式&#xff1f;这可是个经典面试题哦&#xff01;不过别担心&#xff0c;小米在这里为你详细解析&#xff0c;帮你轻松应对&#xff0c;让你在面试…
阅读更多...
深度学习在MRI运动校正中的应用综述

深度学习在MRI运动校正中的应用综述

运动是MRI中的主要挑战之一。由于MR信号是在频率空间中获取的&#xff0c;因此除了其他MR成像伪影之外&#xff0c;成像对象的任何运动都会导致重建图像中产生伪影。深度学习被提出用于重建过程的几个阶段的运动校正。广泛的MR采集序列、感兴趣的解剖结构和病理学以及运动模式&…
阅读更多...
用dcker极简打包java.jar镜像并启动

用dcker极简打包java.jar镜像并启动

用dcker极简打包java.jar镜像并启动 一、本地打包好jar包 二、新建文件夹&#xff0c;将步骤1中的jar包拷贝到文件夹下 三、同目录下新建Dockerfile ## 基础镜像&#xff0c;这里用的是openjdk:8 FROM openjdk:8## 将步骤一打包好的jar包 拷贝到镜像的 跟目录下[目录可以自定义…
阅读更多...
Oracle字段长度不足位数补零

Oracle字段长度不足位数补零

Oracle字段长度不足位数补零 有时候从数据库中取出的月份值是1&#xff0c;而不是01&#xff0c;该怎么办呢 SELECTLPAD( CODE_MONTH, 2, 0 ) FROMtb_cube_TY001 WHERECODE_BM_MEATYPE TY20 AND code_measure MYLX01 AND code_month <> ~ AND CODE_ENTITY 01A AND…
阅读更多...
【实战】十一、看板页面及任务组页面开发（二） —— React17+React Hook+TS4 最佳实践，仿 Jira 企业级项目（二十四）

【实战】十一、看板页面及任务组页面开发（二） —— React17+React Hook+TS4 最佳实践，仿 Jira 企业级项目（二十四）

文章目录 一、项目起航&#xff1a;项目初始化与配置二、React 与 Hook 应用&#xff1a;实现项目列表三、TS 应用&#xff1a;JS神助攻 - 强类型四、JWT、用户认证与异步请求五、CSS 其实很简单 - 用 CSS-in-JS 添加样式六、用户体验优化 - 加载中和错误状态处理七、Hook&…
阅读更多...
“深入探索JVM：解析Java虚拟机的工作原理与优化“

“深入探索JVM：解析Java虚拟机的工作原理与优化“

标题&#xff1a;深入探索JVM&#xff1a;解析Java虚拟机的工作原理与优化 摘要&#xff1a;本篇博客将深入探讨Java虚拟机&#xff08;JVM&#xff09;的工作原理以及如何优化JVM的性能。我们将介绍JVM的组成部分、类加载过程、内存管理、垃圾回收机制以及常见的性能优化技术…
阅读更多...
记一次线上OOM事故

记一次线上OOM事故

OOM 问题 linux内核有个机制叫OOM killer(Out-Of-Memory killer)&#xff0c;当系统需要申请内存却申请不到时&#xff0c;OOM killer会检查当前进程中占用内存最大者&#xff0c;将其杀掉&#xff0c;腾出内存保障系统正常运行。 一般而言&#xff0c;一个应用的内存逐渐增加&…
阅读更多...
最新文章

Copyright @ 2022~2023