Spring-事务2

布满荆棘的人生 2024-03-27 16:32 61阅读 0赞

#### 文章目录 ####

*  前言
 *  一、事务的特性（ACID）
 *  二、事务的隔离级别
 *  三、spring中的事务
 *   *   *  平台事务管理器.
         *  事务定义
         *   *  ISOLation\_XXX：\*\*事务隔离级别.\*\*
             *  PROPAGATION\_XXX：\*\*事务的传播行为\*\*.
         *  事务状态
     *  关系：
 *  四、使用XML文件配置事务
 *   *  1、 搭建环境
     *  2、 配置及业务编写
     *  3、 测试
 *  五、使用注解形式进行事务开发
 *  总结

--------------------

## 前言 ##

事务是逻辑上的一组操作的集合，要么全部成功，要么全部失败。在实际的业务场景中，事务的应用场景范围很广泛，例如转账，订单，支付等

--------------------

## 一、事务的特性（ACID） ##

> 事务有四大特性：
> 
>  *  原子性:事务不可分割
>  *  一致性:事务执行的前后，数据完整性保持一致.
>  *  隔离性:一个事务执行的时候，不应该受到其他事务的打扰
>  *  持久性:一旦结束，数据就永久的保存到数据库.

## 二、事务的隔离级别 ##

在实际的开发中，可能会出现以下几种由数据操作引起的异常情况：  
如果不考虑隔离性:

>  *  脏读:一个事务读到另一个事务未提交数据
>  *  不可重复读:一个事务读到另一个事务已经提交数据（update）导致一个事务多次查询结果不一致
>  *  虚读:一个事务读到另一个事务已经提交数据（insert）导致一个事务多次查询结果不一致

事务存在几种隔离级别：

>  *  未提交读:以上情况都有可能发生。
>  *  已提交读:避免脏读，但不可重复读，虚读是有可能发生。
>  *  可重复读:避免脏读，不可重复读，但是虚读有可能发生。
>  *  串行化:避免以上所有情况.

## 三、spring中的事务 ##

后端分层开发中，事务应用于Service层中。spring提供了事务管理API

#### 平台事务管理器. ####

PlatformTransactionManager

*  getTransaction(TransactionDefinition definition) ：**开启事务**
 *  rollback(TransactionStatus status) ：**回滚事务**
 *  commit(TransactionStatus status) ：**提交事务**

Spring为不同的持久化框架提供了不同PlatformTransactionManager接口实现

> 使用Spring JDBC或iBatis 进行持久化数据时使用（重点）
> 
>  *  org.springframework.jdbc.datasource.DataSourceTransactionManager
> 
> 使用Hibernate进行持久化数据时使用
> 
>  *  org.springframework.orm.hibernate.HibernateTransactionManager
> 
> 使用JPA进行持久化时使用
> 
>  *  org.springframework.orm.jpa.JpaTransactionManager
> 
> 当持久化机制是Jdo时使用
> 
>  *  org.springframework.jdo.JdoTransactionManager
> 
> 使用一个JTA实现来管理事务，在一个事务跨越多个资源时必须使用
> 
>  *  org.springframework.transaction.jta.JtaTransactionManager

#### 事务定义 ####

TransactionDefinition

##### ISOLation\_XXX：**事务隔离级别.** #####

> ISOLATION\_DEFAULT:默认级别. Mysql --> repeatable\_read | Oracle -->> read\_commited  
> 级别如下：
> 
>  *  ISOLATION\_READ\_UNCOMMITTED ： 读未提交
>  *  ISOLATION\_READ\_COMMITTED ： 读已提交
>  *  ISOLATION\_REPEATABLE\_READ ：可重复读
>  *  ISOLATION\_SERIALIZABLE ：串行化

##### PROPAGATION\_XXX：**事务的传播行为**. #####

> 事务的传播行为是用来解决实际开发中的问题  
> 传播行为是指：解决业务层调用事务的关系。

*  PROPAGATION\_REQUIRED: 支持当前事务，如果不存在 就新建一个

