1、回顧

之前介紹了Environment環(huán)境類，這其實是一個單例類，在MyBatis運行開啟后只會存在一個唯一的環(huán)境實例，雖然我們可以在Configuration配置文件中配置多個環(huán)境，但是項目運行中只會存在其中的一個，一般項目會存在開發(fā)環(huán)境和測試環(huán)境、生產環(huán)境三大環(huán)境，其是否可以設置到配置文件中，在開發(fā)時使用開發(fā)環(huán)境，測試時使用測試環(huán)境，正式運營時可以使用生產環(huán)境。

之前還提到Environment類中有三個字段，除了id之外，TransactionFactory和DataSource都是比較復雜的模塊，這一次我們介紹Transaction模塊（即事務模塊）。

2、事務模塊

事務模塊位于org.apache.ibatis.transaction包，這個包內的類均是事務相關的類：

　　org.apache.ibatis.transaction
　　-----org.apache.ibatis.transaction.jdbc
　　----------JdbcTransaction.java
　　----------JdbcTransactionFactory.java
　　-----org.apache.ibatis.transaction.managed
　　----------ManagedTransaction.java
　　----------ManagedTransactionFactory.java
　　-----Transaction.java
　　-----TransactionException.java
　　-----TransactionFactory.java

從上面的類結構中也能看出來，MyBatis的事務模塊采用的是工廠模式。

2.1 事務接口

位于org.apache.ibatis.transaction包的Transaction和TransactionFactory都是接口類。

Transaction是事務接口，其中定義了四個方法：

• commit()-事務提交
• rollBack()-事務回滾
• close()-關閉數(shù)據庫連接
• getConnection()-獲取數(shù)據庫連接

如下代碼所示：

package org.apache.ibatis.transaction;
import java.sql.Connection;
import java.sql.SQLException;
/**
 * 事務，包裝了一個Connection, 包含commit,rollback,close方法
 * 在 MyBatis 中有兩種事務管理器類型(也就是 type=”[JDBC|MANAGED]”):  
 */
public interface Transaction {
  Connection getConnection() throws SQLException;
 void commit() throws SQLException;
 void rollback() throws SQLException;
 void close() throws SQLException;
}

TransactionFactory是事務工廠接口，其中定義了三個方法：

• setProperties(Properties props)-設置屬性
• newTransaction(Connection conn)-創(chuàng)建事務實例
• newTransaction(DataSource dataSource,TransactionIsolationLevel level,boolean autoCommit)-創(chuàng)建事務實例

如下代碼所示：

package org.apache.ibatis.transaction;
import java.sql.Connection;
import java.util.Properties;
import javax.sql.DataSource;
import org.apache.ibatis.session.TransactionIsolationLevel;
/**
 * 事務工廠
 */
public interface TransactionFactory {
 //設置屬性
 void setProperties(Properties props);
 //根據Connection創(chuàng)建Transaction
 Transaction newTransaction(Connection conn);
 //根據數(shù)據源和事務隔離級別創(chuàng)建Transaction
 Transaction newTransaction(DataSource dataSource, TransactionIsolationLevel level, boolean autoCommit);
}

Transacrion接口定義的目的就是為了對具體的事務類型進行抽象，便于擴展；TransactionFactory與其一樣，是對事務工廠的抽象，同樣便于具體類型的事務工廠的擴展實現(xiàn)。

2.2 MyBatis事務類型

說到這里，就不得不提到MyBatis里內置的兩種事務類型及對應的事務工廠了，還記得在上一文中給出的environment配置信息，有這么一句：

 <transactionManager type="JDBC"/>

這里的<transactionManager>標簽就是用于定義項目所使用的事務類型，具體的類型由type屬性來指定，此處指定使用“JDBC”類型事務，當然MyBatis還提供了另外一種“MANAGED”型事務。

• ---JDBC
• ---MANAGED

這里的“JDBC”和“MANAGED”是在Configuration配置類的類型別名注冊器中注冊的別名，其對應的類分別是：JdbcTransactionFactory.class和ManagedTransactionFactory.class。具體的配置如下所述：

typeAliasRegistry.registerAlias("JDBC", JdbcTransactionFactory.class);
typeAliasRegistry.registerAlias("MANAGED", ManagedTransactionFactory.class);

上面的代碼是在Configuration類的無參構造器中定義的，這里拿來僅用于展示，具體說明以后會介紹。

這里提一句：類型別名注冊器額原理就是將別名與具體的類類型以鍵值對的方式保存到一個HashMap中，這樣只要知道別名（鍵），就可以從Map中得到對應的值（Class類型），很簡單！

現(xiàn)在只要知道MyBatis能夠根據你在配置文件中設置的事務類型，直接找到對應的事務工廠類就行了。

