Spring中事务控制的API介绍（PlatformTransactionManager和TransactionDefinition）

news2024/9/28 21:30:12

事务控制的API

PlatformTransactionManager接口

        作用：是一个事务管理器，负责开启、提交或回滚事务
        实现类：DataSourceTransactionManager(sqlSession)

此接口是spring的事务管理器，它里面提供了我们常用的操作事务的方法

public interface PlatformTransactionManager { 
    
  	//开启事务  
    TransactionStatus getTransaction(TransactionDefinition definition) 
        						throws TransactionException; 
    //提交事务
    void commit(TransactionStatus status) throws TransactionException; 
    
  	//回滚事务
    void rollback(TransactionStatus status) throws TransactionException;   
}

Spring为不同的orm框架提供了不同的PlatformTransactionManager接口实现类：

  • DataSourceTransactionManager：使用Spring JDBC或iBatis 进行持久化数据时使用

  • HibernateTransactionManager：使用Hibernate版本进行持久化数据时使用

TransactionDefinition接口

         作用：定义事务的属性
        实现类：DefaultTransactionDefinition

TransactionDefinition接口包含与事务属性相关的方法 ，源代码如下

public interface TransactionDefinition {
    int PROPAGATION_REQUIRED = 0;
    int PROPAGATION_SUPPORTS = 1;
    int PROPAGATION_MANDATORY = 2;
    int PROPAGATION_REQUIRES_NEW = 3;
    int PROPAGATION_NOT_SUPPORTED = 4;
    int PROPAGATION_NEVER = 5;
    int PROPAGATION_NESTED = 6;
    int ISOLATION_DEFAULT = -1;
    int ISOLATION_READ_UNCOMMITTED = 1;
    int ISOLATION_READ_COMMITTED = 2;
    int ISOLATION_REPEATABLE_READ = 4;
    int ISOLATION_SERIALIZABLE = 8;
    int TIMEOUT_DEFAULT = -1;
    
    //传播行为
    int getPropagationBehavior();
	//隔离级别
    int getIsolationLevel();
    //事务超时
    int getTimeout();
    //是否只读
    boolean isReadOnly();
}

 TransactionDefinition 接口定义的事务规则包括：事务隔离级别、事务传播行为、事务超时、事务的只读、回滚规则属性，同时，Spring 还为我们提供了一个默认的实现类：DefaultTransactionDefinition，该类适用于大多数情况。如果该类不能满足需求，可以通过实现 TransactionDefinition 接口来实现自己的事务定义。

事务并发时的安全问题 

问题描述隔离级别
脏读一个事务读取到另一个事务还未提交的数据read-commited
不可重复读一个事务内多次读取一行数据的内容，其结果不一致repeatable-read
幻读一个事务内多次读取一张表中的内容，其结果不一致serialized-read

事务的隔离级别

隔离级别说明
ISOLATION_DEFAULT这是一个platfromtransactionmanager默认的隔离级别，使用数据库默认的事务隔离级别。
ISOLATION_READ_UNCOMMITTED这是事务最低的隔离级别，会产生脏读，不可重复读和幻像读。
ISOLATION_READ_COMMITTED这种事务隔离级别可以避免脏读出现，但是可能会出现不可重复读和幻像读。 Oracle数据库默认的隔离级别。
ISOLATION_REPEATABLE_READ这种事务隔离级别可以防止脏读、不可重复读，但是可能出现幻像读。MySQL数据库默认的隔离级别。
ISOLATION_SERIALIZABLE这是花费最高代价但是最可靠的事务隔离级别，事务被处理为顺序执行。除了防止脏读、不可重复读外，还避免了幻像读。
事务的隔离级别解决的事务并发时的安全问题 
隔离级别是否脏读是否不可重复度是否幻读
ISOLATION_DEFAULTxx√
ISOLATION_READ_UNCOMMITTED√√√
ISOLATION_READ_COMMITTEDx√√
ISOLATION_REPEATABLE_READxx√
ISOLATION_SERIALIZABLExxx

