基于 Sass 的架构之 mysql 数据库

    <dependency>        <groupId>com.baomidou</groupId>        <artifactId>mybatis-plus-boot-starter</artifactId>        <!-- 截止本文编写时，最新的MP版本 -->        <version>3.5.3.1</version>    </dependency>

/** * 多租户配置 */@Setter@Getter@ConfigurationProperties(prefix = "kl.tenant")@RefreshScopepublic class TenantProperties {    /**     * 是否开启多租户     */    private Boolean enable = false;
    /**     * 配置不进行多租户隔离的表名     */    private List<String> ignoreTables = new ArrayList<>();
    /**     * 配置不进行多租户隔离的sql     * 需要配置mapper的全路径如：com.central.user.mapper.SysUserMapper.findList     */    private List<String> ignoreSqls = new ArrayList<>();}

/** * 多租户自动配置 * * @author zlt * @date 2019/8/5 */@EnableConfigurationProperties(TenantProperties.class)public class TenantAutoConfigure {    @Autowired    private TenantProperties tenantProperties;
    @Bean    public TenantLineHandler tenantLineHandler() {        return new TenantLineHandler() {            /**             * 获取租户id             */            @Override            public Expression getTenantId() {                Integer tenantId = KlThreadLocal.getPartnerCode();                if (tenantId != null) {                    return new StringValue(tenantId.toString());                }                return new NullValue();            }
            /**             * 过滤不需要根据租户隔离的表             * @param tableName 表名             */            @Override            public boolean ignoreTable(String tableName) {                return tenantProperties.getIgnoreTables().stream().anyMatch(                        (e) -> e.equalsIgnoreCase(tableName)                );            }        };    }}

public class CustomTenantInterceptor extends TenantLineInnerInterceptor {    private List<String> ignoreSqls;
    public CustomTenantInterceptor(TenantLineHandler tenantLineHandler, List<String> ignoreSqls) {        super(tenantLineHandler);        this.ignoreSqls = ignoreSqls;    }
    @Override    public void beforeQuery(Executor executor, MappedStatement ms, Object parameter, RowBounds rowBounds            , ResultHandler resultHandler, BoundSql boundSql) throws SQLException {        if (isIgnoreMappedStatement(ms.getId())) {            return;        }        super.beforeQuery(executor, ms, parameter, rowBounds, resultHandler, boundSql);    }
    private boolean isIgnoreMappedStatement(String msId) {        return ignoreSqls.stream().anyMatch((e) -> e.equalsIgnoreCase(msId));    }}

/** * mybatis-plus自动配置 * */@EnableConfigurationProperties({MybatisPlusAutoFillProperties.class})public class MybatisPlusAutoConfigure {    @Autowired    private TenantLineHandler tenantLineHandler;
    @Autowired    private TenantProperties tenantProperties;
    @Autowired    private MybatisPlusAutoFillProperties autoFillProperties;
    /**     * 分页插件，自动识别数据库类型     */    @Bean    public MybatisPlusInterceptor paginationInterceptor() {        MybatisPlusInterceptor mpInterceptor = new MybatisPlusInterceptor();        boolean enableTenant = tenantProperties.getEnable();        //是否开启多租户隔离        if (enableTenant) {            CustomTenantInterceptor tenantInterceptor = new CustomTenantInterceptor(                    tenantLineHandler, tenantProperties.getIgnoreSqls());            mpInterceptor.addInnerInterceptor(tenantInterceptor);        }        mpInterceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.MYSQL));        return mpInterceptor;    }
    @Bean    @ConditionalOnMissingBean    @ConditionalOnProperty(prefix = "kl.mybatis-plus.auto-fill", name = "enabled", havingValue = "true", matchIfMissing = true)    public MetaObjectHandler metaObjectHandler() {        return new DateMetaObjectHandler(autoFillProperties);    }}

#kl:  #多租户配置  tenant:    enable: true    ignoreTables:      - sys_user      - sys_role_user      - sys_role_menu    ignoreSqls:      # 用户关联角色时，显示所有角色      - com.central.user.mapper.SysRoleMapper.findAll      # 用户列表显示用户所关联的所有角色      - com.central.user.mapper.SysUserRoleMapper.findRolesByUserIds