基于springboot自定义事务注解「建议收藏」

基于springboot自定义事务注解1.开启注解支持(springboot默认支持注解)2.自定义注解接口3.写事务类4.写切面类2.自定义注解接口importjava.lang.annotation.*;/***注解类*/@Target(ElementType.METHOD)//定义注解用在方法上@Retention(RetentionPolicy.RUNTIME)//运行时注解@Documentedpublic@int

大家好,又见面了,我是你们的朋友全栈君。

基于springboot自定义事务注解

1.开启注解支持(springboot默认支持注解)
2.自定义注解接口
3.写事务类
4.写切面类

2.自定义注解接口

import java.lang.annotation.*;


/** * 注解类 */
@Target(ElementType.METHOD)             //定义注解用在方法上
@Retention(RetentionPolicy.RUNTIME)     //运行时注解
@Documented
public @interface CustomTransaction { 
   
    String value() default "";
}

3.写事务类

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Scope;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.stereotype.Component;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.interceptor.DefaultTransactionAttribute;

@Component
@Scope(value = "prototype")
public class TransactionUtils { 
   


    @Autowired
    private DataSourceTransactionManager dataSourceTransactionManager;

    /** *初始化创建TransactionStatus对象 * @return */
    public TransactionStatus init(){ 
   
        System.out.println("创建事务了...");
        TransactionStatus transactionStatus = dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
        return transactionStatus;
    }

    /** * 提交事务 * @param transactionStatus */
    public void commit(TransactionStatus transactionStatus){ 
   
        System.out.println("提交事务...");
        dataSourceTransactionManager.commit(transactionStatus);
    }


    public void rollback(TransactionStatus transactionStatus){ 
   
        System.out.println("事务回滚了....");
        dataSourceTransactionManager.rollback(transactionStatus);
    }
}

4.写切面类

import io.tianma.common.annotation.CustomTransaction;
import io.tianma.common.utils.TransactionUtils;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.aspectj.lang.reflect.MethodSignature;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.transaction.TransactionStatus;

import java.lang.reflect.Method;

@Aspect
@Component
public class CustomTransactionAspect { 
   

    @Autowired
    TransactionUtils transactionUtils;

    /** * 选择切面的注解CustomTransaction */
    @Pointcut("@annotation(io.tianma.common.annotation.CustomTransaction)")
    public void transactionPointCut() { 
   

    }

    /** * 方法增强@Arounbd * @param point */
    @Around("transactionPointCut()")
    public void around(ProceedingJoinPoint point){ 
   
        MethodSignature signature = (MethodSignature) point.getSignature();
        Method method = signature.getMethod();//获取到方法对象

        //获取到注解类
        CustomTransaction annotation = method.getAnnotation(CustomTransaction.class);
        if(annotation != null){ 
   
            System.out.println(annotation.value());//打印注解上value的内容
        }

        //请求的类名以及方法名
        String className = point.getTarget().getClass().getName();
        String methodName = signature.getName();
        System.out.println("执行的方法为:" + className + "." + methodName + "()");

        //开启事务
        TransactionStatus transactionStatus = transactionUtils.init();

        try { 
   
            //执行方法
            point.proceed();

            //执行成功提交事务
            transactionUtils.commit(transactionStatus);
        } catch (Throwable throwable) { 
   
            //执行方法出错则回滚事务
            transactionUtils.rollback(transactionStatus);
        }
    }
}

5.项目service

    @Override
   @CustomTransaction("新增用户开启事务")
   public void saveUser() { 
   
      SysUserEntity user = new SysUserEntity();
      user.setUserId("D123456");
      user.setName("张三");
      user.setCreateUserId("D123456");
      user.setCreateTime(new Date());
      this.save(user);

// System.out.println(1/0);

      SysUserRoleEntity sysUserRoleEntity = new SysUserRoleEntity();
      sysUserRoleEntity.setRoleId(123456L);
      sysUserRoleEntity.setUserId("123456");

      sysUserRoleService.save(sysUserRoleEntity);
   }

6.先查询数据库

在这里插入图片描述
在这里插入图片描述
查询数据库没有数据

7. 调用api

在这里插入图片描述

可以看出控制台已经执行成功
再查询一次数据库
在这里插入图片描述
在这里插入图片描述
可以看到已经有一条记录产生,并且切面也已经执行了

8.打开注释(System.out.println(1/0)),并且将user_id改为D1234567

SysUserEntity user = new SysUserEntity();
user.setUserId("D1234567");
user.setName("张三");
user.setCreateUserId("D1234567");
user.setCreateTime(new Date());
this.save(user);

System.out.println(1/0);

SysUserRoleEntity sysUserRoleEntity = new SysUserRoleEntity();
sysUserRoleEntity.setRoleId(1234567L);
sysUserRoleEntity.setUserId("1234567");

sysUserRoleService.save(sysUserRoleEntity);

在这里插入图片描述
可以看出事务进行回滚了,再查询一次数据库
在这里插入图片描述
在这里插入图片描述

可以看到报错后事务并没有进行提交,而是进行了回滚

结尾

自此基于springboot的自定义事务注解已完成

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/129167.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • 四个好看的CSS样式表格

    四个好看的CSS样式表格

  • 头文件里面的ifndef /define/endif的作用

    c,c++里面,头文件里面的ifndef/define/endif的作用今天和宿舍同学讨论一个小程序,发现有点地方不大懂······是

    2021年12月25日
  • 网络流量分析

    网络流量分析网络流量分析具体要求收集自己本机的网络流量数据(至少1小时)并进行数据显示。可用wireshark软件抓包网络流量大小的时序图,可按每半分钟、每分钟、每五分钟、每十分钟进行分别显示。流量协议类型直方图可设置过滤条件,显示指定协议数据包、显示时间段数据包、显示长度范围内的数据包提示:由于代码导入pyshark模块,注意wireshark安装路径为C盘programfils文件夹下,…

  • 基于协同过滤的电影推荐系统的设计与实现(协同过滤推荐算法伪代码)

    1Mahout介绍ApacheMahout是ApacheSoftwareFoundation(ASF)旗下的一个开源项目,提供一些可扩展的机器学习领域经典算法的实现,旨在帮助开发人员更加方便快捷地创建智能应用程序。经典算法包括聚类、分类、协同过滤、进化编程等等,并且,在Mahout中还加入了对ApacheHadoop的支持,使这些算法可以更高效的运行在云计算环境中。…

  • java的格式输入语句是_java输入输出语句是什么「建议收藏」

    java的格式输入语句是_java输入输出语句是什么「建议收藏」对于经常上机刷题的来说,首先得解决输入输出方法,Java的输入输出流在Java学习过程的后面部分才会接触,但是我们可以掌握一些简单的,常用的输入输出方法输出流java常用的输出语句有下面三种:System.out.println();//换行打印,输出之后会自动换行System.out.print();//不换行打印System.out.printf();//按格式输出输出示例publiccla…

  • .net Parallel.Foreach的Continue和Break和Return;

    .net Parallel.Foreach的Continue和Break和Return;在Foreach的时候需要多加一个ParallelLoopStatevarparallelOption=newParallelOptions(){MaxDegreeOfParallelism=6}; break类似于for的continue,而stop就类似于for的break Parallel.ForEach(As,parallelOption,(A

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号