核心插件: TenantLineInnerInterceptor
核心处理器:TenantLineHandler
public interface TenantLineHandler {
Expression getTenantId();
default String getTenantIdColumn() {
return "tenant_id";
}
default boolean ignoreTable(String tableName) {
return false;
}
}
说明:
多租户 != 权限过滤,不要乱用,租户之间是完全隔离的!!!
启用多租户后所有执行的method的sql都会进行处理.
自写的sql请按规范书写(sql涉及到多个表的每个表都要给别名,特别是 inner join 的要写标准的 inner join)
@Configuration
public class MybatisPlusConfig {
@Bean
public MybatisPlusInterceptor mybatisPlusInterceptor() {
MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
// 如果要使用分页插件,注意先 add TenantLineInnerInterceptor,再 add PaginationInnerInterceptor。
// 分页插件PaginationInnerInterceptor必须要写在多租户插件后面)
interceptor.addInnerInterceptor(new TenantLineInnerInterceptor(new TenantLineHandler() {
// manager_id = 1088248166370832385
// 获取租户 ID 值表达式,只支持单个 ID 值
@Override
public Expression getTenantId() {
return new LongValue(1088248166370832385L);
}
@Override
public String getTenantIdColumn() {
return "manager_id";
}
// 这是 default 方法,默认返回 false 表示所有表都需要拼多租户条件,true表示不需要多租户条件
@Override
public boolean ignoreTable(String tableName) {
// 不需要多租户条件的表可以继续在List中添加
if (Arrays.asList("role", "user").contains(tableName)) {
return true;
}
return false;
}
}));
// 分页插件
interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));
return interceptor;
}
@Bean
public ConfigurationCustomizer configurationCustomizer() {
return configuration -> configuration.setUseDeprecatedExecutor(false);
}
}
测试
@RunWith(SpringRunner.class)
@SpringBootTest
class TenantTest {
@Resource
UserMapper userMapper;
@Test
public void select() {
// manager_id = 1088248166370832385
List users = userMapper.selectList(null);
users.forEach(System.out::println);
}
}


