@Transactional解读(作用、失效场景与解决方式)

@SpringBootTest
@Slf4j
public class Test {
    @Autowired
    PlatformTransactionManager transactionManager;


    @Autowired
    private TransactionTemplate transactionTemplate;

    @Autowired
    UserService userService;

    @Test
    public void transactionManagerTest(){
        //事务基础信息 超时时间、隔离级别、传播属性等
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();; // 定义事务属性
        // 设置传播行为属性， 默认事务级别。 当前无事务则新建事务，已有事务则加入事务。
        def.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED);
        // 获得事务状态
        TransactionStatus status = transactionManager.getTransaction(def);

        try {
            log.info("执行事务方法");
            // 这里用到 lombok 的链式编程，很简单的原理，set一般不是返回void吗，只需要改为返回当前对象，就是this，就可以实现此功能了
            User user = new User().setName("张三");
            // 事务操作
            // 数据库操作
            userService.insertUser(user);
            //手动设置异常
            int i = 1 / 0;
            // 事务提交
            transactionManager.commit(status);// 提交事务
        } catch (Exception e) {
            // 事务提交
            transactionManager.rollback(status);
            log.error("执行事务异常，需要回滚");
        }
    }

    @Test
    public void transactionTemplateTest() {
        Object execute = transactionTemplate.execute(new TransactionCallback() {
            /**
             * @param transactionStatus 事务运行状态信息 是否是新事务、是否已被标记为回滚等
             * @return
             */
            @Override
            public Object doInTransaction(TransactionStatus transactionStatus) {
                try {
                    log.info("执行事务方法");
                    User user = new User().setName("张三");
                    userService.insertUser(user);
                    // 手动设置异常
                    int i = 1 / 0;
                    log.info("正常执行完成");
                    return "成功";
                } catch (Exception e) {
                    log.error("执行事务异常，需要回滚",e);
                    transactionStatus.setRollbackOnly();
                    return "失败";
                }
            }
        });
    }
}

    @Test
    // 这个注解还是有很多坑需要注意，这在后文中会讲
    @Transactional(rollbackFor = Exception.class)
    public void transactionalTest(){
        // 只用正常些业务代码就可以了，一切交给 Spring 来处理，这里 @Transactional 注解用到的知识就是 AOP
        try {
            User user = new User().setName("张三");
            // 数据库操作
            userService.insertUser(user);
            // 手动设置异常
            int i = 1 / 0;
        } catch (Exception e) {
            log.error("执行事务异常，需要回滚",e);
            // 如果异常被 try 、 catch 吞了是不会回滚的，所有手动抛出去
            throw e;
        }
    }

@Transactional(rollbackFor = Exception.class)
@RestController
@Slf4j
public class TestController {
        @Autowired
        UserService userService;

        @RequestMapping("/test")
        // 这个注解还是有很多坑需要注意，这在后文中会讲
        @Transactional(rollbackFor = Exception.class)
        public void transactionalTest(){
            // 只用正常些业务代码就可以了，一切交给 Spring 来处理，这里 @Transactional 注解用到的知识就是 AOP
            try {
                User user = new User().setName("张三");
                // 数据库操作
                userService.insertUser(user);
                // 手动设置异常
                int i = 1 / 0;
            } catch (Exception e) {
                log.error("执行事务异常，需要回滚",e);
                // 如果异常被 try 、 catch 吞了是不会回滚的，所有手动抛出去
                throw e;
            }
        }
}

