服务器之家:专注于服务器技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|

服务器之家 - 数据库 - Mysql - mybatis 实现 SQL 查询拦截修改详解

mybatis 实现 SQL 查询拦截修改详解

2020-11-26 17:43coderstory Mysql

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

前言

截器的一个作用就是我们可以拦截某些方法的调用,我们可以选择在这些被拦截的方法执行前后加上某些逻辑,也可以在执行这些被拦截的方法时执行自己的逻辑而不再执行被拦截的方法。

Mybatis拦截器设计的一个初衷就是为了供用户在某些时候可以实现自己的逻辑而不必去动Mybatis固有的逻辑。比如我想针对所有的SQL执行某个固定的操作,针对SQL查询执行安全检查,或者记录相关SQL查询日志等等。

Mybatis为我们提供了一个Interceptor接口,可以实现自定义的拦截器。

?
1
2
3
4
5
public interface Interceptor {
 Object intercept(Invocation invocation) throws Throwable;
 Object plugin(Object target);
 void setProperties(Properties properties);
}

接口中包含了三个方法定义

intercept方法为具体的拦截对象的处理方法,传入的Invocation包含了拦截目标类的实力,拦截的方法和方法的入参数组。使用Invocation的procced执行原函数。

plugin 中执行判断是否要进行拦截进,如果不需要拦截,直接返回target,如果需要拦截则调用Plugin类中的wrap静态方法,如果当前拦截器实现了任意接口,则返回一个代理对象,否则直接返回(回忆代理模式的设计)。代理对象实际是一个Plugin类实例,它实现了InvocationHandler接口 ,InvocationHandler接口仅包含invoke方法用于回调方法。

当执行代理对象的接口方法时,会调用Plugin的invoke方法,它会把要执行的对象,方法和参数打包成Invocation对象传给拦截器的intercept方法。Invocation定义了一个procced方法,用于执行被拦截的原方法。

Plugin类定义

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
public class Plugin implements InvocationHandler {
 
 private Object target;
 private Interceptor interceptor;
 private Map, Set> signatureMap;
 
 private Plugin(Object target, Interceptor interceptor, Map, Set> signatureMap) {
  this.target = target;
  this.interceptor = interceptor;
  this.signatureMap = signatureMap;
 }
 
 public static Object wrap(Object target, Interceptor interceptor) {
  Map, Set> 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;
 }
 
 public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
  try {
   Set 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);
  }
 }
 
 private static Map, Set> 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, Set> signatureMap = new HashMap, Set>();
  for (Signature sig : sigs) {
   Set methods = signatureMap.get(sig.type());
   if (methods == null) {
    methods = new HashSet();
    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;
 }
 
 private static Class[] getAllInterfaces(Class type, Map, Set> signatureMap) {
  Set> interfaces = new HashSet>();
  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()]);
 }
 
}

setProperties 方法顾名思义,用于设置属性的。bean的属性初始化方法有很多,这是其中的一种。

mybatis提供了@Intercepts注解用于声明当前类是拦截器,其值为@Signature数组,表明要拦截的接口、方法以及对应的参数类型

?
1
2
3
4
@Intercepts({@Signature(method = "prepare", type = StatementHandler.class, args = {Connection.class}),
    @Signature(method = "query", type = StatementHandler.class, args = {java.sql.Statement.class, ResultHandler.class})})
public class TenantInterceptor implements Interceptor {
.....

例如上面的类声明,第一个Signature标注拦截了StatementHandler类下的入参是一个Connection的名为prepare的方法。

第二个Signature标注拦截StatementHandler类中包含2个入参(分别为Statement和ResultHandler类型)的名为query的方法。

最后,声明的Interceptor需要注册到mybatis的plug中才能生效。

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
<!-- 配置mybatis -->
<bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean">
  <property name="dataSource" ref="dataSource"/>
  <property name="configLocation" value="classpath:mybatis/mybatis-config.xml"/>
  <!-- mapper扫描 -->
  <property name="mapperLocations" value="classpath:mybatis/*/*.xml"/>
  <property name="plugins">
    <array>
      <!-- 注册自己的拦截器 -->
      <bean id="paginationInterceptor" class="xxx.xxx.TenantInterceptor">
      </bean>
    </array>
  </property>
</bean>

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

原文链接:https://blog.coderstory.cn/mybatis-interceptor/

延伸 · 阅读

精彩推荐
  • MysqlMySQL slow_log表无法修改成innodb引擎详解

    MySQL slow_log表无法修改成innodb引擎详解

    这篇文章主要给大家介绍了关于MySQL slow_log表无法修改成innodb引擎的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用MySQL具有一定的参考...

    Jia-Xin2142019-06-25
  • MysqlMySQL中的RAND()函数使用详解

    MySQL中的RAND()函数使用详解

    这篇文章主要介绍了MySQL中的RAND()函数使用详解,是MySQL入门学习中的基础知识,需要的朋友可以参考下 ...

    MYSQL教程网2812020-05-08
  • Mysqlmysql千万级数据大表该如何优化?

    mysql千万级数据大表该如何优化?

    如何设计或优化千万级别的大表?此外无其他信息,个人觉得这个话题有点范,就只好简单说下该如何做,对于一个存储设计,必须考虑业务特点,收集的...

    MYSQL教程网1512019-11-22
  • Mysql数据库Mysql性能优化详解

    数据库Mysql性能优化详解

    这篇文章主要介绍了数据库Mysql性能优化的相关资料,需要的朋友可以参考下...

    我的小草鱼2762020-06-10
  • Mysql详解Centos7 修改mysql指定用户的密码

    详解Centos7 修改mysql指定用户的密码

    本篇文章主要介绍了Centos7 修改mysql指定用户的密码,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧。 ...

    程序猿到攻城狮之旅2862020-07-07
  • Mysql详解MySQL的简易封装以及使用

    详解MySQL的简易封装以及使用

    本文主要介绍了MySQL的简易封装以及使用。具有一定的参考价值,下面跟着小编一起来看下吧...

    YouXianMing1742020-07-29
  • Mysql详解JDBC数据库链接及相关方法的封装

    详解JDBC数据库链接及相关方法的封装

    这篇文章主要介绍了详解JDBC数据库链接及相关方法的封装的相关资料,下面是封装的具体类,用到了泛型和反射,希望能帮助到大家,需要的朋友可以参考...

    MYSQL教程网3202020-08-12
  • MysqlMySql 8.0.11安装配置教程

    MySql 8.0.11安装配置教程

    这篇文章给大家介绍了MySql 8.0.11安装配置教程,本文给大家介绍的非常详细,具有一定的参考借鉴价值,感兴趣的朋友一起看看吧...

    Leohahah2552020-09-01