一、前言

在spring中,事务有两种实现方式:

编程式事务管理: 编程式事务管理使用transactiontemplate可实现更细粒度的事务控制。声明式事务管理: 基于spring aop实现。其本质是对方法前后进行拦截,然后在目标方法开始之前创建或者加入一个事务,在执行完目标方法之后根据执行情况提交或者回滚事务。

声明式事务管理不需要入侵代码,通过@transactional就可以进行事务操作,更快捷而且简单(尤其是配合spring boot自动配置,可以说是精简至极!),且大部分业务都可以满足,推荐使用。

其实不管是编程式事务还是声明式事务,最终调用的底层核心代码是一致的。本文主要介绍编程式事务的一些应用,以及独有的源码分析,再在其他文章中进入核心源码贯穿式讲解。

二、编程式事务解析

编程式事务,spring已经给我们提供好了模板类transactiontemplate,可以很方便的使用,如下图:

transactiontemplate全路径名是:org.springframework.transaction.support.transactiontemplate。看包名也知道了这是spring对事务的模板类。(spring动不动就是各种template…),看下类图先:

实现了transactionoperations、initializingbean这2个接口(熟悉spring源码的知道这个initializingbean又是老套路),我们来看下接口源码如下:

public interface transactionoperations {
 
	@nullable
	<t> t execute(transactioncallback<t> action) throws transactionexception;
 
}
 
public interface initializingbean {
 
	void afterpropertiesset() throws exception;
 
}

如上图,transactionoperations这个接口用来执行事务的回调方法,initializingbean这个是典型的spring bean初始化流程中的预留接口,专用用来在bean属性加载完毕时执行的方法。

回到正题,transactioncallback和transactioncallbackwithoutresult做了什么

@functionalinterface
public interface transactioncallback<t> {
 
	@nullable
	t dointransaction(transactionstatus status);
 
}
 
 
public abstract class transactioncallbackwithoutresult implements transactioncallback<object> {
 
	@override
	@nullable
	public final object dointransaction(transactionstatus status) {
		dointransactionwithoutresult(status);
		return null;
	}
 
	protected abstract void dointransactionwithoutresult(transactionstatus status);
 
}

可见transactioncallbackwithresult实现了transactioncallback接口,重写了dointransaction方法,在内部调用了dointransactionwithoutresult方法,帮我们返回了null,所以,我们就不需要再指定返回值了。 

transactiontemplate的2个接口的impl方法做了什么?

@override
    public void afterpropertiesset() {
        if (this.transactionmanager == null) {
            throw new illegalargumentexception("property 'transactionmanager' is required");
        }
    }
 
 
    @override
    public <t> t execute(transactioncallback<t> action) throws transactionexception {       // 内部封装好的事务管理器
        if (this.transactionmanager instanceof callbackpreferringplatformtransactionmanager) {
            return ((callbackpreferringplatformtransactionmanager) this.transactionmanager).execute(this, action);
        }// 需要手动获取事务,执行方法,提交事务的管理器
        else {// 1.获取事务状态
            transactionstatus status = this.transactionmanager.gettransaction(this);
            t result;
            try {// 2.执行业务逻辑
                result = action.dointransaction(status);
            }
            catch (runtimeexception ex) {
                // 应用运行时异常 -> 回滚
                rollbackonexception(status, ex);
                throw ex;
            }
            catch (error err) {
                // error异常 -> 回滚
                rollbackonexception(status, err);
                throw err;
            }
            catch (throwable ex) {
                // 未知异常 -> 回滚
                rollbackonexception(status, ex);
                throw new undeclaredthrowableexception(ex, "transactioncallback threw undeclared checked exception");
            }// 3.事务提交
            this.transactionmanager.commit(status);
            return result;
        }
    }

如上图所示,实际上afterpropertiesset只是校验了事务管理器不为空,execute()才是核心方法,execute主要步骤:

1.gettransaction()获取事务

