美文网首页BATJ架构
Mybatis插件机制详解

Mybatis插件机制详解

作者: 裘马轻狂大帅 | 来源:发表于2019-04-04 06:43 被阅读4次

    1 概述

    Mybatis插件又称拦截器,Mybatis采用责任链模式,通过动态代理组织多个插件(拦截器),通过这些插件可以改变Mybatis的默认行为(诸如SQL重写之类的),MyBatis 允许你在已映射语句执行过程中的某一点进行拦截调用。默认情况下,MyBatis 允许使用插件来拦截的方法调用包括:

    Executor (update, query, flushStatements, commit, rollback, getTransaction, close, isClosed)

    ParameterHandler (getParameterObject, setParameters)

    ResultSetHandler (handleResultSets, handleOutputParameters)

    StatementHandler (prepare, parameterize, batch, update, query)

    总体概括为:

    拦截执行器的方法

    拦截参数的处理

    拦截结果集的处理

    拦截Sql语法构建的处理

    2 Mybatis四大接口

    既然Mybatis是对四大接口进行拦截的,那我们先要知道Mybatis的四大接口是哪些: Executor,StatementHandler, ResultSetHandler, ParameterHandler。

    Executor是 Mybatis的内部执行器,它负责调用StatementHandler操作数据库,并把结果集通过 ResultSetHandler进行自动映射,另外,它还处理了二级缓存的操作。从这里可以看出,我们也是可以通过插件来实现自定义的二级缓存的。

    StatementHandler是Mybatis直接和数据库执行sql脚本的对象。另外它也实现了Mybatis的一级缓存。这里,我们可以使用插件来实现对一级缓存的操作(禁用等等)。

    ParameterHandler是Mybatis实现Sql入参设置的对象。插件可以改变我们Sql的参数默认设置。

    ResultSetHandler是Mybatis把ResultSet集合映射成POJO的接口对象。我们可以定义插件对Mybatis的结果集自动映射进行修改。

    3 插件Interceptor

    Mybatis的插件实现要实现Interceptor接口,我们看下这个接口定义的方法。

    public interface Interceptor { 

      Object intercept(Invocation invocation) throws Throwable;     

      Object plugin(Object target);   

      void setProperties(Properties properties);

    }

    这个接口只声明了三个方法:

    setProperties方法是在Mybatis进行配置插件的时候可以配置自定义相关属性,即:接口实现对象的参数配置。

    plugin方法是插件用于封装目标对象的,通过该方法我们可以返回目标对象本身,也可以返回一个它的代理,可以决定是否要进行拦截进而决定要返回一个什么样的目标对象。

    intercept方法就是要进行拦截的时候要执行的方法。理解这个接口的定义,先要知道java动态代理机制。plugin接口即返回参数target对象(Executor/ParameterHandler/ResultSetHander/StatementHandler)的代理对象。在调用对应对象的接口的时候,可以进行拦截并处理。

    4 设计实现一个自定义插件

    4.1 需求:

    把Mybatis所有执行的sql都记录下来。

    4.2 代码实现

    通过对org.apache.ibatis.executor.statement.StatementHandler 中的prepare 方法进行拦截即可。

    prepare 方法签名如下:

    Statement prepare(Connection connection, Integer transactionTimeout) throws SQLException;

    自定义一个类,实现 org.apache.ibatis.pluginInterceptor 接口,代码如下:

    package cn.mybatis.mybatis3.interceptor;

    import org.apache.ibatis.executor.statement.StatementHandler;

    import org.apache.ibatis.mapping.BoundSql;

    import org.apache.ibatis.plugin.*;

    import org.slf4j.Logger;

    import org.slf4j.LoggerFactory;

    import java.sql.Connection;

    import java.util.Properties;

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

    public class SQLStatsInterceptor implements Interceptor {

        private final Logger logger = LoggerFactory.getLogger(this.getClass());

        @Override

        public Object intercept(Invocation invocation) throws Throwable {

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

            BoundSql boundSql = statementHandler.getBoundSql();

            String sql = boundSql.getSql();

            logger.info("mybatis intercept sql:{}", sql);

            return invocation.proceed();

        }

        @Override

        public Object plugin(Object target) {

            return Plugin.wrap(target, this);

        }

        @Override

        public void setProperties(Properties properties) {

            String dialect = properties.getProperty("dialect");

            logger.info("mybatis intercept dialect:{}", dialect);

        }

    }

    4.3 这样一个插件就开发完成了,接下来需要在 mybatis-config.xml 文件中增加plugins节点,完整配置如下:

    <?xml version="1.0" encoding="UTF-8" ?>

    <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"

            "http://mybatis.org/dtd/mybatis-3-config.dtd">

    <configuration>

        <plugins>

            <plugin interceptor="com.bytebeats.mybatis3.interceptor.SQLStatsInterceptor">

                <property name="dialect" value="mysql" />

            </plugin>

        </plugins>

    </configuration>

    相关文章

      网友评论

        本文标题:Mybatis插件机制详解

        本文链接:https://www.haomeiwen.com/subject/eayxiqtx.html