热门标签 | HotTags
当前位置:  开发笔记 > 数据库 > 正文

简单了解mybatis拦截器实现原理及实例

这篇文章主要介绍了简单了解mybatis拦截器实现原理及实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

这篇文章主要介绍了简单了解mybatis拦截器实现原理及实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

例行惯例,先看些基本概念:

1 拦截器的作用就是我们可以拦截某些方法的调用,在目标方法前后加上我们自己逻辑

2 Mybatis拦截器设计的一个初衷是为了供用户在某些时候可以实现自己的逻辑而不必去动Mybatis固有的逻辑。

自定义拦截器

/**
 * mybatis 自定义拦截器
 * 三步骤:
 * 1 实现 {@link Interceptor} 接口
 * 2 添加拦截注解 {@link Intercepts}
 * 3 配置文件中添加拦截器
 *
 * 1 实现 {@link Interceptor} 接口
 *   具体作用可以看下面代码每个方法的注释
 * 2 添加拦截注解 {@link Intercepts}
 *   mybatis 拦截器默认可拦截的类型只有四种,即四种接口类型 Executor、StatementHandler、ParameterHandler 和 ResultSetHandler
 *   对于我们的自定义拦截器必须使用 mybatis 提供的注解来指明我们要拦截的是四类中的哪一个类接口
 *   具体规则如下:
 *     a:Intercepts 拦截器: 标识我的类是一个拦截器
 *     b:Signature 署名: 则是指明我们的拦截器需要拦截哪一个接口的哪一个方法
 *       type  对应四类接口中的某一个,比如是 Executor
 *       method 对应接口中的哪类方法,比如 Executor 的 update 方法
 *       args  对应接口中的哪一个方法,比如 Executor 中 query 因为重载原因,方法有多个,args 就是指明参数类型,从而确定是哪一个方法
 * 3 配置文件中添加拦截器
 *   拦截器其实就是一个 plugin,在 mybatis 核心配置文件中我们需要配置我们的 plugin :
 *     
 *       
 *       
 *     
 *
 * 拦截器顺序
 * 1 不同拦截器顺序:
 *   Executor -> ParameterHandler -> StatementHandler -> ResultSetHandler
 *
 * 2 对于同一个类型的拦截器的不同对象拦截顺序:
 *   在 mybatis 核心配置文件根据配置的位置,拦截顺序是 从上往下
 */
@Intercepts({
    @Signature(method = "update", type = Executor.class, args = {MappedStatement.class, Object.class}),
    @Signature(method = "query", type = StatementHandler.class, args = {Statement.class, ResultHandler.class})
})
public class MyInterceptor implements Interceptor {

  /**
   * 这个方法很好理解
   * 作用只有一个:我们不是拦截方法吗,拦截之后我们要做什么事情呢?
   *   这个方法里面就是我们要做的事情
   *
   * 解释这个方法前,我们一定要理解方法参数 {@link Invocation} 是个什么鬼?
   * 1 我们知道,mybatis拦截器默认只能拦截四种类型 Executor、StatementHandler、ParameterHandler 和 ResultSetHandler
   * 2 不管是哪种代理,代理的目标对象就是我们要拦截对象,举例说明:
   *   比如我们要拦截 {@link Executor#update(MappedStatement ms, Object parameter)} 方法,
   *   那么 Invocation 就是这个对象,Invocation 里面有三个参数 target method args
   *     target 就是 Executor
   *     method 就是 update
   *     args  就是 MappedStatement ms, Object parameter
   *
   *  如果还是不能理解,我再举一个需求案例:看下面方法代码里面的需求
   *
   * 该方法在运行时调用
   */
  @Override
  public Object intercept(Invocation invocation) throws Throwable {

    /*
     * 需求:我们需要对所有更新操作前打印查询语句的 sql 日志
     * 那我就可以让我们的自定义拦截器 MyInterceptor 拦截 Executor 的 update 方法,在 update 执行前打印sql日志
     * 比如我们拦截点是 Executor 的 update 方法 : int update(MappedStatement ms, Object parameter)
     *
     * 那当我们日志打印成功之后,我们是不是还需要调用这个query方法呢,如何如调用呢?
     * 所以就出现了 Invocation 对象,它这个时候其实就是一个 Executor,而且 method 对应的就是 query 方法,我们
     * 想要调用这个方法,只需要执行 invocation.proceed()
     */

    /* 因为我拦截的就是Executor,所以我可以强转为 Executor,默认情况下,这个Executor 是个 SimpleExecutor */
    Executor executor = (Executor)invocation.getTarget();

    /*
     * Executor 的 update 方法里面有一个参数 MappedStatement,它是包含了 sql 语句的,所以我获取这个对象
     * 以下是伪代码,思路:
     * 1 通过反射从 Executor 对象中获取 MappedStatement 对象
     * 2 从 MappedStatement 对象中获取 SqlSource 对象
     * 3 然后从 SqlSource 对象中获取获取 BoundSql 对象
     * 4 最后通过 BoundSql#getSql 方法获取 sql
     */
    MappedStatement mappedStatement = ReflectUtil.getMethodField(executor, MappedStatement.class);
    SqlSource sqlSource = ReflectUtil.getField(mappedStatement, SqlSource.class);
    BoundSql boundSql = sqlSource.getBoundSql(args);
    String sql = boundSql.getSql();
    logger.info(sql);

    /*
     * 现在日志已经打印,需要调用目标对象的方法完成 update 操作
     * 我们直接调用 invocation.proceed() 方法
     * 进入源码其实就是一个常见的反射调用 method.invoke(target, args)
     * target 对应 Executor对象
     * method 对应 Executor的update方法
     * args  对应 Executor的update方法的参数
     */

    return invocation.proceed();
  }

