Mybatis 使用插件分析SQL

Mybatis 插件开发是mybatis的高级功能,使用mybatis的插件开发,主要拦截的是mybtais中的4大对象: （1）ParameterHandler：处理SQL的参数对象 （2）ResultSetHandler：处理SQL的返回结果集 （3）StatementHandler：数据库的处理对象，用于执行SQL语句 （4）Executor：MyBatis的执行器，用于执行增删改查操作 我们知道mybatis的执行器有三种: SIMPLE: 默认的执行器, 对每条sql进行预编译->设置参数->执行等操作 BATCH: 批量执行器, 对相同sql进行一次预编译, 然后设置参数, 最后统一执行操作 REUSE: REUSE 执行器会重用预处理语句（prepared statements) 一般情况下,我们都用的默认的执行器.也就是SIMPLE.

拦截大对象和慢SQL的插件就是对Executor这个接口上的方法进行拦截，利用JDK动态代理机制，为接口的实现类创建代理对象,分析执行的时间和返回的数据的个数,根据配置的数据进行分析是否是大对象.然后异步发送事件,使用者实现监听事件,并进行相应的逻辑处理.进行通知或者数据入库. 流程图如下:

关键代码

下面展示一些 内联代码片。

@Intercepts({
          
   
        @Signature(type = Executor.class, method = "query", args = {
          
   MappedStatement.class, Object.class,
                RowBounds.class, ResultHandler.class})})
public class MyBatisInterceptor implements Interceptor {
          
   
 
  long start =  System.currentTimeMillis();
  Object result = invocation.proceed();
  long cost = System.currentTimeMillis()- start;
  int resultSize = result.size();
 //获取执行的结果进行异步分析
 if(cost || resultSize|| 其他指标){
          
   
 	CompletableFuture.runAsync(()->event.fire(result),ForkJoinPool.commonPool())
   }
 }
/**
 * 事件通知接口
 */
public interface EventObserver {
          
   

    void fire(Object arg);
}