spring事务管理的控制问题

<bean id="transactionManager" class="org.springframework.orm.hibernate.HibernateTransactionManager">
  <property name="sessionFactory"><ref local="sessionFactory"/></property>  
 </bean> 
 
  <bean id="userDao" class="hibernate.dao.Dao">
    <property name="sessionFactory"><ref local="sessionFactory"/></property>
  </bean>
  
  <bean id="userDAOProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
     <property name="transactionManager"><ref local="transactionManager"/></property> 
     <property name="target"><ref local="userDao"/></property>
     <property name="transactionAttributes">
       <props>
                  <prop key="insert*">PROPAGATION_REQUIRED</prop>
                  <prop key="get*">PROPAGATION_REQUIRED,readOnly</prop>
		  <prop key="query">PROPAGATION_REQUIRED,readOnly</prop>
		  <prop key="update">PROPAGATION_REQUIRED</prop>
		  <prop key="execute">PROPAGATION_REQUIRED</prop>  
       </props>
     </property>
  </bean>

用spring跟hibernate结合的方式,如果我在插入一条数据时,想往备份数据库的备份表也插入一条同样的记录
例如

public void update()
{  
//从上面的配置文件,得到两个userDaoProxy对象, 
  formalDaoProxy.update(bean);
  backupDaoProxy.update(bean);
}

这样的话,由于正式表与备份表要保持数据一致性,所以,两个update其中一个失败, 另一个都要rollback , 但是这两个Dao, 分别由两个独立事务来自动管理的, commit或rollback都不能干预, 请问怎样可以用代码来控制其rollback?我找了很久都找不到.请教一下大家, 谢谢.

评论

22 楼 zozofo 2007-06-21  

问题解决了，还是在本网站找到的解决办法。提供URL：http://www.iteye.com/topic/10296（见第6个问题）

21 楼 zozofo 2007-06-20  

id：checkuser更改为：checkuserservice

20 楼 zozofo 2007-06-20  

和kele8boy碰到的情况一样，及时target映射的是service层，service包含的两个不同DAO的方法也不能被事务管理。比如update1()和update2()
$update1()//正确
$update2()//异常
update1（）还是被提交、update2()提交失败。两者并没有管理在同一个事务中。
配置文件如下：

<beans>
<bean id="adminDataSource"
class="org.apache.tomcat.dbcp.dbcp.BasicDataSource"
destroy-method="close">

<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql://localhost/joe" />
<property name="username" value="" />
<property name="password" value="" />
</bean>

<bean id="accountDataSource"
class="org.apache.tomcat.dbcp.dbcp.BasicDataSource"
destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql://localhost/test" />
<property name="username" value="root" />
<property name="password" value="123" />
</bean>

<bean id="mySessionFactory"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="adminDataSource" />
<property name="mappingResources">
<list>
<value>backup/Admin.hbm.xml</value>
</list>
</property>
<property name="hibernateProperties">
<value>org.hibernate.dialect.MySQLDialect</value>
</property>
</bean>

<bean id="mySessionFactory2"
class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="accountDataSource" />
<property name="mappingResources">
<list>
<value>backup/Account.hbm.xml</value>
</list>
</property>
<property name="hibernateProperties">
<value>org.hibernate.dialect.MySQLDialect</value>
</property>
</bean>

<bean id="admindao" class="dao.AdminDAO">
<property name="sessionfactory" ref="mySessionFactory" />
</bean>

<bean id="accountdao" class="dao.AccountDAO">
<property name="sessionfactory" ref="mySessionFactory" />
</bean>



<bean id="checkuser" class="service.local.CheckUser">
<property name="admindao" ref="admindao" />
<property name="accountdao" ref="accountdao" />
</bean>

<bean id="myTxManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="mySessionFactory2"/>
</bean>


<bean id="myProductService"
class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="transactionManager">
<ref local="myTxManager"/>
</property>
<property name="target" ref="checkuserservice"/>