事务的传播行为

  • 什么是事务传播行为？

    事务传播行为（propagation behavior）指的就是当一个事务方法被另一个事务方法调用时，这个事务方法应该如何进行。 例如：methodA事务方法调用methodB事务方法时，methodB是继续在调用者methodA的事务中运行呢，还是为自己开启一个新事务运行，这就是由methodB的事务传播行为决定的。

Spring定义了七种传播行为：

事务传播行为类型说明
PROPAGATION_REQUIRED如果当前没有事务，就新建一个事务，如果已经存在一个事务中，加入到这个事务中。这是最常见的选择。
PROPAGATION_SUPPORTS支持当前事务，如果当前没有事务，就以非事务方式执行。
PROPAGATION_MANDATORY使用当前的事务，如果当前没有事务，就抛出异常。
PROPAGATION_REQUIRES_NEW新建事务，如果当前存在事务，把当前事务挂起。
PROPAGATION_NOT_SUPPORTED以非事务方式执行操作，如果当前存在事务，就把当前事务挂起。
PROPAGATION_NEVER以非事务方式执行，如果当前存在事务，则抛出异常。
PROPAGATION_NESTED如果当前存在事务，则在嵌套事务内执行。如果当前没有事务，则执行与REQUIRED类似的操作。

事务超时

timeout事务超时时间： 当前事务所需操作的数据被其他事务占用，则等待。

  • 100：自定义等待时间100（秒）。

  • -1：由数据库指定等待时间，默认值。（建议）

读写性

readonly 读写性

  • true：只读，可提高查询效率，适合查询

  • false：可读可写，适合增删改

回滚规则

rollbackOn 回滚规则，可省略或设置 rollbackOn="Exception"

  • 如果事务中抛出 RuntimeException,则自动回滚

  • 如果事务中抛出 CheckException，不会自动回滚

TransactionStatus

PlatformTransactionManager.getTransaction(…) 方法返回一个 TransactionStatus 对象，该对象代表一个新的或已经存在的事务，源代码如下：

public  interface TransactionStatus{
   boolean isNewTransaction();
   void setRollbackOnly();
   boolean isRollbackOnly();
}

转账案例

新建项目

