Spring JDBC事務管理
阿新 • • 發佈:2019-02-19
JDBC事務管理
Spring提供程式設計式的事務管理(Programmatic transaction manage- ment)與宣告式的事務管理(Declarative transaction management),為不同的事務實現提供了一致的程式設計模型,這節以JDBC事務為例,介紹Spring的事務管理。
5.3.1 Spring對事務的支援
事務是一組原子(Atomic)操作的工作單元,以資料庫存取的例項來說,就是一組SQL指令,這一組SQL指令必須全部執行成功,若因為某個原因未全部執行成功(例如其中一行SQL有錯誤),則先前所有執行過的SQL指令都會被撤消。
舉個簡單的例子,一個客戶從A銀行轉賬至B銀行,要作的動作為從A銀行的賬戶扣款、在B銀行的賬戶加上轉賬的金額,兩個動作必須成功,如果有一個動作失敗,則此次轉賬失敗。
事務還必須保持所參與資源的一致性(Consistent),例如在銀行賬戶的例子中,兩個賬戶的轉賬金額,B賬戶取款的金額不能大於A賬戶的存款金額。每個事務彼此之間必須是隔離的(Isolated),例如在A賬戶中可能有兩筆事務,同時進行存款與提款的動作,兩個事務基本上不需意識到彼此的存在。事務還必須是可持續的(Durable),在某一筆事務之後,這筆事務必須是被記錄下來的。
在這裡將介紹JDBC如何使用事務管理。首先來看看事務的原子性實現,在JDBC中,可以操作Connection的setAutoCommit() 方法,給定false引數,在下達一連串的SQL語句後,自行執行Connection的commit()來送出變更,如果中間發生錯誤,則執行rollback() 來撤消所有的執行,例如:
Java程式碼
在Spring中對JDBC的事務管理加以封裝,Spring事務管理的抽象關鍵在於org.springframework.transaction.PlatformTransactionManager介面的實現:
...
Java程式碼
PlatformTransactionManager介面有許多具體的事務實現類,例如DataSourceTransactionManager、HibernateTransactionManager、JdoTransaction- Manager、JtaTransactionManager等,通過依賴於PlatformTransactionManager介面及各種的技術實現,Spring在事務管理上可以讓開發人員使用一致的程式設計模型,即使所使用的是不同的事務管理技術。
TransactionException是Unchecked Exception。事務的失敗通常都是致命的錯誤,Spring不強迫您一定要處理,而是讓您自行選擇是否要捕捉異常。
getTransaction() 方法根據一個TransactionDefinition物件來回傳一個TransactionStatus物件,TransactionDefinition介面的例項定義了事務的隔離程度(Isolation level)、傳播行為(Propagation behavior)、超時(Timeout)、只讀(Read-only)等,TransactionStatus代表著一個新的事務發起或已經存在的事務,您可以通過它來控制事務的執行或調查的狀態:
...
Java程式碼
Spring提供程式設計式的事務管理(Programmatic transaction management)與宣告式的事務管理(Declarative transaction management):
l 程式設計式的事務管理
程式設計式的事務管理可以清楚地控制事務的邊界,也就是讓您自行實現事務開始時間、撤消操作的時機、結束時間等,可以實現細粒度的事務控制。
l 宣告式的事務管理
然而多數的情況下,事務並不需要細粒度的控制,而是採用宣告式的事務管理,好處是Spring事務管理的相關API可以不用介入程式之中,從物件的角度來看,它並不知道自己正被納入事務管理之中,在不需要事務管理的時候,只要在設定檔案上修改一下設定,即可移去事務管理服務。
5.3.2 JDBC程式設計事務管理
Spring提供兩種方式實現程式設計式的事務管理,一是直接使用PlatformTransaction- Manager實現,二是使用org.springframework.transaction.support.Transaction- Template。
先來看看如何使用PlatformTransactionManager,在這裡使用它的實現類DataSourceTransactionManager,可以改寫一下之前5.2.1節中的JdbcTemplateDemo專案,讓它具有事務管理功能,修改一下UserDAO類的insert() 方法來作示範:
ProgrammaticTransactionDemo UserDAO.java
Java程式碼
在insert()方法中使用了DataSourceTransactionManager來進行事務管理,如果發生了異常,則catch區塊中會進行事務的Rollback,在insert() 方法中故意寫入錯誤的SQL(注意INSERT方法少寫了一個T),因此實際上資料並不會被儲存至資料庫中。
要使用MySQL資料庫進行事務處理,必須建立支援事務的表格型別,例如InnoDB的表格型別,這裡用來建立表格的SQL如下所示:
Java程式碼
另一個實現程式設計式事務管理的方法是使用TransactionTemplate,它需要一個TransactionManager例項,如下所示:
...
Java程式碼
如果發生了異常,則會進行Rollback,否則提交事務,如果沒有回傳值,則也可以使用TransactionCallbackWithoutResult:
...
Java程式碼
5.3.3 JDBC宣告事務管理
Spring宣告式的事務管理依賴它的AOP框架來完成。使用宣告事務管理的好處是,事務管理不能侵入您所開發的元件,具體來說,DAO物件不會意識到正在事務管理之中,事實上也應當如此,因為事務管理是屬於系統層面的服務,而不是業務邏輯的一部分,如果想要改變事務管理策略的話,也只需要在定義檔案中重新配置。
舉個例子來說,可以將5.2.1節中的JdbcTemplateDemo專案修改一下,在不修改UserDAO類的情況下,可以為它加入事務管理的服務,一個簡單的方法是使用TransactionProxyFactoryBean,指定要介入的事務管理物件及其方法,這需要在定義檔案中修改,如下所示:
DeclarativeTransactionDemo beans-config.xml
Java程式碼
TransactionProxyFactoryBean需要一個TransactionManager,由於這裡使用的是JDBC,所以使用DataSourceTransactionManager,TransactionProxyFactoryBean是個代理物件,"target" 屬性指定要代理的物件,事務管理會自動介入指定的方法前後,這裡使用 "transactionAttributes" 屬性指定,"insert*" 表示指定方法名稱以insert開頭的都要納入事務管理,您也可以指定方法全名,如果在方法執行過程中發生錯誤,則所有先前的操作自動撤回,否則正常提交。
在"insert*" 等方法上指定了 "PROPAGATION_REQUIRED",表示在目前的事務中執行操作,如果事務不存在就建立一個新的,相關的常數意義都可以在API檔案的TransactionDefinition介面中找到。您可以加上多個事務定義,中間使用逗號 "," 區隔,例如可以加上只讀,或者是指定某個異常發生時撤回操作:
PROPAGATION_REQUIRED,readOnly,-MyCheckedException
MyCheckedException前面加上 "-" 時,表示發生指定異常時撤消操作,如果前面加上 "+",表示發生異常時立即提交。
由於"userDAO"被"userDAOProxy"代理了,所以要做的是取得"userDAOProxy",而不是"userDAO",例如:
DeclarativeTransactionDemo SpringDAODemo.java
Java程式碼
您也可以設定不同的TransactionInterceptor來得到更多的管理細節,例如:
Java程式碼
即使後來不再需要事務管理,也可以直接在Bean定義檔案中修改配置,而不用修改程式重新進行編譯等動作。
宣告事務管理是利用Spring AOP來達成的,所以執行以上的程式時,請記得您的Classpath設定中必須包括spring-aop.jar。
5.3.4 事務的屬性介紹
Spring使用AOP來完成宣告式的事務管理,因而宣告式事務是以方法為邊界的,Spring的事務屬性(Transaction attribute)自然就在於描述事務應用至方法上的策略,在Spring中事務屬性分作以下的幾個引數:
l 傳播行為(Propagation behavior)
傳播行為定義了事務應用於方法上之邊界(Boundaries),它告知何時該開始一個新的事務,或何時事務該被暫停,或方法是否要在事務中進行。
Spring定義了幾個傳播行為,可以在TransactionDefinition的API檔案說明上找到相對應的常數與說明,以下列出幾個:
表5.1 事務傳播行為說明
傳播行為 說明
PROPAGATION_MANDATORY 方法必須在一個現存的事務中進行,否則丟出異常
PROPAGATION_NESTED 在一個嵌入的事務中進行,如果不是,則同PROPAGATION_REQUIRED
PROPAGATION_NEVER 指出不應在事務中進行,如果有就丟出異常
PROPAGATION_NOT_SUPPORTED 指出不應在事務中進行,如果有就暫停現存的事務
PROPAGATION_REQUIRED 支援現在的事務,如果沒有就建立一個新的事務
PROPAGATION_REQUIRES_NEW 建立一個新的事務,如果現存一個事務就暫停它
PROPAGATION_SUPPORTS 支援現在的事務,如果沒有就以非事務的方式執行
舉個例子來說,如果傳播行為被宣告為PROPAGATION_REQUIRED,則事務的邊界在開始第一個事務的方法呼叫及結束時,如果先前沒有事務被開始,則事務邊界即為目前方法的執行前後。又如果傳播行為被宣告為PROPAGATION_REQUIRES_NEW,則事務的邊界即為該方法執行的前後。
l 隔離層級(Isolation level)
在一個應用程式中,可能有多個事務同時在進行,這些事務應當彼此之間互相不知道另一個事務的存在,好比現在整個應用程式就只有一個事務存在,由於事務彼此之間獨立,若讀取的是同一個資料的話,就容易發生問題,例如:
n Dirty read
某個事務已更新一份資料,另一個事務在此時讀取了同一份資料,由於某些原因,前一個Roll back了操作,則後一個事務所讀取的資料就會是不正確的。
n Non-repeatable read
在一個事務的兩次查詢之中資料不一致,這可能是因為兩次查詢過程中間插入了一個事務更新的原有的資料。
n Phantom read
在一個事務的兩次查詢中資料筆數不一致,例如有一個事務查詢了幾列(Row)資料,而另一個事務卻在此時插入了新的幾列資料,先前的事務在接下來的查詢中,就會發現有幾列資料是它先前所沒有的。
為了避免以上問題的方法之一,需要在某個事務進行過程中鎖定正在更新或查詢的資料欄位,直到目前的事務完成,然而完全鎖定欄位時,若另一個事務來查詢同一份資料就必須等待,直到前一個事務完成並解除鎖定為止,因而會造成應用程式在查詢或更新資料時效率上的問題,而事實上根據需求的不同,並不用在事務進行時完全地鎖定資料,隔離層級可以讓您根據實際的需求,對資料的鎖定進行設定。
Spring提供了幾種隔離層級設定,同類型的設定可以在TransactionDefinition的API檔案說明上找到相對應的常數與說明,以下列出幾個:
表5.2 事務隔離層級說明
隔離層級 說明
ISOLATION_DEFAULT 使用底層資料庫預設的隔離層級
ISOLATION_READ_COMMITTED 允許事務讀取其他並行的事務已經送出(Commit)的
資料欄位,可以防止Dirty read問題
ISOLATION_READ_UNCOMMITTED 允許事務讀取其他並行的事務還沒送出的資料,會發
生Dirty、Nonrepeatable、Phantom read等問題
續表
隔離層級 說明
ISOLATION_REPEATABLE_READ 要求多次讀取的資料必須相同,除非事務本身更新
資料,可防止Dirty、Nonrepeatable read問題
ISOLATION_SERIALIZABLE 完整的隔離層級,可防止Dirty、Nonrepeatabl
e、Phantom read等問題,會鎖定對應的資料表
格,因而有效率問題
l 只讀提示(Read-only hints)
如果事務只進行讀取的動作,則可以利用底層資料庫在只讀操作時發生的一些最佳化動作,由於這個動作利用到資料庫在只讀的事務操作最佳化,因而必須在事務中才有效,也就是說要搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設定。
l 事務超時期間(The transaction timeout period)
有的事務操作可能延續很長一段的時間,事務本身可能關聯到資料表格的鎖定,因而長時間的事務操作會有效率上的問題,對於過長的事務操作,您要考慮Roll back事務並要求重新操作,而不是無限時的等待事務完成。
您可以設定事務超時期間,計時是從事務開始時,所以這個設定必須搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設定。
5.3.5 TransactionAttributeSource、TransactionAttribute
在TransactionProxyFactoryBean上有setTransactionAttributeSource()與setTransaction Attributes()方法,它們是用來設定事務屬性的策略例項。
org.springframework.transaction.interceptor.TransactionAttributeSource介面上有一個getTransactionAttribute() 方法,您可以根據傳遞給它的Method例項與Class例項,決定該回傳一個什麼內容的org.springframework.transaction. interceptor.TransactionAttribute例項,一個最簡單的TransactionAttributeSource實現是org.springframework.transaction.interceptor.MatchAlw
Spring提供程式設計式的事務管理(Programmatic transaction manage- ment)與宣告式的事務管理(Declarative transaction management),為不同的事務實現提供了一致的程式設計模型,這節以JDBC事務為例,介紹Spring的事務管理。
5.3.1 Spring對事務的支援
事務是一組原子(Atomic)操作的工作單元,以資料庫存取的例項來說,就是一組SQL指令,這一組SQL指令必須全部執行成功,若因為某個原因未全部執行成功(例如其中一行SQL有錯誤),則先前所有執行過的SQL指令都會被撤消。
舉個簡單的例子,一個客戶從A銀行轉賬至B銀行,要作的動作為從A銀行的賬戶扣款、在B銀行的賬戶加上轉賬的金額,兩個動作必須成功,如果有一個動作失敗,則此次轉賬失敗。
事務還必須保持所參與資源的一致性(Consistent),例如在銀行賬戶的例子中,兩個賬戶的轉賬金額,B賬戶取款的金額不能大於A賬戶的存款金額。每個事務彼此之間必須是隔離的(Isolated),例如在A賬戶中可能有兩筆事務,同時進行存款與提款的動作,兩個事務基本上不需意識到彼此的存在。事務還必須是可持續的(Durable),在某一筆事務之後,這筆事務必須是被記錄下來的。
在這裡將介紹JDBC如何使用事務管理。首先來看看事務的原子性實現,在JDBC中,可以操作Connection的setAutoCommit() 方法,給定false引數,在下達一連串的SQL語句後,自行執行Connection的commit()來送出變更,如果中間發生錯誤,則執行rollback() 來撤消所有的執行,例如:
Java程式碼
- try {
- .....
- connection.setAutoCommit(false);
- .....
- // 一連串SQL操作
- connection.commit();
- } catch(SQLException) {
- // 發生錯誤,撤消所有變更
- connection.rollback();
- }
try { ..... connection.setAutoCommit(false); ..... // 一連串SQL操作 connection.commit(); } catch(SQLException) { // 發生錯誤,撤消所有變更 connection.rollback(); }
在Spring中對JDBC的事務管理加以封裝,Spring事務管理的抽象關鍵在於org.springframework.transaction.PlatformTransactionManager介面的實現:
...
Java程式碼
- publicinterface PlatformTransactionManager {
- TransactionStatus getTransaction(TransactionDefinition
- definition) throws TransactionException;
- void commit(TransactionStatus status)
- throws TransactionException;
- void rollback(TransactionStatus status)
- throws TransactionException;
- }
public interface PlatformTransactionManager { TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException; void commit(TransactionStatus status) throws TransactionException; void rollback(TransactionStatus status) throws TransactionException; }
PlatformTransactionManager介面有許多具體的事務實現類,例如DataSourceTransactionManager、HibernateTransactionManager、JdoTransaction- Manager、JtaTransactionManager等,通過依賴於PlatformTransactionManager介面及各種的技術實現,Spring在事務管理上可以讓開發人員使用一致的程式設計模型,即使所使用的是不同的事務管理技術。
TransactionException是Unchecked Exception。事務的失敗通常都是致命的錯誤,Spring不強迫您一定要處理,而是讓您自行選擇是否要捕捉異常。
getTransaction() 方法根據一個TransactionDefinition物件來回傳一個TransactionStatus物件,TransactionDefinition介面的例項定義了事務的隔離程度(Isolation level)、傳播行為(Propagation behavior)、超時(Timeout)、只讀(Read-only)等,TransactionStatus代表著一個新的事務發起或已經存在的事務,您可以通過它來控制事務的執行或調查的狀態:
...
Java程式碼
- publicinterface TransactionStatus {
- boolean isNewTransaction();
- void setRollbackOnly();
- boolean isRollbackOnly();
- }
public interface TransactionStatus { boolean isNewTransaction(); void setRollbackOnly(); boolean isRollbackOnly(); }
Spring提供程式設計式的事務管理(Programmatic transaction management)與宣告式的事務管理(Declarative transaction management):
l 程式設計式的事務管理
程式設計式的事務管理可以清楚地控制事務的邊界,也就是讓您自行實現事務開始時間、撤消操作的時機、結束時間等,可以實現細粒度的事務控制。
l 宣告式的事務管理
然而多數的情況下,事務並不需要細粒度的控制,而是採用宣告式的事務管理,好處是Spring事務管理的相關API可以不用介入程式之中,從物件的角度來看,它並不知道自己正被納入事務管理之中,在不需要事務管理的時候,只要在設定檔案上修改一下設定,即可移去事務管理服務。
5.3.2 JDBC程式設計事務管理
Spring提供兩種方式實現程式設計式的事務管理,一是直接使用PlatformTransaction- Manager實現,二是使用org.springframework.transaction.support.Transaction- Template。
先來看看如何使用PlatformTransactionManager,在這裡使用它的實現類DataSourceTransactionManager,可以改寫一下之前5.2.1節中的JdbcTemplateDemo專案,讓它具有事務管理功能,修改一下UserDAO類的insert() 方法來作示範:
ProgrammaticTransactionDemo UserDAO.java
Java程式碼
- package onlyfun.caterpillar;
- import java.util.Iterator;
- import java.util.List;
- import java.util.Map;
- import javax.sql.DataSource;
- import org.springframework.dao.DataAccessException;
- import org.springframework.jdbc.core.JdbcTemplate;
- import org.springframework.jdbc.
- datasource.DataSourceTransactionManager;
- import org.springframework.transaction.TransactionDefinition;
- import org.springframework.transaction.TransactionStatus;
- import org.springframework.transaction.
- support.DefaultTransactionDefinition;
- publicclass UserDAO implements IUserDAO {
- private DataSourceTransactionManager transactionManager;
- private DefaultTransactionDefinition def;
- private JdbcTemplate jdbcTemplate;
- publicvoid setDataSource(DataSource dataSource) {
- jdbcTemplate = new JdbcTemplate(dataSource);
- transactionManager =
- new DataSourceTransactionManager(dataSource);
- // 建立事務的定義
- def = new DefaultTransactionDefinition();
- def.setPropagationBehavior(
- TransactionDefinition.PROPAGATION_REQUIRED);
- }
- publicvoid insert(User user) {
- String name = user.getName();
- int age = user.getAge().intValue();
- TransactionStatus status =
- transactionManager.getTransaction(def);
- try {
- jdbcTemplate.update("INSERT INTO user (name,age) "
- + "VALUES('" + name + "'," + age + ")");
- // 下面的SQL有錯誤,用以測試事務
- jdbcTemplate.update("INSER INTO user (name,age) "
- + "VALUES('" + name + "'," + age + ")");
- }
- catch(DataAccessException e) {
- transactionManager.rollback(status);
- throw e;
- }
- transactionManager.commit(status);
- }
- public User find(Integer id) {
- List rows = jdbcTemplate.queryForList(
- "SELECT * FROM user WHERE id=" + id.intValue());
- Iterator it = rows.iterator();
- if(it.hasNext()) {
- Map userMap = (Map) it.next();
- Integer i = new Integer(
- userMap.get("id").toString());
- String name = userMap.get("name").toString();
- Integer age = new Integer(
- userMap.get("age").toString());
- User user = new User();
- user.setId(i);
- user.setName(name);
- user.setAge(age);
- return user;
- }
- returnnull;
- }
- }
package onlyfun.caterpillar; import java.util.Iterator; import java.util.List; import java.util.Map; import javax.sql.DataSource; import org.springframework.dao.DataAccessException; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc. datasource.DataSourceTransactionManager; import org.springframework.transaction.TransactionDefinition; import org.springframework.transaction.TransactionStatus; import org.springframework.transaction. support.DefaultTransactionDefinition; public class UserDAO implements IUserDAO { private DataSourceTransactionManager transactionManager; private DefaultTransactionDefinition def; private JdbcTemplate jdbcTemplate; public void setDataSource(DataSource dataSource) { jdbcTemplate = new JdbcTemplate(dataSource); transactionManager = new DataSourceTransactionManager(dataSource); // 建立事務的定義 def = new DefaultTransactionDefinition(); def.setPropagationBehavior( TransactionDefinition.PROPAGATION_REQUIRED); } public void insert(User user) { String name = user.getName(); int age = user.getAge().intValue(); TransactionStatus status = transactionManager.getTransaction(def); try { jdbcTemplate.update("INSERT INTO user (name,age) " + "VALUES('" + name + "'," + age + ")"); // 下面的SQL有錯誤,用以測試事務 jdbcTemplate.update("INSER INTO user (name,age) " + "VALUES('" + name + "'," + age + ")"); } catch(DataAccessException e) { transactionManager.rollback(status); throw e; } transactionManager.commit(status); } public User find(Integer id) { List rows = jdbcTemplate.queryForList( "SELECT * FROM user WHERE id=" + id.intValue()); Iterator it = rows.iterator(); if(it.hasNext()) { Map userMap = (Map) it.next(); Integer i = new Integer( userMap.get("id").toString()); String name = userMap.get("name").toString(); Integer age = new Integer( userMap.get("age").toString()); User user = new User(); user.setId(i); user.setName(name); user.setAge(age); return user; } return null; } }
在insert()方法中使用了DataSourceTransactionManager來進行事務管理,如果發生了異常,則catch區塊中會進行事務的Rollback,在insert() 方法中故意寫入錯誤的SQL(注意INSERT方法少寫了一個T),因此實際上資料並不會被儲存至資料庫中。
要使用MySQL資料庫進行事務處理,必須建立支援事務的表格型別,例如InnoDB的表格型別,這裡用來建立表格的SQL如下所示:
Java程式碼
- CREATE TABLE user (
- id INT(11) NOT NULL auto_increment PRIMARY KEY,
- name VARCHAR(100) NOT NULL default'',
- age INT
- ) TYPE = InnoDB;
CREATE TABLE user ( id INT(11) NOT NULL auto_increment PRIMARY KEY, name VARCHAR(100) NOT NULL default '', age INT ) TYPE = InnoDB;
另一個實現程式設計式事務管理的方法是使用TransactionTemplate,它需要一個TransactionManager例項,如下所示:
...
Java程式碼
- TransactionTemplate transactionTemplate =
- new TransactionTemplate(transactionManager);
- ...
- transactionTemplate.execute(new TransactionCallback() {
- public Object doInTransaction(TransactionStatus status) {
- return jdbcTemplate.update("INSERT INTO user (name,age) "
- + "VALUES('" + name + "'," + age + ")");
- }
- });
TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager); ... transactionTemplate.execute(new TransactionCallback() { public Object doInTransaction(TransactionStatus status) { return jdbcTemplate.update("INSERT INTO user (name,age) " + "VALUES('" + name + "'," + age + ")"); } });
如果發生了異常,則會進行Rollback,否則提交事務,如果沒有回傳值,則也可以使用TransactionCallbackWithoutResult:
...
Java程式碼
- transactionTemplate.execute(
- new TransactionCallbackWithoutResult() {
- publicvoid doInTransactionWithoutResult(
- TransactionStatus status) {
- . ...
- }
- });
transactionTemplate.execute( new TransactionCallbackWithoutResult() { public void doInTransactionWithoutResult( TransactionStatus status) { . ... } });
5.3.3 JDBC宣告事務管理
Spring宣告式的事務管理依賴它的AOP框架來完成。使用宣告事務管理的好處是,事務管理不能侵入您所開發的元件,具體來說,DAO物件不會意識到正在事務管理之中,事實上也應當如此,因為事務管理是屬於系統層面的服務,而不是業務邏輯的一部分,如果想要改變事務管理策略的話,也只需要在定義檔案中重新配置。
舉個例子來說,可以將5.2.1節中的JdbcTemplateDemo專案修改一下,在不修改UserDAO類的情況下,可以為它加入事務管理的服務,一個簡單的方法是使用TransactionProxyFactoryBean,指定要介入的事務管理物件及其方法,這需要在定義檔案中修改,如下所示:
DeclarativeTransactionDemo beans-config.xml
Java程式碼
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">
- <bean id="dataSource"
- class="org.springframework.jdbc.
- → datasource.DriverManagerDataSource"
- destroy-method="close">
- <property name="driverClassName"
- value="com.mysql.jdbc.Driver"/>
- <property name="url"
- value="jdbc:mysql://localhost:3306/demo"/>
- <property name="username" value="caterpillar"/>
- <property name="password" value="123456"/>
- </bean>
- <bean id="transactionManager"
- class="org.springframework.jdbc.
- → datasource.DataSourceTransactionManager">
- <property name="dataSource" ref="dataSource"/>
- </bean>
- <bean id="userDAO"
- class="onlyfun.caterpillar.UserDAO">
- <property name="dataSource" ref="dataSource"/>
- </bean>
- <bean id="userDAOProxy"
- class="org.springframework.transaction.
- → interceptor.TransactionProxyFactoryBean">
- <property name="proxyInterfaces">
- <list>
- <value>onlyfun.caterpillar.IUserDAO</value>
- </list>
- </property>
- <property name="target" ref="userDAO"/>
- <property name="transactionManager"
- ref="transactionManager"/>
- <property name="transactionAttributes">
- <props>
- <prop key="insert*">PROPAGATION_REQUIRED</prop>
- </props>
- </property>
- </bean>
- </beans>
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd"> <bean id="dataSource" class="org.springframework.jdbc. → datasource.DriverManagerDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost:3306/demo"/> <property name="username" value="caterpillar"/> <property name="password" value="123456"/> </bean> <bean id="transactionManager" class="org.springframework.jdbc. → datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <bean id="userDAO" class="onlyfun.caterpillar.UserDAO"> <property name="dataSource" ref="dataSource"/> </bean> <bean id="userDAOProxy" class="org.springframework.transaction. → interceptor.TransactionProxyFactoryBean"> <property name="proxyInterfaces"> <list> <value>onlyfun.caterpillar.IUserDAO</value> </list> </property> <property name="target" ref="userDAO"/> <property name="transactionManager" ref="transactionManager"/> <property name="transactionAttributes"> <props> <prop key="insert*">PROPAGATION_REQUIRED</prop> </props> </property> </bean> </beans>
TransactionProxyFactoryBean需要一個TransactionManager,由於這裡使用的是JDBC,所以使用DataSourceTransactionManager,TransactionProxyFactoryBean是個代理物件,"target" 屬性指定要代理的物件,事務管理會自動介入指定的方法前後,這裡使用 "transactionAttributes" 屬性指定,"insert*" 表示指定方法名稱以insert開頭的都要納入事務管理,您也可以指定方法全名,如果在方法執行過程中發生錯誤,則所有先前的操作自動撤回,否則正常提交。
在"insert*" 等方法上指定了 "PROPAGATION_REQUIRED",表示在目前的事務中執行操作,如果事務不存在就建立一個新的,相關的常數意義都可以在API檔案的TransactionDefinition介面中找到。您可以加上多個事務定義,中間使用逗號 "," 區隔,例如可以加上只讀,或者是指定某個異常發生時撤回操作:
PROPAGATION_REQUIRED,readOnly,-MyCheckedException
MyCheckedException前面加上 "-" 時,表示發生指定異常時撤消操作,如果前面加上 "+",表示發生異常時立即提交。
由於"userDAO"被"userDAOProxy"代理了,所以要做的是取得"userDAOProxy",而不是"userDAO",例如:
DeclarativeTransactionDemo SpringDAODemo.java
Java程式碼
- package onlyfun.caterpillar;
- import org.springframework.context.ApplicationContext;
- import org.springframework.context.
- support.ClassPathXmlApplicationContext;
- publicclass SpringDAODemo {
- publicstaticvoid main(String[] args) {
- ApplicationContext context =
- new ClassPathXmlApplicationContext(
- "beans-config.xml");
- User user = new User();
- user.setName("caterpillar");
- user.setAge(new Integer(30));
- IUserDAO userDAO =
- (IUserDAO) context.getBean("userDAOProxy");
- userDAO.insert(user);
- user = userDAO.find(new Integer(1));
- System.out.println("name: " + user.getName());
- }
- }
package onlyfun.caterpillar; import org.springframework.context.ApplicationContext; import org.springframework.context. support.ClassPathXmlApplicationContext; public class SpringDAODemo { public static void main(String[] args) { ApplicationContext context = new ClassPathXmlApplicationContext( "beans-config.xml"); User user = new User(); user.setName("caterpillar"); user.setAge(new Integer(30)); IUserDAO userDAO = (IUserDAO) context.getBean("userDAOProxy"); userDAO.insert(user); user = userDAO.find(new Integer(1)); System.out.println("name: " + user.getName()); } }
您也可以設定不同的TransactionInterceptor來得到更多的管理細節,例如:
Java程式碼
- <?xml version="1.0" encoding="UTF-8"?>
- <beans xmlns="http://www.springframework.org/schema/beans"
- xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
- xsi:schemaLocation="http://www.springframework.org/schema/beans
- http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">
- <bean id="dataSource"
- class="org.springframework.jdbc.
- → datasource.DriverManagerDataSource"
- destroy-method="close">
- <property name="driverClassName"
- value="com.mysql.jdbc.Driver"/>
- <property name="url"
- value="jdbc:mysql://localhost:3306/demo"/>
- <property name="username" value="caterpillar"/>
- <property name="password" value="123456"/>
- </bean>
- <bean id="transactionManager"
- class="org.springframework.jdbc.
- → datasource.DataSourceTransactionManager">
- <property name="dataSource" ref="dataSource"/>
- </bean>
- <bean id="userDAO"
- class="onlyfun.caterpillar.UserDAO">
- <property name="dataSource" ref="dataSource"/>
- </bean>
- <bean id="transactionInterceptor"
- class="org.springframework.transaction.
- → interceptor.TransactionInterceptor">
- <property name="transactionManager" ref="transactionManager"/>
- <property name="transactionAttributeSource"
- value="onlyfun.caterpillar.UserDAO.insert*=
- → PROPAGATION_REQUIRED "/>
- </bean>
- <bean id="userDAOProxy"
- class="org.springframework.aop.
- → framework.ProxyFactoryBean">
- <property name="proxyInterfaces">
- <list>
- <value>onlyfun.caterpillar.IUserDAO</value>
- </list>
- </property>
- <property name="target" ref="userDAO"/>
- <property name="interceptorNames">
- <list>
- <value>transactionInterceptor</value>
- </list>
- </property>
- </bean>
- </beans>
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd"> <bean id="dataSource" class="org.springframework.jdbc. → datasource.DriverManagerDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="url" value="jdbc:mysql://localhost:3306/demo"/> <property name="username" value="caterpillar"/> <property name="password" value="123456"/> </bean> <bean id="transactionManager" class="org.springframework.jdbc. → datasource.DataSourceTransactionManager"> <property name="dataSource" ref="dataSource"/> </bean> <bean id="userDAO" class="onlyfun.caterpillar.UserDAO"> <property name="dataSource" ref="dataSource"/> </bean> <bean id="transactionInterceptor" class="org.springframework.transaction. → interceptor.TransactionInterceptor"> <property name="transactionManager" ref="transactionManager"/> <property name="transactionAttributeSource" value="onlyfun.caterpillar.UserDAO.insert*= → PROPAGATION_REQUIRED "/> </bean> <bean id="userDAOProxy" class="org.springframework.aop. → framework.ProxyFactoryBean"> <property name="proxyInterfaces"> <list> <value>onlyfun.caterpillar.IUserDAO</value> </list> </property> <property name="target" ref="userDAO"/> <property name="interceptorNames"> <list> <value>transactionInterceptor</value> </list> </property> </bean> </beans>
即使後來不再需要事務管理,也可以直接在Bean定義檔案中修改配置,而不用修改程式重新進行編譯等動作。
宣告事務管理是利用Spring AOP來達成的,所以執行以上的程式時,請記得您的Classpath設定中必須包括spring-aop.jar。
5.3.4 事務的屬性介紹
Spring使用AOP來完成宣告式的事務管理,因而宣告式事務是以方法為邊界的,Spring的事務屬性(Transaction attribute)自然就在於描述事務應用至方法上的策略,在Spring中事務屬性分作以下的幾個引數:
l 傳播行為(Propagation behavior)
傳播行為定義了事務應用於方法上之邊界(Boundaries),它告知何時該開始一個新的事務,或何時事務該被暫停,或方法是否要在事務中進行。
Spring定義了幾個傳播行為,可以在TransactionDefinition的API檔案說明上找到相對應的常數與說明,以下列出幾個:
表5.1 事務傳播行為說明
傳播行為 說明
PROPAGATION_MANDATORY 方法必須在一個現存的事務中進行,否則丟出異常
PROPAGATION_NESTED 在一個嵌入的事務中進行,如果不是,則同PROPAGATION_REQUIRED
PROPAGATION_NEVER 指出不應在事務中進行,如果有就丟出異常
PROPAGATION_NOT_SUPPORTED 指出不應在事務中進行,如果有就暫停現存的事務
PROPAGATION_REQUIRED 支援現在的事務,如果沒有就建立一個新的事務
PROPAGATION_REQUIRES_NEW 建立一個新的事務,如果現存一個事務就暫停它
PROPAGATION_SUPPORTS 支援現在的事務,如果沒有就以非事務的方式執行
舉個例子來說,如果傳播行為被宣告為PROPAGATION_REQUIRED,則事務的邊界在開始第一個事務的方法呼叫及結束時,如果先前沒有事務被開始,則事務邊界即為目前方法的執行前後。又如果傳播行為被宣告為PROPAGATION_REQUIRES_NEW,則事務的邊界即為該方法執行的前後。
l 隔離層級(Isolation level)
在一個應用程式中,可能有多個事務同時在進行,這些事務應當彼此之間互相不知道另一個事務的存在,好比現在整個應用程式就只有一個事務存在,由於事務彼此之間獨立,若讀取的是同一個資料的話,就容易發生問題,例如:
n Dirty read
某個事務已更新一份資料,另一個事務在此時讀取了同一份資料,由於某些原因,前一個Roll back了操作,則後一個事務所讀取的資料就會是不正確的。
n Non-repeatable read
在一個事務的兩次查詢之中資料不一致,這可能是因為兩次查詢過程中間插入了一個事務更新的原有的資料。
n Phantom read
在一個事務的兩次查詢中資料筆數不一致,例如有一個事務查詢了幾列(Row)資料,而另一個事務卻在此時插入了新的幾列資料,先前的事務在接下來的查詢中,就會發現有幾列資料是它先前所沒有的。
為了避免以上問題的方法之一,需要在某個事務進行過程中鎖定正在更新或查詢的資料欄位,直到目前的事務完成,然而完全鎖定欄位時,若另一個事務來查詢同一份資料就必須等待,直到前一個事務完成並解除鎖定為止,因而會造成應用程式在查詢或更新資料時效率上的問題,而事實上根據需求的不同,並不用在事務進行時完全地鎖定資料,隔離層級可以讓您根據實際的需求,對資料的鎖定進行設定。
Spring提供了幾種隔離層級設定,同類型的設定可以在TransactionDefinition的API檔案說明上找到相對應的常數與說明,以下列出幾個:
表5.2 事務隔離層級說明
隔離層級 說明
ISOLATION_DEFAULT 使用底層資料庫預設的隔離層級
ISOLATION_READ_COMMITTED 允許事務讀取其他並行的事務已經送出(Commit)的
資料欄位,可以防止Dirty read問題
ISOLATION_READ_UNCOMMITTED 允許事務讀取其他並行的事務還沒送出的資料,會發
生Dirty、Nonrepeatable、Phantom read等問題
續表
隔離層級 說明
ISOLATION_REPEATABLE_READ 要求多次讀取的資料必須相同,除非事務本身更新
資料,可防止Dirty、Nonrepeatable read問題
ISOLATION_SERIALIZABLE 完整的隔離層級,可防止Dirty、Nonrepeatabl
e、Phantom read等問題,會鎖定對應的資料表
格,因而有效率問題
l 只讀提示(Read-only hints)
如果事務只進行讀取的動作,則可以利用底層資料庫在只讀操作時發生的一些最佳化動作,由於這個動作利用到資料庫在只讀的事務操作最佳化,因而必須在事務中才有效,也就是說要搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設定。
l 事務超時期間(The transaction timeout period)
有的事務操作可能延續很長一段的時間,事務本身可能關聯到資料表格的鎖定,因而長時間的事務操作會有效率上的問題,對於過長的事務操作,您要考慮Roll back事務並要求重新操作,而不是無限時的等待事務完成。
您可以設定事務超時期間,計時是從事務開始時,所以這個設定必須搭配傳播行為PROPAGATION_REQUIRED、PROPAGATION_REQUIRES_NEW、PROPAGATION_NESTED來設定。
5.3.5 TransactionAttributeSource、TransactionAttribute
在TransactionProxyFactoryBean上有setTransactionAttributeSource()與setTransaction Attributes()方法,它們是用來設定事務屬性的策略例項。
org.springframework.transaction.interceptor.TransactionAttributeSource介面上有一個getTransactionAttribute() 方法,您可以根據傳遞給它的Method例項與Class例項,決定該回傳一個什麼內容的org.springframework.transaction. interceptor.TransactionAttribute例項,一個最簡單的TransactionAttributeSource實現是org.springframework.transaction.interceptor.MatchAlw