• Spring之事务管理


    1. 事务概念

    (1)事务是数据库操作最基本单元,逻辑上一组操作,要么都成功,如果有一个失败所有操
    作都失败
    (2)典型场景:银行转账

    • bob转账 100 元 给 tom
    • bob 少 100,tom 多 100

    事务四个特性(ACID)
    (1)原子性
    (2)一致性
    (3)隔离性
    (4)持久性

    不使用事务存在的问题:

    @Service
    public class UserService {
        @Autowired
        private UserDao userDao;
        public void transfer(){
                //tom多100元
                userDao.addMoney();
                //模拟异常
                int i=10/0;
                 //bob少100元
                userDao.reduceMoney();
        }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    public interface UserDao {
        public void addMoney();
        public void reduceMoney();
    }
    
    • 1
    • 2
    • 3
    • 4
    @Repository
    public class UserDaoImpl implements UserDao{
        @Autowired
        private JdbcTemplate jdbcTemplate;
        @Override
        public void addMoney() {
            String sql = "update user set money=money+? where name=?";
            jdbcTemplate.update(sql,100,"tom");
        }
    
        @Override
        public void reduceMoney() {
            String sql = "update user set money=money-? where name=?";
            jdbcTemplate.update(sql,100,"bob");
        }
    }
    
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17

    在这里插入图片描述
    在这里插入图片描述

    在 Spring 进行事务管理操作有两种方式:编程式事务管理和声明式事务管理, 其中声明式事务管理又分为基于注解的使用和基于xml的使用

    在这里插入图片描述

    Spring 进行声明式事务管理,底层使用 AOP 原理

    Spring提供一个接口,代表事务管理器,这个接口针对不同的框架提供不同的实现类Spring 事务管理 API
    在这里插入图片描述


    2. 声明式事务–基于注解

    现在使用事务处理上面的转账存在的问题

    1. 在 spring 配置文件配置事务管理器
    在这里插入图片描述

    2. 在 spring 配置文件,开启事务注解

    先引入名称空间tx
    在这里插入图片描述

    然后开启事务注解
    在这里插入图片描述

    3. 在 service 类上面(或者 service 类里面方法上面)添加事务注解
    在这里插入图片描述

    (1)@Transactional,这个注解添加到类上面,也可以添加方法上面
    (2)如果把这个注解添加类上面,这个类里面所有的方法都添加事务
    (3)如果把这个注解添加方法上面,为这个方法添加事务

    完整代码:

    <?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/context   http://www.springframework.org/schema/context/spring-context.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">
    
    
      <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
          <property name="url" value="jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&amp;characterEncoding=utf8"/>
          <property name="username" value="root"/>
          <property name="password" value="19990502"/>
          <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
      </bean>
        <!-- JdbcTemplate 对象 -->
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <!--注入 dataSource-->
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        <!-- 组件扫描 -->
        <context:component-scan base-package="cn.edu.xd"></context:component-scan>
    
        <!--创建事务管理器-->
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <!--注入数据源-->
            <property name="dataSource" ref="dataSource"></property>
        </bean>
    
        <!--开启事务注解-->
        <tx:annotation-driven transaction-manager="transactionManager"></tx:annotation-driven>
    </beans>
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    package cn.edu.xd.service;
    
    import cn.edu.xd.dao.UserDao;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import org.springframework.transaction.annotation.Transactional;
    
    @Service
    @Transactional
    public class UserService {
        @Autowired
        private UserDao userDao;
        public void transfer(){
                //tom多100元
                userDao.addMoney();
                //模拟异常
                int i=10/0;
                 //bob少100元
                userDao.reduceMoney();
        }
    }
    
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22

    UserDao和UserDaoImpl的代码和前面相同
    在这里插入图片描述

    完全注解开发,不使用xml文件

    配置类:

    package cn.edu.xd.config;
    
    import com.alibaba.druid.pool.DruidDataSource;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.ComponentScan;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    import org.springframework.transaction.annotation.EnableTransactionManagement;
    
    import javax.sql.DataSource;
    
    @Configuration
    @ComponentScan(basePackages = "cn.edu.xd") //组件扫描
    @EnableTransactionManagement //开启事务
    public class SpringConfig {
        //创建数据库连接池
        @Bean
        public DruidDataSource getDruidDataSource() {
            DruidDataSource dataSource = new DruidDataSource();
            dataSource.setDriverClassName("com.mysql.jdbc.Driver");
            dataSource.setUrl("jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf8");
            dataSource.setUsername("root");
            dataSource.setPassword("19990502");
            return dataSource;
        }
        //创建 JdbcTemplate 对象
        @Bean
        public JdbcTemplate getJdbcTemplate(DataSource dataSource) {
            //到 ioc 容器中根据类型找到 dataSource
            JdbcTemplate jdbcTemplate = new JdbcTemplate();
            //注入 dataSource
            jdbcTemplate.setDataSource(dataSource);
            return jdbcTemplate;
        }
        //创建事务管理器
        @Bean
        //到 ioc 容器中根据类型找到 dataSource --- DataSource dataSource
        public DataSourceTransactionManager getDataSourceTransactionManager(DataSource dataSource) {
            DataSourceTransactionManager transactionManager = new DataSourceTransactionManager();
            transactionManager.setDataSource(dataSource);//注入数据源
            return transactionManager;
        }
    }
    
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45

    测试代码:

     @Test
        public void testTransfer(){
            ApplicationContext context
                    = new AnnotationConfigApplicationContext(SpringConfig.class);
           UserService userService = context.getBean("userService", UserService.class);
           userService.transfer();
        }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7

    关于@Transactional注解的一些参数

    1. propagation:事务传播行为

    多事务方法直接进行调用,这个过程中事务 是如何进行管理的
    在这里插入图片描述
    propagation的可选参数如下表所示:

    在这里插入图片描述

    @Transactional(propagation = Propagation.REQUIRED)
    
    • 1

    2. ioslation:事务隔离级别

    (1)事务有特性成为隔离性,多事务操作之间不会产生影响。不考虑隔离性产生很多问题
    (2)有三个读问题:脏读、不可重复读、虚(幻)读

    脏读:一个未提交事务读取到另一个未提交事务的数据

    在这里插入图片描述

    不可重复读:一个未提交事务读取到另一提交事务修改数据

    在这里插入图片描述

    幻读:一个未提交事务读取到另一提交事务添加数据

    不同的事务隔离级别可以解决不同的多事务之间产生的问题

    在这里插入图片描述

    @Transactional(isolation = Isolation.READ_COMMITTED)
    
    • 1

    3. timeout:超时时间
    (1)事务需要在一定时间内进行提交,如果超时不提交进行回滚
    (2)默认值是 -1(永不超时) ,设置时间以秒单位进行计算

    @Transactional(timeout = 50)
    
    • 1

    4. readOnly:是否只读

    (1)读:查询操作,写:添加修改删除操作
    (2)readOnly 默认值 false,表示可以查询,可以添加修改删除操作
    (3)设置 readOnly 值是 true,设置成 true 之后,只能查询

    5. rollbackFor:回滚

    设置出现哪些异常进行事务回滚

    6. noRollbackFor:不回滚

    设置出现哪些异常不进行事务回滚


    3. 声明式事务–基于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/context   http://www.springframework.org/schema/context/spring-context.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">
    
    
      <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource">
          <property name="url" value="jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&amp;characterEncoding=utf8"/>
          <property name="username" value="root"/>
          <property name="password" value="19990502"/>
          <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
      </bean>
        <!-- JdbcTemplate 对象 -->
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <!--注入 dataSource-->
            <property name="dataSource" ref="dataSource"></property>
        </bean>
        <!-- 组件扫描 -->
        <context:component-scan base-package="cn.edu.xd"></context:component-scan>
    
        <!--创建事务管理器-->
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <!--注入数据源-->
            <property name="dataSource" ref="dataSource"></property>
        </bean>
    
        <!-- 配置通知-->
        <tx:advice id="txadvice">
            <!--配置事务参数-->
            <tx:attributes>
                <!--指定哪种规则的方法上面添加事务-->
                <tx:method name="transfer" propagation="REQUIRED"/>
            </tx:attributes>
        </tx:advice>
        <!-- 配置切入点和切面-->
        <aop:config>
            <!--配置切入点 UserService中的所有方法-->
            <aop:pointcut id="pt" expression="execution(*
    cn.edu.xd.service.UserService.*(..))"/>
            <!--配置切面-->
            <aop:advisor advice-ref="txadvice" pointcut-ref="pt"/>
        </aop:config>
    </beans>
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49

    去掉UserService上面的@Transactional注解

  • 相关阅读:
    【红外与可见光图像融合】离散平稳小波变换域中基于离散余弦变换和局部空间频率的红外与视觉图像融合方法(Matlab代码实现)
    AI大模型技术:原理、应用和未来展望
    Python和SQL server数据同步更新使用
    队列-线性表-数据结构和算法(Java)
    第二十章 控制进程(一)
    Tomcat context.xml配置详解
    【广州华锐互动】利用AR进行野外地质调查学习,培养学生实践能力
    [计组03]进程详解2
    HBuilder X实现tabBar底部导航记录
    史上最难618,TCL夺得电视行业京东和天猫份额双第一
  • 原文地址:https://blog.csdn.net/qq_43478694/article/details/125475138