Mybatis实现分表插件

背景

事情是酱紫的，阿星的上级leader负责记录信息的业务，每日预估数据量是15万左右，所以引入sharding-jdbc做分表。

上级leader完成业务的开发后，走了一波自测，git push后，就忙其他的事情去了。

项目的框架是springboot+mybaits

出问题了

阿星负责的业务也开发完了，熟练的git pull，准备自测，单元测试run一下，上个厕所回来收工，就是这么自信。

回来后，看下控制台，人都傻了，一片红，内心不禁感叹“如果这是股票基金该多好”。

出了问题就要解决，随着排查深入，我的眉头一皱发现事情并不简单，怎么以前的一些代码都报错了？

随着排查深入，最后跟到了mybatis源码，发现罪魁祸首是sharding-jdbc引起的，因为数据源是sharding-jdbc的，导致后续执行sql的是shardingpreparedstatement。

这就意味着，sharding-jdbc影响项目的所有业务表，因为最终数据库交互都由shardingpreparedstatement去做了，历史的一些sql语句因为sql函数或者其他写法，使得shardingpreparedstatement无法处理而出现异常。

关键代码如下

发现问题后，阿星马上就反馈给leader了。

唉，本来还想摸鱼的，看来摸鱼的时间是没了，还多了一项任务。

分析

竟然交给阿星来做了，就撸起袖子开干吧，先看看分表功能的需求

• 支持自定义分表策略
• 能控制影响范围
• 通用性

分表会提前建立好，所以不需要考虑表不存在的问题，核心逻辑实现，通过分表策略得到分表名，再把分表名动态替换到sql。

分表策略

为了支持分表策略，我们需要先定义分表策略抽象接口，定义如下

/**
 * @author 程序猿阿星
 * @description 分表策略接口
 * @date 2021/5/9
 */
public interface itableshardstrategy {


    /**
     * @author: 程序猿阿星
     * @description: 生成分表名
     * @param tablenameprefix 表前缀名
     * @param value 值
     * @date: 2021/5/9
     * @return: java.lang.string
     */
    string generatetablename(string tablenameprefix,object value);

    /**
     * 验证tablenameprefix
     */
    default void verificationtablenameprefix(string tablenameprefix){
        if (strutil.isblank(tablenameprefix)) {
            throw new runtimeexception("tablenameprefix is null");
        }
    }
}

generatetablename函数的任务就是生成分表名，入参有tablenameprefix、value，tablenameprefix为分表前缀，value作为生成分表名的逻辑参数。

verificationtablenameprefix函数验证tablenameprefix必填，提供给实现类使用。

为了方便理解，下面是id取模策略代码，取模两张表

/**
 * @author 程序猿阿星
 * @description 分表策略id
 * @date 2021/5/9
 */
@component
public class tableshardstrategyid implements itableshardstrategy {
    @override
    public string generatetablename(string tablenameprefix, object value) {
        verificationtablenameprefix(tablenameprefix);
        if (value == null || strutil.isblank(value.tostring())) {
            throw new runtimeexception("value is null");
        }
        long id = long.parselong(value.tostring());
        //此处可以缓存优化
        return tablenameprefix + "_" + (id % 2);
    }
}

传入进来的value是id值，用tablenameprefix拼接id取模后的值，得到分表名返回。

控制影响范围

分表策略已经抽象出来，下面要考虑控制影响范围，我们都知道mybatis规范中每个mapper类对应一张业务主体表，mapper类的函数对应业务主体表的相关sql。

阿星想着，可以给mapper类打上注解，代表该mpaaer类对应的业务主体表有分表需求，从规范来说mapper类的每个函数对应的主体表都是正确的，但是有些同学可能不会按规范来写。

假设mpaaer类对应的是b表，mpaaer类的某个函数写着a表的sql，甚至是历史遗留问题，所以注解不仅仅可以打在mapper类上，同时还可以打在mapper类的任意一个函数上，并且保证小粒度覆盖粗粒度。

阿星这里自定义分表注解，代码如下

/**
 * @author 程序猿阿星
 * @description 分表注解
 * @date 2021/5/9
 */
@target(value = {elementtype.type,elementtype.method})
@retention(retentionpolicy.runtime)
public @interface tableshard {

    // 表前缀名
    string tablenameprefix();

    //值
    string value() default "";

