hibernate - Spring:HibernateTransactionManager 处理多个数据源

Question

在以下代码中(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);

Answer 1

问题:

我刚刚花了一天时间处理这个确切的问题:为什么跨数据源的事务似乎可以与一个 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 来实现。