开发随笔——Spring事务管理 第一部分

前言

我为什么会到spring的事务管理？首先看一下背景和环境

• 项目架构：SSH+MySQL5
• 数据库环境：

数据库Database_A中有一个user表记录着用户信息

数据库Database_B中有一张mdl_user表

• 业务：

业务是这样的，用户登陆到我们网站填写个人信息，如果这些信息与Database_A中某些表的中的数据吻合，那么我们把user表中该用户的status字段设置为1（update操作），同时，我们再将这个用户的某些信息组合成一条记录插入到Database_B的mdl_user表中。

• 问题：

在网站运行过程中，发生过几次Database_A中的user表status状态已经被update成1，而Database_B却没有同步得向mdl_user表insert一条记录的情况。这就造成了2表的数据不同步，Database_A中的user表产生了脏数据。

• 解决方案：

为了杜绝脏数据的产生，于是不得不对系统加入事务管理功能。在mdl_user表插入失败后，能对user表的update更新操作进行rollback回滚。

• 再写两句

之前没有接触过spring的声明式事务，使用的事务都是写在DAO代码中的，这也称之为编程式事务，编程式事务的缺点有很多，第一是事务与数据层耦合，第二是编程式事务不能对多个DAO的事务进行回滚。但是我所遇到的问题已经不仅仅是spring的事务管理就可以解决的，因为我用到了2个Database，所以已经属于分布式事务的范畴了！（搞大了）

• 教程大纲

所以接下来的篇幅，我会先使用一个例子较为详尽得介绍如何在ssh框架中加入spring的事务管理，然后再将例子稍作修改，来介绍下如何让spring管理起分布式事务。

第一部分 Spring+Hibernate事务管理Demo

0、设计数据，demo中我们使用mysql5数据库建立database，命名为db1。建立两张表分别为user1和user2

两张表的表结构一致，为如下所示

1、首先往MyEclipse里导入SSH模板工程（模板工程是我事先创建的，省得以后用SSH开发时后还要一个一个加载支持，里面还加入了dwr和ext的支持）这里我提供这个模板工程的下载 （ftp下载，勾选连接到服务器，用户名 momo 密码 momoko8443）

2、建立package（模板中已经建好了）结构如下，在com.zhiku.vo包中让hibernate自动生成user1，user2两表的映射类以及*.hbm.xml文件。注意<generator class="native">不要使用increment

3、编写dao接口，daoImp实现，service接口，serviceImpl实现，如下图

关键代码如下：

————————————————————————————————

文件:interface IUser1DAO.java

代码:

public interface IUser1DAO {

public User1 insertUser1(User1 user);

}

——————————————————————————————————

文件:interface IUser2DAO.java

代码:

public interface IUser2DAO {

public User2 insertUser2(User2 user);

}

————————————————————————————————

文件:class User1DAOImpl.java

代码:

public class User1DAOImpl extends HibernateDaoSupport implements IUser1DAO {

public User1 insertUser1(User1 user) {

try{

System.out.println("insert User1开始执行...");

HibernateTemplate ht=getHibernateTemplate();

ht.save(user);

return user;

}

catch(DataAccessException e){

System.err.print("User1DAOImpl insertUser1方法 发生异常");

throw e;

}

}

}

——————————————————————————————————

文件:class User1DAOImp2.java

代码:

public class User2DAOImpl extends HibernateDaoSupport implements IUser2DAO {

public User2 insertUser2(User2 user) {

try{

System.out.println("insert User2开始执行...");

HibernateTemplate ht=getHibernateTemplate();

ht.save(user);

return user;

}

catch(DataAccessException e){

System.err.print("User2DAOImpl insertUser2方法 发生异常");

throw e;

}

}

}

————————————————————————————————————

文件:interface IUser1AndUser2Service.java

代码:

public interface IUser1AndUser2Service {

public void insertUser1AndUser2(User1 user);

}

————————————————————————————————

文件:class User1AndUser2ServiceImpl.java

代码:

public class User1AndUser2ServiceImpl implements IUser1AndUser2Service {

private IUser1DAO user1DAOImpl;

private IUser2DAO user2DAOImpl;

public IUser1DAO getUser1DAOImpl() {

return user1DAOImpl;

}

public void setUser1DAOImpl(IUser1DAO user1DAOImpl) {

this.user1DAOImpl = user1DAOImpl;

}

public IUser2DAO getUser2DAOImpl() {

return user2DAOImpl;

}

public void setUser2DAOImpl(IUser2DAO user2DAOImpl) {

this.user2DAOImpl = user2DAOImpl;

}

public void insertUser1AndUser2(User1 user) {

try{

System.out.println("insertUser1AndUser2 方法开始执行");

User1 insertedUser1=user1DAOImpl.insertUser1(user);

User2 user2=new User2();

user2.setName(insertedUser1.getName());

user2DAOImpl.insertUser2(user2);

}

catch(DataAccessException e){

System.err.println("service 抛出异常");

}

}

}

————————————————————————————————————

4、接下去我们写spring配置文件，先来看看原始的已经生成datasource和sessionFactory的applicationContext.xml

——————————————————————

文件:applicationContext.xml

配置:

<bean id="dataSource"

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

<property name="driverClassName"

value="com.mysql.jdbc.Driver">

</property>

<property name="url" value="jdbc:mysql://localhost:3306/db1"></property>

