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事務管理機制