国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 學院 > 開發設計 > 正文

MyBatis攔截器原理探究

2019-11-14 22:13:44
字體:
來源:轉載
供稿:網友
MyBatis攔截器原理探究MyBatis攔截器介紹

MyBatis提供了一種插件(plugin)的功能,雖然叫做插件,但其實這是攔截器功能。那么攔截器攔截MyBatis中的哪些內容呢?

我們進入官網看一看:

MyBatis 允許你在已映射語句執行過程中的某一點進行攔截調用。默認情況下,MyBatis 允許使用插件來攔截的方法調用包括:

  1. Executor (update, query, flushStatements, commit, rollback, getTransaction, close, isClosed)
  2. ParameterHandler (getParameterObject, setParameters)
  3. ResultSetHandler (handleResultSets, handleOutputParameters)
  4. StatementHandler (PRepare, parameterize, batch, update, query)

我們看到了可以攔截Executor接口的部分方法,比如update,query,commit,rollback等方法,還有其他接口的一些方法等。

總體概括為:

  1. 攔截執行器的方法
  2. 攔截參數的處理
  3. 攔截結果集的處理
  4. 攔截Sql語法構建的處理
攔截器的使用攔截器介紹及配置

首先我們看下MyBatis攔截器的接口定義:

public interface Interceptor {  Object intercept(Invocation invocation) throws Throwable;  Object plugin(Object target);  void setProperties(Properties properties);}

比較簡單,只有3個方法。 MyBatis默認沒有一個攔截器接口的實現類,開發者們可以實現符合自己需求的攔截器。

下面的MyBatis官網的一個攔截器實例:

@Intercepts({@Signature(  type= Executor.class,  method = "update",  args = {MappedStatement.class,Object.class})})public class ExamplePlugin implements Interceptor {  public Object intercept(Invocation invocation) throws Throwable {    return invocation.proceed();  }  public Object plugin(Object target) {    return Plugin.wrap(target, this);  }  public void setProperties(Properties properties) {  }}

全局xml配置:

<plugins>    <plugin interceptor="org.format.mybatis.cache.interceptor.ExamplePlugin"></plugin></plugins>

這個攔截器攔截Executor接口的update方法(其實也就是Sqlsession的新增,刪除,修改操作),所有執行executor的update方法都會被該攔截器攔截到。

源碼分析

下面我們分析一下這段代碼背后的源碼。

首先從源頭->配置文件開始分析:

XMLConfigBuilder解析MyBatis全局配置文件的pluginElement私有方法:

private void pluginElement(XNode parent) throws Exception {    if (parent != null) {      for (XNode child : parent.getChildren()) {        String interceptor = child.getStringAttribute("interceptor");        Properties properties = child.getChildrenasproperties();        Interceptor interceptorInstance = (Interceptor) resolveClass(interceptor).newInstance();        interceptorInstance.setProperties(properties);        configuration.addInterceptor(interceptorInstance);      }    }}

具體的解析代碼其實比較簡單,就不貼了,主要就是通過反射實例化plugin節點中的interceptor屬性表示的類。然后調用全局配置類Configuration的addInterceptor方法。

public void addInterceptor(Interceptor interceptor) {   interceptorChain.addInterceptor(interceptor);     }

這個interceptorChain是Configuration的內部屬性,類型為InterceptorChain,也就是一個攔截器鏈,我們來看下它的定義:

public class InterceptorChain {  private final List<Interceptor> interceptors = new ArrayList<Interceptor>();  public Object pluginAll(Object target) {    for (Interceptor interceptor : interceptors) {      target = interceptor.plugin(target);    }    return target;  }  public void addInterceptor(Interceptor interceptor) {    interceptors.add(interceptor);  }  public List<Interceptor> getInterceptors() {    return Collections.unmodifiableList(interceptors);  }}

現在我們理解了攔截器配置的解析以及攔截器的歸屬,現在我們回過頭看下為何攔截器會攔截這些方法(Executor,ParameterHandler,ResultSetHandler,StatementHandler的部分方法):

