java Spring + Hibernate的多租户：SessionFactory已配置为多租户，但未指定租户标识符

gtlvzcf8  于 2023-01-07  发布在  Java
关注(0)|答案(7)|浏览(243)

在一个Spring 3应用程序中，我尝试通过Hibernate 4的本地MultiTenantConnectionProvider和CurrentTenantIdentifierResolver实现多租户，我看到了there was a problem with this in Hibernate 4.1.3，但我运行的是4.1.9，仍然遇到类似的异常：

Caused by:

org.hibernate.HibernateException: SessionFactory configured for multi-tenancy, but no tenant identifier specified
    at org.hibernate.internal.AbstractSessionImpl.<init>(AbstractSessionImpl.java:84)
    at org.hibernate.internal.SessionImpl.<init>(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(<generated>)
    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。显然，这个逻辑是在我设法使连接示例化之后实现的。

配置文件

<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean">
    <property name="dataSource" ref="dataSource" />
    <property name="packagesToScan">
        <list>
            <value>com.afflatus.edu.thoth.entity</value>
        </list>
    </property>
    <property name="hibernateProperties">
        <props>
            <prop key="hibernate.dialect">${hibernate.dialect}</prop>
            <prop key="hibernate.show_sql">${hibernate.show_sql}</prop>
            <prop key="hibernate.hbm2ddl">${hibernate.dbm2ddl}</prop>
            <prop key="hibernate.multiTenancy">DATABASE</prop>
            <prop key="hibernate.multi_tenant_connection_provider">com.afflatus.edu.thoth.connection.MultiTenantConnectionProviderImpl</prop>
            <prop key="hibernate.tenant_identifier_resolver">com.afflatus.edu.thoth.context.MultiTenantIdentifierResolverImpl</prop>
        </props>
    </property>
</bean>

<bean id="transactionManager" class="org.springframework.orm.hibernate4.HibernateTransactionManager">
    <property name="autodetectDataSource" value="false" />
    <property name="sessionFactory" ref="sessionFactory" />
</bean>

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<String, ConnectionProvider> connectionProviders
        = new HashMap<String, ConnectionProvider>();

    @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;
    }

}

有谁能发现什么特别的错误吗？只要打开一个事务，就会抛出一个异常。看起来SessionFactory没有正确打开会话，或者Session只是忽略了CurrentTenantIdentifierResolver返回的值，我相信这是Hibernate 4.1.3中的问题;这个问题应该已经解决了。

Java

7条答案

按热度按时间
h43kikqp

h43kikqp1#

你是否在代码的任何地方使用了@Transactional（比如标记一个服务或者dao类/方法）？
在我注解掉服务类中的@Transactional之前，我一直遇到同样的错误。
我认为这与Hibernate 4的默认openSessionInThread行为有关。
我还配置了没有定制ConnectionProvider和TenantIdentifierResolver实现的hib，我使用基于JNDI的方法，将hib.connection.datasource设置为java：//comp/env/jdbc/，然后将JNDI资源的名称传入我的dao方法，该方法调用
sessionFactory.withOptions().tenantIdentifier(tenant).openSession();
我还在尝试是否可以获得一个可以使用@Transactional的配置，但是基于jndi的方法在线程行为中使用默认会话似乎现在可以工作了。

赞(0）分享  回复(0）举报  2023-01-07
bt1cpqcv

bt1cpqcv2#

  • Forward：虽然我接受了这个答案，其中（将）包含代码，请投赞成票Darren's answer，如果你认为这是有用的。他是我能够解决这个问题的原因。*

好吧，我们开始吧...
As Darren pointed out，这实际上是SessionFactory示例化会话不正确的问题。如果您要手动示例化会话，则不会有任何问题。例如：

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

但是，@Transactional注解导致SessionFactory打开与sessionFactory.getCurrentSession()的会话，这不会从CurrentTenantIdentifierResolver中提取租户标识符。
Darren建议在DAO层手动打开Session，但这意味着每个DAO方法都有一个本地作用域的事务。更好的做法是在服务层。每个服务层调用（即doSomeLogicalTask()）都可能调用多个DAO方法。每个方法都应该绑定到同一个事务，因为它们在逻辑上是相关的。
此外，我不喜欢在每个服务层方法中复制代码来创建和管理事务的想法。相反，我使用AOP来 Package 我的服务层中的每个方法，并建议示例化一个新的Session和处理事务。方面将当前的Session存储在一个TheadLocal堆栈中，DAO层可以访问该堆栈进行查询。
所有这些工作都将允许接口和实现保持与它们修复了bug的对应物相同，除了DAO超类中的一行将从ThreadLocal堆栈而不是SessionFactory获取Session。
我将张贴的代码很快，一旦我清理了一点。如果有人看到任何问题，请随时讨论下面。

赞(0）分享  回复(0）举报  2023-01-07
jgwigjjp

jgwigjjp3#

Hibernate定义了CurrentTenantIdentifierResolver接口，以帮助Spring或JavaEE等框架允许使用默认的Session示例化机制（来自EntityManagerFactory）。
因此，CurrentTenantIdentifierResolver必须通过一个配置属性来设置，这正是您出错的地方，因为您没有提供正确的全限定类名。CurrentTenantIdentifierResolver实现为CurrentTenantIdentifierResolverImpl，hibernate.tenant_identifier_resolver必须为：

<prop key="hibernate.tenant_identifier_resolver">com.afflatus.edu.thoth.context.CurrentTenantIdentifierResolverImpl</prop>

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

赞(0）分享  回复(0）举报  2023-01-07
vaj7vani

vaj7vani4#

尽管这可能是一个比较老的主题，而且答案可能已经被处理过了。我注意到的是以下几点：
在定义类CurrentTenantIdentifierResolverImpl时：

public class CurrentTenantIdentifierResolverImpl implements CurrentTenantIdentifierResolver

但在您的配置中，您引用了多租户标识符解析器实现：

<prop key="hibernate.tenant_identifier_resolver">com.afflatus.edu.thoth.context.MultiTenantIdentifierResolverImpl</prop>

只是指出这一点，因为我今天也犯了同样的错误，在那之后，一切都像一个魅力。

赞(0）分享  回复(0）举报  2023-01-07
7rfyedvj

7rfyedvj5#

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

赞(0）分享  回复(0）举报  2023-01-07
7gyucuyw

7gyucuyw6#

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

赞(0）分享  回复(0）举报  2023-01-07
qq24tv8q

qq24tv8q7#

我使用Sping Boot 3.0.1和Hibernate 6.1.6.Final，通过实现接口HibernatePropertiesCustomizer解决了这个问题。

@Configuration
public class CurrentTenantIdentifierResolverImpl implements CurrentTenantIdentifierResolver, HibernatePropertiesCustomizer {

    private String tenantId = "default";

    @Override
    public String resolveCurrentTenantIdentifier() {
        return tenantId;
    }

    @Override
    public boolean validateExistingCurrentSessions() {
        return false;
    }

    @Override
    public void customize(Map<String, Object> hibernateProperties) {
        hibernateProperties.put(AvailableSettings.MULTI_TENANT_IDENTIFIER_RESOLVER, this);
    }
}

在真实的应用程序中，[字段currentTenant ]将使用不同的作用域（例如request），或者从其他具有适当作用域的bean中获取值。
原始博客文章是作者可以找到here。
必须实现HibernatePropertiesCustomizer这一事实已由blog文章的作者作为issue提交给hib团队，将来可能不再需要。

赞(0）分享  回复(0）举报  2023-01-07
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com