MyBatis事務管理機制

MyBatis做爲Java語言的數據庫框架，對數據庫的事務管理是其很是重要的一個方面。本文將從事務的分類、配置和實現分析MyBatis的事務管理的實現機制。

MyBatis事務的分類

若是想學習Java工程化、高性能及分佈式、深刻淺出。微服務、Spring，MyBatis，Netty源碼分析的朋友能夠加個人Java高級交流：787707172，羣裏有阿里大牛直播講解技術，以及Java大型互聯網技術的視頻免費分享給你們。

對數據庫的事務而言，應該具備如下幾點：建立（create）、提交（commit）、回滾（rollback）、關閉（close）。對應地，MyBatis將事務抽象成了Transaction接口：其接口定義以下：

 

MyBatis的事務管理分爲兩種形式：

一、使用JDBC的事務管理機制：即利用java.sql.Connection對象完成對事務的提交（commit()）、回滾（rollback()）、關閉（close()）等

二、使用MANAGED的事務管理機制：這種機制MyBatis自身不會去實現事務管理，而是讓程序的容器如（JBOSS，Weblogic）來實現對事務的管理

 

MyBatis事務的配置

在使用MyBatis時，通常會在MyBatisXML配置文件中定義相似以下的信息：

 

<environment>節點定義了鏈接某個數據庫的信息，其子節點<transactionManager> 的type 會決定咱們用什麼類型的事務管理機制。

MyBatis事務的建立

MyBatis事務的建立是交給TransactionFactory 事務工廠來建立的，若是咱們將<transactionManager>的type 配置爲"JDBC",那麼，在MyBatis初始化解析<environment>節點時，會根據type="JDBC"建立一個JdbcTransactionFactory工廠，其源碼以下：

/**
 * 解析<transactionManager>節點，建立對應的TransactionFactory
 * @param context
 * @return
 * @throws Exception
 */
 private TransactionFactory transactionManagerElement(XNode context) throws Exception {
 if (context != null) {
 String type = context.getStringAttribute("type");
 Properties props = context.getChildrenAsProperties();
 /*
 在Configuration初始化的時候，會經過如下語句，給JDBC和MANAGED對應的工廠類
 typeAliasRegistry.registerAlias("JDBC", JdbcTransactionFactory.class);
 typeAliasRegistry.registerAlias("MANAGED", ManagedTransactionFactory.class);
 下述的resolveClass(type).newInstance()會建立對應的工廠實例
 */
 TransactionFactory factory = (TransactionFactory) resolveClass(type).newInstance();
 factory.setProperties(props);
 return factory;
 }
 throw new BuilderException("Environment declaration requires a TransactionFactory.");
 }

上述代碼所示，若是type = "JDBC",則MyBatis會建立一個JdbcTransactionFactory.class 實例；若是type="MANAGED"，則MyBatis會建立一個MangedTransactionFactory.class實例。

若是想學習Java工程化、高性能及分佈式、深刻淺出。微服務、Spring，MyBatis，Netty源碼分析的朋友能夠加個人Java高級交流：787707172，羣裏有阿里大牛直播講解技術，以及Java大型互聯網技術的視頻免費分享給你們。

MyBatis對<transactionManager>節點的解析會生成 TransactionFactory實例；而對<dataSource>解析會生成datasouce實例。做爲<environment>節點，會根據TransactionFactory和DataSource實例建立一個Environment對象，代碼以下所示：

private void environmentsElement(XNode context) throws Exception {
 if (context != null) {
 if (environment == null) {
 environment = context.getStringAttribute("default");
 }
 for (XNode child : context.getChildren()) {
 String id = child.getStringAttribute("id");
 //是和默認的環境相同時，解析之
 if (isSpecifiedEnvironment(id)) {
 //1.解析<transactionManager>節點，決定建立什麼類型的TransactionFactory
 TransactionFactory txFactory = transactionManagerElement(child.evalNode("transactionManager"));
 //2. 建立dataSource
 DataSourceFactory dsFactory = dataSourceElement(child.evalNode("dataSource"));
 DataSource dataSource = dsFactory.getDataSource();
 //3. 使用了Environment內置的構造器Builder，傳遞id 事務工廠TransactionFactory和數據源DataSource
 Environment.Builder environmentBuilder = new Environment.Builder(id)
 .transactionFactory(txFactory)
 .dataSource(dataSource);
 configuration.setEnvironment(environmentBuilder.build());
 }
 }
 }
 }

Environment表示着一個數據庫的鏈接，生成後的Environment對象會被設置到Configuration實例中，以供後續的使用。

 

經過事務工廠TransactionFactory很容易獲取到Transaction對象實例。咱們以JdbcTransaction爲例，看一下JdbcTransactionFactory是怎樣生成JdbcTransaction的，代碼以下：

public class JdbcTransactionFactory implements TransactionFactory {
 
 public void setProperties(Properties props) {
 }
 
 /**
 * 根據給定的數據庫鏈接Connection建立Transaction
 * @param conn Existing database connection
 * @return
 */
 public Transaction newTransaction(Connection conn) {
 return new JdbcTransaction(conn);
 }
 
 /**
 * 根據DataSource、隔離級別和是否自動提交建立Transacion
 *
 * @param ds
 * @param level Desired isolation level
 * @param autoCommit Desired autocommit
 * @return
 */
 public Transaction newTransaction(DataSource ds, TransactionIsolationLevel level, boolean autoCommit) {
 return new JdbcTransaction(ds, level, autoCommit);
 }
}

如上說是，JdbcTransactionFactory會建立JDBC類型的Transaction，即JdbcTransaction。相似地，ManagedTransactionFactory也會建立ManagedTransaction。下面分別深刻JdbcTranaction 和ManagedTransaction，看它們究竟是怎樣實現事務管理的。

JdbcTransaction

JdbcTransaction直接使用JDBC的提交和回滾事務管理機制 。它依賴與從dataSource中取得的鏈接connection 來管理transaction 的做用域，connection對象的獲取被延遲到調用getConnection()方法。若是autocommit設置爲on，開啓狀態的話，它會忽略commit和rollback。

直觀地講，就是JdbcTransaction是使用的java.sql.Connection 上的commit和rollback功能，JdbcTransaction只是至關於對java.sql.Connection事務處理進行了一次包裝（wrapper），Transaction的事務管理都是經過java.sql.Connection實現的。

ManagedTransaction

ManagedTransaction讓容器來管理事務Transaction的整個生命週期，意思就是說，使用ManagedTransaction的commit和rollback功能不會對事務有任何的影響，它什麼都不會作，它將事務管理的權利移交給了容器來實現。

歡迎工做一到八年的Java工程師朋友們加入Java高級交流：787707172

本羣提供免費的學習指導 架構資料 以及免費的解答

不懂得問題均可以在本羣提出來 以後還會有直播平臺和講師直接交流噢