JTA不能回滚的问题!

collin000

浏览: 3010 次

最近访客更多访客>>

博主相关

博客

微博

相册

留言

关于我

文章分类

全部博客 (1)

社区版块

存档分类

2007-09 ( 1)
更多存档...

Hibernate Spring JDBC SQL SQL Server

现在公司项目就要开始了, 用 struts2 hibernate spring 开发,.

已经确定使用2个sql server 数据库(sql 2005). 于是使用JTA, jotm 实现分布式事务.

我按照网上搜索的方式配置, 有两个数据源, 产生两个sessionFactory, 但却发现事务无法回滚!!!

看网上说sql 2005 要实现 XA, 需要增加几步操作, 要考一个文件到Binn目录下, 然后执行一个存储过程.

我试了一下, 还是不行.

这个是我测试项目的代码, 就实现一个最简单的插入数据, 也不知道究竟是项目问题还是数据库问题, 总之就是不能回滚~~~

哪位朋友有使用过的经验, 求教! 万分感谢!

以下是spring完整配置:

java 代码

"1.0" encoding="UTF-8"?>
"-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans></beans>
<import resource="classpath:org/codehaus/xfire/spring/xfire.xml"/>
"HelloBean" class="com.powerapps.webservice.HelloImpl" />
"jotm" class="org.springframework.transaction.jta.JotmFactoryBean"/>
"transactionManager" class="org.springframework.transaction.jta.JtaTransactionManager">
"userTransaction">"jotm"/>
"dataSourceA" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown">
"dataSource">
class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown">
"transactionManager">
"jotm" />
"driverName">
<value></value>com.microsoft.sqlserver.jdbc.SQLServerDriver
"url">
<value></value>jdbc:sqlserver://192.168.1.63:1433;selectMethod=cursor;DatabaseName=eHR;
"user">
<value></value>mohr
"password">
<value></value>javadev
"sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
"mappingResources">
<list></list>
<value></value>com/powerapps/model/base/Dictinfo.hbm.xml
<value></value>com/powerapps/model/base/Subdictinfo.hbm.xml
"dataSource">
"dataSourceA" />
"jtaTransactionManager">
"jotm" />
"hibernateProperties">
<props></props>
"hibernate.dialect">org.hibernate.dialect.SQLServerDialect
"hibernate.query.factory_class">org.hibernate.hql.classic.ClassicQueryTranslatorFactory
"hibernate.show_sql">true
"dataSourceB" class="org.enhydra.jdbc.pool.StandardXAPoolDataSource" destroy-method="shutdown">
"dataSource">
class="org.enhydra.jdbc.standard.StandardXADataSource" destroy-method="shutdown">
"transactionManager">
"jotm" />
"driverName">
<value></value>com.microsoft.sqlserver.jdbc.SQLServerDriver
"url">
<value></value>jdbc:sqlserver://192.168.1.63:1433;selectMethod=cursor;DatabaseName=test;
"user">
<value></value>mohr
"password">
<value></value>javadev
"sessionFactoryB" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
"mappingResources">
<list></list>
<value></value>com/powerapps/model/base/Positioninfo.hbm.xml
"dataSource">
"dataSourceB" />
"jtaTransactionManager">
"jotm" />
"hibernateProperties">
<props></props>
"hibernate.dialect">org.hibernate.dialect.SQLServerDialect
"hibernate.query.factory_class">org.hibernate.hql.classic.ClassicQueryTranslatorFactory
"hibernate.show_sql">true
"daoB" class="com.powerapps.dao.base.impl.DaoImplB">
"sessionFactory">
"sessionFactoryB" />
"txProxyTemplate" abstract="true" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
"transactionManager">
"transactionManager"/>
"transactionAttributes">
<props></props>
"get*">PROPAGATION_REQUIRED
"*">PROPAGATION_REQUIRED
"dictProxy" parent="txProxyTemplate" >
"target">
class="com.powerapps.service.admin.base.impl.DictManagerImpl">
"sessionFactory">"sessionFactory" />
"daoB">"daoB" />
"positionProxy" parent="txProxyTemplate" >
"target">
class="com.powerapps.service.admin.base.impl.PositionManagerImpl">
"sessionFactory">"sessionFactoryB" />
"DictAction" class="com.powerapps.action.admin.base.DictAction" singleton="false" autowire="byName">
"SubDictAction" class="com.powerapps.action.admin.base.SubDictAction" singleton="false" autowire="byName">