配置pom.xml
    <dependencies>
        <!-- Spring常用依赖 -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.1.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-aspects</artifactId>
            <version>5.1.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>5.1.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-jdbc</artifactId>
            <version>5.1.8.RELEASE</version>
        </dependency>
        <!-- MySql -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.47</version>
        </dependency>
        <!--连接池-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.0</version>
        </dependency>
        <!--mybatis-->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.5.3</version>
        </dependency>
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-spring</artifactId>
            <version>2.0.3</version>
        </dependency>
        <!--日志-->
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.26</version>
        </dependency>
        <!--junit-->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-test</artifactId>
            <version>5.1.8.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
        </dependency>
    </dependencies>
    <build>
        <resources>
            <!-- 如果不添加此节点src/main/java目录下的所有配置文件都会被漏掉。 -->
            <resource>
                <directory>src/main/java</directory>
                <includes>
                    <include>**/*.xml</include>
                </includes>
            </resource>
<!--            让MyBatis识别resiurces文件夹下的文件-->
            <resource>
                <directory>src/main/resources</directory>
            </resource>
        </resources>
    </build>
配置db.properties
jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3305/spring?characterEncoding=UTF-8
jdbc.username=root
jdbc.password=
配置applicationContext.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:context="http://www.springframework.org/schema/context"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context.xsd
       ">
<!--    Springioc注解扫描支持-->
    <context:component-scan base-package="com.by.service"></context:component-scan>
<!--    配置数据库-->
<!--    加载数据源-->
    <context:property-placeholder location="classpath:db.properties"/>
<!--    配置数据源-->
    <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">
        <property name="driverClassName" value="${jdbc.driver}"></property>
        <property name="url" value="${jdbc.url}"></property>
        <property name="username" value="${jdbc.username}"></property>
        <property name="password" value="${jdbc.password}"></property>
    </bean>
<!--    会话工厂-->
    <bean id="sessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

    <!--让mybatis扫描mapper接口，生成代理类并交给spring的ioc容器去管理-->
    <bean  class="org.mybatis.spring.mapper.MapperScannerConfigurer">
        <!--mapper所在的包-->
        <property name="basePackage" value="com.by.mapper"></property>
        <property name="sqlSessionFactoryBeanName" value="sessionFactory"></property>
    </bean>

<!--DataSourceTransactionManager:是一个数据源事务管理器，负责开启，提交和回滚事务-->
    <bean id="sourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource" ref="dataSource"></property>
    </bean>

<!--    DefaultTransactionDefinition:定义事务属性-->
     <bean id="transactionDefinition" class="org.springframework.transaction.support.DefaultTransactionDefinition">
        <!--
            隔离级别：默认值DEFAULT，等价于REPEATABLE_READ
            传播行为：默认值REQUIRED，methodB()会加入到methodA()事务中
            事务超时：默认值-1，永不超时
            是否只读：默认值false，适用于增删改
            回滚规则：可省略
            
        -->
<!--        以下配置均为默认属性,不用注入-->
<!--&lt;!&ndash;        注入隔离级别&ndash;&gt;-->
<!--        <property name="isolationLevel" value="REPEATABLE"></property>-->
<!--&lt;!&ndash;        注入传播行为&ndash;&gt;-->
<!--        <property name="propagationBehavior" value="REQUIRED"></property>-->
<!--&lt;!&ndash;        注入事务超时&ndash;&gt;-->
<!--        <property name="timeout" value=""></property>-->
<!--&lt;!&ndash;        注入是否只读&ndash;&gt;-->
<!--        <property name="readOnly" value="false"></property>-->
    </bean>
</beans>

三层架构建包

service包下UserService类
public interface UserService {

    void updateUser(String source, String target, Float money);
}
service包下UserServiceImpl实现类
@Service
public class UserServiceImpl implements UserService {

    @Autowired
    private UserMapper userMapper;

    @Autowired
    private PlatformTransactionManager transactionManager;

    @Autowired
     private TransactionDefinition transactionDefinition;


    @Override
    public void addUser(User user) {
        userMapper.addUser(user);
    }
    @Override
    public void updateUser(String source,String target,Float money){
        TransactionStatus transactionStatus = transactionManager.getTransaction(transactionDefinition);
        try {
            //扣钱
            userMapper.updateUserOfSub(source,money);
            int a=6/0;
            //加钱
            userMapper.updateUserOfAdd(target,money);
            //业务执行后，提交事务
            transactionManager.commit(transactionStatus);
        } catch (Exception e) {
            e.printStackTrace();
            //业务出错时，回滚事务
            transactionManager.rollback(transactionStatus);
        }
    }
}
mapper包下UserMapper类
public interface UserMapper {
    void updateUserOfSub(@Param("source") String source, @Param("money")Float money);
    void updateUserOfAdd(@Param("target")String target, @Param("money")Float money);
}
mapper包下UserMapper.xml文件
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.by.mapper.UserMapper">
    <!--转账-->
    <update id="updateUserOfSub">
        update t_user set money=money-#{money} where name=#{source}
    </update>

    <update id="updateUserOfAdd">
        update t_user set money=money+#{money} where name=#{target}
    </update>
</mapper>
 pojo包下User类
public class User {
    private Integer id;
    private String name;
    private Float money;

    public User(String name, Float money) {
        this.name = name;
        this.money = money;
    }

    public User() {
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public Float getMoney() {
        return money;
    }

    public void setMoney(Float money) {
        this.money = money;
    }
}
 测试类
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class ServiceTest {
    @Autowired
    private UserService userService;
    @Test
    public void testAdd(){
        userService.addUser(new User("张wu丰",4000F));

        userService.addUser(new User("宋远桥",2000F));
    }
    @Test
    public void testUpdate(){
        userService.updateUser("张三丰","宋远桥",1F);
    }
}

测试结果

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

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

相关文章

生信 R语言

生信 R语言

11.芯片表达矩阵下游分析 ​rm(list ls())#清除所有变量 options(stringsAsFactors F) #BiocManager::install("CLL") suppressPackageStartupMessages(library(CLL)) data("sCLLex") sCLLex ## ExpressionSet (storageMode: lockedEnvironment) ## as…
阅读更多...
报错curl: (6) Could not resolve host: raw.githubusercontent...的解决办法

报错curl: (6) Could not resolve host: raw.githubusercontent...的解决办法

我起初想要在macOS系统安装pip包&#xff0c;首先在终端安装homebrew&#xff0c;敲了命令&#xff1a;/usr/bin/ruby -e "$(curl -fsSL https://raw.githubusercontent...)" 之后触发的报错&#xff0c;报错内容&#xff1a;curl: (6) Could not resolve host: raw.…
阅读更多...
如何从 Android SD卡/存储卡中恢复删除的照片

如何从 Android SD卡/存储卡中恢复删除的照片

虽然大多数摄影师和智能手机用户都非常喜欢在一张 存储卡上存储数千张照片的能力&#xff0c;但它也可能导致灾难性的数据丢失&#xff0c;而 存储卡照片恢复软件通常是唯一的解决方案。 但是&#xff0c;如果您不迅速采取行动并在图像被覆盖之前恢复图像&#xff0c;那么即使…
阅读更多...
如何向嵌入式设备中添加tcpdump工具

如何向嵌入式设备中添加tcpdump工具

说明&#xff1a;tcpdump是一个在网络设备调试中一个非常重要的工具&#xff0c;它并不像hexdump等工具集成在busybox里面&#xff0c;也不像其他的软件一样只需要依赖linux标准的库就可以实现&#xff0c;它需要pcap相关的库和加密的相关库。 本文主要是基于realtek 83系列的…
阅读更多...
SpringBoot+Redis实现接口防刷功能

SpringBoot+Redis实现接口防刷功能

场景描述&#xff1a; 在实际开发中&#xff0c;当前端请求后台时&#xff0c;如果后端处理比较慢&#xff0c;但是用户是不知情的&#xff0c;此时后端仍在处理&#xff0c;但是前端用户以为没点到&#xff0c;那么再次点击又发起请求&#xff0c;就会导致在短时间内有很多请求…
阅读更多...
《路由与交换技术》---简答题

《路由与交换技术》---简答题

1、什么是STP&#xff1f;解决什么问题&#xff1f; STP代表生成树协议&#xff08;Spanning Tree Protocol&#xff09;。它是用于在计算机网络中解决环路问题的一种协议。 STP的主要目标是消除环路&#xff0c;保持网络的稳定性和可靠性&#xff0c;同时提供冗余路径以实现网…
阅读更多...
批量删除文件名的空格，一键清理让文件名中的空格去无踪

批量删除文件名的空格，一键清理让文件名中的空格去无踪

我们每天都会创建、下载、重命名很多文件&#xff0c;在文件的重命名过程中&#xff0c;我们会不自觉地在文件名中加入空格&#xff0c;这些看似无害的空格&#xff0c;在某些情况下&#xff0c;却可能引发诸多不便。例如&#xff0c;在某些软件或操作系统中&#xff0c;空格可…
阅读更多...
【Java】设计模式之保护性暂停

【Java】设计模式之保护性暂停

设计模式之保护性暂停 Guarded Suspension&#xff0c;这个设计模式&#xff0c;主要用在一个线程等待另一个线程的执行结果&#xff08;发请求等待响应&#xff09; 有一个结果需要从一个线程传递到另一个线程&#xff0c;传递只进行一次&#xff0c;用设计模式保护性暂停。 …
阅读更多...
使用pagehelper插件进行分页查询

使用pagehelper插件进行分页查询

一、导入mybatis和pagehelper坐标 <dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.2.0</version> </dependency> <dependency><groupId&…
阅读更多...
项目管理进阶之PDCA

项目管理进阶之PDCA

前言 项目管理进阶系列&#xff0c;今天开始发布第一篇喽。 博主其实一直在构思&#xff0c;如何开启这个系列&#xff0c;但是我们通常项目管理讲的“五大过程十大领域”&#xff0c;往往太书面了。因此尝试从中抓取几个核心&#xff0c;以供有志之士参考。 那么&#xff0c…
阅读更多...
史诗级长文--决策树

史诗级长文--决策树

决策树 决策树(decision tree)是一种基本的分类与回归方法。 举个通俗易懂的例子&#xff0c;如下图所示的流程图就是一个决策树&#xff0c;长方形代表判断模块(decision block)&#xff0c;椭圆形成代表终止模块(terminating block)&#xff0c;表示已经得出结论&#xff0c;…
阅读更多...
基于商品列表的拖拽排序后端实现

基于商品列表的拖拽排序后端实现

目录 一&#xff1a;实现思路 二&#xff1a;实现步骤 二&#xff1a;实现代码 三&#xff1a;注意点 一&#xff1a;实现思路 后台实现拖拽排序通常需要与前端进行配合&#xff0c;对商品的列表拖拽排序&#xff0c;前端需要告诉后端拖拽的元素和拖动的位置。 这里我们假…
阅读更多...
Java多线程技术11——ThreadPoolExecutor类的使用1

Java多线程技术11——ThreadPoolExecutor类的使用1

1 概述 ThreadPoolExecutor类可以非常方便的创建线程池对象&#xff0c;而不需要程序员设计大量的new实例化Thread相关的代码。 2 队列LinkedBlockingQueue的使用 public class Test1 {public static void main(String[] args) {LinkedBlockingQueue queue new LinkedBlocki…
阅读更多...
Activity启动流程

Activity启动流程

早就想写这个笔记用于记录这段知识&#xff0c;但是碍于太过庞大所以始终没有进行这段知识的整理 很多博客喜欢画一个时序图展示所有的流程&#xff0c;但是过于庞大&#xff0c;看起来有点吃力&#xff0c;这里我们画多个时序图来展示这个流程 1.app请求AMS启动Activity 在前…
阅读更多...
特征工程筛选重要变量

特征工程筛选重要变量

特征筛选主要分为3个方法&#xff1a;过滤法、嵌入法&#xff08;经典的一些树模型比如xgboost&#xff09;、包裹法&#xff08;经典的RFECV&#xff0c;RFE递归特征消除法&#xff09; 过滤法更快速&#xff0c;但更粗糙。 包装法和嵌入法更精确&#xff0c;比较适合具体到算…
阅读更多...
P1262 间谍网络

P1262 间谍网络

1、思路 阅读题目&#xff0c;发现有些间谍可以是被前面的点更新&#xff0c;也就是说&#xff0c;在一开始的时候&#xff0c;把能贿赂的人员从小到达排个序&#xff0c;再使用bfs算法&#xff0c;把他们能到达的人员的贿赂价钱设置为0。 有解的情况&#xff1a; 首先如果有…
阅读更多...
JavaScript：Date 对象-时间日期

JavaScript：Date 对象-时间日期

Date 对象-时间日期: - JS中所有的关于时间信息都需要通过Date对象来表示 // 创建一个Date对象 // 如果直接使用new Date()创建时间对象&#xff0c;它会默认创建一个表示代码执行时刻的对象var d new Date();// 如果希望创建一个指定的时间的Date的对象&#xff0c;需要传递…
阅读更多...
python总结-装饰器

python总结-装饰器

装饰器 装饰器解决日志问题&#xff08;分三个版本&#xff09;多个装饰器带参数的装饰器wraps装饰器内置装饰器property装饰器staticmethod装饰器classmethod装饰器 类装饰器缓存装饰器和计时装饰器综合练习 概念 装饰器来自 Decorator 的直译。什么叫装饰&#xff0c;就是装点…
阅读更多...
【tkinter 电子时钟 实现时间日期 可实现透明 无标题栏】

【tkinter 电子时钟 实现时间日期 可实现透明 无标题栏】

下面是一个使用tkinter实现的简单的电子时钟&#xff0c;包括时间和日期的显示。该窗口是透明的&#xff0c;没有标题栏。 效果&#xff1a; import tkinter as tk from datetime import datetimedef update_time():now datetime.now()time_label.configure(textnow.strftim…
阅读更多...
【一】使用vue-cli创建vue3的helloworld项目

【一】使用vue-cli创建vue3的helloworld项目

不再推荐使用vue-cli命令创建vue3的项目&#xff0c;vue-cli 是 Vue 早期推出的一款脚手架&#xff0c;使用 webpack 创建 Vue 项目。后期推荐使用 create-vue&#xff0c;create-vue 是 Vue3 的专用脚手架&#xff0c;使用 vite 创建 Vue3 的项目(关注【二】使用create-vue创建…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023