-- 開啟事務(wù)
start transaction;
-- 提交事務(wù)
commit;
-- 回滾事務(wù)
rollback;

-- 創(chuàng)建數(shù)據(jù)庫
DROP DATABASE IF EXISTS trans_test;
CREATE DATABASE trans_test DEFAULT CHARACTER SET utf8mb4;
-- ??表
DROP TABLE IF EXISTS user_info;
CREATE TABLE user_info (
	 `id` INT NOT NULL AUTO_INCREMENT,
	 `user_name` VARCHAR (128) NOT NULL,
	 `password` VARCHAR (128) NOT NULL,
	 `create_time` DATETIME DEFAULT now(),
	 `update_time` DATETIME DEFAULT now() ON UPDATE now(),
	 PRIMARY KEY (`id`)
) ENGINE = INNODB DEFAULT CHARACTER
SET = utf8mb4 COMMENT = '用戶表';
-- 操作?志表
DROP TABLE IF EXISTS log_info;
CREATE TABLE log_info (
	 `id` INT PRIMARY KEY auto_increment,
 	`user_name` VARCHAR ( 128 ) NOT NULL,
	 `op` VARCHAR ( 256 ) NOT NULL,
	 `create_time` DATETIME DEFAULT now(),
	 `update_time` DATETIME DEFAULT now() ON UPDATE now() 
) DEFAULT charset 'utf8mb4';

spring:
 datasource:
 url: jdbc:mysql://127.0.0.1:3306/trans_testcharacterEncoding=utf8&useSSL=false
 username: root
 password: root
 driver-class-name: com.mysql.cj.jdbc.Driver
mybatis:
 configuration: # 配置打印 MyBatis?志
  log-impl: org.apache.ibatis.logging.stdout.StdOutImpl
  map-underscore-to-camel-case: true #配置駝峰?動(dòng)轉(zhuǎn)換

  @Data
  public class UserInfo {
        private Integer id;
        private String userName;
        private String password;
        private Date createTime;
        private Date updateTime;
    }
@Data
public class LogInfo {
	 private Integer id;
	 private String userName;
	 private String op;
	 private Date createTime;
	 private Date updateTime;
}

 @Mapper
    public interface UserInfoMapper {
        @Insert("insert into user_info(`user_name`,`password`)values(#{name},#
                {password})")
        Integer insert(String name, String password);
    }
    @Mapper
    public interface LogInfoMapper {
        @Insert("insert into log_info(`user_name`,`op`)values(#{name},#{op})")
        Integer insertLog(String name, String op);
    }

@Slf4j
    @Service
    public class UserService {
        @Autowired
        private UserInfoMapper userInfoMapper;
        public void registryUser(String name, String password) {
            //插???信息
            userInfoMapper.insert(name, password);
        }
    }
    @Slf4j
    @Service
    public class LogService {
        @Autowired
        private LogInfoMapper logInfoMapper;
        public void insertLog(String name, String op) {
            //記錄??操作
            logInfoMapper.insertLog(name, "?戶注冊");
        }
    }

@RequestMapping("/user")
    @RestController
    public class UserController {
        @Autowired
        private UserService userService;
        @RequestMapping("/registry")
        public String registry(String name, String password) {
            //??注冊
            userService.registryUser(name, password);
            return "注冊成功";
        }
    }

@RequestMapping("/user")
    @RestController
    public class UserController {
        // JDBC 事務(wù)管理器
        @Autowired
        private DataSourceTransactionManager dataSourceTransactionManager;
        // 定義事務(wù)屬性
        @Autowired
        private TransactionDefinition transactionDefinition;
        @Autowired
        private UserService userService;
        @RequestMapping("/registry")
        public String registry(String name, String password) {
            // 開啟事務(wù)
            TransactionStatus transactionStatus = dataSourceTransactionManager
                    .getTransaction(transactionDefinition);
            //??注冊
            userService.registryUser(name, password);
            //提交事務(wù)
            dataSourceTransactionManager.commit(transactionStatus);
            //回滾事務(wù)
            //dataSourceTransactionManager.rollback(transactionStatus);
            return "注冊成功";
        }
    }

  //回滾事務(wù) 
  dataSourceTransactionManager.rollback(transactionStatus);

    @RequestMapping("/trans")
    @RestController
    public class TransactionalController {
        @Autowired
        private UserService userService;
        @Transactional
        @RequestMapping("/registry")
        public String registry(String name, String password) {
            //??注冊
            userService.registryUser(name, password);
            return "注冊成功";
        }
    }

    @Slf4j
    @RequestMapping("/trans")
    @RestController
    public class TransactionalController {
        @Autowired
        private UserService userService;
        @Transactional
        @RequestMapping("/registry")
        public String registry(String name, String password) {
            //??注冊
            userService.registryUser(name, password);
            log.info("??數(shù)據(jù)插?成功");
            //強(qiáng)制程序拋出異常
            int a = 10 / 0;
            return "注冊成功";
        }
    }