2.dointransaction()执行业务逻辑,这里就是用户自定义的业务代码。如果是没有返回值的,就是dointransactionwithoutresult()。

3.commit()事务提交:调用abstractplatformtransactionmanager的commit,rollbackonexception()异常回滚:调用abstractplatformtransactionmanager的rollback(),事务提交回滚。源码见后续文章

三、编程式事务示例

public class springtransactionexample {
 
    private static string url = "jdbc:mysql://localhost:3306/spring_transaction?usessl=false&characterencoding=utf-8&autoreconnect=true";
    private static string user = "root";
    private static string password = "root";
 
    public static void main(string[] args) {
        // 获取数据源
        final datasource ds = new drivermanagerdatasource(url, user, password);
        // 编程式事务
        final transactiontemplate template = new transactiontemplate();
        // 设置事务管理器
        template.settransactionmanager(new datasourcetransactionmanager(ds));
 
        template.execute(new transactioncallback<object>() {
            @override
            public object dointransaction(transactionstatus transactionstatus) {
                connection conn = datasourceutils.getconnection(ds);
                object savepoint = null;
                try {
                    {
                        // 插入
                        preparedstatement prepare = conn.preparestatement("insert into person(id, name) values (?, ?)");
                        prepare.setstring(1, "1");
                        prepare.setstring(2, "1111");
                        prepare.executeupdate();
                    }
 
                    // 设置保存点,回滚的化,不会回滚保存点之前的操作
                    savepoint = transactionstatus.createsavepoint();
                    {
                        // 插入
                        preparedstatement prepare = conn.preparestatement("insert into person(id, name) values (?, ?)");
                        prepare.setstring(1, "2");
                        prepare.setstring(2, "222");
                        prepare.executeupdate();
                    }
 
                    {
                        // 更新
                        preparedstatement prepare = conn.preparestatement("update person set name = ? where id = ?");
                        prepare.setstring(1, "jak");
                        prepare.setint(2, 6);
                        prepare.executeupdate();
 
                        // 模拟异常
//                        int i = 1 / 0;
                    }
                } catch (sqlexception e) {
                    e.printstacktrace();
                } catch (exception e) {
                    system.out.println("更新失败");
                    if (savepoint != null) {
                        // 回滚到保存点
                        transactionstatus.rollbacktosavepoint(savepoint);
                    } else {
                        transactionstatus.setrollbackonly();
                    }
                }
                return null;
            }
        });
    }
}

四、transactioncallback

编程式事务带返回值

public class transactioncallbacktest {
    private static string url = "jdbc:mysql://localhost:3306/spring_transaction?usessl=false&characterencoding=utf-8&autoreconnect=true";
    private static string user = "root";
    private static string password = "root";
 
    public static void main(string[] args) {
        // 获取数据源
        final datasource ds = new drivermanagerdatasource(url, user, password);
        // 编程式事务
        final transactiontemplate template = new transactiontemplate();
        // 设置事务管理器
        template.settransactionmanager(new datasourcetransactionmanager(ds));
        connection connection = datasourceutils.getconnection(ds);
        test1(template, connection);
        test2(template, connection);
    }
 
    // 方式一: 匿名内部类
    @suppresswarnings("all")
    public static void test1(transactiontemplate template,  connection connection) {
        // transactioncallback有返回值
        template.execute(new transactioncallback<object>() {
            @override
            public object dointransaction(transactionstatus status) {
                try {
                    // 插入
                    preparedstatement prepare = connection.preparestatement("insert into person(id, name) values (?, ?)");
                    prepare.setint(1, 1);
                    prepare.setstring(2, "jak");
                    prepare.executeupdate();
                    // 模拟异常
                    // int i = 1 / 0;
                    system.out.println("数据已插入");
                } catch (sqlexception e) {
                    e.printstacktrace();
                } catch (exception e) {
                    system.out.println("更新失败");
                    status.setrollbackonly();
                }
                return null;
            }
        });
    }
 
