JdbcTemplate与事务

JdbcTemplate操作采用的是JDBC默认的AutoCommit模式，也就是说我们还
无法保证数据操作的原子性（要么全部生效，要么全部无效），如：
---------------------------------↓-------------------------------↓-----------------------------------
JdbcTemplate jdbcTemplate = new JdbcTemplate(dataSource);
jdbcTemplate.update("UPDATE user SET age = 10 WHERE id = 'erica'");
jdbcTemplate.update("UPDATE user SET age = age+1 WHERE id = 'erica'");
---------------------------------↑-------------------------------↑-----------------------------------
由于采用了AutoCommit模式，第一个update操作完成之后被自动提交，数据库
中”erica”对应的记录已经被更新，如果第二个操作失败，我们无法使得整个事务回滚到最
初状态。对于这个例子也许无关紧要，但是对于一个金融帐务系统而言，这样的问题将导致
致命错误。
为了实现数据操作的原子性，我们需要在程序中引入事务逻辑，在JdbcTemplate中引入
事务机制，在Spring中有两种方式：
1． 代码控制的事务管理
2． 参数化配置的事务管理
下面就这两种方式进行介绍。
★ 代码控制的事务管理
首先，进行以下配置，假设配置文件为（Application-Context.xml）：
---------------------------------↓-------------------------------↓-----------------------------------
<beans>
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName">
<value>net.sourceforge.jtds.jdbc.Driver</value>
</property>
<property name="url">
<value>jdbc:jtds:sqlserver://127.0.0.1:1433/Sample</value>
</property>
<property name="username">
<value>test</value>
</property>
<property name="password">
<value>changeit</value>
</property>
</bean>
<bean id="transactionManager"
class="org.springframework.jdbc.datasource.DataSourceTransac
tionManager">
<property name="dataSource">
<ref local="dataSource" />
</property>
</bean>
<bean id="userDAO" class="net.xiaxin.dao.UserDAO">
<property name="dataSource">
<ref local="dataSource" />
</property>
<property name="transactionManager">
<ref local="transactionManager" />
</property>
</bean>
</beans>
---------------------------------↑-------------------------------↑-----------------------------------
配置中包含了三个节点:
● dataSource
这里我们采用了apache dhcp组件提供的DataSource实现，并为其配置了
JDBC驱动、数据库URL、用户名和密码等参数。
● transactionManager
针对JDBC DataSource类型的数据源，我们选用了
DataSourceTransactionManager
作为事务管理组件。
如果需要使用基于容器的数据源（JNDI），我们可以采用如下配置：
---------------------------------↓-------------------------------↓-----------------------------------
<bean id="dataSource"
class="org.springframework.jndi.JndiObjectFactoryBean">
<property name="jndiName">
<value>jdbc/sample</value>
</property>
</bean>
<bean id="transactionManager"
class="org.springframework.transaction.jta.JtaTrans
actionManager"
/>
---------------------------------↑-------------------------------↑-----------------------------------
userDAO 申明了一个UserDAO Bean，并为其指定了dataSource和
transactionManger资源。
UserDAO对应的代码如下：
---------------------------------↓-------------------------------↓-----------------------------------
public class UserDAO {
private DataSource dataSource;
private PlatformTransactionManager transactionManager;
public PlatformTransactionManager getTransactionManager() {
return transactionManager;
}
public void setTransactionManager(PlatformTransactionManager
transactionManager) {
this.transactionManager = transactionManager;
}
public DataSource executeTestSource() {
return dataSource;
}
public void setDataSource(DataSource dataSource) {
this.dataSource = dataSource;
}
public void insertUser() {
TransactionTemplate tt =
new TransactionTemplate(getTransactionManager());
tt.execute(new TransactionCallback() {
public Object doInTransaction(TransactionStatus status) {
JdbcTemplate jt = new JdbcTemplate(executeTestSource());
jt.update(
"insert into users (username) values ('xiaxin');");
jt.update(
"insert into users (id,username) values(2,
'erica');");
return null;
}
});
}
}
---------------------------------↑-------------------------------↑-----------------------------------
可以看到，在insertUser方法中，我们引入了一个新的模板类：
org.springframework.transaction.support.TransactionTemplate。
TransactionTemplate封装了事务管理的功能，包括异常时的事务回滚，以及操作成
功后的事务提交。和JdbcTemplate一样，它使得我们无需在琐碎的try/catch/finally代码
中徘徊。在doInTransaction中进行的操作，如果抛出未捕获异常将被自动回滚，如果成功执行，
则将被自动提交。
这里我们故意制造了一些异常来观察数据库操作是否回滚（通过在第二条语句中更新自
增ID字段故意触发一个异常）：
编写一个简单的TestCase来观察实际效果：
---------------------------------↓-------------------------------↓-----------------------------------
InputStream is = new FileInputStream("Application-Context.xml");
XmlBeanFactory factory = new XmlBeanFactory(is);
UserDAO userDAO = (UserDAO) factory.getBean("userDAO");
userDAO.insertUser();
---------------------------------↑-------------------------------↑-----------------------------------
相信大家多少觉得上面的代码有点凌乱，Callback类的编写似乎也有悖于日常的编程
习惯（虽然笔者觉得这一方法比较有趣，因为它巧妙的解决了笔者在早期自行开发数据访问
模板中曾经遇到的问题）。
如何进一步避免上面这些问题？Spring 的容器事务管理机制在这里即体现出其强大
的能量。

