在以下代码中(Spring 3):
@Transactional("txManager")
public class DaoHolder {
@Transactional(value="txManager", readOnly=false, propagation=Propagation.REQUIRES_NEW, rollbackFor={Exception.class})
private void runTransactionalMethod() throws Exception {
dao1.insertRow();
dao2.insertRow();
//throw new Exception();
}
//...
}
- dao1 使用附加到 datasource1 的 session 工厂
- dao2 使用附加到 datasource2 的 session 工厂
- txManager 是一个 HibernateTransactionManager,使用与 dao1 相同的 session 工厂
上面的代码以事务方式正常工作 - 特别是,当没有抛出异常时,每个 dao 操作都会被提交(到 2 个不同的数据源)。当抛出异常时,每个 dao 操作都会回滚。
我的问题是:它为什么会起作用?我读过的所有地方都被告知在处理多个数据源时使用 JtaTransactionManager。我宁愿不使用JTA。 如果我让它在 HibernateTransactionManager 下运行会产生什么后果?
更多细节供有兴趣的人引用:
每个数据源的定义如下:
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="${jdbc.driverClassName}" />
<property name="url" value="${jdbc.url}" />
<property name="username" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
<property name="initialSize" value="${jdbc.initial_size}" />
<property name="maxActive" value="${jdbc.max_active}" />
</bean>
每个 session 工厂的定义如下:
<bean id="sessionFactory" class="org.springframework.orm.hibernate3.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="mappingResources">
<list>
... multiple *.hbm.xml files here ...
</list>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">${hibernate.dialect}</prop>
<prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
</props>
</property>
</bean>
事务管理器的定义如下:
<bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory"/>
</bean>
每个 dao 类都扩展了 HibernateDaoSupport,insertRow 方法的内容或多或少类似于 dao1:
getHibernateTemplate().save(obj);
对于 dao2:
getHibernateTemplate().merge(obj);
最佳答案
问题:
我刚刚花了一天时间处理这个确切的问题:为什么跨数据源的事务似乎可以与一个 hibernate 事务管理器一起使用?
和你一样,我也在多个地方读到了我需要使用 JtaTransactionManager 的文章……结果证明他们是对的!我来解释一下:
配置:
和你一样,我从 2 个数据源、2 个 session 工厂和 1 个 HibernateTransactionManager 开始。
我的测试代码看起来也与您的非常相似,我可以成功地将对象保存到两个数据库中。如果我手动抛出异常,则数据库中不会出现任何保存。因此,似乎两者都被正确回滚。但是,当我打开 hibernate 的调试日志记录时,我可以看到 实际上并没有将保存发送到数据库,因此没有什么可以回滚。
问题出在测试中,所以我改一下你的测试,证明单事务管理器确实不行!
JB Nizet 在 1 月 2 日提出了我们需要的改变:
Have you tried calling flush on both sessions before throwing the exception?
更好的测试:
首先,为每个 DAO 添加一个刷新函数。这是我的样子:
public void flush() {
sessionFactory.getCurrentSession().flush();
}
你的可能看起来像这样:
public void flush() {
getHibernateTemplate().flush();
}
现在,修改您的测试以在异常之前刷新每个 dao:
@Transactional("txManager")
public class DaoHolder {
@Transactional(value="txManager", readOnly=false, propagation=Propagation.REQUIRES_NEW, rollbackFor={Exception.class})
private void runTransactionalMethod() throws Exception {
dao1.insertRow();
dao2.insertRow();
dao1.flush();
dao2.flush();
throw new Exception();
}
//...
}
结果:
只有与 txManager 关联的数据源被回滚。这是有道理的,因为 txManager 不知道其他数据源。
总结:
就我而言,我不需要在一个事务中访问 2 个数据库,单独的事务就可以了。所以我简单地定义了第二个事务管理器:
<bean id="txManager2" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory2"/>
</bean>
并在我访问第二个数据库的任何地方的事务注释中按名称引用它:
@Transactional(value="txManager2"...)
我现在可以为我的第二个数据库获取带注释的事务,但我仍然无法跨两个数据库获取事务...看来您需要一个 JtaTransactionManager 来实现。
关于hibernate - Spring:HibernateTransactionManager 处理多个数据源,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/8700160/