1 Star 3 Fork 0

pliu/transactionalDemo

加入 Gitee
与超过 1200万 开发者一起发现、参与优秀开源项目,私有仓库也完全免费 :)
免费加入
该仓库未声明开源许可证文件(LICENSE),使用请关注具体项目描述及其代码上游依赖。
克隆/下载
贡献代码
同步代码
取消
提示: 由于 Git 不支持空文件夾,创建文件夹后会生成空的 .keep 文件
Loading...
README

transactionalDemo

介绍

手写@Transational事务注解的小demo

软件架构

采用全注解方式,无xml文件 JdbcTemplate入库

手写事务注解的思路

  1. 定义事务注解
  2. 封装手动事务
  3. 扫包--定义一个事务扫包AOP
  4. 拦截方法的时候,使用反射判断该方法是否加了事务注解,有就开启事务

安装教程

  1. 运行mainTest.java的main方法前,请务必修改TxConfig.java中的数据源信息
  2. t_users.sql有测试表的表结构,数据库mysql
  3. 运行mainTest

手写事务注解的思路:

1,定义事务注解 2,封装手动事务 3,扫包--定义一个事务扫包AOP 4,拦截方法的时候,使用反射判断该方法是否加了事务注解,有就开启事务

1. 定义事务注解

/**
 * 手写事务注解:
 *  1,定义事务注解
 *  
 *  @Target说明了Annotation所修饰的对象范围:Annotation可被用于 packages、types(类、接口、枚举、Annotation类型)、类型成员(方法、构造方法、成员变量、枚举值)、方法参数和本地变量(如循环变量、catch参数)。在Annotation类型的声明中使用了target可更加明晰其修饰的目标。
 *  1.	CONSTRUCTOR:用于描述构造器
 *  2.	FIELD:用于描述域
 *  3.	LOCAL_VARIABLE:用于描述局部变量
 *  4.	METHOD:用于描述方法
 *  5.	PACKAGE:用于描述包
 *  6.	PARAMETER:用于描述参数
 *  7.	TYPE:用于描述类、接口(包括注解类型) 或enum声明
 *  
 *  @Retention
 *  表示需要在什么级别保存该注释信息,用于描述注解的生命周期(即:被描述的注解在什么范围内有效)
 */
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface LpTransactional {
	
}

2. 封装手动事务

/**
 * 手写事务注解:
 *  2,封装手动事务
 */
@Component
@Scope("prototype") //多例,线程安全
public class TransactionUtils {

	private TransactionStatus transactionStatus;

	// 获取事务源
	@Autowired
	private DataSourceTransactionManager dataSourceTransactionManager;

	// 开启事务
	public TransactionStatus begin() {
		transactionStatus =
				dataSourceTransactionManager.getTransaction(new DefaultTransactionAttribute());
		return transactionStatus;
	}

	// 提交事务
	public void commit(TransactionStatus transactionStatus) {
		dataSourceTransactionManager.commit(transactionStatus);
	}

	// 回滚事务
	public void rollback() {
		dataSourceTransactionManager.rollback(transactionStatus);
	}

}

3. 扫包拦截加事务

/**
 * 手写事务注解:
 *  3,扫包--定义一个事务扫包AOP
 *  4,拦截方法的时候,使用反射判断该方法是否加了事务注解,有就开启事务
 */
@Aspect
@Component
public class LpAopTransaction {
    @Autowired
    private TransactionUtils transactionUtils;

    //异常通知
    @AfterThrowing("execution(* com.pliu.service.*.*.*(..))")
	public void afterThrowing() {
		System.out.println("---回滚事务---");
		transactionUtils.rollback();
	}




    //环绕通知 在方法之前和之后处理事情
	@Around("execution(* com.pliu.service.*.*.*(..))")
	public void around(ProceedingJoinPoint pjp) throws Throwable {

        TransactionStatus transactionStatus = begin(pjp);
        //调用目标代理对象方法
        pjp.proceed();

        commit(transactionStatus);

	}


    /**
     * 判断事务状态,提交事务
     * @param transactionStatus
     */
    private void commit(TransactionStatus transactionStatus) {
        if (transactionStatus != null) {
            System.out.println("---提交事务---");
            transactionUtils.commit(transactionStatus);
        }
    }