<property name="username" value="root"></property>

<property name="password" value="root"></property>

</bean>

<bean id="sessionFactory"

class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">

<property name="dataSource">

<ref bean="dataSource" />

</property>

<property name="hibernateProperties">

<props>

<prop key="hibernate.dialect">

org.hibernate.dialect.MySQLDialect

</prop>

</props>

</property>

<property name="mappingResources">

<list>

<value>com/zhiku/vo/User1.hbm.xml</value>

<value>com/zhiku/vo/User2.hbm.xml</value>

</list>

</property>

</bean>

——————————————————————————

先写IOC，往配置文件中加入daoImp 和serviceImp的注入配置

——————————————————————————

文件:applicationContext.xml

配置:

<bean id="user1DAOImpl" class="com.zhiku.dao.impl.User1DAOImpl">

<property name="sessionFactory">

<ref local="sessionFactory"/>

</property>

</bean>

<bean id="user2DAOImpl" class="com.zhiku.dao.impl.User2DAOImpl">

<property name="sessionFactory">

<ref local="sessionFactory"/>

</property>

</bean>

<bean id="user1AndUser2ServiceImpl" class="com.zhiku.service.impl.User1AndUser2ServiceImpl">

<property name="user1DAOImpl">

<ref local="user1DAOImpl"/>

</property>

<property name="user2DAOImpl">

<ref local="user2DAOImpl"/>

</property>

</bean>

————————————————————————————————

5、关键的来了，加入spring的事务管理

————————————————————————————————

文件:applicationContext.xml

配置:

<!—声明一个hibernateTransactionManager 来管理sesseionFactory的事务-->

<bean id="hibernateTransactionManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">

<property name="sessionFactory">

<ref local="sessionFactory"/>

</property>

</bean>

<!—-代理类，用来代理user1AndUser2ServiceImpl，了解Spring Aop的朋友已经很好懂，taget就是你要代理的对象，transactionManager设置成前面那个hibernateTransactionManager，下面的transactionAttributes 是用来定义那些方法需要添加进事务，这里用了insert*通配符的方式定义所有insert开头的方法都要被添加进事务（REQUIRED）-->

<bean id="user1AndUser2ServiceProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">

<property name="transactionManager">

<ref local="hibernateTransactionManager"/>

</property>

<property name="target">

<ref local="user1AndUser2ServiceImpl"/>

</property>

<property name="transactionAttributes">

<props>

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

</props>

</property>

</bean>

————————————————————————————————————

6、写action 测试事务提交，方便起见这里就不使用struts的action来调用user1AndUser2ServiceProxy了，直接在com.zhiku.struts.action下建立一个TestAction类，在main方法中调用user1AndUser2ServiceProxy测试事务。

——————————————————————————————————

文件:class TestAction.java

代码:

public static void main(String[] args) {

try{

ApplicationContext ctx=new ClassPathXmlApplicationContext("applicationContext.xml");

IUser1AndUser2Service user1AndUser2ServiceImpl=(IUser1AndUser2Service)ctx.getBean("user1AndUser2ServiceProxy");

User1 user=new User1();

user.setName("momoko");

user1AndUser2ServiceImpl.insertUser1AndUser2(user);

}

catch(DataAccessException e){

System.err.println("action 执行中发生异常");

}

}

——————————————————————————————

执行这个action。db1中的user1和user2两表应该插入了相同的记录，控制台输出

查看数据库，可以发现插入成功，两表都各自新增一行记录“1 、 momoko”。

7、测试事务的回滚：因为在两表的插入过程中没有发生异常错误，故事务提交成功，为了演示事务管理中最重要的回滚操作，我们需要插入user2表的时候来点小错误。俗话说得好没有困难，我们也要制造困难帮助他。

修改一下User1AndUser2ServiceImpl.java 让其插入user2表的时候将name字段加大到45字符以上，使其在持久化时抛出DataAccessException异常

——————————————————————————

文件:class User1AndUser2ServiceImpl.java

代码:

public void insertUser1AndUser2(User1 user) {

try{

System.out.println("insertUser1AndUser2 方法开始执行");

User1 insertedUser1=user1DAOImpl.insertUser1(user);

User2 user2=new User2();

String tmp="制造困难制造困难制造困难制造困难制造困难制造困难制造困难制造困难制造困难制造困难制造困难制造困难";

user2.setName(insertedUser1.getName()+tmp);

user2DAOImpl.insertUser2(user2);

}

catch(DataAccessException e){

System.err.println("service 抛出异常");

throw e;

}

}

——————————————————————————————————————

Run一下，看下控制台。果然如我们所期望的那样，user2DAOImpl的insert方法遇到困难了。

紧接着我们打开mysql，看看user1表的插入有没有被回滚？恩，很好，还是各有1条记录。OK!!! Rollback成功。

 

至此第一部分非分布式的事务管理演示完毕，晚上继续第二部分 spring管理分布式事务。

这里提供下这个demo的工程包下载（jar包已经除去，ftp下载，勾选连接到服务器，用户名 momo 密码 momoko8443）

• spring_hibernate_transaction_Demo.rar (739 KB)
• 描述: spring + hibernate 事务管理demo工程源码（无jar包）
• 下载次数: 95

分享到：

第二部分spring+hibernate+jta 分布式事务 ...

• 2008-05-07 12:54
• 浏览 2807
• 评论(0)
• 查看更多