    // 方式二:lamda表达式
    @suppresswarnings("all")
    public static void test2(transactiontemplate template,  connection connection) {
        template.execute((status) -> {
            try {
                // 插入
                preparedstatement prepare = connection.preparestatement("insert into person(id, name) values (?, ?)");
                prepare.setint(1, 2);
                prepare.setstring(2, "hyd");
                prepare.executeupdate();
                // 模拟异常
                // int i = 1 / 0;
                system.out.println("数据已插入");
            } catch (sqlexception e) {
                e.printstacktrace();
            } catch (exception e) {
                system.out.println("更新失败");
                status.setrollbackonly();
            }
            return null;
        });
    }
 
}

五、transactioncallbackwithoutresult

编程式事务不带返回值

public class transactioncallbackwithoutresulttest {
 
    private static string url = "jdbc:mysql://localhost:3306/spring_transaction?usessl=false&characterencoding=utf-8&autoreconnect=true";
    private static string user = "root";
    private static string password = "root";
 
    @suppresswarnings("all")
    public static void test(transactiontemplate template, connection connection) {
        template.execute(new transactioncallbackwithoutresult() {
            // dointransactionwithoutresult无返回值
            @override
            public void dointransactionwithoutresult(transactionstatus status) {
                try {
                    // 插入
                    preparedstatement prepare = connection.preparestatement("insert into person(id, name) values (?, ?)");
                    prepare.setint(1, 1);
                    prepare.setstring(2, "jak");
                    prepare.executeupdate();
                    // 模拟异常
                    // int i = 1 / 0;
                    system.out.println("数据已插入");
                } catch (sqlexception e) {
                    e.printstacktrace();
                } catch (exception e) {
                    system.out.println("更新失败");
                    status.setrollbackonly();
                }
            }
        });
    }
 
    public static void main(string[] args) {
        // 获取数据源
        final datasource ds = new drivermanagerdatasource(url, user, password);
        // 编程式事务
        final transactiontemplate template = new transactiontemplate();
        // 设置事务管理器
        template.settransactionmanager(new datasourcetransactionmanager(ds));
        connection connection = datasourceutils.getconnection(ds);
        test(template, connection);
    }
}

踩坑指南,上述方式 不知道为啥,事务一直不回滚,改为jdbctemplate方式,可以正常回滚,不知道什么原因

public class jdbctemplatetest {
 
    private static string url = "jdbc:mysql://localhost:3306/spring_transaction?usessl=false&characterencoding=utf-8&autoreconnect=true";
    private static string user = "root";
    private static string password = "root";
 
    @suppresswarnings("all")
    public static void test(transactiontemplate template,  jdbctemplate jdbctemplate) {
        template.execute(new transactioncallbackwithoutresult() {
            // dointransactionwithoutresult无返回值
            @sneakythrows
            @override
            public void dointransactionwithoutresult(transactionstatus status) {
                try {
                    // 插入
                    jdbctemplate.execute("insert into person(id, name) values (2, 'jak')");
                    // 模拟异常
                    int i = 1 / 0;
                    system.out.println("数据已插入");
                } catch (exception e) {
                    // 标记事务回滚
                    status.setrollbackonly();
                }
            }
        });
    }
 
    public static void main(string[] args) {
        // 获取数据源
        final datasource ds = new drivermanagerdatasource(url, user, password);
        // 编程式事务
        final transactiontemplate template = new transactiontemplate();
        // jdbctemplate
        final jdbctemplate jdbctemplate = new jdbctemplate();
        // 设置事务管理器
        template.settransactionmanager(new datasourcetransactionmanager(ds));
        // 配置数据源
        jdbctemplate.setdatasource(ds);
        test(template,  jdbctemplate);
    }
}

到此这篇关于spring源码解析之编程式事务的文章就介绍到这了,更多相关spring编程式事务内容请搜索www.887551.com以前的文章或继续浏览下面的相关文章希望大家以后多多支持www.887551.com!