    //是否是字段名，如果是需要解析请求参数改字段名的值（默认否）
    boolean fieldflag() default false;

    // 对应的分表策略类
    class<? extends itableshardstrategy> shardstrategy();


}

注解的作用范围是类、接口、函数，运行时生效。

tablenameprefix与shardstrategy属性都好理解，表前缀名和分表策略，剩下的value与fieldflag要怎么理解，分表策略分两类，第一类依赖表中某个字段值，第二类则不依赖。

根据企业id取模，属于第一类，此处的value设置企业id入参字段名，fieldflag为true，意味着，会去解析获取企业id字段名对应的值。

根据日期分表，属于第二类，直接在分表策略实现类里面写就行了，不依赖表字段值，value与fieldflag无需填写，当然你value也可以设置时间格式，具体看分表策略实现类的逻辑。

通用性

抽象分表策略与分表注解都搞定了，最后一步就是根据分表注解信息，去执行分表策略得到分表名，再把分表名动态替换到sql中，同时具有通用性。

mybatis框架中，有拦截器机制做扩展，我们只需要拦截statementhandler#prepare函数，即statementhandle创建statement之前，先把sql里面的表名动态替换成分表名。

mybatis分表拦截器流程图如下

mybatis分表拦截器代码如下，有点长哈，主流程看intercept函数就好了。

/**
 * @author 程序员阿星
 * @description 分表拦截器
 * @date 2021/5/9
 */
@intercepts({
        @signature(
                type = statementhandler.class,
                method = "prepare",
                args = {connection.class, integer.class}
        )
})
public class tableshardinterceptor implements interceptor {

    private static final reflectorfactory defaultreflectorfactory = new defaultreflectorfactory();

    @override
    public object intercept(invocation invocation) throws throwable {

        // metaobject是mybatis里面提供的一个工具类，类似反射的效果
        metaobject metaobject = getmetaobject(invocation);
        boundsql boundsql = (boundsql) metaobject.getvalue("delegate.boundsql");
        mappedstatement mappedstatement = (mappedstatement)
                metaobject.getvalue("delegate.mappedstatement");

        //获取mapper执行方法
        method method = invocation.getmethod();

        //获取分表注解
        tableshard tableshard = gettableshard(method,mappedstatement);

        // 如果method与class都没有tableshard注解或执行方法不存在，执行下一个插件逻辑
        if (tableshard == null) {
            return invocation.proceed();
        }

        //获取值
        string value = tableshard.value();
        //value是否字段名，如果是，需要解析请求参数字段名的值
        boolean fieldflag = tableshard.fieldflag();

        if (fieldflag) {
            //获取请求参数
            object parameterobject = boundsql.getparameterobject();

            if (parameterobject instanceof mappermethod.parammap) { //parammap类型逻辑处理

                mappermethod.parammap parametermap = (mappermethod.parammap) parameterobject;
                //根据字段名获取参数值
                object valueobject = parametermap.get(value);
                if (valueobject == null) {
                    throw new runtimeexception(string.format("入参字段%s无匹配", value));
                }
                //替换sql
                replacesql(tableshard, valueobject, metaobject, boundsql);

            } else { //单参数逻辑

                //如果是基础类型抛出异常
                if (isbasetype(parameterobject)) {
                    throw new runtimeexception("单参数非法，请使用@param注解");
                }

                if (parameterobject instanceof map){
                    map<string,object>  parametermap =  (map<string,object>)parameterobject;
                    object valueobject = parametermap.get(value);
                    //替换sql
                    replacesql(tableshard, valueobject, metaobject, boundsql);
                } else {
                    //非基础类型对象
                    class<?> parameterobjectclass = parameterobject.getclass();
                    field declaredfield = parameterobjectclass.getdeclaredfield(value);
                    declaredfield.setaccessible(true);
                    object valueobject = declaredfield.get(parameterobject);
                    //替换sql
                    replacesql(tableshard, valueobject, metaobject, boundsql);
                }
            }

        } else {//无需处理parameterfield
            //替换sql
            replacesql(tableshard, value, metaobject, boundsql);
        }
        //执行下一个插件逻辑
        return invocation.proceed();
    }


