JDBCTemplate事物处理-转载

JdbcTemplate 与事务管理

JdbcTemplate操作采用的是JDBC默认的AutoCommit模式，也就是说我们还无法保证数据操作的原子性（要么全部生效，要么全部无效），如：

JdbcTemplatejdbcTemplate=newJdbcTemplate(dataSource);

jdbcTemplate.update("UPDATEuserSETage=10WHEREid='erica'");

jdbcTemplate.update("UPDATEuserSETage=age+1WHEREid='erica'");

由于采用了AutoCommit模式，第一个update操作完成之后被自动提交，数据库中”erica”对应的记录已经被更新，如果第二个操作失败，我们无法使得整个事务回滚到最初状态。对于这个例子也许无关紧要，但是对于一个金融帐务系统而言，这样的问题将导致致命错误。

为了实现数据操作的原子性，我们需要在程序中引入事务逻辑，在JdbcTemplate中引入事务机制，在Spring中有两种方式：

1．代码控制的事务管理

2．参数化配置的事务管理

下面就这两种方式进行介绍。

代码控制的事务管理

首先，进行以下配置，假设配置文件为（Application-Context.xml）：

<beans>

<beanid="dataSource"

class="org.apache.commons.dbcp.BasicDataSource"

destroy-method="close">

<propertyname="driverClassName">

<value>net.sourceforge.jtds.jdbc.Driver</value>

</property>

<propertyname="url">

<value>jdbc:jtds:sqlserver://127.0.0.1:1433/Sample</value>

</property>

<propertyname="username">

<value>test</value>

</property>

<propertyname="password">

<value>changeit</value>

</property>

</bean>

<beanid="transactionManager"

class="org.springframework.jdbc.datasource.DataSourceTransac

tionManager">

<propertyname="dataSource">

<reflocal="dataSource"/>

</property>

</bean>

<beanid="userDAO"class="net.xiaxin.dao.UserDAO">

<propertyname="dataSource">

<reflocal="dataSource"/>

</property>

<propertyname="transactionManager">

<reflocal="transactionManager"/>

</property>

</bean>

</beans>

配置中包含了三个节点:

ØdataSource

这里我们采用了apachedhcp组件提供的DataSource实现，并为其配置了

JDBC驱动、数据库URL、用户名和密码等参数。

ØtransactionManager

针对JDBCDataSource类型的数据源，我们选用了

DataSourceTransactionManager

作为事务管理组件。

如果需要使用基于容器的数据源（JNDI），我们可以采用如下配置：

<beanid="dataSource"

class="org.springframework.jndi.JndiObjectFactoryBean">

<propertyname="jndiName">

<value>jdbc/sample</value>

</property>

</bean>

<beanid="transactionManager"

class="org.springframework.transaction.jta.JtaTrans

actionManager"

/>

ØuserDAO

申明了一个UserDAOBean，并为其指定了dataSource和

transactionManger资源。

UserDAO对应的代码如下：

publicclassUserDAO{

privateDataSourcedataSource;

privatePlatformTransactionManagertransactionManager;

publicPlatformTransactionManagergetTransactionManager(){

returntransactionManager;

}

publicvoidsetTransactionManager(PlatformTransactionManager

transactionManager){

this.transactionManager=transactionManager;

}

publicDataSourceexecuteTestSource(){

returndataSource;

}

publicvoidsetDataSource(DataSourcedataSource){

this.dataSource=dataSource;

}

publicvoidinsertUser(){

TransactionTemplatett=newTransactionTemplate(getTransactionManager());

tt.execute(newTransactionCallback(){

publicObjectdoInTransaction(TransactionStatusstatus){

JdbcTemplatejt=newJdbcTemplate(executeTestSource());

jt.update(

"insertintousers(username)values('xiaxin');");

jt.update(

"insertintousers(id,username)values(2,

'erica');");

returnnull;

}

});

}

}

可以看到，在insertUser方法中，我们引入了一个新的模板类：org.springframework.transaction.support.TransactionTemplate。TransactionTemplate封装了事务管理的功能，包括异常时的事务回滚，以及操作成功后的事务提交。和JdbcTemplate一样，它使得我们无需在琐碎的try/catch/finally代码中徘徊。