> A,B 如果A有事务，B使用A的事务，如果A没有事务，B就开启一个新的事务.(A,B是在一个事务中。)

*  PROPAGATION\_SUPPORTS: 支持当前事务，如果不存在，就不使用事务

> A,B 如果A有事务，B使用A的事务，如果A没有事务，B就不使用事务.

*  PROPAGATION\_MANDATORY: 支持当前事务，如果不存在，抛出异常

> A,B 如果A有事务，B使用A的事务，如果A没有事务，抛出异常.

*  PROPAGATION\_REQUIRES\_NEW: 如果有事务存在，挂起当前事务，创建一个新的事务

> A,B 如果A有事务，B将A的事务挂起，重新创建一个新的事务.(A,B不在一个事务中.事务互不影响.)

*  PROPAGATION\_NOT\_SUPPORTED: 以非事务方式运行，如果有事务存在，挂起当前事务

> A,B 非事务的方式运行，A有事务，就会挂起当前的事务.

*  PROPAGATION\_NEVER: 以非事务方式运行，如果有事务存在，抛出异常
 *  PROPAGATION\_NESTED: 如果当前事务存在，则嵌套事务执行

> 基于SavePoint技术.  
> A,B A有事务，A执行之后，将A事务执行之后的内容保存到SavePoint.B事务有异常的话，用户需要自己设置事务提交还是回滚.

*  常用:(重点)  
    PROPAGATION\_REQUIRED  
    PROPAGATION\_REQUIRES\_NEW  
    PROPAGATION\_NESTED

#### 事务状态 ####

TransactionStatus

*  是否有保存点
 *  是否是一个新的事务
 *  事务是否已经提交

### 关系： ###

> 关系:PlatformTransactionManager通过TransactionDefinition设置事务相关信息管理事务，管理事务过程中，产生一些事务状态，状态由TransactionStatus记录。

## 四、使用XML文件配置事务 ##

*spring支持声明式事务管理，只需要配置文件，不需要额外的编写代码*  
演示如下：

### 1、 搭建环境 ###

> 创建account表并插入两条数据