下面對上面提到的兩種事務類型進行解讀。

• ---JDBC事務模型：JdbcTransaction
• ---MANAFED事務模型：ManagedTransaction

二者的不同之處在于：前者是直接使用JDK提供的JDBC來管理事務的各個環(huán)節(jié)：提交、回滾、關閉等操作，而后者則什么都不做，那么后者有什么意義呢，當然很重要。　

當我們單獨使用MyBatis來構建項目時，我們要在Configuration配置文件中進行環(huán)境（environment）配置，在其中要設置事務類型為JDBC，意思是說MyBatis被單獨使用時就需要使用JDBC類型的事務模型，因為在這個模型中定義了事務的各個方面，使用它可以完成事務的各項操作。

而MANAGED類型的事務模型其實是一個托管模型，也就是說它自身并不實現(xiàn)任何事務功能，而是托管出去由其他框架來實現(xiàn)，你可能還不明白，這個事務的具體實現(xiàn)就交由如Spring之類的框架來實現(xiàn)，而且在使用SSM整合框架后已經不再需要單獨配置環(huán)境信息（包括事務配置與數(shù)據源配置），因為在在整合jar包（mybatis-spring.jar）中擁有覆蓋mybatis里面的這部分邏輯的代碼，實際情況是即使你顯式設置了相關配置信息，系統(tǒng)也會視而不見......

托管的意義顯而易見，正是為整合而設。

我們學習MyBatis的目的正是由于其靈活性和與Spring等框架的無縫整合的能力，所以有關JDBC事務模塊的內容明顯不再是MyBatis功能中的重點，也許只有在單獨使用MyBatis的少量系統(tǒng)中才會使用到。

2.3 JDBC事務模型

雖然JDBC事務類型很少使用到，但是作為MyBatis不可分割的一部分，我們還是需要進行一定的了解，JDBC事務的實現(xiàn)是對JDK中提供的JDBC事務模塊的再封裝，以適用于MyBatis環(huán)境。

MyBatis中的JDBC事務模塊包括兩個部分，分別為JDBC事務工廠和JDBC事務，整個事務模塊采用的是抽象工廠模式，那么對應于每一項具體的事務處理模塊必然擁有自己的事務工廠，事務模塊實例通過事務工廠來創(chuàng)建（事務工廠將具體的事務實例的創(chuàng)建封裝起來）。

首先我們來看JDBC事務工廠：JdbcTransactionFactory

JdbcTransactionFactory繼承自TransactionFactory接口，實現(xiàn)了其中的所有方法。分別為一個設置屬性的方法和兩個新建事務實例的方法（參數(shù)不同），內容很簡單，作用也很簡單。

其中setProperties()方法用于設置屬性，這個方法在XMLConfigBuilder中解析事務標簽時調用，用于解析事務標簽的下級屬性標簽<property>（一般情況下我們并不會進行設置，但是如果我們進行了設置，那就會覆蓋MyBatis中的默認設置）之后將其設置到創(chuàng)建的事務實例中。然而針對JDBC事務模型，在事務工廠的設置屬性方法中沒有任何執(zhí)行代碼，也就說明JDBC事務模塊并不支持設置屬性的功能，即使你在配置文件中設置的一些信息，也不會有任何作用。

那么這個方法有什么用呢？前面提到，這個設置用于覆蓋默認設置，只是JDBC事務模塊并不支持而已，但并不代表別的事務模型不支持，同時這個方法也可用于功能擴展。

另外兩個方法顯而易見，就是用于創(chuàng)建JDBC事務實例的生產方法，只是參數(shù)不同，方法的重載而已。其中一個生產方法僅需傳遞一個實例Connection，這代表一個數(shù)據庫連接。而另一個方法需要傳遞三個參數(shù)(DataSource、TransactionIsolationLevel、boolean)，其實這對應于MyBatis中SqlSession的兩種生產方式，其參數(shù)與這里一一對應，這部分內容以后介紹，此處不再贅述。

然后我們來看看JDBC事務類：JdbcTransaction

其中有四個參數(shù)：

 protected Connection connection;
 protected DataSource dataSource;
 protected TransactionIsolationLevel level;
 protected boolean autoCommmit;

這四個參數(shù)分別對應事務工廠中的兩個生產方法中的總共四個參數(shù)，對應的在事務類中定義了兩個構造器，構造實例的同時進行賦值：

public JdbcTransaction(DataSource ds, TransactionIsolationLevel desiredLevel, boolean desiredAutoCommit) {
   dataSource = ds;
   level = desiredLevel;
   autoCommmit = desiredAutoCommit;
 }
 public JdbcTransaction(Connection connection) {
   this.connection = connection;
 }