  /**
   * 这个方法也很好理解
   * 作用就只有一个:那就是Mybatis在创建拦截器代理时候会判断一次,当前这个类 MyInterceptor 到底需不需要生成一个代理进行拦截,
   * 如果需要拦截,就生成一个代理对象,这个代理就是一个 {@link Plugin},它实现了jdk的动态代理接口 {@link InvocationHandler},
   * 如果不需要代理,则直接返回目标对象本身
   *
   * Mybatis为什么会判断一次是否需要代理呢?
   * 默认情况下,Mybatis只能拦截四种类型的接口:Executor、StatementHandler、ParameterHandler 和 ResultSetHandler
   * 通过 {@link Intercepts} 和 {@link Signature} 两个注解共同完成
   * 试想一下,如果我们开发人员在自定义拦截器上没有指明类型,或者随便写一个拦截点,比如Object,那Mybatis疯了,难道所有对象都去拦截
   * 所以Mybatis会做一次判断,拦截点看看是不是这四个接口里面的方法,不是则不拦截,直接返回目标对象,如果是则需要生成一个代理
   *
   * 该方法在 mybatis 加载核心配置文件时被调用
   */
  @Override
  public Object plugin(Object target) {
    /*
     * 看了这个方法注释,就应该理解,这里的逻辑只有一个,就是让mybatis判断,要不要进行拦截,然后做出决定是否生成一个代理
     *
     * 下面代码什么鬼,就这一句就搞定了?
     * Mybatis判断依据是利用反射,获取这个拦截器 MyInterceptor 的注解 Intercepts和Signature,然后解析里面的值,
     * 1 先是判断要拦截的对象是四个类型中 Executor、StatementHandler、ParameterHandler、 ResultSetHandler 的哪一个
     * 2 然后根据方法名称和参数(因为有重载)判断对哪一个方法进行拦截 Note:mybatis可以拦截这四个接口里面的任一一个方法
     * 3 做出决定,是返回一个对象呢还是返回目标对象本身(目标对象本身就是四个接口的实现类,我们拦截的就是这四个类型)
     *
     * 好了,理解逻辑我们写代码吧~~~ What !!! 要使用反射,然后解析注解,然后根据参数类型,最后还要生成一个代理对象
     * 我一个小白我怎么会这么高大上的代码嘛,怎么办?
     *
     * 那就是使用下面这句代码吧 哈哈
     * mybatis 早就考虑了这里的复杂度,所以提供这个静态方法来实现上面的逻辑
     */
    return Plugin.wrap(target, this);
  }

  /**
   * 这个方法最好理解,如果我们拦截器需要用到一些变量参数,而且这个参数是支持可配置的,
   * 类似Spring中的@Value("${}")从application.properties文件获取
   * 这个时候我们就可以使用这个方法
   *
   * 如何使用?
   * 只需要在 mybatis 配置文件中加入类似如下配置,然后 {@link Interceptor#setProperties(Properties)} 就可以获取参数
   *   
   *      
   *      
   *   
   *   方法中获取参数:properties.getProperty("username");
   *
   * 问题:为什么要存在这个方法呢,比如直接使用 @Value("${}") 获取不就得了?
   * 原因是 mybatis 框架本身就是一个可以独立使用的框架,没有像 Spring 这种做了很多依赖注入的功能
   *
   * 该方法在 mybatis 加载核心配置文件时被调用 
   */
  @Override
  public void setProperties(Properties properties) {
    String username = properties.getProperty("username");
    String password = properties.getProperty("password");
    // TODO: 2019/2/28 业务逻辑处理...
  }
}