CREATE TABLE `account` (
        `id` int(11) NOT NULL AUTO_INCREMENT,
        `money` double DEFAULT NULL,
        PRIMARY KEY (`id`)
    ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8;
    
    INSERT INTO `account` VALUES ('1',  '1000');
    INSERT INTO `account` VALUES ('2',  '1000');

> 新建项目略  
> 导入pom.xml依赖

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>com.wmj</groupId>
        <artifactId>SpringTX</artifactId>
        <version>1.0-SNAPSHOT</version>
    
        <properties>
            <maven.compiler.source>8</maven.compiler.source>
            <maven.compiler.target>8</maven.compiler.target>
        </properties>
        <dependencies>
            
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-context</artifactId>
                <version>5.3.24</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-jdbc</artifactId>
                <version>5.3.24</version>
            </dependency>
            
            <dependency>
                <groupId>org.aspectj</groupId>
                <artifactId>aspectjweaver</artifactId>
                <version>1.9.9.1</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-tx</artifactId>
                <version>5.3.24</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis</artifactId>
                <version>3.5.11</version>
            </dependency>
            
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis-spring</artifactId>
                <version>2.0.7</version>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>8.0.31</version>
            </dependency>
    		
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>1.2.9</version>
            </dependency>
    		
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>1.18.24</version>
            </dependency>
    		
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.17</version>
            </dependency>
    		
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.13.2</version>
                <scope>test</scope>
            </dependency>
    
        </dependencies>
    </project>

### 2、 配置及业务编写 ###

> 配置mybatis-config.xml

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration
            PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
            "https://mybatis.org/dtd/mybatis-3-config.dtd">
    <configuration>
    
        
        <settings>
            <setting name="logImpl" value="LOG4J"/>
        </settings>
    
    </configuration>

> 配置日志

log4j.rootLogger=DEBUG, stdout
    log4j.appender.stdout=org.apache.log4j.ConsoleAppender
    log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
    log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

> 配置数据源

db.username = 帐号
    db.password = 密码
    db.url = jdbc:mysql:///库名?serverTimezone=Asia/Shanghai&characterEncoding=UTF8
    db.driverClassName = com.mysql.cj.jdbc.Driver

> 搭建后端业务代码

控制层

package com.wmj.controller;
    
    import com.wmj.service.TestService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Controller;
    
    
    /**
     * --效率，是成功的核心关键--
     *
     * @Author lzl
     * @Date 2023/2/13 16:04
     */
    @Controller
    public class TestController {
        
    
        @Autowired
        private TestService service;
    
        public void testTx(Integer id1,Integer id2,Double money){
        
            service.transferMoney(id1,id2,money);
        }
    }

业务层接口及其实现类

package com.wmj.service;
    
    /**
     * --效率，是成功的核心关键--
     *
     * @Author lzl
     * @Date 2023/2/13 16:10
     */
    
    public interface TestService {
        
    
        void transferMoney(Integer id1, Integer id2, Double money);
    }

package com.wmj.service.impl;
    
    import com.wmj.mapper.TestMapper;
    import com.wmj.service.TestService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    /**
     * --效率，是成功的核心关键--
     *
     * @Author lzl
     * @Date 2023/2/13 16:11
     */
    @Service
    public class TestServiceImpl implements TestService {
        
    
        @Autowired
        private TestMapper mapper;
        @Override
        public void transferMoney(Integer id1, Integer id2, Double money) {
        
            mapper.dmoney(id1,money);
            int a =  1/0;
            mapper.amoney(id2,money);
        }
    }

持久层接口及其xml数据访问

package com.wmj.mapper;
    
    import org.apache.ibatis.annotations.Param;
    import org.springframework.stereotype.Repository;
    
    /**
     * --效率，是成功的核心关键--
     *
     * @Author lzl
     * @Date 2023/2/13 16:12
     */
    @Repository
    public interface TestMapper {
        
        Integer dmoney(@Param("id1") Integer id1, @Param("money") Double money);
    
        Integer amoney(@Param("id2") Integer id2, @Param("money") Double money);
    }

<?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.wmj.mapper.TestMapper">
    
    
        <update id="dmoney">
            update account set money = money - #{money} where id = #{id1}
        </update>
        <update id="amoney">
            update account set money = money + #{money} where id = #{id2}
        </update>
    </mapper>

> 配置spring核心配置文件application.xml

<?xml version="1.0" encoding="UTF-8"?>
    <beans xmlns="http://www.springframework.org/schema/beans"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xmlns:context="http://www.springframework.org/schema/context"
           xmlns:aop="http://www.springframework.org/schema/aop"
           xmlns:tx="http://www.springframework.org/schema/tx"
           xsi:schemaLocation="
            http://www.springframework.org/schema/beans
            http://www.springframework.org/schema/beans/spring-beans.xsd
            http://www.springframework.org/schema/aop
            http://www.springframework.org/schema/aop/spring-aop.xsd
            http://www.springframework.org/schema/tx
            http://www.springframework.org/schema/tx/spring-tx.xsd
            http://www.springframework.org/schema/context
            http://www.springframework.org/schema/context/spring-context.xsd">
        
    
        
        <context:component-scan base-package="com.wmj"></context:component-scan>
    
        
        <context:property-placeholder location="classpath:db.properties"></context:property-placeholder>
    
        
        <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
            <property name="username" value="${db.username}"></property>
            <property name="password" value="${db.password}"></property>
            <property name="url" value="${db.url}"></property>
            <property name="driverClassName" value="${db.driverClassName}"></property>
        </bean>
    
        
        <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
            
            <property name="dataSource" ref="dataSource"></property>
            
            <property name="configLocation" value="classpath:mybatis-config.xml"></property>
            
            <property name="mapperLocations" value="classpath:mapper/*.xml"></property>
    
        </bean>
    
        
        <bean id="mapperScannerConfigurer" class="org.mybatis.spring.mapper.MapperScannerConfigurer">
            <property name="basePackage" value="com.wmj.mapper"></property>
        </bean>
    
        
        <bean name="transactionManager"
              class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource"></property>
        </bean>
    
        
        <tx:advice id="txAdvice" transaction-manager="transactionManager">
            <tx:attributes>
                
                
                <tx:method name="transferMoney" isolation="REPEATABLE_READ"
                           propagation="REQUIRED" read-only="false" />
            </tx:attributes>
        </tx:advice>
    
        
        <aop:config>
            
            <aop:pointcut expression="execution(* com.wmj.service.impl.*ServiceImpl.*(..))"
                          id="txPc" />
            
            <aop:advisor advice-ref="txAdvice" pointcut-ref="txPc" />
        </aop:config>
    
    </beans>

### 3、 测试 ###

package com.test;
    
    import com.wmj.controller.TestController;
    import org.junit.Test;
    import org.springframework.context.support.ClassPathXmlApplicationContext;
    
    /**
     * --效率，是成功的核心关键--
     *
     * @Author lzl
     * @Date 2023/2/13 16:02
     */
    
    public class Demo1 {
        
        @Test
        public void testTX(){
        
            ClassPathXmlApplicationContext applicationContext =
                    new ClassPathXmlApplicationContext("application.xml");
            TestController controller = (TestController)applicationContext.getBean("testController");
            controller.testTx(1,2,200.00);
        }
    }

执行结果：  
当没有遇到异常时，转账能正常执行，不在演示，此处演示当遇到异常时的事务效果  
代码执行前数据库：  
![在这里插入图片描述][9aca25ba1ea64f9ca26bb8395fbfa192.png]

![在这里插入图片描述][d9c0197d4dac4af4a0618db2aea44ebe.png]  
当遇到异常，代码终止执行，此时数据库

![在这里插入图片描述][b4232f249a1544faa4a59897e26f524d.png]  
转账并没有进行提交，此时说明我们的事务配置成功！

## 五、使用注解形式进行事务开发 ##

spring给我们提供了事务注解开发的方式，大大减少了代码编写，十分方便

> 创建项目配置基本与上方相同，我们将application.xml内容进行修改如下：

> 将业务实现类改造如下：

package com.wmj.service.impl;
    
    import com.wmj.mapper.AccountMapper;
    import com.wmj.service.AccountService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Isolation;
    import org.springframework.transaction.annotation.Propagation;
    import org.springframework.transaction.annotation.Transactional;
    
    /**
     * @Transactional 配置事务
     * 可以写在类上，也可以写在方法上
     */
    //@Transactional(isolation = Isolation.REPEATABLE_READ,propagation = Propagation.REQUIRED,readOnly = false)
    @Service
    package com.wmj.service.impl;
    
    import com.wmj.mapper.TestMapper;
    import com.wmj.service.TestService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    /**
     * --效率，是成功的核心关键--
     *
     * @Author lzl
     * @Date 2023/2/13 16:11
     */
    /**
     * @Transactional 配置事务
     * 可以写在类上，也可以写在方法上
     */
    //@Transactional(isolation = Isolation.REPEATABLE_READ,propagation = Propagation.REQUIRED,readOnly = false)
    @Service
    public class TestServiceImpl implements TestService {
        
    
        @Autowired
        private TestMapper mapper;
        @Transactional(isolation = Isolation.REPEATABLE_READ,propagation = Propagation.REQUIRED,readOnly = false)
        @Override
        public void transferMoney(Integer id1, Integer id2, Double money) {
        
            mapper.dmoney(id1,money);
            int a =  1/0;
            mapper.amoney(id2,money);
        }
    }

测试略

--------------------

## 总结 ##

本次主要记录了spring的事务支持，及其两种开发方式。再会！！！

[9aca25ba1ea64f9ca26bb8395fbfa192.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/2f00b5cf3eae435a85bd8ce3a7bad5fe.png
[d9c0197d4dac4af4a0618db2aea44ebe.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/db1afad0e3c14535b399db672591a4bc.png
[b4232f249a1544faa4a59897e26f524d.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/27/75d1c06a01c2421f947eb544513062f8.png