@Transactional
    @RequestMapping("/registry")
    public String registry(String name, String password) {
        //??注冊
        userService.registryUser(name, password);
        log.info("??數(shù)據(jù)插?成功");
        //對異常進(jìn)?捕獲
        try {
            //強(qiáng)制程序拋出異常
            int a = 10 / 0;
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "注冊成功";
    }

@Transactional
    @RequestMapping("/registry")
    public String registry(String name, String password) {
        //??注冊
        userService.registryUser(name, password);
        log.info("??數(shù)據(jù)插?成功");
        //對異常進(jìn)?捕獲
        try {
            //強(qiáng)制程序拋出異常
            int a = 10 / 0;
        } catch (Exception e) {
            //將異常重新拋出去
            throw e;
        }
        return "注冊成功";
    }

 	@Transactional
    @RequestMapping("/registry")
    public String registry(String name, String password) {
        //??注冊
        userService.registryUser(name, password);
        log.info("??數(shù)據(jù)插?成功");
        //對異常進(jìn)?捕獲
        try {
            //強(qiáng)制程序拋出異常
            int a = 10 / 0;
        } catch (Exception e) {
            // ?動(dòng)回滾事務(wù)
   	TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
        }
        return "注冊成功";
    }

    @Transactional(rollbackFor = Exception.class)
    @RequestMapping("/r2")
    public String r2(String name, String password) throws IOException {
        //??注冊
        userService.registryUser(name, password);
        log.info("??數(shù)據(jù)插?成功");
        if (true) {
            throw new IOException();
        }
        return "r2";
    }

 public enum Isolation {
        DEFAULT(-1),
        READ_UNCOMMITTED(1),
        READ_COMMITTED(2),
        REPEATABLE_READ(4),
        SERIALIZABLE(8);
        private final int value;

        private Isolation(int value) {
            this.value = value;
        }

        public int value() {
            return this.value;
        }
    }

@Transactional(isolation = Isolation.READ_COMMITTED)
@RequestMapping("/r3")
public String r3(String name,String password) throws IOException {
 	//... 代碼省略
 	return "r3"; 
}

 public enum Propagation {
        REQUIRED(0),
        SUPPORTS(1),
        MANDATORY(2),
        REQUIRES_NEW(3),
        NOT_SUPPORTED(4),
        NEVER(5),
        NESTED(6);
        private final int value;
        private Propagation(int value) {
            this.value = value;
        }
        public int value() {
            return this.value;
        }
    }

@RequestMapping("/propaga")
    @RestController
    public class PropagationController {
        @Autowired
        private UserService userService;
        @Autowired
        private LogService logService;
        @Transactional(propagation = Propagation.REQUIRED)
        @RequestMapping("/p1")
        public String r3(String name, String password) {
            //??注冊
            userService.registryUser(name, password);
            //記錄操作?志
            logService.insertLog(name, "??注冊");
            return "r3";
        }
    }

@Slf4j
    @Service
    public class UserService {
        @Autowired
        private UserInfoMapper userInfoMapper;
        @Transactional(propagation = Propagation.REQUIRED)
        public void registryUser(String name, String password) {
            //插???信息
            userInfoMapper.insert(name, password);
        }
    }
    @Slf4j
    @Service
    public class LogService {
        @Autowired
        private LogInfoMapper logInfoMapper;
        @Transactional(propagation = Propagation.REQUIRED)
        public void insertLog(String name, String op) {
            int a = 10 / 0;
            //記錄??操作
            logInfoMapper.insertLog(name, "??注冊");
        }
    }

 @Service
    public class UserService {
        @Autowired
        private UserInfoMapper userInfoMapper;
        @Transactional(propagation = Propagation.REQUIRES_NEW)
        public void registryUser(String name, String password) {
            //插???信息
            userInfoMapper.insert(name, password);
        }
    }
    @Service
    public class LogService {
        @Autowired
        private LogInfoMapper logInfoMapper;
        @Transactional(propagation = Propagation.REQUIRES_NEW)
        public void insertLog(String name, String op) {
            int a = 10 / 0;
            //記錄??操作
            logInfoMapper.insertLog(name, "??注冊");
        }
    }

    @Slf4j
    @Service
    public class UserService {
        @Autowired
        private UserInfoMapper userInfoMapper;
        @Transactional(propagation = Propagation.NEVER)
        public void registryUser(String name, String password) {
            //插???信息
            userInfoMapper.insert(name, password);
        }
    }

@Slf4j
    @Service
    public class UserService {
        @Autowired
        private UserInfoMapper userInfoMapper;
        @Transactional(propagation = Propagation.NESTED)
        public void registryUser(String name, String password) {
            //插???信息
            userInfoMapper.insert(name, password);
        }
    }
    @Slf4j
    @Service
    public class LogService {
        @Autowired
        private LogInfoMapper logInfoMapper;
        @Transactional(propagation = Propagation.NESTED)
        public void insertLog(String name, String op) {
            int a = 10 / 0;
            //記錄??操作
            logInfoMapper.insertLog(name, "??注冊");
        }
    }

 @Service
    public class LogService {
        @Autowired
        private LogInfoMapper logInfoMapper;
        @Transactional(propagation = Propagation.NESTED)
        public void insertLog(String name, String op) {
            try {
                int a = 10 / 0;
            } catch (Exception e) {
                //回滾當(dāng)前事務(wù)
                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            }
            //記錄??操作
            logInfoMapper.insertLog(name, "??注冊");
        }
    }

 @Service
    public class UserService {
        @Autowired
        private UserInfoMapper userInfoMapper;
        @Transactional(propagation = Propagation.REQUIRED)
        public void registryUser(String name, String password) {
            //插???信息
            userInfoMapper.insert(name, password);
        }
    }
    @Service
    public class LogService {
        @Autowired
        private LogInfoMapper logInfoMapper;
        @Transactional(propagation = Propagation.REQUIRED)
        public void insertLog(String name, String op) {
            try {
                int a = 10 / 0;
            } catch (Exception e) {
                //回滾當(dāng)前事務(wù)
                TransactionAspectSupport.currentTransactionStatus().setRollbackOnly();
            }
            //記錄??操作
            logInfoMapper.insertLog(name, "??注冊");
        }
    }