Spring + Hibernate的多租户：“SessionFactory配置为多租户，但没有指定租户标识符”

在Spring 3应用程序中，我试图通过Hibernate 4的本机MultiTenantConnectionProvider和CurrentTenantIdentifierResolver实现多租户。 我看到在Hibernate 4.1.3中存在这个问题 ，但是我运行4.1.9并且仍然得到类似的exception：

Caused by: org.hibernate.HibernateException: SessionFactory configured for multi-tenancy, but no tenant identifier specified at org.hibernate.internal.AbstractSessionImpl.(AbstractSessionImpl.java:84) at org.hibernate.internal.SessionImpl.(SessionImpl.java:239) at org.hibernate.internal.SessionFactoryImpl$SessionBuilderImpl.openSession(SessionFactoryImpl.java:1597) at org.hibernate.internal.SessionFactoryImpl.openSession(SessionFactoryImpl.java:963) at org.springframework.orm.hibernate4.HibernateTransactionManager.doBegin(HibernateTransactionManager.java:328) at org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java:371) at org.springframework.transaction.interceptor.TransactionAspectSupport.createTransactionIfNecessary(TransactionAspectSupport.java:334) at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:105) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172) at org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:631) at com.afflatus.edu.thoth.repository.UserRepository$$EnhancerByCGLIB$$c844ce96.getAllUsers() at com.afflatus.edu.thoth.service.UserService.getAllUsers(UserService.java:29) at com.afflatus.edu.thoth.HomeController.hello(HomeController.java:37) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:601) at org.springframework.web.method.support.InvocableHandlerMethod.invoke(InvocableHandlerMethod.java:219) at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:132) at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:104) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandleMethod(RequestMappingHandlerAdapter.java:746) at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:687) at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:80) at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:925) at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:856) at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:915) at org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:811) at javax.servlet.http.HttpServlet.service(HttpServlet.java:735) at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:796) at javax.servlet.http.HttpServlet.service(HttpServlet.java:848) at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:671) at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:448) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:138) at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:564) at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:213) at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1070) at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:375) at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:175) at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1004) at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:136) at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:258) at org.eclipse.jetty.server.handler.HandlerCollection.handle(HandlerCollection.java:109) at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97) at org.eclipse.jetty.server.Server.handle(Server.java:439) at org.eclipse.jetty.server.HttpChannel.run(HttpChannel.java:246) at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:265) at org.eclipse.jetty.io.AbstractConnection$ReadCallback.run(AbstractConnection.java:240) at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:589) at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:520) at java.lang.Thread.run(Thread.java:722) enter code here 

以下是相关代码。 在MultiTenantConnectionProvider我现在简单地编写了一些哑代码，每次只返回一个新连接，并且CurrentTenantIdentifierResolver总是返回相同的ID。 显然，这个逻辑是在我设法获得实例化连接之后实现的。

config.xml中

     com.afflatus.edu.thoth.entity     ${hibernate.dialect} ${hibernate.show_sql} ${hibernate.dbm2ddl} DATABASE com.afflatus.edu.thoth.connection.MultiTenantConnectionProviderImpl com.afflatus.edu.thoth.context.MultiTenantIdentifierResolverImpl        

