带有 2 个数据库的休眠随机“会话已关闭错误”

Question

我需要在单个 DAO 类中使用 2 个不同的数据库。其中一个数据库是读/写的，而另一个是只读的。

我为这些数据库创建了 2 个数据源、2 个会话工厂和 2 个事务管理器（读/写数据库的事务管理器是平台事务管理器）。我在服务方法上使用@Transactional 来配置Spring 进行事务管理。

当我们在 DAO 类中调用 sessionFactory.getCurrentSession() 时，我们得到随机 Session is closed! 异常（我不能总是生成它，它有时可以正常工作，有时会出错）：

org.hibernate.SessionException: Session is closed!
at org.hibernate.internal.AbstractSessionImpl.errorIfClosed(AbstractSessionImpl.java:133)
at org.hibernate.internal.SessionImpl.setFlushMode(SessionImpl.java:1435)
at org.springframework.orm.hibernate4.SpringSessionContext.currentSession(SpringSessionContext.java:99)
at org.hibernate.internal.SessionFactoryImpl.getCurrentSession(SessionFactoryImpl.java:1014)

我不需要使用全局事务 (XA)，我只想查询 2 个不同的数据库。

我已经阅读了这个帖子，它建议像我们现在一样在 DAO 层中注入两个单独的会话工厂：Session factories to handle multiple DB connections

根据这个答案，AbstractRoutingDataSource 也不适用于单个 Dao 类：https://stackoverflow.com/a/7379048/572380

我的 dao 中的示例代码如下所示：

Criteria criteria = sessionFactory1.getCurrentSession().createCriteria(MyClass.class);
criteria.add(Restrictions.eq("id", id));
criteria.list();

criteria = sessionFactory2.getCurrentSession().createCriteria(MyClass2.class); // generates random "Session is closed!" error.
criteria.add(Restrictions.eq("id", id));
criteria.list();

我也尝试过使用“doInHibernate”方法。但是传递给它的会话也随机抛出“会话已关闭！”例外：

    @Autowired
    protected HibernateTemplate hibernateTemplate;

    @SuppressWarnings("unchecked")
    protected List<Map<String, Object>> executeStaticQuery(final String sql) {
        HibernateCallback<List<Map<String, Object>>> hibernateCallback = new HibernateCallback<List<Map<String, Object>>>() {
            @Override
            public List<Map<String, Object>> doInHibernate(Session session) throws HibernateException {
                SQLQuery query = session.createSQLQuery(sql);
                query.setResultTransformer(CriteriaSpecification.ALIAS_TO_ENTITY_MAP);
                return query.list();
            }
        };
        return hibernateTemplate.execute(hibernateCallback);
    }

Answer 1

那么您的应用程序中有以下代码吗？如果你不添加它，可能是它导致了问题。

<bean id="transactionManager"   
class="org.springframework.orm.hibernate3.HibernateTransactionManager">    
<property name="sessionFactory" ref="sessionFactory"/>    
</bean>    
<tx:annotation-driven/>

删除该属性，如下所述

<property name="current_session_context_class">thread</property>

您正在覆盖将其设置为 SpringSessionContext.class 的 Spring。几乎可以肯定，这至少是您问题的一部分。

Spring 管理您的会话对象。它管理的这些会话对象与 Spring 事务相关联。因此，您收到该错误的事实对我来说意味着这很可能是由于您处理交易的方式。

换句话说，不要这样做

Transaction tx = session.beginTransaction();

除非你想自己管理会话的生命周期，在这种情况下你需要调用 session.open() 和 session.close()

改为使用框架来处理事务。我会利用 Spring 方面和使用 @Transactional 的声明性方法，就像我之前描述的那样，它既干净又简单，但是如果你想务实地做到这一点，你也可以使用 Spring 来做到这一点。按照参考手册中概述的示例进行操作。请看以下链接：

http://static.springsource.org/spring/docs/3.1.x/spring-framework-reference/html/orm.html#orm-hibernate-tx-programmatic

Answer 2

以上错误提示，您无法获取会话，因为会话有时会关闭。您可以使用 openSession() 方法代替 getCurrentSession() 方法。

Session session = this.getSessionFactory().openSession();
session.beginTransaction();
// Your Code Here.
 session.close();

这种方法的缺点是您将明确需要关闭会话。 在单线程环境中，它比 getCurrentSession() 慢。

也请检查此链接：- Hibernate Session is closed

Answer 3

问题是您有一个休眠会话和两个数据存储。会话绑定到事务。如果您向另一个数据库打开一个新事务，这将有效地为该数据库和该实体管理器打开一个新会话。

这相当于@Transactional(propagation = Propagation.REQUIRES_NEW)

您需要确保有两个不同的事务/会话绑定到对两个数据库的每个持久操作。

Answer 4

如果所有配置都正确，那么一切都应该正常工作而不会出错

我认为你在 DAO 中错过了 @Qualifier(value="sessionFactory1") and @Qualifier(value="sessionFactory2")

请看这些例子

Hibernate configuring multiple datasources and multiple session factories

https://medium.com/@joeclever/using-multiple-datasources-with-spring-boot-and-spring-data-6430b00c02e7

Answer 5

不鼓励使用 HibernateTemplate。这里给出了明确的解释https://stackoverflow.com/a/18002931/1840818

如上所述，必须使用声明式事务管理。