MybatisPlus拦截器如何实现数据表分表

 更新时间:2024年11月06日 09:29:12   作者:樘棣寂寂  
为了解决MySQL中大数据量的查询效率问题,采用水平拆分策略,通过取模运算确定表后缀,实现数据的有效管理,设计分表时,需利用线程变量存取请求参数,并通过拦截器确定操作的具体表名,从而优化数据处理性能,此方法适用于业务表数据量大或快速增长的场景

MybatisPlus拦截器实现数据表分表

很多项目都会存在一些数据量很大或者数据量增加很快的业务表,由于mysql的数据量达到一定量后会影响我们的查询效率,为了避免该类问题发生,我们需要在项目前期设计的时候针对这两类情况做一个分表的设计。

这里的分表指的是水平拆分(只是表名不同,其余字段都一致,主键id不允许重复),对某一个数字取模运算做为拆分后表的后缀名,具体要分多少张表可通过自己实际的项目情况确定。

首先创建请求参数传递的一个辅助类

/**
 * 请求参数传递辅助类
 */
public class RequestDataHelper {
    /**
     * 请求参数存取
     */
    private static final ThreadLocal<Map<String, Object>> REQUEST_DATA = new ThreadLocal<>();

    /**
     * 设置请求参数
     *
     * @param requestData 请求参数 MAP 对象
     */
    public static void setRequestData (Map<String, Object> requestData) {
        REQUEST_DATA.set(requestData);
    }

    /**
     * 获取请求参数
     *
     * @return 请求参数 MAP 对象
     */
    public static Map<String, Object> getRequestData () {
        return REQUEST_DATA.get();
    }
}

该辅助类主要作用有:

  • a.设置请求参数
  • b.将请求参数存取到线程变量中
  • c.获取请求参数

简单的说就是在涉及到需要分表的数据操作时,将请求参数放入线程变量中。

然后在拦截器里面获取这个参数,做特定的处理,找到我们具体要操作的那张表。

这里的请求参数大家可以把它理解成跟我们分表后的表名产生关联的数据。

这里面的线程变量是仅在当前线程下可使用的数据,与其他线程做隔离。

在本文中不做详细解释。

在涉及到分表的数据层操作前(Mybatisplus或者Mybatis增删改查数据前)

将请求参数放入线程变量

RequestDataHelper.setRequestData(Collections.singletonMap("studentId", param.getStudentId()));
        LambdaQueryWrapper<StudentRecordEntity> queryWrapper = new LambdaQueryWrapper<>();
        queryWrapper.eq(StudentRecordEntity::getStudentId, param.getStudentId());
        List<StudentRecordEntity> studentRecordEntityList = super.list(queryWrapper);

Mybatisplus 拦截器代码

/**
     * Mybatis plus 拦截器
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();

        //动态表插件
        DynamicTableNameInnerInterceptor dynamicTableNameInnerInterceptor = new DynamicTableNameInnerInterceptor();
        dynamicTableNameInnerInterceptor.setTableNameHandler((sql, tableName) -> {
            // 获取参数方法
            if (tableName.equalsIgnoreCase("t_student_record")) {
                Map<String, Object> paramMap = RequestDataHelper.getRequestData();
                long studentId= Long.parseLong(String.valueOf(paramMap.get("studentId")));
                int mod = (int) (studentId% 16);
                return tableName + "_" + mod;

            } else {
                return tableName;
            }
        });
        interceptor.addInnerInterceptor(dynamicTableNameInnerInterceptor);
        return interceptor;
    }

这里面t_student_record表就是要拆分的表,如果有多个,在if里面写多个。

studentId就是调用的时候传入线程变量的请求参数,对它%16就是分了16张表,根据实际业务情况,需要分多少张就把%后面的数字改为多少。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

相关文章

  • Mysql查看最大连接数和修改最大连接数的讲解

    Mysql查看最大连接数和修改最大连接数的讲解

    今天小编就为大家分享一篇关于Mysql查看最大连接数和修改最大连接数的讲解,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2019-03-03
  • MySQL数据库 1067错误号的解决方法

    MySQL数据库 1067错误号的解决方法

    这篇文章主要介绍了MySQL数据库 1067错误号的解决方法,非常不错,具有参考借鉴价值,需要的朋友可以参考下
    2016-12-12
  • 关于mysql init_connect的几个要点总结

    关于mysql init_connect的几个要点总结

    下面小编就为大家带来一篇关于mysql init_connect的几个要点总结。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-03-03
  • mysql数据库太大了如何备份与还原

    mysql数据库太大了如何备份与还原

    今天小编就为大家分享一篇关于mysql数据库太大了如何备份与还原,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
    2019-03-03
  • mysql ERROR 1045 (28000)问题的解决方法

    mysql ERROR 1045 (28000)问题的解决方法

    这篇文章主要介绍了mysql ERROR 1045 (28000)问题的解决方法,文中步骤介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-10-10
  • mysql8.0主从复制搭建与配置方案

    mysql8.0主从复制搭建与配置方案

    MySQL主从复制是一个异步的复制过程,就是有两个数据库服务器,一个是主(master)数据库服务器,另一个是从(slave)数据库服务器。
    2022-09-09
  • mysql数据库开发规范【推荐】

    mysql数据库开发规范【推荐】

    这篇文章主要介绍了mysql数据库开发规范的相关内容,还是十分不错的,这里给大家分享下,需要的朋友可以参考。
    2017-10-10
  • Mysql分组查询取max那条记录其它字段方式

    Mysql分组查询取max那条记录其它字段方式

    这篇文章主要介绍了Mysql分组查询取max那条记录其它字段方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教
    2023-08-08
  • Mysql联表update数据的示例详解

    Mysql联表update数据的示例详解

    这篇文章主要介绍了Mysql联表update数据的示例详解,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-11-11
  • 安装MySQL后,需要调整的10个性能配置项

    安装MySQL后,需要调整的10个性能配置项

    这篇文章主要介绍了安装MySQL后,需要调整的10个性能配置项,帮助大家更好的理解和使用MySQL数据库,感兴趣的朋友可以了解下
    2020-12-12

最新评论