事务管理器在实际的开发过程中主要是配合注解的使用,也可以在代码中手动的创建事务管理器,
注解是结合@Transaction注解,手动的可以在网上找一些资料,创建TransactionTemplate手动的调用execute方法.
事务管理器的作用是什么呢,其实就是connection的自动提交设置成false,方法执行结束后统一的commit或者rollback,道理是很简单的.

image.png

如果没有事务管理器,那两条sql语句,就得手动的获取connection,并讲自动提交设置为false,再统一提交或者回滚

 public static void main(String[] args) throws IOException, SQLException, ClassNotFoundException, InstantiationException, IllegalAccessException{
        // 1 提供Properties实例对象
        Properties pros = new Properties();
        FileInputStream fs = new FileInputStream("C:\\Users\\DuoDuo\\Desktop\\codeTest\\springboottest\\src\\main\\resources\\jdbc.properties");
        pros.load(fs);
        // 2 读取配置信息
        String url = pros.getProperty("url");
        String user = pros.getProperty("username");
        String password = pros.getProperty("password");
        String driverClass = pros.getProperty("driver-class-name");
        // 4 加载驱动
        Class<Driver> clazz = (Class<Driver>) Class.forName(driverClass);
        Driver driver = clazz.newInstance();
        // 5 注册驱动
        DriverManager.registerDriver(driver);
        // 6 获取对象
        Connection conn = DriverManager.getConnection(url, user, password);
        // 7 取消自动提交
        conn.setAutoCommit(false);
        // 8 获取Statement
        PreparedStatement preparedStatement = conn.prepareStatement("select * from empage");
        // 9 执行sql  这里省略多条的update语句
        ResultSet resultSet = preparedStatement.executeQuery();
        // 10 打印
        while(resultSet.next()){
            int id = resultSet .getInt("id");
            String ename = resultSet .getString("ename");
            int age = resultSet .getInt("age");
            System.out.println(id+ename+age);
        }
        //11 自动提交 or rollback
        conn.commit();
    }

在spring项目中,可以从容器中获取datasource,再Connection connection = dataSource.getConnection();获取连接,一般都是从连接池中获取连接
从示例中也可以看到,java是如何与数据库交换数据的,PreparedStatement是驱动自己去实现的,本例使用的是mysql驱动

有了事务管理器之后,十分的方便,如果结合了spring只需要一个注解就可以实现,本文重点分析使用注解的方式,结合mybatis是如何工作的
1.数据源datasource
org.springframework.boot.autoconfigure.jdbc.DataSourceConfiguration.Hikari#dataSource
spring默认使用的是HikariDataSource数据源

image.png

2.事务管理器
org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration.JdbcTransactionManagerConfiguration#transactionManager
默认使用的是DataSourceTransactionManager

image.png

image.png

org.springframework.aop.config.AopConfigUtils#registerAutoProxyCreatorIfNecessary(org.springframework.beans.factory.support.BeanDefinitionRegistry, java.lang.Object)

image.png

image.png

image.png

image.png

image.png

image.png

bindResource方法将连接放到threadlocal中,后续会被获取,因为这里只是创建了一个connection,并没有执行sql,后续再mybatis中从线程中获取连接执行sql
TransactionSynchronizationManager.bindResource(obtainDataSource(), txObject.getConnectionHolder());

image.png

image.png

image.png

image.png