Mybatis事务源码分析

Mybatis是一个支持自定义SQL语句&＃xff0c;存储过程&＃xff0c;高级映射的数据持久化框架。

它封装了JDBC&＃xff0c;在框架中隐藏了几乎所有的JDBC的API&＃xff0c;这里说下从源码的角度Mybatis 3.x (笔者用的是3.2.8)是如何封装JDBC来实现事务处理的。

回忆下mybatis是怎么使用事务管理的&＃xff0c;session.commit(),session.rollback(), JDBC呢,是connection.commit(),connection.rollback()。所以这篇文章的内容就变成了如何从session.commit()到connection.commit()。

首先从session来看看&＃xff0c;我们获得一个session对象其实是DefaultSqlSession对象&＃xff0c;这个类中的commit() 方法如下。

public void commit() {commit(false);}public void commit(boolean force) {try {executor.commit(isCommitOrRollbackRequired(force));dirty &＃61; false;} catch (Exception e) {throw ExceptionFactory.wrapException("Error committing transaction. Cause: " &＃43; e, e);} finally {ErrorContext.instance().reset();}}private boolean isCommitOrRollbackRequired(boolean force) {return (!autoCommit && dirty) || force;}

然后到CachingExecutor 中的方法

public void commit(boolean required) throws SQLException {delegate.commit(required);tcm.commit();}//也许对这执行commit的对象不熟悉&＃xff0c;看下面
private Executor delegate;
private TransactionalCacheManager tcm &＃61; new TransactionalCacheManager();

  所以真正我们关心的事务是另外一个Executor&＃xff0c;BaseExecutor中commit()方法

public void commit(boolean required) throws SQLException {if (closed) throw new ExecutorException("Cannot commit, transaction is already closed");clearLocalCache();flushStatements();if (required) {transaction.commit();}}

 前面两个方法是跟缓存相关&＃xff0c;只有最后一个才是我们关心的,JDBCTransaction类中的commit()

public void commit() throws SQLException {if (connection !&＃61; null && !connection.getAutoCommit()) {if (log.isDebugEnabled()) {log.debug("Committing JDBC Connection [" &＃43; connection &＃43; "]");}connection.commit();}}

 现在我们明白了&＃xff0c;JDBCTransaction中包装了一个connection的对象。这也是我们在使用mybatis配置文件时设置的事务管理类。