MybatisPlus设置动态表名

MybatisPlus设置动态表名

小编为你讲解MybatisPlus设置动态表名的电脑小知识，具体介绍如下：

对于一些数据量比较大的表，为了提高查询性能，我们一般将表拆分成多张表，常见的是根据数据量，按年分表或者按月分表；

分表虽然太高了查询性能，但是在查询的时候，如何才能查询执行分表数据呢，这里整理了一下，使用MybatisPlus设置动态表名的功能实现。

增加MyBatisPlus配置类

import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.handler.TableNameHandler;
import com.baomidou.mybatisplus.extension.plugins.inner.DynamicTableNameInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.HashMap;
@Configuration
public class MyBatisPlusConfig {
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor mybatisPlusInterceptor = new MybatisPlusInterceptor();
        DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor();
        HashMap<String, TableNameHandler> map = new HashMap<>();
        map.put("my_test", (sql, tableName) -> DynamicTableTreadLocal.INSTANCE.getTableName());
        
        // 如果存在多张分表，则在下面添加多条记录
        dynamicTableNameInnerInterceptor.setTableNameHandlerMap(map);
        mybatisPlusInterceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);
        return mybatisPlusInterceptor;
    }
}

方法解析

MybatisPlusInterceptor

该插件是核心插件,目前代理了Executor#query和Executor#update和StatementHandler#prepare方法

方法属性

private List<InnerInterceptor> interceptors = new ArrayList<>();

InnerInterceptor接口

目前已有的功能:

• 自动分页:PaginationInnerInterceptor
• 多租户:TenantLineInnerInterceptor
• 动态表名:DynamicTableNameInnerInterceptor
• 乐观锁:OptimisticLockerInnerInterceptor
• sql 性能规范:IllegalSQLInnerInterceptor
• 防止全表更新与删除:BlockAttackInnerInterceptor

注意事项

使用多个功能需要注意顺序关系,建议使用如下顺序

• 多租户,动态表名
• 分页,乐观锁
• sql 性能规范,防止全表更新与删除

总结: 对 sql 进行单次改造的优先放入,不对 sql 进行改造的最后放入

增加本地动态线程设置表名

public enum DynamicTableTreadLocal {
    INSTANCE;
    private ThreadLocal<String> tableName = new ThreadLocal<>();
    public String getTableName() {
        return tableName.get();
    }
    public void setTableName(String tableName) {
        this.tableName.set(tableName);
    }
    public void remove() {
        tableName.remove();
    }
}