声明式事务

本文涉及的产品
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: Spring 框架对 JDBC 进行封装,使用 JdbcTemplate 方便实现对数据库操作

Spring 框架对 JDBC 进行封装,使用 JdbcTemplate 方便实现对数据库操作


准备工作



<dependencies>
<!-- 基于Maven依赖传递性,导入spring-context依赖即可导入当前所需所有jar包 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>5.3.1</version>
</dependency>
<!-- Spring 持久化层支持jar包 -->
<!-- Spring 在执行持久化层操作、与持久化层技术进行整合过程中,需要使用orm、jdbc、tx三个
jar包 -->
<!-- 导入 orm 包就可以通过 Maven 的依赖传递性把其他两个也导入 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-orm</artifactId>
<version>5.3.1</version>
</dependency>
<!-- Spring 测试相关 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>5.3.1</version>
</dependency>
<!-- junit测试 -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<!-- MySQL驱动 -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.16</version>
</dependency>
<!-- 数据源 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.0.31</version>
</dependency>
</dependencies>


创建jdbc.properties


jdbc.user=root
jdbc.password=atguigu
jdbc.url=jdbc:mysql://localhost:3306/ssm
jdbc.driver=com.mysql.cj.jdbc.Driver



配置Spring的配置文件


<!--导入外部属性文件-->
<context:property-placeholderlocation="classpath:jdbc.properties"/>
<!--配置数据源-->
<beanid="druidDataSource"class="com.alibaba.druid.pool.DruidDataSource"> 
 <propertyname="url"value="${atguigu.url}"/>
  <propertyname="driverClassName"value="${atguigu.driver}"/>
  <propertyname="username"value="${atguigu.username}"/>
  <propertyname="password"value="${atguigu.password}"/>
</bean>
<!--配置JdbcTemplate-->
<beanid="jdbcTemplate"class="org.springframework.jdbc.core.JdbcTemplate">  <!--装配数据源-->
  <propertyname="dataSource"ref="druidDataSource"/>
</bean>


声明式事务概念


编程式的实现方式存在缺陷:

细节没有被屏蔽:具体操作过程中,所有细节都需要程序员自己来完成,比较繁琐。


代码复用性不高:如果没有有效抽取出来,每次实现功能都需要自己编写代码,代码就没有得到复用。


声明式事务

既然事务控制的代码有规律可循,代码的结构基本是确定的,所以框架就可以将固定模式的代码抽取出来,进行相关的封装。

封装起来后,我们只需要在配置文件中进行简单的配置即可完成操作。

 

好处1:提高开发效率

好处2:消除了冗余的代码

好处3:框架会综合考虑相关领域中在实际开发环境下有可能遇到的各种问题,进行了健壮性、性能等各个方面的优化


代码讲解



配置Spring的配置文件


<!--扫描组件-->
<context:component-scanbase-package="com.atguigu.spring.tx.annotation">
</context:component-scan>
<!--导入外部属性文件-->
<context:property-placeholderlocation="classpath:jdbc.properties"/>
<!--配置数据源-->
<beanid="druidDataSource"class="com.alibaba.druid.pool.DruidDataSource">  
<propertyname="url"value="${jdbc.url}"/>
  <propertyname="driverClassName"value="${jdbc.driver}"/>
  <propertyname="username"value="${jdbc.username}"/>
  <propertyname="password"value="${jdbc.password}"/>
</bean>
<!--配置JdbcTemplate-->
<beanid="jdbcTemplate"class="org.springframework.jdbc.core.JdbcTemplate">
  <!--装配数据源-->
  <propertyname="dataSource"ref="druidDataSource"/>
</bean>


创建表


