声明式事务传播属性研究

港控/mmm° 2022-06-05 01:47 188阅读 0赞

#### 声明式事务传播属性 ####

**propagation配置的就是一个事务的传播性问题。**

所谓事务传播性，就是被调用者的事务与调用者的事务之间的关系。举例说明。

//in A.java
    Class A {
        @Transactional(propagation=propagation.REQUIRED)
        public void aMethod {
            B b = new B();
            b.bMethod();
        }
    }
    
    //in B.java
    Class B {
        @Transactional(propagation=propagation.REQUIRED)
        public void bMethod { 
            //something 
        }
    }

*  Propagation.REQUIRED  
    说明：
    
    1.  在上面例子中，传播性被设置成REQUIRED，注意，这是默认值，也即不进行该参数的配置等于配置成REQUIRED
    2.  REQUIRED的含义是，**支持当前已经存在的事务，如果还没有事务，就创建一个新事务。**在上面这个例子中，假设调用aMethod前不存在任何事务，那么执行aMethod时会自动开启一个事务，而由aMethod调用bMethod时，由于事务已经存在，因此会使用已经存在的事务（也就是执行aMethod之前创建的那个事务）。
    3.  对于这样的配置，如果bMethod过程中发生异常需要回滚，那么aMethod中所进行的所有数据库操作也将同时被回滚，**因为这两个方法使用了同一个事务。**
 *  Propagation.NOT\_SUPPORTED  
    说明：NOT\_SUPPORTED的含义是，强制不在事务中运行，如果当前存在一个事务，则挂起该事务。

@Override
    @Transactional(propagation = Propagation.NOT_SUPPORTED)
    public void transaction() { //第一条记录插入成功，第二条记录主键冲突，报运行期错误，不回滚
        PlatCity platCity = new PlatCity();
        platCity.setCityId(5);
        platCity.setCityName("beijing");
        platCity.setCityCode("005");
        this.addPlatCity(platCity);
        platCity.setCityId(5);
        platCity.setCityName("shanghai");
        platCity.setCityCode("006");
        this.addPlatCity(platCity);
    }

*  Propagation.REQUIRES\_NEW和Propagation.NESTED  
    
    
    > 接口PlatService实现类PlatServiceImpl，调用PlatService2接口实现类

@Override
    @Transactional(propagation = Propagation.REQUIRED)
    public void transaction() { //第一条记录插入成功，第二条记录主键冲突，报运行期错误，不回滚
        PlatCity platCity = new PlatCity();
        for(int i=5;i<10;i++){
            platCity.setCityId(i);
            platCity.setCityName("beijing");
            platCity.setCityCode("005");
            platCityMapper.addPlatCity(platCity);
        }
        platCity.setCityId(22);
        platCity.setCityName("shanghai");
        platCity.setCityCode("006");
        try {
            platCityService2.addPlatCity(platCity);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

> PlatService2接口实现类PlatServiceImpl2

@Override
    @Transactional(propagation = Propagation.REQUIRES_NEW)
    public int addPlatCity(PlatCity entity) {
        PlatCity platCity = new PlatCity();
        for(int i=10;i<15;i++){
            platCity.setCityId(i);
            platCity.setCityName("shanghai");
            platCity.setCityCode("006");
            platCityMapper.addPlatCity(platCity);
        }
        int flag = platCityMapper.addPlatCity(entity);
        if(flag == 1){
            throw new RuntimeException("运行期异常");
        }
        return flag;
    }

\*\*结论：\*\*

1.  REQUIRES\_NEW的含义是，挂起当前事务，创建一个新事务，如果还没有事务，就简单地创建一个新事务。
2.  NESTED的含义是，在当前事务中创建一个嵌套事务，如果还没有事务，那么就简单地创建一个新事务。
3.  请注意以上两者的区别，大多数情况下一上两种传播性行为是类似的，不过在事务回滚的问题上，以上两者有很大的区别。  
    
    
    1.  REQUIRES\_NEW会创建一个与原事务无关的新事务，尽管是由一个事务调用了另一个事务，但却没有父子关系。
    2.  **如果bMethod的传播性是REQUIRES\_NEW，而抛出了一个异常，则bMethod一定会被回滚，而如果aMethod捕获并处理了这个bMethod抛出的异常，那么aMethod仍有可能成功提交。当然，如果aMethod没有处理这个异常，那么aMethod也会被回滚。**
    3.  **如果aMethod在bMethod完成后出现了异常，那么bMethod已经提交而无法回滚，只有aMethod被回滚了。**
4.  对于NESTED，虽然也会创建一个新事务，但是这个事务与调用者是有父子关系的相互依存的
    
    1.  **如果bMethod的传播性是NESTED，而抛出了一个异常，事务的回滚行为与REQUIRES\_NEW是一致的**
    2.  **但是如果aMethod在bMethod完成后出现了异常，bMethod同样也会被回滚。**因为事实上，EJB中没有对于NESTED传播性的类似实现，NESTED并不是真正启动了一个事务，而是开启了一个新的savepoint。
        
         *  Propagation.NEVER  
            说明：NEVER的含义很简单，就是**强制要求不在事务中运行**，如果当前存在一个事务，则抛出异常，因此如果bMethod传播性是NEVER，则一定抛出异常。

@Override
    @Transactional(propagation = Propagation.REQUIRED)
    public void transaction() { //第一条记录插入成功，第二条记录主键冲突，报运行期错误，不回滚
        PlatCity platCity = new PlatCity();
        for(int i=5;i<10;i++){
            platCity.setCityId(i);
            platCity.setCityName("beijing");
            platCity.setCityCode("005");
            platCityMapper.addPlatCity(platCity);
        }
        platCity.setCityId(5);
        platCity.setCityName("shanghai");
        platCity.setCityCode("006");
        try {
            platCityService2.addPlatCity(platCity);
        } catch (Exception e) {
            e.printStackTrace();
        }
    // throw new RuntimeException("错误");
    }

@Override
    @Transactional(propagation = Propagation.NEVER)
    public int addPlatCity(PlatCity entity) {
        PlatCity platCity = new PlatCity();
        for(int i=10;i<15;i++){
            platCity.setCityId(i);
            platCity.setCityName("shanghai");
            platCity.setCityCode("006");
            platCityMapper.addPlatCity(platCity);
        }
        int flag = platCityMapper.addPlatCity(entity);
    // if(flag == 1){ 
    // throw new RuntimeException("运行期异常");
    // }
        return flag;
    }

*  Propagation.SUPPORTS  
    SUPPORTS的含义是，**支持当前事务，如果没有事务那么就不在事务中运行**。SUPPORTS传播性的逻辑含义比较模糊，因此一般是不推荐使用的。
 *  Propagation.MANDATORY  
    说明：MANDATORY的含义是，**支持当前已经存在的事务，如果还没有事务，就抛出一个异常。**如果上例中aMethod的传播性配置为MANDATORY，我们就无法在没有事务的情况下调用aMethod。*传播性为MANDATORY的方法必定是一个其他事务的子事务，当逻辑上独立存在没有意义或者可能违反数据、事务完整性的时候，就可以考虑设置这样的传播性设置。*

来源网址：[http://deltamaster.is-programmer.com/posts/28489.html][http_deltamaster.is-programmer.com_posts_28489.html]

[http_deltamaster.is-programmer.com_posts_28489.html]: http://deltamaster.is-programmer.com/posts/28489.html