public ParameterHandler newParameterHandler(MappedStatement mappedStatement, Object parameterObject, BoundSql boundSql) {    ParameterHandler parameterHandler = mappedStatement.getLang().createParameterHandler(mappedStatement, parameterObject, boundSql);    parameterHandler = (ParameterHandler) interceptorChain.pluginAll(parameterHandler);    return parameterHandler;}public ResultSetHandler newResultSetHandler(Executor executor, MappedStatement mappedStatement, RowBounds rowBounds, ParameterHandler parameterHandler,  ResultHandler resultHandler, BoundSql boundSql) {    ResultSetHandler resultSetHandler = new DefaultResultSetHandler(executor, mappedStatement, parameterHandler, resultHandler, boundSql, rowBounds);    resultSetHandler = (ResultSetHandler) interceptorChain.pluginAll(resultSetHandler);    return resultSetHandler;}public StatementHandler newStatementHandler(Executor executor, MappedStatement mappedStatement, Object parameterObject, RowBounds rowBounds, ResultHandler resultHandler, BoundSql boundSql) {    StatementHandler statementHandler = new RoutingStatementHandler(executor, mappedStatement, parameterObject, rowBounds, resultHandler, boundSql);    statementHandler = (StatementHandler) interceptorChain.pluginAll(statementHandler);    return statementHandler;}public Executor newExecutor(Transaction transaction, ExecutorType executorType, boolean autoCommit) {    executorType = executorType == null ? defaultExecutorType : executorType;    executorType = executorType == null ? ExecutorType.SIMPLE : executorType;    Executor executor;    if (ExecutorType.BATCH == executorType) {      executor = new BatchExecutor(this, transaction);    } else if (ExecutorType.REUSE == executorType) {      executor = new ReuseExecutor(this, transaction);    } else {      executor = new SimpleExecutor(this, transaction);    }    if (cacheEnabled) {      executor = new CachingExecutor(executor, autoCommit);    }    executor = (Executor) interceptorChain.pluginAll(executor);    return executor;}

以上4個方法都是Configuration的方法。這些方法在MyBatis的一個操作(新增,刪除,修改,查詢)中都會被執行到,執行的先后順序是Executor,ParameterHandler,ResultSetHandler,StatementHandler(其中ParameterHandler和ResultSetHandler的創建是在創建StatementHandler[3個可用的實現類CallableStatementHandler,PreparedStatementHandler,SimpleStatementHandler]的時候,其構造函數調用的[這3個實現類的構造函數其實都調用了父類BaseStatementHandler的構造函數])。

這4個方法實例化了對應的對象之后,都會調用interceptorChain的pluginAll方法,InterceptorChain的pluginAll剛才已經介紹過了,就是遍歷所有的攔截器,然后調用各個攔截器的plugin方法。注意:攔截器的plugin方法的返回值會直接被賦值給原先的對象

由于可以攔截StatementHandler,這個接口主要處理sql語法的構建,因此比如分頁的功能,可以用攔截器實現,只需要在攔截器的plugin方法中處理StatementHandler接口實現類中的sql即可,可使用反射實現。

MyBatis還提供了 @Intercepts和 @Signature關于攔截器的注解。官網的例子就是使用了這2個注解,還包括了Plugin類的使用:

@Overridepublic Object plugin(Object target) {    return Plugin.wrap(target, this);}

下面我們就分析這3個 "新組合" 的源碼,首先先看Plugin類的wrap方法:

public static Object wrap(Object target, Interceptor interceptor) {    Map<Class<?>, Set<Method>> signatureMap = getSignatureMap(interceptor);    Class<?> type = target.getClass();    Class<?>[] interfaces = getAllInterfaces(type, signatureMap);    if (interfaces.length > 0) {      return Proxy.newProxyInstance(          type.getClassLoader(),          interfaces,          new Plugin(target, interceptor, signatureMap));    }    return target;}

Plugin類實現了InvocationHandler接口,很明顯,我們看到這里返回了一個JDK自身提供的動態代理類。我們解剖一下這個方法調用的其他方法:

getSignatureMap方法:

