我们如何使用Hibernate作为ORM单独的数据库和模式构建Spring MVC多租户应用程序

从春天 io u 转移到堆栈溢出，但你没有解释过多租户完整的演示应用程序，它可以被视为问题解决者事实上没有人看到对你的答案满意，你现在可以分享多租户模式的工作演示和单独的数据库完整代码，人们可以在任何地方使用它

package com.domain.model;

import javax.persistence.*;
@Entity
@Table
public class Employee {
@Id
@GeneratedValue(strategy = GenerationType.IDENTITY)
private int employeeId;
@Column
private String employeeName;
public String getEmployeeName() {
return employeeName;
}
public void setEmployeeName(String employeeName) {
this.employeeName = employeeName;
}
public int getEmployeeId() {
return employeeId;
}
public void setEmployeeId(int employeeId) {
this.employeeId = employeeId;
}
}
package com.domain.multitenancy;
import org.hibernate.context.spi.CurrentTenantIdentifierResolver;
import org.springframework.web.context.request.RequestContextHolder;
import org.springframework.web.context.request.ServletRequestAttributes;
public class CurrentTenantIdentifierResolverimpl implements CurrentTenantIdentifierResolver {
@Override
public String resolveCurrentTenantIdentifier() {
ServletRequestAttributes attr = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
String tenantId = attr.getRequest().getParameter("tenantId");
return tenantId;
}
@Override
public boolean validateExistingCurrentSessions() {
return true;
}
}

package com.domain.multitenancy;
import com.domain.master.MasterService;
import org.hibernate.service.jdbc.connections.spi.AbstractDataSourceBasedMultiTenantConnectionProviderImpl;
import javax.sql.DataSource;
public class MultiTenantConnectionprovideImpl extends AbstractDataSourceBasedMultiTenantConnectionProviderImpl {
@Override
protected DataSource selectAnyDataSource() {
return MasterService.getDataSourceHashMap().get("tenantId1");
}
@Override
protected DataSource selectDataSource(String tenantIdentifier) {
return MasterService.getDataSourceHashMap().get(tenantIdentifier);
}
}

package com.domain.master;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import javax.sql.DataSource;
import java.util.HashMap;
public class MasterService {
public static HashMap<String, DataSource> getDataSourceHashMap() {
DriverManagerDataSource dataSource = new DriverManagerDataSource();
dataSource.setDriverClassName("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/multiten");
dataSource.setUsername("root");
dataSource.setPassword("root");
DriverManagerDataSource dataSource1 = new DriverManagerDataSource();
dataSource1.setDriverClassName("com.mysql.jdbc.Driver");
dataSource1.setUrl("jdbc:mysql://localhost:3306/multiten_1");
dataSource1.setUsername("root");
dataSource1.setPassword("root");
HashMap hashMap = new HashMap();
hashMap.put("tenantId1", dataSource);
hashMap.put("tenantId2", dataSource1);
return hashMap;
}
}

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc.xsd
http://www.springframework.org/schema/tx  http://www.springframework.org/schema/tx/spring-tx.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">
<context:component-scan base-package="com.domain"/>
<mvc:annotation-driven/>
<context:property-placeholder location="classpath:application.properties"/>
<tx:annotation-driven transaction-manager="transactionManager"/>
<bean id="sessionFactory" class="org.springframework.orm.hibernate4.LocalSessionFactoryBean" >
<property name="packagesToScan">
<list>
<value>com.domain.model</value>
</list>
</property>
<property name="hibernateProperties">
<props>
<prop key="hibernate.hbm2ddl.auto">create</prop>
<prop key="hibernate.dialect">${hibernate.dialect}</prop>
<prop key="hibernate.show_sql">${hibernate.show_sql:false}</prop>
<prop key="hibernate.format_sql">${hibernate.format_sql:false}</prop>
<prop key="hibernate.multiTenancy">DATABASE</prop>
<prop key="hibernate.tenant_identifier_resolver">com.domain.multitenancy.CurrentTenantIdentifierResolverimpl</prop>
<prop key="hibernate.multi_tenant_connection_provider">com.domain.multitenancy.MultiTenantConnectionprovideImpl</prop>
</props>
</property>
</bean>
<bean id="transactionManager"  class="org.springframework.orm.hibernate4.HibernateTransactionManager">
<property name="sessionFactory" ref="sessionFactory" />
</bean>
<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property name="prefix" value="/WEB-INF/views/"/>
<property name="suffix" value=".jsp"/>
</bean>
</beans>