三个核心方法都加了详细的注释,而且结合案例需求说明问题

那么多文字不想行看,没关系有概括

总结:

1.在mybatis中可被拦截的类型有四种(按照拦截顺序):

  • Executor:拦截执行器的方法。
  • ParameterHandler:拦截参数的处理。
  • ResultHandler:拦截结果集的处理。
  • StatementHandler:拦截Sql语法构建的处理。

2.各个参数的含义:

  • @Intercepts:标识该类是一个拦截器;
  • @Signature:指明自定义拦截器需要拦截哪一个类型,哪一个方法;

2.1 type:对应四种类型中的一种;

2.2 method:对应接口中的哪类方法(因为可能存在重载方法);

2.3 args:对应哪一个方法;

不知道能否帮助你理解,我的表达能力有限~~~

接下来我们看看 Plugin 类

package org.apache.ibatis.plugin;

/**
 * Plugin 类其实就是一个代理类,因为它实现了jdk动态代理接口 InvocationHandler
 * 我们核心只需要关注两个方法
 * wrap:
 *   如果看懂了代码案例1的例子,那么这个方法很理解,这个方法就是 mybatis 提供给开发人员使用的一个工具类方法,
 *   目的就是帮助开发人员省略掉 反射解析注解 Intercepts 和 Signature,有兴趣的可以去看看源码 Plugin#getSignatureMap 方法
 *
 * invoke:
 *   这个方法就是根据 wrap 方法的解析结果,判断当前拦截器是否需要进行拦截,
 *   如果需要拦截:将 目标对象+目标方法+目标参数 封装成一个 Invocation 对象,给我们自定义的拦截器 MyInterceptor 的 intercept 方法
 *          这个时候就刚好对应上了上面案例1中对 intercept 方法的解释了,它就是我们要处理自己逻辑的方法,
 *          处理好了之后是否需要调用目标对象的方法,比如上面说的 打印了sql语句,是否还要查询数据库呢?答案是肯定的
 *   如果不需要拦截:则直接调用目标对象的方法
 *          比如直接调用 Executor 的 update 方法进行更新数据库
 *
 */
class Plugin implements InvocationHandler {

  public static Object wrap(Object target, Interceptor interceptor) {
    // 省略
  }

  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    // 省略
  }
}

贴一段网上的通用解释吧:

Plugin的wrap方法,它根据当前的Interceptor上面的注解定义哪些接口需要拦截,然后判断当前目标对象是否有实现对应需要拦截的接口,如果没有则返回目标对象本身,如果有则返回一个代理对象。而这个代理对象的InvocationHandler正是一个Plugin。所以当目标对象在执行接口方法时,如果是通过代理对象执行的,则会调用对应InvocationHandler的invoke方法,也就是Plugin的invoke方法。

所以接着我们来看一下该invoke方法的内容。这里invoke方法的逻辑是:如果当前执行的方法是定义好的需要拦截的方法,则把目标对象、要执行的方法以及方法参数封装成一个Invocation对象,再把封装好的Invocation作为参数传递给当前拦截器的intercept方法。如果不需要拦截,则直接调用当前的方法。Invocation中定义了定义了一个proceed方法,其逻辑就是调用当前方法,所以如果在intercept中需要继续调用当前方法的话可以调用invocation的procced方法。

这就是Mybatis中实现Interceptor拦截的一个思想

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。