private static Map<Class<?>, Set<Method>> getSignatureMap(Interceptor interceptor) {    Intercepts interceptsAnnotation = interceptor.getClass().getAnnotation(Intercepts.class);    if (interceptsAnnotation == null) { // issue #251      throw new PluginException("No @Intercepts annotation was found in interceptor " + interceptor.getClass().getName());          }    Signature[] sigs = interceptsAnnotation.value();    Map<Class<?>, Set<Method>> signatureMap = new HashMap<Class<?>, Set<Method>>();    for (Signature sig : sigs) {      Set<Method> methods = signatureMap.get(sig.type());      if (methods == null) {        methods = new HashSet<Method>();        signatureMap.put(sig.type(), methods);      }      try {        Method method = sig.type().getMethod(sig.method(), sig.args());        methods.add(method);      } catch (NoSuchMethodException e) {        throw new PluginException("Could not find method on " + sig.type() + " named " + sig.method() + ". Cause: " + e, e);      }    }    return signatureMap;}

getSignatureMap方法解釋:首先會拿到攔截器這個類的 @Interceptors注解,然后拿到這個注解的屬性 @Signature注解集合,然后遍歷這個集合,遍歷的時候拿出 @Signature注解的type屬性(Class類型),然后根據這個type得到帶有method屬性和args屬性的Method。由于 @Interceptors注解的 @Signature屬性是一個屬性,所以最終會返回一個以type為key,value為Set<Method>的Map。

@Intercepts({@Signature(  type= Executor.class,  method = "update",  args = {MappedStatement.class,Object.class})})  

比如這個 @Interceptors注解會返回一個key為Executor,value為集合(這個集合只有一個元素,也就是Method實例,這個Method實例就是Executor接口的update方法,且這個方法帶有MappedStatement和Object類型的參數)。這個Method實例是根據 @Signature的method和args屬性得到的。如果args參數跟type類型的method方法對應不上,那么將會拋出異常。

getAllInterfaces方法:

private static Class<?>[] getAllInterfaces(Class<?> type, Map<Class<?>, Set<Method>> signatureMap) {    Set<Class<?>> interfaces = new HashSet<Class<?>>();    while (type != null) {      for (Class<?> c : type.getInterfaces()) {        if (signatureMap.containsKey(c)) {          interfaces.add(c);        }      }      type = type.getSuperclass();    }    return interfaces.toArray(new Class<?>[interfaces.size()]);}

getAllInterfaces方法解釋:根據目標實例target(這個target就是之前所說的MyBatis攔截器可以攔截的類,Executor,ParameterHandler,ResultSetHandler,StatementHandler)和它的父類們,返回signatureMap中含有target實現的接口數組。

所以Plugin這個類的作用就是根據 @Interceptors注解,得到這個注解的屬性 @Signature數組,然后根據每個 @Signature注解的type,method,args屬性使用反射找到對應的Method。最終根據調用的target對象實現的接口決定是否返回一個代理對象替代原先的target對象。

比如MyBatis官網的例子,當Configuration調用newExecutor方法的時候,由于Executor接口的update(MappedStatement ms, Object parameter)方法被攔截器被截獲。因此最終返回的是一個代理類Plugin,而不是Executor。這樣調用方法的時候,如果是個代理類,那么會執行:

public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {    try {      Set<Method> methods = signatureMap.get(method.getDeclaringClass());      if (methods != null && methods.contains(method)) {        return interceptor.intercept(new Invocation(target, method, args));      }      return method.invoke(target, args);    } catch (Exception e) {      throw ExceptionUtil.unwrapThrowable(e);    }}

沒錯,如果找到對應的方法被代理之后,那么會執行Interceptor接口的interceptor方法。

這個Invocation類如下:

public class Invocation {  private Object target;  private Method method;  private Object[] args;  public Invocation(Object target, Method method, Object[] args) {    this.target = target;    this.method = method;    this.args = args;  }  public Object getTarget() {    return target;  }  public Method getMethod() {    return method;  }  public Object[] getArgs() {    return args;  }  public Object proceed() throws InvocationTargetException, IllegalaccessException {    return method.invoke(target, args);  }}

它的proceed方法也就是調用原先方法(不走代理)。

總結

MyBatis攔截器接口提供的3個方法中,plugin方法用于某些處理器(Handler)的構建過程。interceptor方法用于處理代理類的執行。setProperties方法用于攔截器屬性的設置。

其實MyBatis官網提供的使用 @Interceptors和 @Signature注解以及Plugin類這樣處理攔截器的方法,我們不一定要直接這樣使用。我們也可以拋棄這3個類,直接在plugin方法內部根據target實例的類型做相應的操作。

總體來說MyBatis攔截器還是很簡單的,攔截器本身不需要太多的知識點,但是學習攔截器需要對MyBatis中的各個接口很熟悉,因為攔截器涉及到了各個接口的知識點。


發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 集安市| 嘉善县| 谷城县| 余庆县| 铅山县| 兴安盟| 永善县| 二连浩特市| 吉隆县| 同德县| 双城市| 淮北市| 博乐市| 台东县| 阿克苏市| 黄平县| 惠东县| 文成县| 新乐市| 陇南市| 南城县| 股票| 卫辉市| 大名县| 利辛县| 类乌齐县| 通州市| 淄博市| 平阴县| 宿州市| 武义县| 呼图壁县| 大城县| 天柱县| 阳山县| 安国市| 西丰县| 宁陵县| 城口县| 邯郸县| 赫章县|