• 第5章Spring 事务(测试)-Spring的事务注解（小项目中），AspectJ的AOP配置管理事务（大项目中）...

    第5章Spring 事务(测试)-Spring的事务注解(小项目中)，AspectJ的AOP配置管理事务(大项目中)

    spring框架中提供的事务处理方案

    适合中小项目使用的， 注解方案。

    1. 1.适合中小项目使用的， 注解方案。
    2.   spring框架自己用aop实现给业务方法增加事务的功能， 使用@Transactional注解增加事务。
    3.   @Transactional注解是spring框架自己注解，放在public方法的上面，表示当前方法具有事务。
    4.   可以给注解的属性赋值，表示具体的隔离级别，传播行为，异常信息等等
    5.  
    6.   使用@Transactional的步骤：
    7.   1.需要声明事务管理器对象
    8.     "xx" class="DataSourceTransactionManager">

    1. 使用 Spring 的事务注解管理事务(掌握)

    通过@Transactional 注解方式，可将事务织入到相应 public 方法中，实现事务管理。

    1. @Transactional 的所有可选属性如下所示：
    2. ➢ propagation：用于设置事务传播属性。该属性类型为 Propagation 枚举，默认值为Propagation.REQUIRED。
    3. ➢ isolation：用于设置事务的隔离级别。该属性类型为 Isolation 枚举，默认值为Isolation.DEFAULT。
    4. ➢ readOnly：用于设置该方法对数据库的操作是否是只读的。该属性为 boolean，默认值为 false。
    5. ➢ timeout：用于设置本操作与数据库连接的超时时限。单位为秒，类型为 int，默认值为-1，即没有时限。
    6. ➢ rollbackFor：指定需要回滚的异常类。类型为 Class[]，默认值为空数组。当然，若只有一个异常类时，可以不使用数组。
    7. ➢ rollbackForClassName：指定需要回滚的异常类类名。类型为 String[]，默认值为空数组。当然，若只有一个异常类时，可以不使用数组。
    8. ➢ noRollbackFor：指定不需要回滚的异常类。类型为 Class[]，默认值为空数组。当然，若只有一个异常类时，可以不使用数组。
    9. ➢ noRollbackForClassName：指定不需要回滚的异常类类名。类型为 String[]，默认值为空数组。
    10. 	当然，若只有一个异常类时，可以不使用数组。
    11. 	需要注意的是，@Transactional 若用在方法上，只能用于 public 方法上。对于其他非 public
    12. 方法，如果加上了注解@Transactional，虽然 Spring 不会报错，但不会将指定事务织入到该
    13. 方法中。因为 Spring 会忽略掉所有非 public 方法上的@Transaction 注解。
    14. 	若@Transaction 注解在类上，则表示该类上所有的方法均将在执行时织入事务。

    • 实现注解的事务步骤：

      1. 声明事务管理器

        2.     
        3.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        4.         
        5.         <property name="dataSource" ref="myDataSource" />
        6.     bean>

      2. 开启注解驱动

        2.     <tx:annotation-driven transaction-manager="transactionManager" />

      3. 业务层 public 方法加入事务属性

      1. @Transactional(
      2.             propagation = Propagation.REQUIRED,
      3.             isolation = Isolation.DEFAULT,
      4.             readOnly = false,
      5.             rollbackFor = {
      6.                     NullPointerException.class,  NotEnoughException.class
      7.             }

    • 此时的spring配置文件：

      1. "1.0" encoding="UTF-8"?>
      2. <beans xmlns="http://www.springframework.org/schema/beans"
      3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.        xmlns:context="http://www.springframework.org/schema/context"
      5.        xmlns:tx="http://www.springframework.org/schema/tx"
      6.        xsi:schemaLocation="http://www.springframework.org/schema/beans
      7.        http://www.springframework.org/schema/beans/spring-beans.xsd
      8.        http://www.springframework.org/schema/context
      9.        https://www.springframework.org/schema/context/spring-context.xsd
      10.        http://www.springframework.org/schema/tx
      11.        http://www.springframework.org/schema/tx/spring-tx.xsd">
      12.  
      13.     
      14.     <context:property-placeholder location="classpath:jdbc.properties" />
      15.  
      16.     
      17.     <bean id="myDataSource" class="com.alibaba.druid.pool.DruidDataSource"
      18.           init-method="init" destroy-method="close">
      19.         
      20.         
      21.         <property name="url" value="${jdbc.url}" />
      22.         <property name="username" value="${jdbc.username}"/>
      23.         <property name="password" value="${jdbc.passwd}" />
      24.         <property name="maxActive" value="${jdbc.max}" />
      25.     bean>
      26.  
      27.     
      28.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
      29.         
      30.         <property name="dataSource" ref="myDataSource" />
      31.         
      32.         <property name="configLocation" value="classpath:mybatis.xml" />
      33.     bean>
      34.  
      35.     
      36.     <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
      37.         
      38.         <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
      39.         
      40.         <property name="basePackage" value="com.bjpowernode.dao"/>
      41.     bean>
      42.  
      43.     
      44.     <bean id="buyService" class="com.bjpowernode.service.impl.BuyGoodsServiceImpl">
      45.         <property name="goodsDao" ref="goodsDao" />
      46.         <property name="saleDao" ref="saleDao" />
      47.     bean>
      48.  
      49.     
      50.     
      51.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
      52.         
      53.         <property name="dataSource" ref="myDataSource" />
      54.     bean>
      55.  
      56.     
      57.     <tx:annotation-driven transaction-manager="transactionManager" />
      58. beans>

    • com.bjpowernode.service.impl.BuyGoodsServiceImpl

      1. package com.bjpowernode.service.impl;
      2.  
      3. import com.bjpowernode.dao.GoodsDao;
      4. import com.bjpowernode.dao.SaleDao;
      5. import com.bjpowernode.domain.Goods;
      6. import com.bjpowernode.domain.Sale;
      7. import com.bjpowernode.excep.NotEnoughException;
      8. import com.bjpowernode.service.BuyGoodsService;
      9. import org.springframework.transaction.annotation.Isolation;
      10. import org.springframework.transaction.annotation.Propagation;
      11. import org.springframework.transaction.annotation.Transactional;
      12.  
      13. public class BuyGoodsServiceImpl implements BuyGoodsService {
      14.  
      15.     private SaleDao saleDao;
      16.     private GoodsDao goodsDao;
      17.  
      18.     /**
      19.      *
      20.      * rollbackFor:表示发生指定的异常一定回滚.
      21.      *   处理逻辑是：
      22.      *     1) spring框架会首先检查方法抛出的异常是不是在rollbackFor的属性值中
      23.      *         如果异常在rollbackFor列表中，不管是什么类型的异常，一定回滚。
      24.      *     2) 如果你的抛出的异常不在rollbackFor列表中，spring会判断异常是不是RuntimeException,
      25.      *         如果是一定回滚。
      26.      *
      27.      */
      28.    /* @Transactional(
      29.             propagation = Propagation.REQUIRED,
      30.             isolation = Isolation.DEFAULT,
      31.             readOnly = false,
      32.             rollbackFor = {
      33.                     NullPointerException.class,  NotEnoughException.class
      34.             }
      35.     )*/
      36.  
      37.     //使用的是事务控制的默认值， 默认的传播行为是REQUIRED，默认的隔离级别DEFAULT
      38.     //默认抛出运行时异常，回滚事务。
      39.     @Transactional(rollbackFor=Exception.class)
      40.     @Override
      41.     public void buy(Integer goodsId, Integer nums) {
      42.         System.out.println("=====buy方法的开始====");
      43.         //记录销售信息，向sale表添加记录
      44.         Sale sale  = new Sale();
      45.         sale.setGid(goodsId);
      46.         sale.setNums(nums);
      47.         saleDao.insertSale(sale);
      48.  
      49.         //更新库存
      50.         Goods goods  = goodsDao.selectGoods(goodsId);
      51.         if( goods == null){
      52.             //商品不存在
      53.             throw  new  NullPointerException("编号是："+goodsId+",商品不存在");
      54.         } else if( goods.getAmount() < nums){
      55.             //商品库存不足
      56.             throw new NotEnoughException("编号是："+goodsId+",商品库存不足");
      57.         }
      58.         //修改库存了
      59.         Goods buyGoods = new Goods();
      60.         buyGoods.setId( goodsId);
      61.         buyGoods.setAmount(nums);
      62.         goodsDao.updateGoods(buyGoods);
      63.         System.out.println("=====buy方法的完成====");
      64.     }
      65.     public void setSaleDao(SaleDao saleDao) {
      66.         this.saleDao = saleDao;
      67.     }
      68.     public void setGoodsDao(GoodsDao goodsDao) {
      69.         this.goodsDao = goodsDao;
      70.     }
      71. }

    • 测试入下：

      1. 正常查询：

      2. 查询一个不存在的一条数据

      3. 购买的数量超过库中的数据

      4. 此时我们在查询一条正常的

    2.使用 AspectJ 的 AOP 配置管理事务(掌握)

    适合大型项目，有很多的类，方法，需要大量的配置事务，使用aspectj框架功能，在spring配置文件中声明类，方法需要的事务。这种方式业务方法和事务配置完全分离。

    1. Step1：maven 依赖 pom.xml

      1. 新加入 aspectj 的依赖坐标
      2. <dependency>
      3. <groupId>org.springframeworkgroupId>
      4. <artifactId>spring-aspectsartifactId>
      5. <version>5.2.5.RELEASEversion>
      6. dependency>

    2. Step：在容器中添加事务管理器

      2.     
      3.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
      4.         <property name="dataSource" ref="myDataSource" />
      5.     bean>

    3. 修改spring配置文件(重点)

      1. "1.0" encoding="UTF-8"?>
      2. <beans xmlns="http://www.springframework.org/schema/beans"
      3.        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
      4.        xmlns:context="http://www.springframework.org/schema/context"
      5.        xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
      6.        xsi:schemaLocation="http://www.springframework.org/schema/beans
      7.        http://www.springframework.org/schema/beans/spring-beans.xsd
      8.        http://www.springframework.org/schema/context
      9.        https://www.springframework.org/schema/context/spring-context.xsd
      10.        http://www.springframework.org/schema/tx
      11.        http://www.springframework.org/schema/tx/spring-tx.xsd http://www.springframework.org/schema/aop https://www.springframework.org/schema/aop/spring-aop.xsd">
      12.  
      13.     
      14.     <context:property-placeholder location="classpath:jdbc.properties" />
      15.  
      16.     
      17.     <bean id="myDataSource" class="com.alibaba.druid.pool.DruidDataSource"
      18.           init-method="init" destroy-method="close">
      19.         
      20.         
      21.         <property name="url" value="${jdbc.url}" />
      22.         <property name="username" value="${jdbc.username}"/>
      23.         <property name="password" value="${jdbc.passwd}" />
      24.         <property name="maxActive" value="${jdbc.max}" />
      25.     bean>
      26.  
      27.     
      28.     <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
      29.         
      30.         <property name="dataSource" ref="myDataSource" />
      31.         
      32.         <property name="configLocation" value="classpath:mybatis.xml" />
      33.     bean>
      34.  
      35.     
      36.     <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
      37.         
      38.         <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" />
      39.         
      40.         <property name="basePackage" value="com.bjpowernode.dao"/>
      41.     bean>
      42.  
      43.     
      44.     <bean id="buyService" class="com.bjpowernode.service.impl.BuyGoodsServiceImpl">
      45.         <property name="goodsDao" ref="goodsDao" />
      46.         <property name="saleDao" ref="saleDao" />
      47.     bean>
      48.  
      49.     
      50.     
      51.     <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
      52.         <property name="dataSource" ref="myDataSource" />
      53.     bean>
      54.  
      55.     
      56.     <tx:advice id="myAdvice" transaction-manager="transactionManager">
      57.         
      58.         <tx:attributes>
      59.             
      60.             <tx:method name="buy" propagation="REQUIRED" isolation="DEFAULT"
      61.                        rollback-for="java.lang.NullPointerException,com.bjpowernode.excep.NotEnoughException"/>
      62.  
      63.             
      64.             <tx:method name="add*" propagation="REQUIRES_NEW" />
      65.             
      66.             <tx:method name="modify*" />
      67.             
      68.             <tx:method name="remove*" />
      69.             
      70.             <tx:method name="*" propagation="SUPPORTS" read-only="true" />
      71.         tx:attributes>
      72.     tx:advice>
      73.  
      74.     
      75.     <aop:config>
      76.         
      77.         <aop:pointcut id="servicePt" expression="execution(* *..service..*.*(..))"/>
      78.  
      79.         
      80.         <aop:advisor advice-ref="myAdvice" pointcut-ref="servicePt" />
      81.     aop:config>
      82.  
      83.  
      84. beans>

    4. 此时达到的效果和上面spring的注解完成的效果是一样的，这里就不测试了。

  • 相关阅读:
    centos 7.9系统安装老版本jenkins,并解决插件问题
    SpringBoot自动配置原理解析
    微光互联 TX800-U 扫码器无法输出中文到光标的问题
    【Sentinel Go】新手指南、流量控制、熔断降级和并发隔离控制
    el-form for循环动态校验规则
    java计算机毕业设计二手车商城MyBatis+系统+LW文档+源码+调试部署
    Zookeeper集群安装教程
    ROS机器人实战，对标古月老师HRMRP机器人（一）——机器人总体方案设计
    Spring Boot中使用Swagger3.0.0版本构建RESTful APIs
    JVM的主要组成及其作用
  • 原文地址：https://blog.csdn.net/weixin_48370579/article/details/127827749