REATETABLE`t_book`(
book_id`int(11)NOTNULLAUTO_INCREMENTCOMMENT'主键',
`book_name`varchar(20)DEFAULTNULLCOMMENT'图书名称',
`price`int(11)DEFAULTNULLCOMMENT'价格',
`stock`int(10)unsignedDEFAULTNULLCOMMENT'库存(无符号)',
PRIMARYKEY(`book_id`)
)ENGINE=InnoDBAUTO_INCREMENT=3DEFAULTCHARSET=utf8;
insert into`t_book`(`book_id`,`book_name`,`price`,`stock`)values(1,'斗破苍穹',80,100),(2,'斗罗大陆',50,100);
CREATETABLE`t_user`(
`user_id`int(11)NOTNULLAUTO_INCREMENTCOMMENT'主键',
`username`varchar(20)DEFAULTNULLCOMMENT'用户名',
`balance`int(10)unsignedDEFAULTNULLCOMMENT'余额(无符号)',
PRIMARYKEY(`user_id`)
)ENGINE=InnoDBAUTO_INCREMENT=2DEFAULTCHARSET=utf8;
insert into`t_user`(`user_id`,`username`,`balance`)values(1,'admin',50);



创建组件


创建BookController


@Controller
public class BookController {
    @Autowired
    private BookService bookService;
    public void buyBook(Integer bookId, Integer userId){
    bookService.buyBook(bookId, userId);
    }
}



创建接口BookService:


public interface BookService {    
void buyBook(Integer bookId, Integer userId);
}



创建实现类BookServiceImpl:


eb3580dd7396436abe6a0d02fb6bc4f0.pnga8a12801d04d4c3b8b414c71e2afda00.pnga40d5a5f482a4d29876ab898d6eca112.png


测试无事务情况


381c8b7f95474f02999285db0b14682f.png


②模拟场景
用户购买图书,先查询图书的价格,再更新图书的库存和用户的余额
假设用户id为1的用户,购买id为1的图书
用户余额为50,而图书价格为80

购买图书之后,用户的余额为-30,数据库中余额字段设置了无符号,因此无法将-30插入到余额字段
此时执行sql语句会抛出SQLException


③观察结果

因为没有添加事务,图书的库存更新了,但是用户的余额没有更新
显然这样的结果是错误的,购买图书是一个完整的功能,更新库存和更新余额要么都成功要么都失败


加入事务


<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource"></property>
</bean>
<!--
开启事务的注解驱动
通过注解@Transactional所标识的方法或标识的类中所有的方法,都会被事务管理器管理事务
-->
<!-- transaction-manager属性的默认值是transactionManager,如果事务管理器bean的id正好就
是这个默认值,则可以省略这个属性 -->
<tx:annotation-driven transaction-manager="transactionManager" />


注意:导入的名称空间需要 tx 结尾的那个。


添加事务注解

因为service层表示业务逻辑层,一个方法表示一个完成的功能,因此处理事务一般在service层处理在BookServiceImpl的buybook()添加注解@Transactiona


观察结果

由于使用了Spring的声明式事务,更新库存和更新余额都没有执行


@Transactional注解标识的位置

@Transactional标识在方法上,咋只会影响该方法

@Transactional标识的类上,咋会影响类中所有的方法


事务属性:只读


对一个查询操作来说,如果我们把它设置成只读,就能够明确告诉数据库,这个操作不涉及写操作。这样数据库就能够针对查询操作来进行优化。


6d863076299d4720b2801f1915e86aeb.png

c533939f7e64484981a287cb0b10bb70.png


事务属性:超时


事务在执行过程中,有可能因为遇到某些问题,导致程序卡住,从而长时间占用数据库资源。而长时间占用资源,大概率是因为程序运行出现了问题(可能是Java程序或MySQL数据库或网络连接等等)。


此时这个很可能出问题的程序应该被回滚,撤销它已做的操作,事务结束,把资源让出来,让其他正常程序可以执行

概括来说就是一句话:超时回滚,释放资源。


a692b84066d0443aab7c4ccd6f2c4336.png5a0d892609034de7a99d848cd59b7a0c.png


事务属性:回滚策略


声明式事务默认只针对运行时异常回滚,编译时异常不回滚。
可以通过@Transactional中相关属性设置回滚策略
rollbackFor属性:需要设置一个Class类型的对象

rollbackForClassName属性:需要设置一个字符串类型的全类名
noRollbackFor属性:需要设置一个Class类型的对象
rollbackFor属性:需要设置一个字符串类型的全类名


4b1f70300b9f4d8abfd9bee85281a696.pngc6b432025c8a49f7b3d75bf04ac3e583.png


事务属性:事务隔离级别


数据库系统必须具有隔离并发运行各个事务的能力,使它们不会相互影响,避免各种并发问题。一个事务与其他事务隔离的程度称为隔离级别。SQL标准中规定了多种事务隔离级别,不同隔离级别对应不同的干扰程度,隔离级别越高,数据一致性就越好,但并发性越弱。


隔离级别一共有四种:


读未提交:READ UNCOMMITTED
允许Transaction01读取Transaction02未提交的修改。
读已提交:READ COMMITTED

要求Transaction01只能读取Transaction02已提交的修改。
可重复读:REPEATABLE READ
确保Transaction01可以多次从一个字段中读取到相同的值,即Transaction01执行期间禁止其它
事务对这个字段进行更新。

串行化:SERIALIZABLE
确保Transaction01可以多次从一个表中读取到相同的行,在Transaction01执行期间,禁止其它事务对这个表进行添加、更新、删除操作。可以避免任何并发问题,但性能十分低下。


0778685eb6a344ab9eb44627e3ebb798.png362404213e1348e18c8cd733da7e8303.png

@Transactional(isolation = Isolation.DEFAULT)//使用数据库默认的隔离级别
@Transactional(isolation = Isolation.READ_UNCOMMITTED)//读未提交
@Transactional(isolation = Isolation.READ_COMMITTED)//读已提交
@Transactional(isolation = Isolation.REPEATABLE_READ)//可重复读
@Transactional(isolation = Isolation.SERIALIZABLE)//串行化


事务属性:事务传播行为


当事务方法被另一个事务方法调用时,必须指定事务应该如何传播。例如:方法可能继续在现有事务中运行,也可能开启一个新事务,并在自己的事务中运行。


8a1e670d8f5546508f0e826b55e95e69.png

ffb4885b518941aebb03688cf808c27e.png


可以通过@Transactional中的propagation属性设置事务传播行为
修改BookServiceImpl中buyBook()上,注解@Transactional的propagation属性

@Transactional(propagation = Propagation.REQUIRED),默认情况,表示如果当前线程上有已经开启的事务可用,那么就在这个事务中运行。经过观察,购买图书的方法buyBook()在checkout()中被调用,checkout()上有事务注解,因此在此事务中执行。所购买的两本图书的价格为80和50,而用户的余额为100,因此在购买第二本图书时余额不足失败,导致整个checkout()回滚,即只要有一本书买不了,就都买不了

@Transactional(propagation = Propagation.REQUIRES_NEW),表示不管当前线程上是否有已经开启的事务,都要开启新事务。同样的场景,每次购买图书都是在buyBook()的事务中执行,因此第一本图书购买成功,事务结束,第二本图书购买失败,只在第二次的buyBook()中回滚,购买第一本图书不受影响,即能买几本就买几本


相关实践学习
如何在云端创建MySQL数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
6月前
|
XML SQL Java
【Spring事务】声明式事务 使用详解
【Spring事务】声明式事务 使用详解
90 0
|
数据库
通过基于注解的声明式事务实现事务功能~2
通过基于注解的声明式事务实现事务功能~
|
5月前
|
XML Java 数据库
在Spring框架中,事务管理是一个重要的功能
在Spring框架中,事务管理是一个重要的功能
19 0
|
XML SQL Java
Spring 中声明式事务和编程式事务的使用
Spring 中声明式事务和编程式事务的使用
160 0
|
XML Java 关系型数据库
通过基于注解的声明式事务实现事务功能~1
通过基于注解的声明式事务实现事务功能~
通过基于注解的声明式事务实现事务功能~1
|
Java 数据库连接 Spring
|
Java Spring
声明式事务
声明式事务
61 0
|
关系型数据库 MySQL Java
SpringMVC+MyBatis声明式事务管理
SpringMVC+MyBatis声明式事务管理
SpringMVC+MyBatis声明式事务管理
|
Java Spring 容器
【小家Spring】从基于@Transactional全注解方式的声明式事务入手,彻底掌握Spring事务管理的原理(下)
【小家Spring】从基于@Transactional全注解方式的声明式事务入手,彻底掌握Spring事务管理的原理(下)
|
XML 安全 Java
Spring框架的事务管理
Spring框架的事务管理