在doInTransaction中进行的操作，如果抛出未捕获异常将被自动回滚，如果成功执行，则将被自动提交。

这里我们故意制造了一些异常来观察数据库操作是否回滚（通过在第二条语句中更新自增ID字段故意触发一个异常）：

编写一个简单的TestCase来观察实际效果：

InputStreamis=newFileInputStream("Application-Context.xml");

XmlBeanFactoryfactory=newXmlBeanFactory(is);

UserDAOuserDAO=(UserDAO)factory.getBean("userDAO");

userDAO.insertUser();

相信大家多少觉得上面的代码有点凌乱，Callback类的编写似乎也有悖于日常的编程习惯（虽然笔者觉得这一方法比较有趣，因为它巧妙的解决了笔者在早期自行开发数据访问模板中曾经遇到的问题）。

如何进一步避免上面这些问题？Spring的容器事务管理机制在这里即体现出其强大的能量。

u参数化配置的事务管理

在上面的Application-Context.xml增加一个事务代理（UserDAOProxy）配置，同时，由于事务由容器管理，UserDAO不再需要TransactionManager设定，将其移除：

<beanid="UserDAOProxy"

class="org.springframework.transaction.interceptor.Transac

tionProxyFactoryBean">

<propertyname="transactionManager">

<refbean="transactionManager"/>

</property>

<propertyname="target">

<reflocal="userDAO"/>

</property>

<propertyname="transactionAttributes">

<props>

<propkey="insert*">PROPAGATION_REQUIRED</prop>

<propkey="*">PROPAGATION_REQUIRED,readOnly</prop>

</props>

</property>

</bean>

<beanid="userDAO"class="net.xiaxin.dao.UserDAO">

<propertyname="dataSource">

<reflocal="dataSource"/>

</property>

</bean>

上面的配置中，UserDAOProxy节点配置了一个针对userDAObean的事务代理（由target属性指定）。

通过transactionAttributes属性，我们指定了事务的管理策略，即对所有以insert开头的方法进行事务管理，如果被管理方法抛出异常，则自动回滚方法中的事务，如果成功执行，则在方法完成之后进行事务提交。另一方面，对于其他方法（通过通配符*表示），则进行只读事务管理，以获得更好的性能。

与之对应，UserDAO.insertUser的代码修改如下：

publicvoidinsertUser(RegisterInforegInfo){

JdbcTemplatejt=newJdbcTemplate(executeTestSource());

jt.update("insertintousers(username)values('xiaxin');");

jt.update("insertintousers(id,username)values(2,'erica');");

}

测试代码修改如下：

InputStreamis=newFileInputStream("Application-Context.xml");

XmlBeanFactoryfactory=newXmlBeanFactory(is);

//注意这里须通过代理Bean"userDAOProxy"获得引用，而不是直接getBean(“userDAO”)

//此外这里还存在一个有关强制转型的潜在问题，请参见HibernateinSpring一节后

//关于强制转型的补充描述。

UserDAOuserDAO=(UserDAO)factory.getBean("userDAOProxy");

userDAO.insertUser();

可以看到，insertUser变得非常简洁。数据逻辑清晰可见，对比前面代码控制的事务管理，以及传统的JDBC操作，相信大家会有一些霍然开朗的感觉。

细心的读者会说，这只不过将代码转移到了配置文件，并没有减少太多的工作量。这点区别也许并不重要，从应用维护的角度而言，配置化的事务管理显然更具优势。何况，实际开发中，如果前期设计细致，方法的事务特性确定之后一般不会发生大的变动，之后频繁的维护过程中，我们只需面对代码中的数据逻辑即可。

上面我们结合JdbcTemplate介绍了Spring中的模板操作以及事务管理机制。Spring作为一个开放式的应用开发平台。同时也针对其他组件提供了良好的支持。在持久层，Spring提供面向了Hibernate、ibatis和JDO的模板实现，同样，这些实现也为我们的开发提供了强有力的支持。