Springboot事务

系统管理员 2023-02-24 03:54 32阅读 0赞

# AOP形式给Service层或者Controller层添加事务 #

## 步骤一：添加spring的AOP依赖 ##

<dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-aspects</artifactId>
            </dependency>

## 步骤二：配置类（代码末尾可以修改控制Service层还是Controller层） ##

package com.jdkj.monthlySalePerformanceAppraisal.config;
    
    import java.util.Collections;
    import java.util.HashMap;
    import java.util.Map;
    
    import javax.sql.DataSource;
    
    import org.springframework.aop.aspectj.AspectJExpressionPointcut;
    import org.springframework.aop.support.DefaultPointcutAdvisor;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    import org.springframework.transaction.TransactionDefinition;
    import org.springframework.transaction.interceptor.NameMatchTransactionAttributeSource;
    import org.springframework.transaction.interceptor.RollbackRuleAttribute;
    import org.springframework.transaction.interceptor.RuleBasedTransactionAttribute;
    import org.springframework.transaction.interceptor.TransactionAttribute;
    import org.springframework.transaction.interceptor.TransactionInterceptor;
    
    @Configuration
    public class TxAnoConfig {
    
    
        @Autowired
        private DataSource dataSource;
    
        @Bean("txManager")
        public DataSourceTransactionManager txManager() {
            return new DataSourceTransactionManager(dataSource);
        }
    
        /**
         * @Description: 事务拦截器
         * @Param: [txManager]
         * @Return: org.springframework.transaction.interceptor.TransactionInterceptor
         * @Author: WQ
         * @Date: 2020/7/8
         */
        @Bean("txAdvice")
        public TransactionInterceptor txAdvice(DataSourceTransactionManager txManager) {
            NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();
            RuleBasedTransactionAttribute readOnlyTx = new RuleBasedTransactionAttribute();
            readOnlyTx.setReadOnly(true);
            readOnlyTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);
            RuleBasedTransactionAttribute requiredTx = new RuleBasedTransactionAttribute(TransactionDefinition.PROPAGATION_REQUIRED,
                    Collections.singletonList(new RollbackRuleAttribute(Exception.class)));
            requiredTx.setTimeout(5);
            Map<String, TransactionAttribute> txMap = new HashMap<>();
            txMap.put("add*", requiredTx);
            txMap.put("save*", requiredTx);
            txMap.put("insert*", requiredTx);
            txMap.put("update*", requiredTx);
            txMap.put("delete*", requiredTx);
            txMap.put("get*", readOnlyTx);
            txMap.put("query*", readOnlyTx);
            source.setNameMap(txMap);
            return new TransactionInterceptor(txManager, source);
        }
    
        /**
         * 切面拦截规则 参数会自动从容器中注入
         */
        @Bean
        public DefaultPointcutAdvisor defaultPointcutAdvisor(TransactionInterceptor txAdvice) {
            DefaultPointcutAdvisor pointcutAdvisor = new DefaultPointcutAdvisor();
            pointcutAdvisor.setAdvice(txAdvice);
            AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();
            //控制service层
    //        pointcut.setExpression("execution (* com.jdkj.monthlySalePerformanceAppraisal.service.*.*(..))");
            //控制controller层
            pointcut.setExpression("execution (* com.jdkj.monthlySalePerformanceAppraisal.controller.*.*(..))");
            pointcutAdvisor.setPointcut(pointcut);
            return pointcutAdvisor;
        }
    
    
    }

## 打开控制台可以看到事务的回滚（[修改日志级别][Link 1]），数据库中的数据也没有改变 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXFpYW5nOTE1_size_16_color_FFFFFF_t_70][]

[Link 1]: https://blog.csdn.net/weiqiang915/article/details/107201641
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXFpYW5nOTE1_size_16_color_FFFFFF_t_70]: /images/20230209/b33d9f2d3b2b418487562896cfea9254.png