Spring的事務管理入門：編程式事務管理（TransactionTemplate）！！！

時間 2019-11-07

標籤 spring 事務管理入門編程 transactiontemplate 欄目 Spring 简体版

原文原文鏈接

轉載自 http://blog.csdn.net/zq9017197/article/details/6321391java

Spring能夠支持編程式事務和聲明式事務。spring

Spring使用事務管理器，每一個不一樣平臺的事務管理器都實現了接口：PlatformTransactionManagersql

此接口是事務管理的核心，提供了三個須要實現的函數：數據庫

[java] view plain copyapache

print ?編程

commit(TransactionStatus status) ;
getTransaction(TransactionDefinition definition) ;
rollback(TransactionStatus status) ;

若是咱們使用的是JDBC來處理事務，那麼這個事務管理器就是DataSourceTransactionManager。oracle

經過Spring文檔查找到這個類，發現其須要DataSource這個類。也就是隻要實現了javax.sql.DataSource這個接口的類，均可以做爲參數傳入到DataSourceTransactionManager。函數

而後，找到包org.springframework.transaction.support中的 TransactionTemplate。編碼

發現TransactionTemplate中有一個重要的方法：.net

[java] view plain copy

print ?

execute(TransactionCallback action) ;

就是利用這個方法，咱們能夠在這個方法中添加事務。

這個方法須要傳入參數 TransactionCallback。

TransactionCallback，顧名思義，就是事務回調而後查到TransactionCallback。

發現這是一個接口（這也必須是接口，由於任務都是本身具體定義的）

裏面只有一個方法：

[java] view plain copy

print ?

doInTransaction(TransactionStatus status) ;

很明顯，就是在一個事務中須要作的事情都包括這這個方法中了。

而這個doInTransaction 又傳入了一個參數，此次是 TransactionStatus，繼續顧名思義，也就是事務狀態。

查詢下去，這個 TransactionStatus 仍是一個接口。看看這個接口定義了哪些服務（方法）：

[java] view plain copy

print ?

hasSavepoint() ;
isCompleted() ;
isNewTransaction() ;
setRollbackOnly() ;

當須要回滾的時候，須要在調用 setRoolbackOnly(); 就OK了。

好了，走了這麼久，如今就來簡單總結一下編程式事務管理。

首先： 由於咱們使用的是特定的平臺，因此，咱們須要建立一個合適咱們的平臺事務管理PlateformTransactionManager。若是使用的是 JDBC的話，就用DataSourceTransactionManager。注意須要傳入一個DataSource，這樣，平臺才知道如何和數據庫打交道。

第二： 爲了使得平臺事務管理器對咱們來講是透明的，就須要使用 TransactionTemplate。使用TransactionTemplat須要傳入一個 PlateformTransactionManager 進入，這樣，咱們就獲得了一個 TransactionTemplate，而不用關心到底使用的是什麼平臺了。

第三： TransactionTemplate 的重要方法就是 execute 方法，此方法就是調用 TransactionCallback 進行處理。

也就是說，實際上咱們須要處理的事情所有都是在 TransactionCallback 中編碼的。

第四： 也就是 TransactionCallback 接口，咱們能夠定義一個類並實現此接口，而後做爲 TransactionTemplate.execute 的參數。把須要完成的事情放到 doInTransaction中，而且傳入一個 TransactionStatus 參數。此參數是來調用回滾的。

也就是說 ，PlateformTransactionManager 和 TransactionTemplate 只需在程序中定義一次，而TransactionCallback 和 TransactionStatus 就要針對不一樣的任務屢次定義了。

這就是Spring的編程式事務管理。下面貼出例子代碼：

TemplateUtils

[java] view plain copy

print ?

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;
import org.apache.log4j.Logger;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.simple.SimpleJdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.support.TransactionTemplate;
public class TemplateUtils {
private static Logger logger = Logger.getLogger(TemplateUtils.class);
private static String oracleDS = "java:OracleDS";
private static DataSource dataSource = null;
static {
try {
Context context = new InitialContext();
dataSource = (DataSource) context.lookup(oracleDS);
} catch (NamingException e) {
logger.info("查找數據源失敗···", e);
}
}
public static TransactionTemplate getTransactionTemplate() {
PlatformTransactionManager txManager = new DataSourceTransactionManager(
dataSource);
return new TransactionTemplate(txManager);
}
public static JdbcTemplate getJdbcTemplate() {
return new JdbcTemplate(dataSource);
}
public static NamedParameterJdbcTemplate getNamedParameterJdbcTemplate() {
return new NamedParameterJdbcTemplate(dataSource);
}
public static SimpleJdbcTemplate getSimpleJdbcTemplate() {
return new SimpleJdbcTemplate(dataSource);
}
}

Test

[java] view plain copy

print ?

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import org.springframework.transaction.support.TransactionCallback;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;
@SuppressWarnings("all")
public class Test {
public void m1() throws Exception {
TransactionTemplate transactionTemplate = TemplateUtils
.getTransactionTemplate();
Object object = transactionTemplate.execute(new TransactionCallback() {
public Object doInTransaction(TransactionStatus status) {
try {
// 數據庫操做1
// 數據庫操做2
} catch (Exception e) {
status.setRollbackOnly();
e.printStackTrace();
}
return null;
}
});
}
public void m2() throws Exception {
TransactionTemplate transactionTemplate = TemplateUtils
.getTransactionTemplate();
transactionTemplate.execute(new TransactionCallbackWithoutResult() {
protected void doInTransactionWithoutResult(TransactionStatus s) {
try {
// 數據庫操做1
// 數據庫操做2
} catch (Exception e) {
s.setRollbackOnly();
e.printStackTrace();
}
}
});
}
public void m3() throws Exception {
Context ctx = new InitialContext();
DataSource ds = (DataSource) ctx.lookup("java:OracleDS");
JdbcTemplate jt = new JdbcTemplate(ds);
DefaultTransactionDefinition tf = new DefaultTransactionDefinition();
PlatformTransactionManager tm = new DataSourceTransactionManager(ds);
TransactionStatus ts = tm.getTransaction(tf);
try {
// 數據庫操做1
// 數據庫操做2
tm.commit(ts);
} catch (Exception e) {
tm.rollback(ts);
e.printStackTrace();
}
}
}