JDBCTemplate事物处理-转载

谁践踏了优雅 2022-05-21 03:38 269阅读 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">

</property>

<property name="password">

<value>changeit</value>

</property>

</bean>

<bean id="transactionManager"  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

<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.JtaTransactionManager"/>

Ø 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 的容器事务管理机制在这里即体现出其强大的能量。

u 参数化配置的事务管理

在上面的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");