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的会话工厂
• dao2使用附加到datasource2的会话工厂
• txManager是一个使用与dao1相同的会话工厂的HibernateTransactionManager

上面的代码以事务方式正常工作 - 特别是,当没有抛出异常时,每个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,并且对于dao1,insertRow方法的内容或多或少都是这样:

getHibernateTemplate().save(obj);

并为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.