Mybatis实现分库分表

目前开源的分库分表中间件都做的很重，而且包含了一部分重写JDBC的功能，感觉费事的很，需要非常了解mysql通信协议以及socket才能顺利写完，门槛高，线上维护又麻烦。何不利用mybatis现成的功能去搞定这个分库分表。

正文

首先实现org.apache.ibatis.plugin.Interceptor接口，复写以下三个方法：

//实现拦截逻辑的地方，内部要通过invocation.proceed()显式地推进责任链前进，
//也就是调用下一个拦截器拦截目标方法

Object intercept(Invocation invocation) throws Throwable;

//用当前这个拦截器生成对目标target的代理，实际是通过Plugin.wrap(target,this)来完成的，
//把目标target和拦截器this传给了包装函数

Object plugin(Object target);

//设置额外的参数，参数配置在拦截器的Properties节点里

void setProperties(Properties properties);

如果想要拦截所有的sql，在实现类上添加 annotation

@Intercepts({@Signature(type = StatementHandler.class, method = "prepare", 
args = {Connection.class})})

注：Mybatis支持对Executor、StatementHandler、PameterHandler和ResultSetHandler进行拦截，也就是说会对这4种对象进行代理。

框架如上，具体实现有两个重要点：

1 表的拆分规则

可以在Mapper对象中加上一个annotation，按以下方式去获取：

String className = id.substring(0, id.lastIndexOf("."));

Class  classObj = Class.forName(className);

//根据配置自动生成分表SQL

TableSeg tableSeg = classObj.getAnnotation(TableSeg.class);

TableSeg对象定义：

@Target({ ElementType.TYPE })

@Retention(RetentionPolicy.RUNTIME)

@Inherited

@Documented

public @interface TableSeg {

/**

* 表名

* @return

*/

public String tableName();

/**

* 分表方式，取模，如%5：表示取5余数，

* 如果不设置，直接根据shardBy值分表

* @return

*/

public String shardType();

/**

* 根据什么字段分表

* 多个字段用数学表达表示,如a+b   a-b

* @return

*/

public String shardBy();

}

2 sql解析与替换

可以通过以下方法去获取BoundSql，这个对象有关于这个sql的内容

StatementHandler statementHandler = (StatementHandler) invocation.getTarget();

BoundSql boundSql = statementHandler.getBoundSql();

目前看到一些常规做法都是利用string 的replace方案替换sql中的表名，这显然一个埋坑的做法。利用词法分析器才是完美方案，可以使用antlr4，grammar文件可以去github上找到。

antlr值得深入学习。

---

总结

在编写插件时需注意以下几个原则：

1)不编写不必要的插件；

2)实现plugin方法时判断一下目标类型，是本插件要拦截的对象才执行Plugin.wrap方法，否者直接返回目标本省，这样可以减少目标被代理的次数。