    @override
    public object plugin(object target) {
        // 当目标类是statementhandler类型时，才包装目标类，否者直接返回目标本身, 减少目标被代理的次数
        if (target instanceof statementhandler) {
            return plugin.wrap(target, this);
        } else {
            return target;
        }
    }


    /**
     * @param object
     * @methodname: isbasetype
     * @author: 程序员阿星
     * @description: 基本数据类型验证，true是，false否
     * @date: 2021/5/9
     * @return: boolean
     */
    private boolean isbasetype(object object) {
        if (object.getclass().isprimitive()
                || object instanceof string
                || object instanceof integer
                || object instanceof double
                || object instanceof float
                || object instanceof long
                || object instanceof boolean
                || object instanceof byte
                || object instanceof short) {
            return true;
        } else {
            return false;
        }
    }

    /**
     * @param tableshard 分表注解
     * @param value      值
     * @param metaobject mybatis反射对象
     * @param boundsql   sql信息对象
     * @author: 程序猿阿星
     * @description: 替换sql
     * @date: 2021/5/9
     * @return: void
     */
    private void replacesql(tableshard tableshard, object value, metaobject metaobject, boundsql boundsql) {
        string tablenameprefix = tableshard.tablenameprefix();
        //获取策略class
        class<? extends itableshardstrategy> strategyclazz = tableshard.shardstrategy();
        //从spring ioc容器获取策略类

        itableshardstrategy tableshardstrategy = springutil.getbean(strategyclazz);
        //生成分表名
        string shardtablename = tableshardstrategy.generatetablename(tablenameprefix, value);
        // 获取sql
        string sql = boundsql.getsql();
        // 完成表名替换
        metaobject.setvalue("delegate.boundsql.sql", sql.replaceall(tablenameprefix, shardtablename));
    }

    /**
     * @param invocation
     * @author: 程序猿阿星
     * @description: 获取metaobject对象-mybatis里面提供的一个工具类，类似反射的效果
     * @date: 2021/5/9
     * @return: org.apache.ibatis.reflection.metaobject
     */
    private metaobject getmetaobject(invocation invocation) {
        statementhandler statementhandler = (statementhandler) invocation.gettarget();
        // metaobject是mybatis里面提供的一个工具类，类似反射的效果
        metaobject metaobject = metaobject.forobject(statementhandler,
                systemmetaobject.default_object_factory,
                systemmetaobject.default_object_wrapper_factory,
                defaultreflectorfactory
        );

        return metaobject;
    }

    /**
     * @author: 程序猿阿星
     * @description: 获取分表注解
     * @param method
     * @param mappedstatement
     * @date: 2021/5/9
     * @return: com.xing.shard.interceptor.tableshard
     */
    private tableshard gettableshard(method method, mappedstatement mappedstatement) throws classnotfoundexception {
        string id = mappedstatement.getid();
        //获取class
        final string classname = id.substring(0, id.lastindexof("."));
        //分表注解
        tableshard tableshard = null;
        //获取mapper执行方法的tableshard注解
        tableshard = method.getannotation(tableshard.class);
        //如果方法没有设置注解，从mapper接口上面获取tableshard注解
        if (tableshard == null) {
            // 获取tableshard注解
            tableshard = class.forname(classname).getannotation(tableshard.class);
        }
        return tableshard;
    }

}

到了这里，其实分表功能就已经完成了，我们只需要把分表策略抽象接口、分表注解、分表拦截器抽成一个通用jar包，需要使用的项目引入这个jar，然后注册分表拦截器，自己根据业务需求实现分表策略，在给对应的mpaaer加上分表注解就好了。

实践跑起来

这里阿星单独写了一套demo，场景是有两个分表策略，表也提前建立好了

• 根据id分表
• tb_log_id_0
• tb_log_id_1
• 根据日期分表
• tb_log_date_202105
• tb_log_date_202106

预警：后面都是代码实操环节，请各位读者大大耐心看完（非java开发除外）。

tableshardstrategy定义

/**
 * @author wx
 * @description 分表策略日期
 * @date 2021/5/9
 */
@component
public class tableshardstrategydate implements itableshardstrategy {

    private static final string date_pattern = "yyyymm";

    @override
    public string generatetablename(string tablenameprefix, object value) {
        verificationtablenameprefix(tablenameprefix);
        if (value == null || strutil.isblank(value.tostring())) {
            return tablenameprefix + "_" +dateutil.format(new date(), date_pattern);
        } else {
            return tablenameprefix + "_" +dateutil.format(new date(), value.tostring());
        }
    }
}