★ 参数化配置的事务管理
在上面的Application-Context.xml增加一个事务代理（UserDAOProxy）配置，同时，
由于事务由容器管理，UserDAO不再需要TransactionManager设定，将其移除：
---------------------------------↓-------------------------------↓-----------------------------------
<bean id="UserDAOProxy"
class="org.springframework.transaction.interceptor.Transac
tionProxyFactoryBean">
<property name="transactionManager">
<ref bean="transactionManager" />
</property>
<property name="target">
<ref local="userDAO" />
</property>
<property name="transactionAttributes">
<props>
<prop key="insert*">PROPAGATION_REQUIRED</prop>
<prop key="*">PROPAGATION_REQUIRED,readOnly</prop>
</props>
</property>
</bean>
<bean id="userDAO" class="net.xiaxin.dao.UserDAO">
<property name="dataSource">
<ref local="dataSource" />
</property>
</bean>
---------------------------------↑-------------------------------↑-----------------------------------
上面的配置中，UserDAOProxy节点配置了一个针对userDAO bean的事务代理（由
target属性指定）。
通过transactionAttributes属性，我们指定了事务的管理策略，即对所有以insert
开头的方法进行事务管理，如果被管理方法抛出异常，则自动回滚方法中的事务，如果成功
执行，则在方法完成之后进行事务提交。另一方面，对于其他方法（通过通配符*表示），
则进行只读事务管理，以获得更好的性能。
与之对应，UserDAO.insertUser的代码修改如下：
---------------------------------↓-------------------------------↓-----------------------------------
public void insertUser(RegisterInfo regInfo) {
JdbcTemplate jt = new JdbcTemplate(executeTestSource());
jt.update("insert into users (username) values ('xiaxin');");
jt.update("insert into users (id,username) values (2,'erica');");
}
---------------------------------↑-------------------------------↑-----------------------------------
测试代码修改如下：
---------------------------------↓-------------------------------↓-----------------------------------
InputStream is = new FileInputStream("Application-Context.xml");
XmlBeanFactory factory = new XmlBeanFactory(is);
//注意这里须通过代理Bean"userDAOProxy"获得引用，而不是直接getBean(“userDAO”)
//此外这里还存在一个有关强制转型的潜在问题，请参见Hibernate in Spring一节后
//关于强制转型的补充描述。
UserDAO userDAO = (UserDAO) factory.getBean("userDAOProxy");
userDAO.insertUser();
---------------------------------↑-------------------------------↑-----------------------------------
可以看到，insertUser变得非常简洁。数据逻辑清晰可见，对比前面代码控制的事务
管理，以及传统的JDBC操作，相信大家会有一些霍然开朗的感觉。
细心的读者会说，这只不过将代码转移到了配置文件，并没有减少太多的工作量。这点
区别也许并不重要，从应用维护的角度而言，配置化的事务管理显然更具优势。何况，实际
开发中，如果前期设计细致，方法的事务特性确定之后一般不会发生大的变动，之后频繁的
维护过程中，我们只需面对代码中的数据逻辑即可。
上面我们结合JdbcTemplate介绍了Spring中的模板操作以及事务管理机制。Spring
作为一个开放式的应用开发平台。同时也针对其他组件提供了良好的支持。在持久层，
Spring提供面向了Hibernate、ibatis和JDO的模板实现，同样，这些实现也为我们的开发
提供了强有力的支持。