我要求在单个DAO类中使用2个不同的数据库.其中一个数据库是读/写,而另一个是只读的.
我为这些数据库创建了2个数据源,2个会话工厂和2个事务管理器(读/写数据库的事务管理器是平台事务管理器).我在服务方法上使用@Transactional来配置Spring进行事务管理.
我们随机会话已关闭！当我们在DAO类中调用sessionFactory.getCurrentSession()时出现异常(我不能总是生成它,它有时可以正常工作,有时会出错)：
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
来自my 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”方法.但传递给它的会话也随机抛出“Session is closed！”例外：
@Autowired
protected HibernateTemplate hibernateTemplate;
@SuppressWarnings("unchecked")
protected Listsql) {
HibernateCallbacksqlQuery query = session.createsqlQuery(sql);
query.setResultTransformer(CriteriaSpecification.ALIAS_TO_ENTITY_MAP);
return query.list();
}
};
return hibernateTemplate.execute(hibernateCallback);
}
你重写Spring,将它设置为SpringSessionContext.class.这几乎肯定是你问题的至少一部分.
Spring管理您的会话对象.它管理的这些会话对象与Spring事务相关联.因此,您收到该错误的事实意味着我很可能是由于您处理交易的方式.
换句话说,不要这样做
Transaction tx = session.beginTransaction();
除非你想自己管理会话的生命周期,在这种情况下你需要调用session.open()和session.close()
而是使用框架来处理事务.我会利用spring方面和使用@Transactional的声明方法,就像我之前描述的那样,它更干净,更简单,但是如果你想要实用,那么你也可以用Spring做到这一点.按照参考手册中列出的示例进行操作.请参阅以下链接：