<property name="transactionAttributes">
<props>
<prop key="update*">PROPAGATION_REQUIRED</prop>

</props>
</property>
</bean>



</beans>

19 楼 zzcclp 2007-03-09  

如下是我的代码：
<bean id="userManagerTarget" class="zzc.stu.service.impl.UserManagerImpl">
<property name="dao">
<ref local="userDAO"/>
</property>
</bean>
<bean id="userManager" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="transactionManager">
<ref local="myTransactionManager"/>
</property>
<property name="target">
<ref local="userManagerTarget"/>
</property>
<property name="transactionAttributes">
<props>
<prop key="save*">PROPAGATION_REQUIRED</prop>
<prop key="remove*">PROPAGATION_REQUIRED</prop>
<prop key="*">PROPAGATION_REQUIRED,readOnly</prop>
</props>
</property>
</bean>

18 楼 zzcclp 2007-03-09  

<property name="target"><ref local="userDao"/></property>
你的target指向的应该是service层的类，而不是直接的dao

17 楼 我想我是海 2007-03-06  

terry_yip 写道

因为这种结合方式本身就带"自动"的事务管理机制了.

所谓的自动是不需要你写代码显式进行事务管理。但前提还是还你去手动配置，让Spring知道你哪里需要事务参与。没有说你用Spring配置了一个DAO，那么这个DAO就有了神奇的自动事务管理功能。
最简单的做法就是把你那两个DAO的事务配置去掉（还原从纯粹的Bean非代理Bean），再在Service加上事务代理即可。
这样完整配置下来，从Service开始到结束都是一个事务，两个DAO的操作属于同一个事务中的操作。简单有效，何乐而不为？干嘛要每个DAO配上事务，而且为每个DAO配事务极度不可取。

16 楼 ahuaxuan 2007-03-06  

TransactionProxyFactoryBean的target应该是业务对象，你需要做的就是把业务对象付给TransactionProxyFactoryBean的target，然后其他一样配置，这样，你的service就能享受声明式事务处理了，或者通过自动代理来简化声明式事务的配置也是可以的

15 楼 terry_yip 2007-03-06  

有个问题我不明白, 很多人都说我不应在DAO层做事务管理, 我也认同这个说法,但是,我觉得我是被spring和hibernate结合的方式逼着我这样做的, 因为这种结合方式本身就带"自动"的事务管理机制了. 不知是否我的那个配置文件的bean的名字带有DAO误导了大家,还是我真的有什么别的方法不知道,难道我应该把那个spring默认的事务管废掉,自己写commit, rollback吗? 如果是这样的话, 那我这部分直接用hibernate做算了, 为何还要用spring+hibernate方法呢??请大家指点一下,或说说你们在项目中是怎么处理这个问题的.

14 楼 ahuaxuan 2007-03-06  

是这样的，但是很少有人在dao上做事务控制的，应该是CompleteService类才对，理论上讲我们不应该在持久层做事务控制，应该在业务层（极少数情况除外），楼主对事务的概念非常模糊，建议去系统的看看相关的书籍

13 楼 terry_yip 2007-03-06  

Godlikeme 写道

如果service层有事务控制，整个事务由最外层service层事务控制，propagation required.

你的意思, 是不是这样, 例如 我再写多一个CompleteDao类, 然后加入类似方法

public void updateBoth()
{
   xxDao.update(bean);
   xxBackupDao.update(bean)
}



然后, 在配置文件中,

  <bean id="CompleteDAOProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"> 
     <property name="transactionManager">
          <ref local="transactionManager"/>
     </property>   
     <property name="target"><ref local="CompleteDao"/></property> 
     <property name="transactionAttributes"> 
       <props> 
           <prop key="updateBoth">PROPAGATION_REQUIRED</prop> 
       </props> 
     </property> 
  </bean> 


是不是这样?

