问题 Spring：HibernateTransactionManager处理多个数据源

在下面的一段代码中（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的会话工厂
dao2使用附加到datasource2的会话工厂
txManager是一个 为HibernateTransactionManager 使用与dao1相同的会话工厂

上面的代码 以事务方式正常工作 - 特别是，当没有抛出异常时，每个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>

每个会话工厂的定义如下：

<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个会话工厂和1个HibernateTransactionManager开始。

我的测试代码看起来与你的非常相似，我可以成功地将对象保存到两个数据库。如果我手动抛出异常，则数据库中都不会出现保存。所以它们似乎正在被正确回滚。但是，当我打开hibernate的调试日志时，我可以看到 实际上没有保存实际发送到数据库，所以没有任何回滚。

问题出在测试中，因此我将更改您的测试以证明单个事务管理器实际上不起作用！

我们需要的改变是由JB Nizet在1月2日提出的：

在抛出异常之前，您是否尝试在两个会话上调用flush？

一个更好的测试：

首先，为每个DAO添加一个flush函数。这就是我的样子：

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注释中通过名称引用它：

@Transactional(value="txManager2"...)

我现在可以为我的第二个数据库获取带注释的事务，但我仍然无法跨两个数据库获取事务......似乎你需要一个 的JtaTransactionManager 为了那个原因。

你能展示代码吗？ insertRow() 会话工厂，事务管理器等的配置和配置？ - axtavt

当然，刚刚补充:) - machinery

您确定您的DAO实际使用不同的数据源吗？从您发布的配置中不清楚。 - axtavt

是的，我百分百肯定。操作完成后，我实际检查数据库的结果，所以为了这个问题，我必须配置错误并查看同一个数据库。数据源是位于同一主机上的两个Postgres DB。 - machinery

在抛出异常之前，您是否尝试在两个会话上调用flush？ - JB Nizet

非常感谢这个非常详细的解释:)我将不得不再次看看我的测试，但是AFAIR我实际上看到了数据库中出现的行而不仅仅是在Hibernate中。我会告诉你我的发现。问候美丽的奥斯汀市（曾经住在那里:)）... - machinery

在原始测试中，直到异常之后才会发生刷新。因此，数据库要么成功地插入和提交两个行，要么在任何插入命中数据库之前失败。事务和回滚的目的是撤消已经命中数据库的未提交的插入。 - Henry

（续）令人困惑的是，如果您直接使用jdbc，hibernate不会像您期望的那样立即将插入数据发送到数据库。一个类比是你已经写了一张支票，但是你从来没有把它放在邮件中......所以没有必要去银行停止付款。为了测试银行的停止支付系统，我们实际上需要将支票放入邮件中，这就是刷新正在进行的操作。 - Henry

非常感谢！完美的解释。有相同问题的相同情况。现在一切都很清楚了！ - Dante

问题 Spring：HibernateTransactionManager处理多个数据源

答案:

问题：

组态：

一个更好的测试：

结果：

概要：

热门问题