目标

  1. 默认情况下，租户是使用tentid，实现表内隔离
  2. 租户可以选择独立数据库，独立文件系统。

ZLT多租户实现方案

概要

ZLT使用的实际是Mybatis-Plus的多租户方案。

注意其中关键的两个类，
TenantSqlParser TenantHandler
其中TenantSqlParser 需要一个 TenantHandler 接口成员，

根据TenantHandler 接口的
getTenantId()
getTenantIdColumn()
doTableFilter(String tableName)
三个方法分别配置租户ID的获取，租户ID的字段名，以及是否过滤该表

ZLT的多租户机制及其增强 - 图1

实现代码

实际上就是设置tentid，Mybatis-Plus会自动插入脚本，在crud层面自动处理了tentId

  2. public class TenantContextHolder {
  3.     /**
  4.      * 支持父子线程之间的数据传递
  5.      */
  6.     private static final ThreadLocal<String> CONTEXT = new TransmittableThreadLocal<>();
  8.     public static void setTenant(String tenant) {
  9.         CONTEXT.set(tenant);
  10.     }
  12.     public static String getTenant() { return CONTEXT.get();    }
  14.     public static void clear() {
  15.         CONTEXT.remove();
  16.     }
  17. }

自动化配置，这个代码是丢在启动器里面的

  1. @EnableConfigurationProperties(TenantProperties.class)
  2. public class TenantAutoConfigure {
  3.     @Autowired
  4.     private TenantProperties tenantProperties;
  6.     @Bean
  7.     public TenantHandler tenantHandler() {
  8.         return new TenantHandler() {
  9.             /**
  10.              * 获取租户id
  11.              */
  12.             @Override
  13.             public Expression getTenantId(boolean where) {
  14.                 String tenant = TenantContextHolder.getTenant();
  15.                 if (tenant != null) {
  16.                     return new StringValue(TenantContextHolder.getTenant());
  17.                 }
  18.                 return new NullValue();
  19.             }
  21.             /**
  22.              * 获取租户列名
  23.              */
  24.             @Override
  25.             public String getTenantIdColumn() {
  26.                 return "tenant_id";
  27.             }
  29.             /**
  30.              * 过滤不需要根据租户隔离的表
  31.              * @param tableName 表名
  32.              */
  33.             @Override
  34.             public boolean doTableFilter(String tableName) {
  35.                 return tenantProperties.getIgnoreTables().stream().anyMatch(
  36.                         (e) -> e.equalsIgnoreCase(tableName)
  37.                 );
  38.             }
  39.         };
  40.     }
  42.     /**
  43.      * 过滤不需要根据租户隔离的MappedStatement
  44.      */
  45.     @Bean
  46.     public ISqlParserFilter sqlParserFilter() {
  47.         return metaObject -> {
  48.             MappedStatement ms = SqlParserHelper.getMappedStatement(metaObject);
  49.             return tenantProperties.getIgnoreSqls().stream().anyMatch(
  50.                     (e) -> e.equalsIgnoreCase(ms.getId())
  51.             );
  52.         };
  53.     }
  54. }

代码增强：实现对多租户信息的获取

重写mybatis-plus里面的MultiTenantSqlParser的代码，这是对接口AbstractJsqlParser的实现。

  1.     protected Expression builderExpression(Expression currentExpression, Table table) {
  2.         Expression tenantExpression = this.tenantHandler.getTenantId(false);
  3.         Object appendExpression;
  5.         // 多个tenant id的情况
  6.         if (tenantExpression instanceof MultiOrExpression){
  7.             appendExpression = tenantExpression;
  8.         }else if (!(tenantExpression instanceof SupportsOldOracleJoinSyntax)) {
  10.         .....
  11.     }