1. 程式人生 > >MyBatis事務管理機制

MyBatis事務管理機制

element 成了 logic connect ole sre action mybatis事務 nod

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

MyBatis事務的分類

對數據庫的事務而言,應該具有以下幾點:創建(create)、提交(commit)、回滾(rollback)、關閉(close)。對應地,MyBatis將事務抽象成了Transaction接口:其接口定義如下:

MyBatis的事務管理分為兩種形式:

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

2、使用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實例。

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功能不會對事務有任何的影響,它什麽都不會做,它將事務管理的權利移交給了容器來實現。

MyBatis事務管理機制