#Application.properties file in classpath
jdbc.driverClassName = com.mysql.jdbc.Driver
jdbc.url = jdbc:mysql://localhost:3306/multiten
jdbc.username = root
jdbc.password = root
hibernate.dialect = org.hibernate.dialect.MySQL5Dialect
hibernate.show_sql = true
hibernate.format_sql = false

我举了这个例子

这些是我得到的错误：

org.springframework.web.util.NestedServletException： Request 处理失败;嵌套异常是 org.springframework.transaction.CannotCreateTransactionException：无法打开休眠会话进行事务;嵌套异常是 org.hibernate.HibernateException： SessionFactory 配置为多租户，但未指定租户标识符 org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java：979) org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java：869) javax.servlet.http.HttpServlet.service(HttpServlet.java：660) org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java：843) javax.servlet.http.HttpServlet.service(HttpServlet.java：741) org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java：53)
根源 org.springframework.transaction.CannotCreateTransactionException：无法打开休眠会话进行事务;嵌套异常是 org.hibernate.HibernateException： SessionFactory 配置为多租户，但未指定租户标识符 org.springframework.orm.hibernate4.HibernateTransactionManager.doBegin(HibernateTransactionManager.java：544) org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java：373) org.springframework.transaction.interceptor.TransactionAspectSupport.createTransactionIfNeed(TransactionAspectSupport.java：427) org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java：276) org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java：96) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java：179) org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java：208) com.sun.proxy.$Proxy 22.save(未知来源) com.domain.controller.EmployeeController.saveEmployee(EmployeeController.java：35) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.lang.reflect.Method.invoke(未知来源) org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java：221) org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java：136) org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java：110) org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java：832) org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java：743) org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java：85) org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java：961) org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java：895) org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java：967) org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java：869) javax.servlet.http.HttpServlet.service(HttpServlet.java：660) org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java：843) javax.servlet.http.HttpServlet.service(HttpServlet.java：741) org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java：53)
根源 org.hibernate.HibernateException：为多租户配置的会话工厂，但未指定租户标识符 org.hibernate.internal.AbstractSessionImpl.(摘要会议.java：85) org.hibernate.internal.SessionImpl.(会议.java：239) org.hibernate.internal.SessionFactoryImpl$SessionBuilderImpl.openSession(SessionFactoryImpl.java：1618) org.hibernate.internal.SessionFactoryImpl.openSession(SessionFactoryImpl.java：978) org.springframework.orm.hibernate4.HibernateTransactionManager.doBegin(HibernateTransactionManager.java：436) org.springframework.transaction.support.AbstractPlatformTransactionManager.getTransaction(AbstractPlatformTransactionManager.java：373)org.springframework.transaction.interceptor.TransactionAspectSupport.createTransactionIfNeed(TransactionAspectSupport.java：427) org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java：276) org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java：96) org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java：179) org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java：208) com.sun.proxy.$Proxy 22.save(未知来源) com.domain.controller.EmployeeController.saveEmployee(EmployeeController.java：35) sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) java.lang.reflect.Method.invoke(未知来源) org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java：221) org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java：136) org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java：110) org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java：832) org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java：743) org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java：85) org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java：961) org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java：895) org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java：967) org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java：869) javax.servlet.http.HttpServlet.service(HttpServlet.java：660) org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java：843) javax.servlet.http.HttpServlet.service(HttpServlet.java：741) org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java：53)
注意：服务器日志中提供了根本原因的完整堆栈跟踪。

事务

会话;嵌套异常为 org.hibernate.HibernateException： SessionFactory 配置为多租户，但未指定租户标识符

上述错误表明未指定租户标识符。请仔细检查您的配置和标识符类实现名称。

收到此错误的原因是租户标识符解析程序需要返回默认值，以防它无法从所选策略中找到适当的租户 ID(在本例中，你尝试从请求参数获取租户 ID)。我已经使用了下面的更新代码，它不再显示错误。

public class CurrentTenantIdentifierResolverimpl implements CurrentTenantIdentifierResolver {
@Override
public String resolveCurrentTenantIdentifier() {
ServletRequestAttributes attr = (ServletRequestAttributes) RequestContextHolder.getRequestAttributes();
String tenantId = attr.getRequest().getParameter("tenantId");
if (tenantId==null) {
//return default tenant
return "tenantId1";
}
return tenantId;
}
@Override
public boolean validateExistingCurrentSessions() {
return true;
}
}

谢伦德拉先生，我们如何在不设置默认 ID 的情况下为其设置租户 ID，并从 Spring Security 获取用户名并将其传递给租户 ID

相关内容

最新更新

热门标签：