實(shí)例詳解Spring JDBC事務(wù)管理
Spring提供編程式的事務(wù)管理（Programmatic transaction manage- ment）與聲明式的事務(wù)管理（Declarative transaction management），為不同的事務(wù)實(shí)現(xiàn)提供了一致的編程模型，這節(jié)以JDBC事務(wù)為例，介紹Spring的事務(wù)管理。
Spring對(duì)事務(wù)的支持
事務(wù)是一組原子（Atomic）操作的工作單元，以數(shù)據(jù)庫(kù)存取的實(shí)例來(lái)說(shuō)，就是一組SQL指令，這一組SQL指令必須全部執(zhí)行成功，若因?yàn)槟硞€(gè)原因未全部執(zhí)行成功（例如其中一行SQL有錯(cuò)誤），則先前所有執(zhí)行過(guò)的SQL指令都會(huì)被撤消。
舉個(gè)簡(jiǎn)單的例子，一個(gè)客戶從A銀行轉(zhuǎn)賬至B銀行，要作的動(dòng)作為從A銀行的賬戶扣款、在B銀行的賬戶加上轉(zhuǎn)賬的金額，兩個(gè)動(dòng)作必須成功，如果有一個(gè)動(dòng)作失敗，則此次轉(zhuǎn)賬失敗。
事務(wù)還必須保持所參與資源的一致性（Consistent），例如在銀行賬戶的例子中，兩個(gè)賬戶的轉(zhuǎn)賬金額，B賬戶取款的金額不能大于A賬戶的存款金額。每個(gè)事務(wù)彼此之間必須是隔離的（Isolated），例如在A賬戶中可能有兩筆事務(wù)，同時(shí)進(jìn)行存款與提款的動(dòng)作，兩個(gè)事務(wù)基本上不需意識(shí)到彼此的存在。事務(wù)還必須是可持續(xù)的（Durable），在某一筆事務(wù)之后，這筆事務(wù)必須是被記錄下來(lái)的。
在這里將介紹JDBC如何使用事務(wù)管理。首先來(lái)看看事務(wù)的原子性實(shí)現(xiàn)，在JDBC中，可以操作Connection的setAutoCommit（） 方法，給定false參數(shù)，在下達(dá)一連串的SQL語(yǔ)句后，自行執(zhí)行Connection的commit（）來(lái)送出變更，如果中間發(fā)生錯(cuò)誤，則執(zhí)行 rollback（） 來(lái)撤消所有的執(zhí)行，例如：
| try { ..... connection.setAutoCommit(false); ..... // 一連串SQL操作 connection.commit(); } catch(SQLException) { // 發(fā)生錯(cuò)誤，撤消所有變更 connection.rollback(); } |
在Spring中對(duì)JDBC的事務(wù)管理加以封裝，Spring事務(wù)管理的抽象關(guān)鍵在于org.springframework.transaction.PlatformTransactionManager接口的實(shí)現(xiàn)：
| public interface PlatformTransactionManager { TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException; void commit(TransactionStatus status) throws TransactionException; void rollback(TransactionStatus status) throws TransactionException; } |
PlatformTransactionManager 接口有許多具體的事務(wù)實(shí)現(xiàn)類，例如DataSourceTransactionManager、 HibernateTransactionManager、JdoTransaction- Manager、JtaTransactionManager等，通過(guò)依賴于PlatformTransactionManager接口及各種的技術(shù)實(shí)現(xiàn)，Spring在事務(wù)管理上可以讓開(kāi)發(fā)人員使用一致的編程模型，即使所使用的是不同的事務(wù)管理技術(shù)。
TransactionException是Unchecked Exception.事務(wù)的失敗通常都是致命的錯(cuò)誤，Spring不強(qiáng)迫您一定要處理，而是讓您自行選擇是否要捕捉異常。
getTransaction（） 方法根據(jù)一個(gè)TransactionDefinition對(duì)象來(lái)回傳一個(gè)TransactionStatus對(duì)象，TransactionDefinition接口的實(shí)例定義了事務(wù)的隔離程度（Isolation level）、傳播行為（Propagation behavior）、超時(shí)（Timeout）、只讀（Read-only）等，TransactionStatus代表著一個(gè)新的事務(wù)發(fā)起或已經(jīng)存在的事務(wù)，您可以通過(guò)它來(lái)控制事務(wù)的執(zhí)行或調(diào)查的狀態(tài)：
| public interface TransactionStatus { boolean isNewTransaction(); void setRollbackOnly(); boolean isRollbackOnly(); } |
Spring提供編程式的事務(wù)管理（Programmatic transaction management）與聲明式的事務(wù)管理（Declarative transaction management）：
編程式的事務(wù)管理
編程式的事務(wù)管理可以清楚地控制事務(wù)的邊界，也就是讓您自行實(shí)現(xiàn)事務(wù)開(kāi)始時(shí)間、撤消操作的時(shí)機(jī)、結(jié)束時(shí)間等，可以實(shí)現(xiàn)細(xì)粒度的事務(wù)控制。
聲明式的事務(wù)管理
然而多數(shù)的情況下，事務(wù)并不需要細(xì)粒度的控制，而是采用聲明式的事務(wù)管理，好處是Spring事務(wù)管理的相關(guān)API可以不用介入程序之中，從對(duì)象的角度來(lái)看，它并不知道自己正被納入事務(wù)管理之中，在不需要事務(wù)管理的時(shí)候，只要在設(shè)置文件上修改一下設(shè)置，即可移去事務(wù)管理服務(wù)。
JDBC編程事務(wù)管理Spring提供兩種方式實(shí)現(xiàn)編程式的事務(wù)管理，一是直接使用PlatformTransaction- Manager實(shí)現(xiàn)，二是使用org.springframework.transaction.support.Transaction- Template.
先來(lái)看看如何使用PlatformTransactionManager，在這里使用它的實(shí)現(xiàn)類 DataSourceTransactionManager，可以改寫一下之前幾節(jié)中的JdbcTemplateDemo項(xiàng)目，讓它具有事務(wù)管理功能，修改一下UserDAO類的insert（） 方法來(lái)作示范：ProgrammaticTransactionDemo UserDAO.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; 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); // 建立事務(wù)的定義 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有錯(cuò)誤，用以測(cè)試事務(wù) 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; } } |
要使用MySQL數(shù)據(jù)庫(kù)進(jìn)行事務(wù)處理，必須建立支持事務(wù)的表格類型，例如InnoDB的表格類型，這里用來(lái)建立表格的SQL如下所示：
| CREATE TABLE user ( id INT(11) NOT NULL auto_increment PRIMARY KEY, name VARCHAR(100) NOT NULL default '', age INT ) TYPE = InnoDB; |
另一個(gè)實(shí)現(xiàn)編程式事務(wù)管理的方法是使用TransactionTemplate，它需要一個(gè)TransactionManager實(shí)例，如下所示：
| 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 + ")"); } }); |
如果發(fā)生了異常，則會(huì)進(jìn)行Rollback，否則提交事務(wù)，如果沒(méi)有回傳值，則也可以使用TransactionCallbackWithoutResult：
| transactionTemplate.execute( new TransactionCallbackWithoutResult() { public void doInTransactionWithoutResult( TransactionStatus status) { . ... } }); |
5.3.3 JDBC聲明事務(wù)管理
Spring聲明式的事務(wù)管理依賴它的AOP框架來(lái)完成。使用聲明事務(wù)管理的好處是，事務(wù)管理不能侵入您所開(kāi)發(fā)的組件，具體來(lái)說(shuō)，DAO對(duì)象不會(huì)意識(shí)到正在事務(wù)管理之中，事實(shí)上也應(yīng)當(dāng)如此，因?yàn)槭聞?wù)管理是屬于系統(tǒng)層面的服務(wù)，而不是業(yè)務(wù)邏輯的一部分，如果想要改變事務(wù)管理策略的話，也只需要在定義文件中重新配置。
舉個(gè)例子來(lái)說(shuō)，可以將5.2.1節(jié)中的JdbcTemplateDemo 項(xiàng)目修改一下，在不修改UserDAO類的情況下，可以為它加入事務(wù)管理的服務(wù)，一個(gè)簡(jiǎn)單的方法是使用 TransactionProxyFactoryBean，指定要介入的事務(wù)管理對(duì)象及其方法，這需要在定義文件中修改，如下所示：
DeclarativeTransactionDemo beans-config.xml
| <?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需要一個(gè)TransactionManager，由于這里使用的是JDBC，所以使用 DataSourceTransactionManager，TransactionProxyFactoryBean是個(gè)代理對(duì)象，"target" 屬性指定要代理的對(duì)象，事務(wù)管理會(huì)自動(dòng)介入指定的方法前后，這里使用 "transactionAttributes" 屬性指定，"insert*" 表示指定方法名稱以insert開(kāi)頭的都要納入事務(wù)管理，您也可以指定方法全名，如果在方法執(zhí)行過(guò)程中發(fā)生錯(cuò)誤，則所有先前的操作自動(dòng)撤回，否則正常提交。
在"insert*" 等方法上指定了 "PROPAGATION_REQUIRED"，表示在目前的事務(wù)中執(zhí)行操作，如果事務(wù)不存在就建立一個(gè)新的，相關(guān)的常數(shù)意義都可以在API文件的 TransactionDefinition接口中找到。您可以加上多個(gè)事務(wù)定義，中間使用逗號(hào) "，" 區(qū)隔，例如可以加上只讀，或者是指定某個(gè)異常發(fā)生時(shí)撤回操作：
PROPAGATION_REQUIRED，readOnly，-MyCheckedException
MyCheckedException前面加上 "-" 時(shí)，表示發(fā)生指定異常時(shí)撤消操作，如果前面加上 "+"，表示發(fā)生異常時(shí)立即提交。
由于"userDAO"被"userDAOProxy"代理了，所以要做的是取得"userDAOProxy"，而不是"userDAO"，例如：
DeclarativeTransactionDemo SpringDAODemo.java
| 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()); } } |
您也可以設(shè)置不同的TransactionInterceptor來(lái)得到更多的管理細(xì)節(jié)，例如：
| <?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> |
同樣的，由于不再于設(shè)置文件中設(shè)置代理對(duì)象，所以直接取得"userDAO"實(shí)例進(jìn)行操作即可。
【編輯推薦】
