Solon详解（四）- Solon的事务传播机制

Solon详解系列文章：
Solon详解（一）- 快速入门
Solon详解（二）- Solon的核心
Solon详解（三）- Solon的web开发
Solon详解（四）- Solon的事务传播机制
Solon详解（五）- Solon扩展机制之Solon Plugin
Solon详解（六）- Solon的校验扩展框架使用与扩展

在前面的篇章里咱们已经见识了 Solon 对事务的控制，及其优雅曼妙的身姿。该篇将对事务进行详解。出于对用户的学习成本考虑，Solon 借签了Spring 的事务传播策略；因此体验上几乎同样。

1、为何要有传播机制？

Solon 对事务的控制，是使用 aop 切面实现的，因此不用关心事务的开始，提交 ，回滚，只须要在方法上加 @XTran 注解便可。

这时候就容易产生一些疑问：

• 场景一：classA 方法调用了 classB 方法，但两个方法都有事务
  • 这个时候若是 classB 方法异常，是让 classB 方法提交，仍是两个一块儿回滚？
• 场景二：classA 方法调用了 classB 方法，可是只有 classA 方法加了事务
  • 是否把 classB 也加入 classA 的事务，若是 classB 异常，是否回滚 classA？
• 场景三：classA 方法调用了 classB 方法，二者都有事务，classB 已经正常执行完，但 classA 异常
  • 是否须要回滚 classB 的数据？

这个时候事务的传播机制和策略就派上用场了

2、传播机制生效条件

由于 Solon 是使用 aop 来代理事务控制 ，是针对于接口或类的，因此在同一个类中两个方法的调用，传播机制是不生效的

3、传播机制的策略

下面的类型都是针对于被调用方法来讲的，理解起来要想象成两个 class 方法的调用才能够。

传番策略	说明
TranPolicy.required	支持当前事务，若是没有则建立一个新的。这是最多见的选择。也是默认。
TranPolicy.requires_new	新建事务，若是当前存在事务，把当前事务挂起。
TranPolicy.nested	若是当前有事务，则在当前事务内部嵌套一个事务；不然新建事务。
TranPolicy.mandatory	支持当前事务，若是没有事务则报错。
TranPolicy.supports	支持当前事务，若是没有则不使用事务。
TranPolicy.not_supported	以无事务的方式执行，若是当前有事务则将其挂起。
TranPolicy.never	以无事务的方式执行，若是当前有事务则报错。

4、事务的隔离级别

属性	说明
unspecified	默认（JDBC默认）
read_uncommitted	脏读：其它事务，可读取未提交数据
read_committed	只读取提交数据：其它事务，只能读取已提交数据
repeatable_read	可重复读：保证在同一个事务中屡次读取一样数据的结果是同样的
serializable	可串行化读：要求事务串行化执行，事务只能一个接着一个地执行，不能并发执行

5、@XTran 属性说明

属性	说明
policy	事务传导策略
isolation	事务隔离等级
readOnly	是否为只读事务

6、示例

• 父回滚，子回滚

@XService
public class UserService{
    @XTran
    public void addUser(UserModel user){
        //....
    }
}

@XController
public class DemoController{
    @XInject
    UserService userService; 
    
    //父回滚，子回滚
    //
    @XTran
    @XMapping("/user/add2")
    pubblic void addUser2(UserModel user){
        userService.addUser(user); 
        throw new RuntimeException("不让你加");
    }
}

• 父回滚，子不回滚

@XService
public class UserService{
    @XTran(policy = TranPolicy.requires_new)
    public void addUser(UserModel user){
        //....
    }
}

@XController
public class DemoController{
    @XInject
    UserService userService; 
    
    //父回滚，子不回滚
    //
    @XTran
    @XMapping("/user/add2")
    pubblic void addUser2(UserModel user){
        userService.addUser(user); 
        throw new RuntimeException("不让你加；但仍是加了:(");
    }
}

• 子回滚父不回滚

@XService
public class UserService{
    @XTran(policy = TranPolicy.nested)
    public void addUser(UserModel user){
        //....
        throw new RuntimeException("不让你加");
    }
}

@XController
public class DemoController{
    @XInject
    UserService userService; 
    
    //子回滚父不回滚
    //
    @XTran
    @XMapping("/user/add2")
    pubblic void addUser2(UserModel user){
        try{
            userService.addUser(user); 
        }catch(ex){ }
    }
}

• 多数据源事务示例

@XService
public class UserService{
    @Db("db1")
    UserMapper userDao;
    
    @XTran
    public void addUser(UserModel user){
        userDao.insert(user);
    }
}

@XService
public class AccountService{
    @Db("db2")
    AccountMappeer accountDao;

    @XTran
    public void addAccount(UserModel user){
        accountDao.insert(user);
    }
}

@XController
public class DemoController{
    @XInject
    AccountService accountService; 
    
    @XInject
    UserService userService; 
    
    @XTran
    @XMapping("/user/add")
    pubblic void addUser(UserModel user){
        userService.addUser(user);     //会执行db1事务
        
        accountService.addAccount(user);    //会执行db2事务
    }
}