如何使用 MyBatisPlus 輕松實(shí)現(xiàn)多租戶功能

@Configurationpublic class MyBatisPlusConfig {    /**     * 分頁插件     *     * @return     */    @Bean    public PaginationInterceptor paginationInterceptor() {        PaginationInterceptor paginationInterceptor = new PaginationInterceptor();        // 創(chuàng)建SQL解析器集合        List<ISqlParser> sqlParserList = new ArrayList<>();        // 創(chuàng)建租戶SQL解析器        TenantSqlParser tenantSqlParser = new TenantSqlParser();        // 設(shè)置租戶處理器        tenantSqlParser.setTenantHandler(new TenantHandler() {            @Override            public Expression getTenantId() {                // 設(shè)置當(dāng)前租戶ID，實(shí)際情況你可以從cookie、或者緩存中拿都行                return new StringValue("jiannan");            }
            @Override            public String getTenantIdColumn() {                // 對應(yīng)數(shù)據(jù)庫租戶ID的列名                return "tenant_id";            }
            @Override            public boolean doTableFilter(String tableName) {                // 是否需要需要過濾某一張表              /*  List<String> tableNameList = Arrays.asList("sys_user");                if (tableNameList.contains(tableName)){                    return true;                }*/                return false;            }        });        sqlParserList.add(tenantSqlParser);        paginationInterceptor.setSqlParserList(sqlParserList);        return paginationInterceptor;    }}

@Testpublic void select(){    List<User> users = userMapper.selectList(Wrappers.<User>lambdaQuery().eq(User::getAge, 18));    users.forEach(System.out::println);}DEBUG==>  Preparing: SELECT id, login_name, name, password, email, salt, sex, age, phone, user_type, status, organization_id, create_time, update_time, version, tenant_id FROM sys_user WHERE sys_user.tenant_id = 'jiannan' AND is_delete = '0' AND age = ? DEBUG==> Parameters: 18(Integer)DEBUG<==      Total: 0

paginationInterceptor.setSqlParserFilter(new ISqlParserFilter() {    @Override    public boolean doFilter(MetaObject metaObject) {        MappedStatement ms = SqlParserHelper.getMappedStatement(metaObject);        // 對應(yīng)Mapper、dao中的方法        if("com.example.demo.mapper.UserMapper.selectList".equals(ms.getId())){            return true;        }        return false;    }});

/** * 用戶 Mapper 接口 */public interface UserMapper extends BaseMapper<User> {    /**     * 自定Wrapper修改     *     * @param userWrapper 條件構(gòu)造器     * @param user        修改的對象參數(shù)     * @return     */    @SqlParser(filter = true)    int updateByMyWrapper(@Param(Constants.WRAPPER) Wrapper<User> userWrapper, @Param("user") User user);}
# 開啟 SQL 解析緩存注解生效，如果你的MP版本在3.1.1及以上則不需要配置mybatis-plus:  global-config:    sql-parser-cache: true