详解SpringBoot中JdbcTemplate的事务控制

程序员文章站 2022-03-07 22:14:37

目录原生jdbc的事务控制spring的声明式事务控制尝试jdbctemplate的事务控制transactiontemplate的编程式事务控制前言jdbctemplate是spring-jdbc提...

前言

jdbctemplate是spring-jdbc提供的数据库核心操作类，那对jdbctemplate进行事务控制呢？

我的环境：spring-boot-2.1.3，druid-1.1.3。

原生jdbc的事务控制

即，批处理+自动提交的控制方式，

public static void demo(string[] args) throws sqlexception, classnotfoundexception {
    string url = "jdbc:mysql://10.1.4.16:3306/szhtest";
    string username = "ababab";
    string password = "123456";
    string sql1 = "insert xx";
    string sql2 = "insert xx";
    class.forname("com.mysql.jdbc.driver");
    connection conn = drivermanager.getconnection(url, username, password);
    statement statement = conn.createstatement();
    // 获取到原本的自动提交状态
    boolean ac = conn.getautocommit();
    // 批处理多条sql操作
    statement.addbatch(sql1);
    statement.addbatch(sql2);
    // 关闭自动提交
    conn.setautocommit(false);
    try {
        // 提交批处理
        statement.executebatch();
        // 若批处理无异常，则准备手动commit
        conn.commit();
    } catch (exception e) {
        e.printstacktrace();
        // 批处理抛异常，则rollback
        try {
            conn.rollback();
        } catch (sqlexception ex) {
            ex.printstacktrace();
        }
    } finally {
        // 恢复到原本的自动提交状态
        conn.setautocommit(ac);
        if (statement != null) {
            try {
                statement.close();
            } catch (sqlexception e) {
                e.printstacktrace();
            }
        }
        if (conn != null) {
            try {
                conn.close();
            } catch (sqlexception e) {
                e.printstacktrace();
            }
        }
    }
}

spring的声明式事务控制

bean的类或方法上加@transactional，事务控制粒度较大，只能控制在方法级别，不能控制到代码粒度级别。

尝试jdbctemplate的事务控制

采取跟原生jdbc事务控制一样的方法试试，在批处理前关闭自动提交，若批处理失败则回滚的思路。

@requestmapping("/druiddata1")
public string druiddata1() throws sqlexception {
    string sql1 = "insert into user_tmp(`id`, `username`) values(22, 222)";
    // id=1的主键冲突插入失败
    string sql2 = "insert into user_tmp(`id`, `username`) values(1, 111)";
    connection conn = jdbctemplate.getdatasource().getconnection();
    log.info("1:{}", conn);
    boolean ac = conn.getautocommit();
    conn.setautocommit(false);
    try {
        int[] rs2 = jdbctemplate.batchupdate(new string[]{sql1, sql2});
        conn.commit();
    } catch (throwable e) {
        log.error("error occured, cause by: {}", e.getmessage());
        conn.rollback();
    } finally {
        conn.setautocommit(ac);
        if (conn != null) {
            try {
                conn.close();
            } catch (sqlexception e) {
                log.error("error occurred while closing connectin, cause by: {}", e.getmessage());
            }
        }
    }
    return "test";
}

期望结果：id=1的因为主键冲突，所以id=22的也要回滚。

实际结果：id=1的插入失败，id=22的插入成功，未回滚。

原因分析：自始至终都是同一个connection连接对象，按道理不应该无法控制自动提交，唯一的解释是jdbctemplate.batchupdate()中真正使用的连接对象并非代码中的conn，于是一方面把conn打印出来，另一方面准备调试jdbctemplate.batchupdate()源码内部，看看是否使用了另外获取到的connection。

调试流程：jdbctemplate.batchupdate()