DBMNG数据库管理与应用

书籍是全世界的营养品。生活里没有书籍,就好像没有阳光;智慧里没有书籍,就好像鸟儿没有翅膀。
当前位置:首页 > 经验分享 > Java组件

java+Spring3.0+中的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的模板实现,同样,这些实现也为我们的开发
提供了强有力的支持。

本站文章内容,部分来自于互联网,若侵犯了您的权益,请致邮件chuanghui423#sohu.com(请将#换为@)联系,我们会尽快核实后删除。
Copyright © 2006-2023 DBMNG.COM All Rights Reserved. Powered by DEVSOARTECH            豫ICP备11002312号-2

豫公网安备 41010502002439号