其次在該類中實現(xiàn)了Transaction接口，實現(xiàn)了其中的四個方法，三個功能性方法，和一個獲取數(shù)據庫連接的方法。三個功能方法分別是提交、回滾和關閉。

  @Override
  public void commit() throws SQLException {
    if (connection != null && !connection.getAutoCommit()) {
      if (log.isDebugEnabled()) {
        log.debug("Committing JDBC Connection [" + connection + "]");
      }
      connection.commit();
    }
  }

 @Override
 public void rollback() throws SQLException {
   if (connection != null && !connection.getAutoCommit()) {
     if (log.isDebugEnabled()) {
       log.debug("Rolling back JDBC Connection [" + connection + "]");
     }
     connection.rollback();
   }
 }

 @Override
 public void close() throws SQLException {
   if (connection != null) {
     resetAutoCommit();
     if (log.isDebugEnabled()) {
       log.debug("Closing JDBC Connection [" + connection + "]");
     }
     connection.close();
   }
 }

通過觀察這三個方法，可以發(fā)現(xiàn)，其中都使用了connection來進行具體操作，因此這些方法使用的前提就是先獲取connection數(shù)據庫連接，Connection的獲取使用getConnection()方法

 @Override
 public Connection getConnection() throws SQLException {
   if (connection == null) {
     openConnection();
   }
   return connection;
 }

在上面的方法中調用了openConnection()方法：

 protected void openConnection() throws SQLException {
    if (log.isDebugEnabled()) {
      log.debug("Opening JDBC Connection");
    }
    connection = dataSource.getConnection();
    if (level != null) {
      connection.setTransactionIsolation(level.getLevel());
    }
    setDesiredAutoCommit(autoCommmit);
 }

可見connection是從數(shù)據源dataSource中獲取的，最后會調用setDesiredAutoCommit()方法：

  protected void setDesiredAutoCommit(boolean desiredAutoCommit) {
    try {
      if (connection.getAutoCommit() != desiredAutoCommit) {
        if (log.isDebugEnabled()) {
          log.debug("Setting autocommit to " + desiredAutoCommit + " on JDBC Connection [" + connection + "]");
        }
        connection.setAutoCommit(desiredAutoCommit);
      }
    } catch (SQLException e) {
     // Only a very poorly implemented driver would fail here,
     // and there's not much we can do about that.
     throw new TransactionException("Error configuring AutoCommit.  "
         + "Your driver may not support getAutoCommit() or setAutoCommit(). "
         + "Requested setting: " + desiredAutoCommit + ".  Cause: " + e, e);
   }
 }

這個方法的目的就是為connection中的自動提交賦值（真或假）。

這么看來，我們創(chuàng)建事務實例所提供的三個參數(shù)就是為connection服務的，其中DataSource是用來獲取Connection實例的，而TransactionIsolationLevel（事務級別）和boolean（自動提交）是用來填充connection的，通過三個參數(shù)我們獲得了一個圓滿的Connection實例，然后我們就可以使用這個實例來進行事務操作：提交、回滾、關閉。

2.4 關于自動提交

在之前的代碼中我們能看到在關閉操作之前調用了一個方法：resetAutoCommit()：

 protected void resetAutoCommit() {
   try {
     if (!connection.getAutoCommit()) {
       // MyBatis does not call commit/rollback on a connection if just selects were performed.
       // Some databases start transactions with select statements
       // and they mandate a commit/rollback before closing the connection.
       // A workaround is setting the autocommit to true before closing the connection.
       // Sybase throws an exception here.
       if (log.isDebugEnabled()) {
        log.debug("Resetting autocommit to true on JDBC Connection [" + connection + "]");
      }
      connection.setAutoCommit(true);
    }
  } catch (SQLException e) {
    log.debug("Error resetting autocommit to true "
        + "before closing the connection.  Cause: " + e);
  }
}

這里相對自動提交做個解說，如果設置自動提交為真，那么數(shù)據庫將會將每一個SQL語句當做一個事務來執(zhí)行，為了將多條SQL當做一個事務進行提交，必須將自動提交設置為false，然后進行手動提交。一般在我們的項目中，都需要將自動提交設置為false，即將自動提交關閉，使用手動提交

這個方法中通過對connection實例中的自動提交設置（真或假）進行判斷，如果為false，表明不執(zhí)行自動提交，則復位，重新將其設置為true。（自動提交的默認值為true）這個操作執(zhí)行在connection關閉之前?？梢钥醋鍪沁B接關閉之前的復位操作。

2.5 問題

在JdbcTransaction中提供的兩個構造器中以Connection為參數(shù)的構造器額作用是什么呢？

我們需要自動組裝一個完整的Connection，以其為參數(shù)來生產一個事務實例。這用在什么場景中呢？

以上為個人經驗，希望能給大家一個參考，也希望大家多多支持腳本之家。

最新評論