protected TransactionAttribute computeTransactionAttribute(Method method,
    Class<?> targetClass) {
   
        // Don't allow no-public methods as required.
        if (allowPublicMethodsOnly() && !Modifier.isPublic(method.getModifiers())) {
   
	return null;
        }

private int getDepth(Class<?> exceptionClass, int depth) {
        if (exceptionClass.getName().contains(this.exceptionName)) {
            // Found it!
            return depth;
}
        // If we've gone as far as we can go and haven't found it...
        if (exceptionClass == Throwable.class) {
            return -1;
}
return getDepth(exceptionClass.getSuperclass(), depth + 1);
}

@Transactional(rollbackFor = Exception.class) 

@RestController
@Slf4j
public class TestController {
    @Autowired
    UserService userService;

    @RequestMapping("/test")
    public void Test(){
        // 这里就相当于使用了 this.transactionalTest(); 使用的是本地对象的方法，没有用到spring容器，就无法触发AOP，导致事务失效
        transactionalTest();
    }
    
    // 这个注解还是有很多坑需要注意，这在后文中会讲
    @Transactional(rollbackFor = Exception.class)
    public void transactionalTest(){
        // 只用正常些业务代码就可以了，一切交给 Spring 来处理，这里 @Transactional 注解用到的知识就是 AOP
        try {
            User user = new User().setName("张三");
            // 数据库操作
            userService.insertUser(user);
            // 手动设置异常
            int i = 1 / 0;
        } catch (Exception e) {
            log.error("执行事务异常，需要回滚",e);
            // 如果异常被 try 、 catch 吞了是不会回滚的，所有手动抛出去
            throw e;
        }
    }
}

@RestController
@Slf4j
@EnableAspectJAutoProxy(proxyTargetClass = true,exposeProxy = true)
public class TestController {
    @Autowired
    UserService userService;



    @RequestMapping("/test")
    public void Test(){
        // 这里就相当于使用了 this.transactionalTest(); 使用的是本地对象的方法，没有用到spring容器，就无法触发AOP，导致事务失效
        ((TestController) AopContext.currentProxy()).transactionalTest();
    }

    // 这个注解还是有很多坑需要注意，这在后文中会讲
    @Transactional(rollbackFor = Exception.class)
    public void transactionalTest(){
        // 只用正常些业务代码就可以了，一切交给 Spring 来处理，这里 @Transactional 注解用到的知识就是 AOP
        try {
            User user = new User().setName("张三");
            // 数据库操作
            userService.insertUser(user);
            // 手动设置异常
            int i = 1 / 0;
        } catch (Exception e) {
            log.error("执行事务异常，需要回滚",e);
            // 如果异常被 try 、 catch 吞了是不会回滚的，所有手动抛出去
            throw e;
        }
    }
}

@RestController
@Slf4j
public class TestController {
    @Autowired
    UserService userService;
    @Autowired
    TestController testController;



    @RequestMapping("/test")
    public void Test(){
        testController.transactionalTest();
    }

    // 这个注解还是有很多坑需要注意，这在后文中会讲
    @Transactional(rollbackFor = Exception.class)
    public void transactionalTest(){
        // 只用正常些业务代码就可以了，一切交给 Spring 来处理，这里 @Transactional 注解用到的知识就是 AOP
        try {
            User user = new User().setName("张三");
            // 数据库操作
            userService.insertUser(user);
            // 手动设置异常
            int i = 1 / 0;
        } catch (Exception e) {
            log.error("执行事务异常，需要回滚",e);
            // 如果异常被 try 、 catch 吞了是不会回滚的，所有手动抛出去
            throw e;
        }
    }
}

@RestController
@Slf4j
public class TestController implements ApplicationContextAware {
    @Autowired
    UserService userService;

    private static ApplicationContext applicationContext;


    @RequestMapping("/test")
    public void Test(){
        TestController bean = applicationContext.getBean(TestController.class);
        bean.transactionalTest();
    }

    // 这个注解还是有很多坑需要注意，这在后文中会讲
    @Transactional(rollbackFor = Exception.class)
    public void transactionalTest(){
        // 只用正常些业务代码就可以了，一切交给 Spring 来处理，这里 @Transactional 注解用到的知识就是 AOP
        try {
            User user = new User().setName("张三");
            // 数据库操作
            userService.insertUser(user);
            // 手动设置异常
            int i = 1 / 0;
        } catch (Exception e) {
            log.error("执行事务异常，需要回滚",e);
            // 如果异常被 try 、 catch 吞了是不会回滚的，所有手动抛出去
            throw e;
        }
    }

    @Override
    public void setApplicationContext(ApplicationContext applicationContext) throws BeansException {
        TestController.applicationContext = applicationContext;
    }
}

    @Transactional(rollbackFor = Exception.class)
    public void transactionalTest(){
        // 只用正常些业务代码就可以了，一切交给 Spring 来处理，这里 @Transactional 注解用到的知识就是 AOP
        try {
            User user = new User().setName("张三");
            // 数据库操作
            userService.insertUser(user);
            // 手动设置异常
            int i = 1 / 0;
        } catch (Exception e) {
            // 为啥写 catch ，还要写 throw e 抛出异常呢，因为要记日志啊，不记日志的话也可以不用，但哪个不写报错日志，出bug不是给自己挖坑吗
            log.error("执行事务异常，需要回滚",e);
            // 如果异常被 try 、 catch 吞了是不会回滚的
//            throw e;
        }
    }