多租户应用程序中的MyBatis spring

Question

Hi在多租户中使用MyBatis spring需要帮助。应用程序...

有可能吗？特别是因为我看不到可以在sqlSessionFactory上配置“ MapperScannerConfigurer”运行。

Answer 1

Spring具有AbstractRoutingDataSource来解决此问题

http://spring.io/blog/2007/01/23/dynamic-datasource-routing/

Answer 2

可以使用工厂创建承租人范围的数据源，并将其连接到SqlSessionFactory，供mybatis-spring生成的映射器使用。这是相关的app-context.xml部分

<bean id="dataSourceFactory" class="com.myapp.TenantDataSourceFactory"
      depends-on="tenant" scope="singleton"/>

<bean id="dataSource" factory-bean="dataSourceFactory" factory-method="getObject"
      destroy-method="close" scope="tenant" >
    <aop:scoped-proxy/>
</bean>

<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
    <property name="dataSource" ref="dataSource"/>
    <property name="configLocation" value="classpath:myBatisConfig.xml" />
</bean>

<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
    <property name="basePackage" value="com.myapp" />
    <property name="annotationClass" value="com.myapp.mapper.Mapper"/>
    <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory"/>
</bean>

和TenantDataSourceFactory：

public class TenantDataSourceFactory {

@Autowired Tenant tenant;

  public DataSource getObject() throws Exception {
    BasicDataSource ds = new BasicDataSource();
    ds.setDriverClassName("org.postgresql.Driver");
    ds.setUrl(String.format("jdbc:postgresql://%s:%s/%s",
            tenant.getDbHost(), tenant.getDbPort(), tenant.getDbName()));
    ds.setUsername(tenant.getDbUser());
    ds.setPassword(tenant.getDbPassword());
    return ds;
  }

}

tenant范围是自定义范围，其中包含作为租户名称的Map<String, Map<String, Object>>到范围Bean映射。它基于current租户的概念调度到给定的租户。

Answer 3

这是使用插件（也称为拦截器）来切换“模式”或“目录”的另一种方法。

取决于您使用的数据库，每个租户都有自己的数据库或架构。一些例子：

• MySQL：每个租户都有自己的'数据库'，并且插件应调用setCatalog。
• Oracle：每个租户都有自己的'schema'，并且插件应调用setSchema。
• SQL Server：每个租户都有自己的'数据库'，并且插件应调用setCatalog。

假设您通过ThreadLocal传递了租户ID，这是示例插件实现。

import java.sql.Connection;

import org.apache.ibatis.executor.statement.StatementHandler;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.plugin.Intercepts;
import org.apache.ibatis.plugin.Invocation;
import org.apache.ibatis.plugin.Signature;

@Intercepts(
  @Signature(
    type = StatementHandler.class,
    method = "prepare",
    args = { Connection.class, Integer.class }))
public class MultiTenantInterceptor implements Interceptor {
  @Override
  public Object intercept(Invocation invocation) throws Throwable {
    Object[] args = invocation.getArgs();
    Connection con = (Connection) args[0];
    con.setSchema(TenantIdHolder.getTenantId());
    // con.setCatalog(TenantIdHolder.getTenantId());
    return invocation.proceed();
  }
}

[TenantIdHolder只是ThreadLocal持有人。

public class TenantIdHolder {
  private static ThreadLocal<String> value = new ThreadLocal<>();

  public static void setTenantId(String tenantId) {
    value.set(tenantId);
  }

  public static String getTenantId() {
    return value.get();
  }
}

这里是使用HSQLDB的demo。