12 楼 ahuaxuan 2007-03-06  

terry_yip 写道

ahuaxuan 写道

terry_yip 写道

OK,如果我将事务管理放在service层,但是又要用spring和hibernate结合的方式对数据进行存取,各位如何建议我解决这个问题呢?

这里面根本就没有什么问题，你只要给service加上事务代理就ok了，不会有什么问题

如果我用JDBC的方法来连,  我可以connnection.commit()或connnection.rollback();

如果用hibernate的方式来连接,

Transaction tx = session.beginTransaction();
tx.commit();或tx.rollback();

但用我以上的方式来连接数据库,是怎么rollback()或commit()呢? 其实我问题的核心就是在这个点上.

如果是声明式事务处理，你只要抛出异常就自动rollback了，如果不抛异常，方法自动通过，那就commit了，不需要你手动的rollback何commit，这个就是声明式事务处理的优点之一

11 楼 Godlikeme 2007-03-06  

terry_yip 写道

Godlikeme 写道

有没有service层？
Service层有没有设置transaction？
个人认为，应该在service层做这种事务控制。

有逻辑事务层, 我上面的public void update()方法,就是在相当于你说的service层做的,但问题是, 我再开一个transaction,怎样能控制当其中一个DaoProxy.update(bean)失败了,另一个update的操作rollback?

如果service层有事务控制，整个事务由最外层service层事务控制，propagation required.

10 楼 terry_yip 2007-03-06  

ahuaxuan 写道

terry_yip 写道

OK,如果我将事务管理放在service层,但是又要用spring和hibernate结合的方式对数据进行存取,各位如何建议我解决这个问题呢?

这里面根本就没有什么问题，你只要给service加上事务代理就ok了，不会有什么问题

如果我用JDBC的方法来连,  我可以connnection.commit()或connnection.rollback();

如果用hibernate的方式来连接,

Transaction tx = session.beginTransaction();
tx.commit();或tx.rollback();

但用我以上的方式来连接数据库,是怎么rollback()或commit()呢? 其实我问题的核心就是在这个点上.

9 楼 ahuaxuan 2007-03-06  

terry_yip 写道

OK,如果我将事务管理放在service层,但是又要用spring和hibernate结合的方式对数据进行存取,各位如何建议我解决这个问题呢?

这里面根本就没有什么问题，你只要给service加上事务代理就ok了，不会有什么问题

8 楼 terry_yip 2007-03-06  

OK,如果我将事务管理放在service层,但是又要用spring和hibernate结合的方式对数据进行存取,各位如何建议我解决这个问题呢?

7 楼 ahuaxuan 2007-03-06  

引用

备份数据库的备份表也插入一条同样的记录

备份数据库？ 有两个数据库？
如果主表何备份表在一个schema里，只要把最外面的update方法的事务传播途径设置称required就可以了

6 楼 kof99th 2007-03-06  

事务应该配置在service上，而不是dao

5 楼 kof99th 2007-03-06  

事务应该配置在service上，而不是dao

4 楼 terry_yip 2007-03-06  

我最主要的问题是,

public void update()   
{       
  formalDaoProxy.update(bean);  //update1 
  backupDaoProxy.update(bean);   //update2
}

最主要的问题是, update1一执行成功,马上被自动commit了,如果接下来update2失败了,那主数据库和备份数据库中的数据就不一致了. 所以我想把两个update,归为一个事务当中,两个update都成功,才两个一起commit. 但是又不想把所有相关代码都重写,所以问一下有没有解决的办法.

3 楼 terry_yip 2007-03-06  

Godlikeme 写道

有没有service层？
Service层有没有设置transaction？
个人认为，应该在service层做这种事务控制。

有逻辑事务层, 我上面的public void update()方法,就是在相当于你说的service层做的,但问题是, 我再开一个transaction,怎样能控制当其中一个DaoProxy.update(bean)失败了,另一个update的操作rollback?