以下是在struts action中代码:

java 代码

public String test()
{
dictProxy.testJta();
return "DictSearchPage";
}

以下是中间层的代码: 中间曾继承了一个 BaseManagerImpl, 而 BaseManagerImpl 又继承了 BaseDaoImpl

save方法就是 BaseDaoImpl 中实现的. 以下代码中头两条记录都插入进分别的库了, 应该是回滚才对!

java 代码

public void testJta()
{
try
{
Dictinfo aDictinfo = new Dictinfo();
aDictinfo.setName("111");
super.saveObject(aDictinfo);
//数据库1 继承过来 BaseDaoImpl 的sessionsessionFactory
Positioninfo position = new Positioninfo();
position.setName("111");
daoB.saveObject(position);
//数据库2 daoB中的sessionsessionFactory
Dictinfo dictinfo = new Dictinfo();
super.saveObject(dictinfo);
//Name字段不能为空, 出错拉, 应该把之前的插入都回滚
}
catch(Exception e)
{
e.printStackTrace();
}
}

分享到：

2007-09-21 18:03
浏览 3010
评论(12)
论坛回复 / 浏览 (12 / 7449)
查看更多

12 楼 heartsong 2007-09-26

建议用编程式的事务处理。

即类似:
DefaultTransactionDefinition def = new DefaultTransactionDefinition();
def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED);
DataSourceTransactionManager txManager = (DataSourceTransactionManager) BeanFactory.getBeanByName("txManager");
TransactionStatus status = txManager.getTransaction(def);
try{
    //要处理的过程
}
catch (Exception ex) {
    //在这里处理rollback
    txManager.rollback(status);
    log.info("ROLLBACK!");
    throw ex;
}
txManager.commit(status);

11 楼 collin000 2007-09-26

to 楼上:
我想JTA应该是没啥问题, 毕竟是j2ee标准组件, 至于jotm就拿不准了, 它官方2年多没更新了...
哎. 发现要学的东西太多了, 都排成大队了.

PS: 莫非楼上在东京? 强~~~

10 楼 ddandyy 2007-09-26

现在JTA已经比较好了吧反正我们这用着还是不错的
现在的版本也比以前快了很多

9 楼 collin000 2007-09-26

首先非常感谢daquan198163的回答, 终于可以回滚了, 但是在oracle10g下, sql2005下仍然不行. (正在处理中...有经验的朋友请指教啊!!!)
看来程序没有问题, 是数据库没有配好的原因(sql对j2ee支持真是垃圾, oracle什么都不用配).

现在还有几个问题:

1 我的程序没有抛异常(throw new RuntimeException()),但确实是回滚了. 这点和文档与书上说的有点出入, 不知是怎么回事? (以前作单数据源时根本没有在意这件事, 测试一下可以回滚就没有理了) 不过这个是小问题!

2 这个是关于Session的使用.
记得robbin曾经总结说: 使用JTA时是先启动事务, 在这个全局事务范围内会启动多个session, 而hibernate则先打开session再启动事务, 顺序正好相反.
我试了试OpenSessionInView模式, 可以正常使用.
这样是不是说像

Session session = getSession()
session.方法(...)

这样的代码就只能用于读数据,写数据就有问题了? 目前还没试过.

3 我问了一个朋友, 他有很多年经验了. 说JTA事务是比较占资源的, 并且jotm的bug比较多, 使用它们的话不合算, 干脆就不用分布事务. 我想请教一下各位大牛关于这些的看法.