**
 * @author 程序猿阿星
 * @description 分表策略id
 * @date 2021/5/9
 */
@component
public class tableshardstrategyid implements itableshardstrategy {
    @override
    public string generatetablename(string tablenameprefix, object value) {
        verificationtablenameprefix(tablenameprefix);
        if (value == null || strutil.isblank(value.tostring())) {
            throw new runtimeexception("value is null");
        }
        long id = long.parselong(value.tostring());
        //可以加入本地缓存优化
        return tablenameprefix + "_" + (id % 2);
    }
}

mapper定义

mapper接口

/**
 * @author 程序猿阿星
 * @description
 * @date 2021/5/8
 */
@tableshard(tablenameprefix = "tb_log_date",shardstrategy = tableshardstrategydate.class)
public interface logdatemapper {

    /**
     * 查询列表-根据日期分表
     */
    list<logdate> querylist();

    /**
     * 单插入-根据日期分表
     */
    void  save(logdate logdate);

}


-------------------------------------------------------------------------------------------------


/**
 * @author 程序猿阿星
 * @description
 * @date 2021/5/8
 */
@tableshard(tablenameprefix = "tb_log_id",value = "id",fieldflag = true,shardstrategy = tableshardstrategyid.class)
public interface logidmapper {

    /**
     * 根据id查询-根据id分片
     */
    logid queryone(@param("id") long id);

    /**
     * 单插入-根据id分片
     */
    void save(logid logid);
}

mapper.xml

<?xml version="1.0" encoding="utf-8" ?>
<!doctype mapper
        public "-//mybatis.org//dtd mapper 3.0//en"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xing.shard.mapper.logdatemapper">
    
    //对应logdatemapper#querylist函数
    <select id="querylist" resulttype="com.xing.shard.entity.logdate">
        select
        id as id,
        comment as comment,
        create_date as createdate
        from
        tb_log_date
    </select>
    
    //对应logdatemapper#save函数
    <insert id="save" >
        insert into tb_log_date(id, comment,create_date)
        values (#{id}, #{comment},#{createdate})
    </insert>
</mapper>

-------------------------------------------------------------------------------------------------

<?xml version="1.0" encoding="utf-8" ?>
<!doctype mapper
        public "-//mybatis.org//dtd mapper 3.0//en"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.xing.shard.mapper.logidmapper">
    
    //对应logidmapper#queryone函数
    <select id="queryone" resulttype="com.xing.shard.entity.logid">
        select
        id as id,
        comment as comment,
        create_date as createdate
        from
        tb_log_id
        where
        id = #{id}
    </select>
    
    //对应save函数
    <insert id="save" >
        insert into tb_log_id(id, comment,create_date)
        values (#{id}, #{comment},#{createdate})
    </insert>

</mapper>

执行下单元测试

日期分表单元测试执行

    @test
    void test() {
        logdate logdate = new logdate();
        logdate.setid(snowflake.nextid());
        logdate.setcomment("测试内容");
        logdate.setcreatedate(new date());
        //插入
        logdatemapper.save(logdate);
        //查询
        list<logdate> logdates = logdatemapper.querylist();
        system.out.println(jsonutil.tojsonprettystr(logdates));
    }

输出结果

id分表单元测试执行

    @test
    void test() {
        logid logid = new logid();
        long id = snowflake.nextid();
        logid.setid(id);
        logid.setcomment("测试");
        logid.setcreatedate(new date());
        //插入
        logidmapper.save(logid);
        //查询
        logid logidobject = logidmapper.queryone(id);
        system.out.println(jsonutil.tojsonprettystr(logidobject));
    }

输出结果

小结一下

本文可以当做对mybatis进阶的使用教程，通过mybatis拦截器实现分表的功能，满足基本的业务需求，虽然比较简陋，但是mybatis这种扩展机制与设计值得学习思考。

有兴趣的读者也可以自己写一个，或基于阿星的做改造，毕竟是简陋版本，还是有很多场景没有考虑到。

另外分表的demo项目，阿星放到了gitee，大家按需自取

gitee地址:

项目结构：

到此这篇关于mybatis实现分表插件的文章就介绍到这了,更多相关mybatis 分表插件内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！