/**

 * 注解声明式事务配置(相当于上述的aop方式的配置)

 * @author liyong

 *

 */

@Configuration

public class TxAdviceTransactionConfig {

    private static final String AOP_POINTCUT_EXPRESSION = "execution(* com.mike.mihome.*.service..*.*(..))";

    @Autowired

    private PlatformTransactionManager transactionManager;

    @Bean

    public TransactionInterceptor txAdvice(){

        NameMatchTransactionAttributeSource source = new NameMatchTransactionAttributeSource();

        //只读事务，不做更新操作

        RuleBasedTransactionAttribute readOnlyTx = new RuleBasedTransactionAttribute();

        readOnlyTx.setReadOnly(true);

        readOnlyTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_NOT_SUPPORTED);

        //当前存在事务就使用当前事务，当前不存在事务就创建一个新的事务

        RuleBasedTransactionAttribute requiredTx = new RuleBasedTransactionAttribute();

//        requiredTx.setRollbackRules(Collections.singletonList(new RollbackRuleAttribute(Exception.class))); //设置异常类型

        requiredTx.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);

        requiredTx.setTimeout(10000);

        Map<String, TransactionAttribute> txMap = new HashMap<String, TransactionAttribute>();

        txMap.put("query*", readOnlyTx);

        txMap.put("get*", readOnlyTx);

        txMap.put("*", requiredTx);

        source.setNameMap(txMap);

        TransactionInterceptor txAdvice = new TransactionInterceptor(transactionManager, source);

        return txAdvice;

    }

    @Bean

    public Advisor txAdviceAdvisor() {

        AspectJExpressionPointcut pointcut = new AspectJExpressionPointcut();

        pointcut.setExpression(AOP_POINTCUT_EXPRESSION);

        return new DefaultPointcutAdvisor(pointcut, txAdvice());

    }

}