推荐阅读
  • 如何实现织梦DedeCms全站伪静态
    本文介绍了如何通过修改织梦DedeCms源代码来实现全站伪静态,以提高管理和SEO效果。全站伪静态可以避免重复URL的问题,同时通过使用mod_rewrite伪静态模块和.htaccess正则表达式,可以更好地适应搜索引擎的需求。文章还提到了一些相关的技术和工具,如Ubuntu、qt编程、tomcat端口、爬虫、php request根目录等。 ... [详细]
  • 一、Hadoop来历Hadoop的思想来源于Google在做搜索引擎的时候出现一个很大的问题就是这么多网页我如何才能以最快的速度来搜索到,由于这个问题Google发明 ... [详细]
  • 本文介绍了在开发Android新闻App时,搭建本地服务器的步骤。通过使用XAMPP软件,可以一键式搭建起开发环境,包括Apache、MySQL、PHP、PERL。在本地服务器上新建数据库和表,并设置相应的属性。最后,给出了创建new表的SQL语句。这个教程适合初学者参考。 ... [详细]
  • 本文介绍了使用postman进行接口测试的方法,以测试用户管理模块为例。首先需要下载并安装postman,然后创建基本的请求并填写用户名密码进行登录测试。接下来可以进行用户查询和新增的测试。在新增时,可以进行异常测试,包括用户名超长和输入特殊字符的情况。通过测试发现后台没有对参数长度和特殊字符进行检查和过滤。 ... [详细]
  • 延迟注入工具(python)的SQL脚本
    本文介绍了一个延迟注入工具(python)的SQL脚本,包括使用urllib2、time、socket、threading、requests等模块实现延迟注入的方法。该工具可以通过构造特定的URL来进行注入测试,并通过延迟时间来判断注入是否成功。 ... [详细]
  • 本文介绍了一个免费的asp.net控件,该控件具备数据显示、录入、更新、删除等功能。它比datagrid更易用、更实用,同时具备多种功能,例如属性设置、数据排序、字段类型格式化显示、密码字段支持、图像字段上传和生成缩略图等。此外,它还提供了数据验证、日期选择器、数字选择器等功能,以及防止注入攻击、非本页提交和自动分页技术等安全性和性能优化功能。最后,该控件还支持字段值合计和数据导出功能。总之,该控件功能强大且免费,适用于asp.net开发。 ... [详细]
  • Skywalking系列博客1安装单机版 Skywalking的快速安装方法
    本文介绍了如何快速安装单机版的Skywalking,包括下载、环境需求和端口检查等步骤。同时提供了百度盘下载地址和查询端口是否被占用的命令。 ... [详细]
  • PHP图片截取方法及应用实例
    本文介绍了使用PHP动态切割JPEG图片的方法,并提供了应用实例,包括截取视频图、提取文章内容中的图片地址、裁切图片等问题。详细介绍了相关的PHP函数和参数的使用,以及图片切割的具体步骤。同时,还提供了一些注意事项和优化建议。通过本文的学习,读者可以掌握PHP图片截取的技巧,实现自己的需求。 ... [详细]
  • 这是原文链接:sendingformdata许多情况下,我们使用表单发送数据到服务器。服务器处理数据并返回响应给用户。这看起来很简单,但是 ... [详细]
  • 本文讨论了Alink回归预测的不完善问题,指出目前主要针对Python做案例,对其他语言支持不足。同时介绍了pom.xml文件的基本结构和使用方法,以及Maven的相关知识。最后,对Alink回归预测的未来发展提出了期待。 ... [详细]
  • 本文介绍了adg架构设置在企业数据治理中的应用。随着信息技术的发展,企业IT系统的快速发展使得数据成为企业业务增长的新动力,但同时也带来了数据冗余、数据难发现、效率低下、资源消耗等问题。本文讨论了企业面临的几类尖锐问题,并提出了解决方案,包括确保库表结构与系统测试版本一致、避免数据冗余、快速定位问题等。此外,本文还探讨了adg架构在大版本升级、上云服务和微服务治理方面的应用。通过本文的介绍,读者可以了解到adg架构设置的重要性及其在企业数据治理中的应用。 ... [详细]
  • 本文介绍了在Win10上安装WinPythonHadoop的详细步骤,包括安装Python环境、安装JDK8、安装pyspark、安装Hadoop和Spark、设置环境变量、下载winutils.exe等。同时提醒注意Hadoop版本与pyspark版本的一致性,并建议重启电脑以确保安装成功。 ... [详细]
  • 本文介绍了在Mac上搭建php环境后无法使用localhost连接mysql的问题,并通过将localhost替换为127.0.0.1或本机IP解决了该问题。文章解释了localhost和127.0.0.1的区别,指出了使用socket方式连接导致连接失败的原因。此外,还提供了相关链接供读者深入了解。 ... [详细]
  • 本文介绍了关于apache、phpmyadmin、mysql、php、emacs、path等知识点,以及如何搭建php环境。文章提供了详细的安装步骤和所需软件列表,希望能帮助读者解决与LAMP相关的技术问题。 ... [详细]
  • 标题: ... [详细]
author-avatar
ly荚n嚯嚯
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有