    /**
     * 判断是否有@LpTransactional事务注解,有的话开启事务
     * @param pjp
     * @return null或事务状态transactionStatus
     * @throws NoSuchMethodException
     */
	private TransactionStatus begin(ProceedingJoinPoint pjp) throws NoSuchMethodException {
        //1,获取代理对象的方法
        LpTransactional lpTransactional = getLpTransactional(pjp);
        TransactionStatus transactionStatus = null;
        if (lpTransactional != null) {
            //3,加了的话开始事务
            System.out.println("---开启事务---");
            transactionStatus = transactionUtils.begin();
        }
        return transactionStatus;
    }

    /**
     * 获取代理对象的方法,判断是否有@LpTransactional事务注解
     * @param pjp
     * @return null或者LpTransactional对象
     * @throws NoSuchMethodException
     */
	private LpTransactional getLpTransactional(ProceedingJoinPoint pjp) throws NoSuchMethodException {
        // 获取方法名称
        String methodName = pjp.getSignature().getName();
        // 获取目标对象
        Class<?> classTarget = pjp.getTarget().getClass();
        // 获取目标对象类型
        Class<?>[] par = ((MethodSignature) pjp.getSignature()).getParameterTypes();
        // 获取目标对象方法
        Method objMethod = classTarget.getMethod(methodName, par);
        LpTransactional lpTransactional = objMethod.getDeclaredAnnotation(LpTransactional.class);
        return lpTransactional;
    }
}

4. 配置类和测试类

  • 配置类
/**
 * @Description: 声明式事务配置类
 * 笔记:注解方式的声明式事务使用步骤:
 *      1,导入相关依赖(数据源、数据库驱动、Spring-jdbc模块)
 *      2,配置数据源、JdbcTemplate(Spring提供的简化数据库操作的工具)操作数据
 *      3,给方法上标注@Transactional 表示当前方法是一个事务方法;
 *      4,@EnableTransactionManagement 开启基于注解的事务管理功能;
 *      5,配置事务管理器来控制事务;
 * 		    @Bean
 * 		    public PlatformTransactionManager/DataSourceTransactionManager transactionManager()
 * 		以上5步;
 */
@EnableAspectJAutoProxy        //开启AOP代理自动配置
@EnableTransactionManagement   //基于注解的事务管理
@ComponentScan({"com.pliu"})	 //扫包路径
@Configuration
public class TxConfig {

    @Bean
    public DataSource dataSource() throws Exception {
        ComboPooledDataSource dataSource = new ComboPooledDataSource();
        //数据源请更换成你自己的
        dataSource.setUser("xxxx");
        dataSource.setPassword("xxxxxxxx");
        dataSource.setDriverClass("com.mysql.jdbc.Driver");
        dataSource.setJdbcUrl("jdbc:mysql://47.98.216.253:3306/pliu?useUnicode=true&characterEncoding=UTF-8");
        return dataSource;
    }
    @Bean
    public JdbcTemplate jdbcTemplate() throws Exception {
        //spring对@Configuration配置类有特殊处理,不会重复创建数据源对象
        return new JdbcTemplate(dataSource());
    }

    //注册事务管理器
    @Bean
    public DataSourceTransactionManager platformTransactionManager() throws Exception {
        return new DataSourceTransactionManager(dataSource());
    }


}

  • 测试类
public class mainTest {

	public static void main(String[] args) {

		AnnotationConfigApplicationContext applicationContext =
				new AnnotationConfigApplicationContext(TxConfig.class);
		UserService userService = (UserService) applicationContext.getBean("userServiceImpl");
		userService.add();
	}


}

空文件

简介

手写@Transational事务注解的小demo 展开 收起
取消

发行版

暂无发行版

贡献者

全部

近期动态

不能加载更多了
马建仓 AI 助手
尝试更多
代码解读
代码找茬
代码优化
1
https://gitee.com/hellopliu/transactionalDemo.git
git@gitee.com:hellopliu/transactionalDemo.git
hellopliu
transactionalDemo
transactionalDemo
master

搜索帮助