事务的传播

news2024/9/9 4:29:56

- 七种传播机制
- 支持当前事务
- 不支持当前事务
- 嵌套事务

七种传播机制

事务传播机制：解决一个事务在多个方法传递的问题
传播机制有以下7种
REQUIRED (默认)：如果当前存在事务，则加入该事务，如果不存在事务，则创建一个新事务。
REQUIRES_NEW：无论当前是否存在事务，都会创建一个新事务。如果当前存在事务，会将其挂起。
SUPPORTS：如果当前存在事务，则加入该事务，如果不存在事务，则以非事务的方式执行。
NOT_SUPPORTED：以非事务的方式执行方法，如果当前存在事务，则将其挂起。
MANDATORY：如果当前存在事务，则加入该事务，如果不存在事务，则抛出异常。
NEVER：以非事务的方式执行方法，如果当前存在事务，则抛出异常。
NESTED：如果当前存在事务，则嵌套在该事务中执行；如果不存在事务，则创建一个新事务。嵌套事务是一个独立的子事务，可以单独提交或回滚，但最终必须与外部事务一起提交或回滚。
在这里插入图片描述

支持当前事务

在这里插入图片描述
那么就涉及到如果方法2/方法3出问题；是全部回滚；还是回滚当前呢？
以第二个方法Method2为示例；进行演示机制1效果（是否真的Method2出现异常；事务全部都回滚；因为传播机制变成一个事务整体）
调用链如下；正常逻辑上是调用日志的Interface；但是我们当前需要显示一下错误的信息；所以才选择调用LogService
在这里插入图片描述

创建日志表、用户表：两张表才能演示才效果是不是都回滚。

CREATE TABLE UserInfo (
    id INT AUTO_INCREMENT PRIMARY KEY,
    username VARCHAR(255) NOT NULL,
    password VARCHAR(255) NOT NULL,
    photo VARCHAR(255),
    createtime DATETIME,
    updatetime DATETIME,
    state INT
);

CREATE TABLE Log (
    id INT AUTO_INCREMENT PRIMARY KEY,
    timestamp DATETIME NOT NULL,
    message TEXT
);

创建实体类对应UserInfo、log

package com.example.demo.entity;
import lombok.Data;
import java.time.LocalDateTime;
@Data
public class Log {
    private int id;
    private LocalDateTime timestamp;
    private String message;
}

package com.example.demo.entity;
import lombok.Data;
import java.time.LocalDateTime;
@Data
public class UserInfo {
    private int id;
    private String username;
    private String password;
    private String photo;
    private LocalDateTime createtime;
    private LocalDateTime updatetime;
    private int state;
}

UserService做两件事情；调用UserMapper和调用LogService（正常逻辑调用LogMapper；这里为了异常演示）

package com.example.demo.service;


import com.example.demo.entity.Log;
import com.example.demo.entity.UserInfo;
import com.example.demo.mapper.UserMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service
public class UserService {
    @Autowired
    private UserMapper userMapper;
    @Autowired
    private LogService logService;

    public int del(Integer id) {
        return userMapper.del(id);
    }
    
    @Transactional(propagation = Propagation.REQUIRED)
    public int add(UserInfo userInfo) {
        // 给用户表添加用户信息
        int addUserResult = userMapper.add(userInfo);
        System.out.println("添加用户结果：" + addUserResult);
        // 添加日志信息
        Log log = new Log();
        log.setMessage("添加用户信息");
        logService.add(log);
        return addUserResult;
    }

}

LogService：

package com.example.demo.service;

import com.example.demo.entity.Log;
import com.example.demo.mapper.LogMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.interceptor.TransactionAspectSupport;

@Service
public class LogService {

    @Autowired
    private LogMapper logMapper;

    @Transactional(propagation = Propagation.REQUIRED)
    public int add(Log log) {
        int result = logMapper.add(log);
        System.out.println("添加日志结果：" + result);
        // 回滚操作
    int num=10/0;
        return result;
    }
    
}

这里的演示还不能用回滚操作来代替算数异常；因为内层是要回滚；外层没感知异常。它们都是一个事务；那就出问题了；报错。

UserCOntroller：

package com.example.demo.controller;

import com.example.demo.entity.UserInfo;
import com.example.demo.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

//演示事务传播机制

@RestController
@RequestMapping("/user3")
public class UserController3 {
    @Autowired
    private UserService userService;

    @RequestMapping("/add")
    @Transactional(propagation = Propagation.REQUIRED)
    public int add(String username, String password) {
        if (null == username || null == password ||
                username.equals("") || password.equals("")) return 0;
        UserInfo user = new UserInfo();
        user.setUsername(username);
        user.setPassword(password);
        int result = userService.add(user);
        // 用户添加操作
        return result;
    }

}