spring事务源码分析

系统管理员 2024-02-17 10:24 49阅读 0赞

请直接看原文

原文链接:[61 张图，剖析 Spring 事务源码，就是要钻到底！ - 掘金 (juejin.cn)][61 _ Spring _ - _ _juejin.cn]

\--------------------------------------------------------------------------------------------------------------------------------

下面是捡几个重点说

.aop给方法增加事务功能代码

.为当前事务设置隔离级别

.关闭事务自动提交

.设置事务超时时间

.创建出数据库连接对象connection之后,当前线程将它保存在了threadlocal中。 当前线程在 **ThreadLocal** 中保存了一个 map，key 是DataSource数据库连接配置源，value 是数据库连接对象Connection.

protected void doBegin(Object transaction, TransactionDefinition definition) {
            //强制转化事务对象
            DataSourceTransactionObject txObject = (DataSourceTransactionObject) transaction;
            Connection con = null;
    
            try {
                //判断事务对象没有数据库连接持有器
                if (!txObject.hasConnectionHolder() ||
                        txObject.getConnectionHolder().isSynchronizedWithTransaction()) {
                    //通过数据源获取一个数据库连接对象
                    Connection newCon = obtainDataSource().getConnection();
                    if (logger.isDebugEnabled()) {
                        logger.debug("Acquired Connection [" + newCon + "] for JDBC transaction");
                    }
                    //把我们的数据库连接包装成一个ConnectionHolder对象 然后设置到我们的txObject对象中去
                    txObject.setConnectionHolder(new ConnectionHolder(newCon), true);
                }
    
                //标记当前的连接是一个同步事务
                txObject.getConnectionHolder().setSynchronizedWithTransaction(true);
                con = txObject.getConnectionHolder().getConnection();
    
                //为当前的事务设置隔离级别
                Integer previousIsolationLevel = DataSourceUtils.prepareConnectionForTransaction(con, definition);
                txObject.setPreviousIsolationLevel(previousIsolationLevel);
    
                //关闭自动提交
                if (con.getAutoCommit()) {
                    txObject.setMustRestoreAutoCommit(true);
                    if (logger.isDebugEnabled()) {
                        logger.debug("Switching JDBC Connection [" + con + "] to manual commit");
                    }
                    con.setAutoCommit(false);
                }
    
                //判断事务为只读事务
                prepareTransactionalConnection(con, definition);
                //设置事务激活
                txObject.getConnectionHolder().setTransactionActive(true);
    
                //设置事务超时时间
                int timeout = determineTimeout(definition);
                if (timeout != TransactionDefinition.TIMEOUT_DEFAULT) {
                    txObject.getConnectionHolder().setTimeoutInSeconds(timeout);
                }
    
                // 绑定我们的数据源和连接到我们的同步管理器上   把数据源作为key,数据库连接作为value 设置到线程变量中
                if (txObject.isNewConnectionHolder()) {
                    TransactionSynchronizationManager.bindResource(obtainDataSource(), txObject.getConnectionHolder());
                }
            }
    
            catch (Throwable ex) {
                if (txObject.isNewConnectionHolder()) {
                    //释放数据库连接
                    DataSourceUtils.releaseConnection(con, obtainDataSource());
                    txObject.setConnectionHolder(null, false);
                }
                throw new CannotCreateTransactionException("Could not open JDBC Connection for transaction", ex);
            }
        }

[61 _ Spring _ - _ _juejin.cn]: https://juejin.cn/post/7160485887489343501