SpringBoot多租户实战：动态数据源与租户隔离

这样每次业务操作前都绑定了租户ID，完事清理掉。注意，如果线程池复用，记得用类似TransmittableThreadLocal避免泄露。

SQL自动改写

MyBatis拦截器在SQL执行前，根据租户ID加上过滤条件。

@Intercepts({
    @Signature(type= StatementHandler.class, method="prepare", args={Connection.class, Integer.class})
})
public class TenantInterceptor implements Interceptor {
    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        String tenantId = TenantContext.getTenantId();
        if (tenantId == null) {
            return invocation.proceed();
        }
        StatementHandler handler = (StatementHandler) invocation.getTarget();
        BoundSql boundSql = handler.getBoundSql();
        String sql = boundSql.getSql();
        String newSql = addTenantCondition(sql, tenantId);
        resetSql(handler, boundSql, newSql);
        return invocation.proceed();
    }

    private String addTenantCondition(String sql, String tenantId) {
        // 不建议直接字符串拼接，用SQL解析库防止注入
        return SqlParser.addTenantCondition(sql, tenantId);
    }
}

那个'提示'部分改写为注释或正文里说，不单独用块引用提示。

动态数据源配置

当不同租户数据库实例不同时，需要动态切换数据源。Spring的AbstractRoutingDataSource是个现成的选择。

配置文件

spring:
  datasource:
    master:
      url: jdbc:mysql://localhost:3306/master_db
      username: root
      password: 123456
      driver-class-name: com.mysql.cj.jdbc.Driver
    tenant1:
      url: jdbc:mysql://localhost:3306/tenant1_db
      username: tenant1
      password: tenant1pass
      driver-class-name: com.mysql.cj.jdbc.Driver
    tenant2:
      url: jdbc:mysql://localhost:3306/tenant2_db
      username: tenant2
      password: tenant2pass
      driver-class-name: com.mysql.cj.jdbc.Driver

路由实现

public class TenantDataSourceRouter extends AbstractRoutingDataSource {
    @Override
    protected Object determineCurrentLookupKey() {
        return TenantContext.getTenantId();
    }
}

@Configuration
public class DataSourceConfig {