MultiTenantConnectionProvider.java

 package com.afflatus.edu.thoth.connection; import java.util.Properties; import java.util.HashMap; import java.util.Map; import org.hibernate.service.jdbc.connections.spi.AbstractMultiTenantConnectionProvider; import org.hibernate.service.jdbc.connections.spi.ConnectionProvider; import org.hibernate.ejb.connection.InjectedDataSourceConnectionProvider; import org.springframework.jdbc.datasource.DriverManagerDataSource; import org.hibernate.cfg.*; public class MultiTenantConnectionProviderImpl extends AbstractMultiTenantConnectionProvider { private final Map connectionProviders = new HashMap(); @Override protected ConnectionProvider getAnyConnectionProvider() { System.out.println("barfoo"); Properties properties = getConnectionProperties(); DriverManagerDataSource ds = new DriverManagerDataSource(); ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://127.0.0.1:3306/test"); ds.setUsername("root"); ds.setPassword(""); InjectedDataSourceConnectionProvider defaultProvider = new InjectedDataSourceConnectionProvider(); defaultProvider.setDataSource(ds); defaultProvider.configure(properties); return (ConnectionProvider) defaultProvider; } @Override protected ConnectionProvider selectConnectionProvider(String tenantIdentifier) { System.out.println("foobar"); Properties properties = getConnectionProperties(); DriverManagerDataSource ds = new DriverManagerDataSource(); ds.setDriverClassName("com.mysql.jdbc.Driver"); ds.setUrl("jdbc:mysql://127.0.0.1:3306/test2"); ds.setUsername("root"); ds.setPassword(""); InjectedDataSourceConnectionProvider defaultProvider = new InjectedDataSourceConnectionProvider(); defaultProvider.setDataSource(ds); defaultProvider.configure(properties); return (ConnectionProvider) defaultProvider; } private Properties getConnectionProperties() { Properties properties = new Properties(); properties.put(AvailableSettings.DIALECT, "org.hibernate.dialect.MySQLDialect"); properties.put(AvailableSettings.DRIVER, "com.mysql.jdbc.Driver"); properties.put(AvailableSettings.URL, "jdbc:mysql://127.0.0.1:3306/test"); properties.put(AvailableSettings.USER, "root"); properties.put(AvailableSettings.PASS, ""); return properties; } } 

CurrentTenantIdentifierResolver.java

 package com.afflatus.edu.thoth.context; import org.hibernate.context.spi.CurrentTenantIdentifierResolver; public class CurrentTenantIdentifierResolverImpl implements CurrentTenantIdentifierResolver { public String resolveCurrentTenantIdentifier() { return "1"; } public boolean validateExistingCurrentSessions() { return true; } } 

任何人都可以看到特别错误吗？ 一旦打开事务，就会抛出exception。 似乎 SessionFactory没有正确打开Session，或者Session只是忽略了CurrentTenantIdentifierResolver返回的值，我认为这是Hibernate 4.1.3中的问题; 本来应该已经解决了。

Answer 1

您是否在代码中的任何位置使用@Transactional（即标记服务或dao类/方法）？ 在我的服务类中注释掉@Transactional之前，我遇到了同样的错误。 我认为这与Hibernate 4的默认openSessionInThread行为有关。

我还配置了hibernate而没有ConnectionProvider和TenantIdentifierResolver的自定义实现。 我正在使用基于jndi的方法，将hibernate.connection.datasource设置为java：// comp / env / jdbc /，然后将jndi资源的名称传递给我的dao方法，该方法调用sessionFactory.withOptions（ ）.tenantIdentifier（租客）.openSession（）;

我还在玩，看看我是否可以使用@Transactional进行配置，但是基于jndi的方法在线程行为中使用默认会话似乎现在正在运行。

Answer 2

前瞻：虽然我接受了这个（将）包含代码的答案，如果您认为这是有用的，请提升Darren的答案 。 他是我能够解决这个问题的原因。

好的，我们在这里……

正如Darren指出的那样 ，这实际上是SessionFactory不正确地实例化会话的问题。 如果您要手动实例化会话，则没有问题。 例如：

 sessionFactory.withOptions().tenantIdentifier(tenant).openSession(); 

但是，@ @Transactional注释会导致SessionFactory使用sessionFactory.getCurrentSession()打开会话，该会话不会从CurrentTenantIdentifierResolver提取租户标识符。

Darren建议在DAO层手动打开Session，但这意味着每个DAO方法都有一个本地范围的事务。 更好的地方是服务层。 每个服务层调用（即doSomeLogicalTask() ）可以调用多个DAO方法。 有意义的是，每个都应该绑定到同一个事务，因为它们在逻辑上是相关的。

此外，我不喜欢在每个服务层方法中复制代码以创建和管理事务的想法。 相反，我使用AOP来包装我的服务层中的每个方法，并提供实例化新Session和处理事务的建议。 方面将当前Session存储在TheadLocal堆栈中，DAO层可以访问该堆栈以进行查询。

所有这些工作将允许接口和实现保持与其错误修复的对应物相同，除了DAO超类中的一行将从ThreadLocal堆栈而不是SessionFactory获取Session 。 修复错误后，可以更改此设置。

一旦我清理了一下，我会很快发布代码。 如果有人发现任何问题，请随时在下面讨论。

Answer 3

虽然这可能是一个较旧的主题，但答案可能已经得到了解决。 我注意到的是以下内容：

在您的定义中，类CurrentTenantIdentifierResolverImpl：

 public class CurrentTenantIdentifierResolverImpl implements CurrentTenantIdentifierResolver 

但是在您的配置中，您引用了MultiTenantIdentifierResolverImpl：

 com.afflatus.edu.thoth.context.MultiTenantIdentifierResolverImpl 

只是指出这一点，因为我今天犯了同样的错误，之后它就像一个魅力。

Answer 4

正如我在本文中所解释的，Hibernate定义了CurrentTenantIdentifierResolver接口，以帮助Spring或Java EE等框架允许使用默认的Session实例化机制（来自EntityManagerFactiry ）。

因此，必须通过配置属性设置CurrentTenantIdentifierResolver ，这是您出错的原因，因为您没有提供正确的完全限定类名。 CurrentTenantIdentifierResolver实现是CurrentTenantIdentifierResolverImpl ， hibernate.tenant_identifier_resolver必须是：

 com.afflatus.edu.thoth.context.CurrentTenantIdentifierResolverImpl 

修复此问题后，当HibernateTransactionManager调用getSessionFactory().openSession() ，Hibernate将使用CurrentTenantIdentifierResolverImpl来解析租户标识符。

Answer 5

也许您需要将hibernate的版本升级到最后的4.X并使用注释或方面来启动事务

Answer 6

当我的CurrentTenantIdentifierResolver实现为resolveCurrentTenantIdentifier（）方法返回null时，我遇到了类似的问题