Spring事务和事务传播机制-阿里云开发者社区

Spring事务和事务传播机制

2023-10-25 101

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： Spring事务和事务传播机制

一:Spring中事务的实现

Spring中的事务操作分为两类:

1:编程式事务(手动写代码操作事务)

2:声明式事务(利用注解自动开启和提交事务)

二:Spring事务的操作

在spring操作中，也分为三个步骤，开启事务，回滚事务，提交事务。

下面，我们通过案例来进行操作。

2.1:Spring编程式实现事务

2.1.1:User表

#创建用户表
create table user(
    userId int primary key auto_increment,
    #约定用户名是独一无二的
    username varchar(64) unique ,
    #密码
    password varchar(64)
);

2.1.2:Mapper接口声明的方法

在mapper中声明的方法，我们用的是添加一个用户信息的操作。返回的数字代表影响的行数。

@Mapper
public interface UserMapper {
    //返回int的数据
    int addUserInfo(UserInfo userInfo);
}

2.1.3:Service层

@Service
public class UserService {
    @Autowired
    private UserMapper userMapper;
    public Integer addUserInfo(UserInfo userInfo){
        return userMapper.addUserInfo(userInfo);
    }
}

2.1.4:Controller层

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;
    //添加这个注解，将事务管理器引入进来
    @Autowired
    private DataSourceTransactionManager transactionManager;
    //设置事务的属性
    @Autowired
    private TransactionDefinition transactionDefinition;
    //返回受影响的行数
    @RequestMapping("/add")
    public Integer add(UserInfo userInfo){
        //第一步:非空校验
        if(userInfo==null||!StringUtils.hasLength(userInfo.getUsername())
        ||!StringUtils.hasLength(userInfo.getPassword())){
            return 0;
        }
        //1.开启事务,得到并开启事务
        TransactionStatus transaction = transactionManager.getTransaction(transactionDefinition);
        Integer integer = userService.addUserInfo(userInfo);
        System.out.println(integer);
        //2:回滚事务
        transactionManager.rollback(transaction);
        return integer;
    }
}

此时，由于我们对添加用户信息这一条进行了回滚，所以，新的用户信息添加不到数据库当中，但是返回的数值仍旧是1.

但当我们将回滚事务转变成提交事务，我们看数据库里面能不能得到添加的用户信息。

@RestController
@RequestMapping("/user")
public class UserController {
    @Autowired
    private UserService userService;
    //添加这个注解，将事务管理器引入进来
    @Autowired
    private DataSourceTransactionManager transactionManager;
    //设置事务的属性
    @Autowired
    private TransactionDefinition transactionDefinition;
    //返回受影响的行数
    @RequestMapping("/add")
    public Integer add(UserInfo userInfo){
        //第一步:非空校验
        if(userInfo==null||!StringUtils.hasLength(userInfo.getUsername())
        ||!StringUtils.hasLength(userInfo.getPassword())){
            return 0;
        }
        //1.开启事务,得到并开启事务
        TransactionStatus transaction = transactionManager.getTransaction(transactionDefinition);
        Integer integer = userService.addUserInfo(userInfo);
        System.out.println(integer);
        //2:回滚事务
        transactionManager.commit(transaction);
        return integer;
    }
}

运行结果:

2.2:Spring声明式事务(自动)

在controller层添加@Transactional这个注解，就可以开启事务了。

特点:

1:@Transaction这个注解可以加在类和方法上，加在类上代表这个类里面的public方法，都具有事务，加在方法上，代表此处的方法具有事务。

2:@Transactional，在方法执行前开启事务，在方法执行后提交事务，如若在方法执行过程中，出现异常，则回滚事务。

2.2.1:实现案例

@Transactional
    @RequestMapping("/insert")
    public Integer insert(UserInfo userInfo){
        if(userInfo==null||!StringUtils.hasLength(userInfo.getUsername())
        ||!StringUtils.hasLength(userInfo.getPassword())){
            return 0;
        }
        Integer integer = userService.addUserInfo(userInfo);
        return integer;
    }

上述代码中，在方法运行过程中，并没有出现异常，那么，就会自动提交事务。倘若，我们给这个方法中添加算数异常，看看会发生什么?

@Transactional
    @RequestMapping("/insert")
    public Integer insert(UserInfo userInfo){
        if(userInfo==null||!StringUtils.hasLength(userInfo.getUsername())
        ||!StringUtils.hasLength(userInfo.getPassword())){
            return 0;
        }
        Integer integer = userService.addUserInfo(userInfo);
        System.out.println(integer);
        //搞一个算数异常
        int num=10/0;
        return integer;
    }

此时就会报出算数异常，在方法中出现算数异常，那么，此时，就会出现事务回滚，即不添加新的用户信息。

2.2.2: @Transactional注意事项

当程序中有try-catch语句时，即使程序中有异常，事务也不会回滚。

@Transactional
    @RequestMapping("/insert")
    public Integer insert(UserInfo userInfo){
        if(userInfo==null||!StringUtils.hasLength(userInfo.getUsername())
        ||!StringUtils.hasLength(userInfo.getPassword())){
            return 0;
        }
        Integer integer = userService.addUserInfo(userInfo);
        System.out.println(integer);
        //搞一个算数异常
        try {
            int num=10/0;
        } catch (Exception e) {
            System.out.println(e.getMessage());
        }
        return integer;
    }

当在程序中，出现算数异常时，我们添加用户名wangwu和密码12345。

控制台代码:

数据库表:

从上述结果来看，发现添加上了，此时，事务并没有进行回滚。

如何解决?

解决方案一:将异常继续抛出，交给spring

解决方案二:

@Transactional
    @RequestMapping("/insert")
    public Integer insert(UserInfo userInfo){
        if(userInfo==null||!StringUtils.hasLength(userInfo.getUsername())
        ||!StringUtils.hasLength(userInfo.getPassword())){
            return 0;
        }
        Integer integer = userService.addUserInfo(userInfo);
        System.out.println(integer);
        //搞一个算数异常
        try {
            int num=10/0;
        } catch (Exception e) {
            System.out.println(e.getMessage());
            //使用代码，手动回滚事务
            TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
        return integer;
    }