8 楼 daquan198163 2007-09-24

如果这样还不行，只能怀疑SqlServer的问题了

抛异常是必要条件

7 楼 collin000 2007-09-24

谢谢 daquan198163 回答, 我testJta把代码改为:

    catch(Exception e)
    {
    throw new RuntimeException();
    }

仍然不行啊...

顺便说句, 我以前单数据源作的时候都没有抛异常的, 却回滚了...
抛不抛异常是必要条件吗?

6 楼 daquan198163 2007-09-24

不抛异常spring不会回滚事务的

5 楼 collin000 2007-09-24

to daquan198163:
不明白你的意思, 我这个异常捕捉纯粹是为了在控制台看异常情况, 没有其他任何作用的. (我这个只是测试项目, 只是为了测试分布事务)

4 楼 daquan198163 2007-09-24

问题出在这里：
# catch(Exception e)
#     {
#         e.printStackTrace();
#     }
建议补习一下Spring基础

3 楼 collin000 2007-09-24

多谢上面两位关注!
回 daquan198163:

配事务了, testJta方法是 dictProxy 中的方法.

<bean id="txProxyTemplate" abstract="true" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
 <property name="transactionManager">
 <ref bean="transactionManager"/>
 </property>
 <property name="transactionAttributes">
 <props>
<prop key="get*">PROPAGATION_REQUIRED</prop>
<prop key="*">PROPAGATION_REQUIRED</prop>
 </props>
 </property>
</bean>

<bean id="dictProxy" parent="txProxyTemplate" >
 <property name="target">
 <bean class="com.powerapps.service.admin.base.impl.DictManagerImpl">
<property name="sessionFactory"><ref bean="sessionFactory" /></property>
<property name="daoB"><ref bean="daoB" /></property>
</bean>
 </property>
</bean>

2 楼 daquan198163 2007-09-24

<div class='quote_div'>以下是中间层的代码: 中间曾继承了一个 BaseManagerImpl, 而 BaseManagerImpl 又继承了 BaseDaoImpl
save方法就是 BaseDaoImpl 中实现的. 以下代码中头两条记录都插入进分别的库了, 应该是回滚才对!
<div class='code_title'>
<div class='code_title'>java 代码</div>
<div class='dp-highlighter'>
<div class='bar'> </div>
<ol class='dp-j'>
 <li class='alt'>public void testJta() </li>
 <li class=''>{ </li>
 <li class='alt'> try </li>
 <li class=''> { </li>
 <li class='alt'> Dictinfo aDictinfo = new Dictinfo(); </li>
 <li class=''> aDictinfo.setName("111"); </li>
 <li class='alt'> super.saveObject(aDictinfo); </li>
 <li class=''> //数据库1 继承过来 BaseDaoImpl 的sessionsessionFactory </li>
 <li class='alt'> </li>
 <li class=''> Positioninfo position = new Positioninfo(); </li>
 <li class='alt'> position.setName("111"); </li>
 <li class=''> daoB.saveObject(position); </li>
 <li class='alt'> //数据库2 daoB中的sessionsessionFactory </li>
 <li class=''> </li>
 <li class='alt'> Dictinfo dictinfo = new Dictinfo(); </li>
 <li class=''> super.saveObject(dictinfo); </li>
 <li class='alt'> //Name字段不能为空, 出错拉, 应该把之前的插入都回滚 </li>
 <li class=''> } </li>
 <li class='alt'> catch(Exception e) </li>
 <li class=''> { </li>
 <li class='alt'> e.printStackTrace(); </li>
 <li class=''> } </li>
 <li class='alt'> </li>
 <li class=''>} </li>
</ol>
</div>
</div>
</div>
 
 
这个testJta方法配了事务了么？

1 楼 whistler 2007-09-24

关注中，希望有经验得朋友能够给个思路

发表评论

您还没有登录,请您登录后再发表评论

最近访客更多访客>>

博主相关

文章分类

社区版块

存档分类

最新评论