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使用连接到数据源1的会话工厂
• da2使用连接到数据源2的会话工厂
• 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);

and for dao2:

getHibernateTemplate().merge(obj);

Answer 1

问题:

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