Подтвердить что ты не робот

Multi-Tenancy с Spring + Hibernate: "SessionFactory настроен для многопользовательской аренды, но не указан идентификатор арендатора"

В приложении Spring 3 я пытаюсь реализовать многопользовательский режим с помощью Hibernate 4 native MultiTenantConnectionProvider и CurrentTenantIdentifierResolver. Я вижу, что была проблема с этим в 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 в этой точке. Очевидно, что эта логика должна была быть реализована после того, как мне удалось создать соединения для создания экземпляров.

config.xml

<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; это должно было быть разрешено.

4b9b3361

ОТВЕТЫ

Ответ 1

Вперед: Хотя я принял этот ответ, который (будет) содержит код, пожалуйста, воздержитесь Даррен, если вы считаете, что это было полезно. Он по той причине, что я смог решить это вообще.

Хорошо, так что мы идем....

Как указал Даррен, это действительно проблема с SessionFactory, создающим экземпляр сеанса неправильно. Если вы должны были создать сеанс вручную, у вас нет проблем. например:

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

Однако аннотация @Transactional заставляет SessionFactory открывать сеанс с sessionFactory.getCurrentSession(), который не вытягивает идентификатор арендатора из CurrentTenantIdentifierResolver.

Даррен предложил открыть сеанс вручную на уровне DAO, но это означает, что каждый метод DAO будет иметь транзакцию с локальным охватом. Лучшее место для этого - на уровне обслуживания. Каждый вызов уровня обслуживания (т.е. doSomeLogicalTask()) может вызывать несколько методов DAO. Имеет смысл, что каждый из них должен быть связан с одной и той же транзакцией, поскольку они логически связаны.

Кроме того, мне не понравилась идея дублирования кода в каждом методе уровня сервиса для создания и управления транзакцией. Вместо этого я использовал AOP для обертывания каждого метода на моем уровне сервиса с помощью рекомендации создать новый Session и обработать транзакцию. Аспект хранит текущий Session в стеке TheadLocal, к которому может быть доступен уровень DAO для запросов.

Вся эта работа позволит интерфейсам и реализациям оставаться идентичными их исправленным ошибкой аналогам, за исключением одной строки в суперклассе DAO, который получит Session из стека ThreadLocal, а не SessionFactory. Это может быть изменено после исправления ошибки.

Я отправлю код в ближайшее время, как только я его немного очищу. Если кто-либо видит какие-либо проблемы с этим, не стесняйтесь обсуждать ниже.

Ответ 2

Используете ли вы @Transactional в любом месте своего кода (т.е. отмечаете службу или dao class/method)? Я столкнулся с той же ошибкой, пока я не прокомментировал @Transactional в моем классе обслуживания. Я думаю, что это связано с поведением openSessionInThread по умолчанию для Hibernate 4.

У меня также есть спящий режим, настроенный без специальной реализации ConnectionProvider и TenantIdentifierResolver. Я использую подход на основе jndi, устанавливая hibernate.connection.datasource в java://comp/env/jdbc/, а затем передавая имя ресурса jndi в мои методы dao, которые вызывают sessionFactory.withOptions().tenantIdentifier(арендатор).openSession();

Я все еще играю, чтобы посмотреть, смогу ли я получить конфигурацию, работающую с @Transactional, но теперь работает jndi-подход с сеансом по умолчанию в потоковом режиме.

Ответ 3

Даже если это может быть более старая тема, и ответ может быть уже рассмотрен. Я заметил следующее:

В вашем определении класса CurrentTenantIdentifierResolverImpl:

public class CurrentTenantIdentifierResolverImpl implements CurrentTenantIdentifierResolver

Но в вашей конфигурации вы ссылаетесь на MultiTenantIdentifierResolverImpl:

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

Просто указывая это, потому что сегодня я совершил ту же самую ошибку, после чего все это работало как шарм.

Ответ 4

Возможно, вам нужно обновить версию hibernate до последнего 4.X и использовать аннотацию или аспекты для начала транзакции.

Ответ 5

У меня была аналогичная проблема, когда моя реализация CurrentTenantIdentifierResolver вернула значение null для метода resolveCurrentTenantIdentifier()

Ответ 6

Hibernate определяет интерфейс CurrentTenantIdentifierResolver, чтобы помочь фреймворкам, таким как Spring или Java EE, разрешить использование механизма экземпляра по умолчанию Session (будь то из EntityManagerFactiry).

Итак, параметр 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 для разрешения идентификатора арендатора.