Java

dependencygroupIdcom.github.jsqlparser/groupIdartifac…新建mybatis的statementHander拦截器拦截器

面试题

dependencygroupIdcom.github.jsqlparser/groupIdartifactIdjsqlparser/artifactIdversion4.6/version/dependency

添加拦截器代码

cn.hutool.core.collection.CollUtil;

import

net.sf.jsqlparser.parser.CCJSqlParserUtil;

import

net.sf.jsqlparser.schema.Table;

import

net.sf.jsqlparser.statement.insert.Insert;

import

net.sf.jsqlparser.statement.update.Update;

import

net.sf.jsqlparser.statement.update.UpdateSet;

import

org.apache.ibatis.executor.parameter.ParameterHandler;

import

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

import

org.apache.ibatis.mapping.BoundSql;

import

org.apache.ibatis.plugin.Interceptor;

import

org.apache.ibatis.plugin.Intercepts;

import

org.apache.ibatis.plugin.Invocation;

import

org.apache.ibatis.plugin.Signature;

import

org.springframework.stereotype.Component;import

import

指定要拦截的方法签名这里是拦截Executor的update方法Signature(type

method

CollUtil.newArrayList(product,category);private

static

{tableColumns.put(product,CollUtil.newArrayList(name,price));}Overridepublic

Object

(StatementHandler)invocation.getTarget();//要想监控表首先要从拦截器中拿到sql语句看sql语句干了什么对那些表和那些字段做了什么BoundSql

boundSql

statementHandler.getBoundSql();String

sql

使用JSqlParser解析器解析sql语句net.sf.jsqlparser.statement.Statement

statement

CCJSqlParserUtil.parse(sql);if(statement

instanceof

update.getTable().getName();if(tables.contains(name)){ListString

updataSets

tableColumns.get(name);ArrayListUpdateSet

updateSets

updateSet.getColumns().get(0).getColumnName();if(updataSets.contains(columnName)){sendMessage(

if(statement

table.getName();if(tables.contains(name)){sendMessage(添加了数据,name);}}return

void

https://oapi.dingtalk.com/robot/send?access_token1cfb9a7b20e849a26b572a8ff98f62ee2a220028cd1452901a486e131435621f;JSONArray

array

JSONArray();array.add(18236435312);JSONObject

msg

JSONObject();msg.set(msgtype,text);msg.set(text,new

JSONObject().set(content,警告ThreadlocalUtil.get().getNickName()-

option

JSONObject().set(atMobiles,array));String

json

HttpRequest.post(url).body(json).execute().body();}}遇到的问题

因为这个pagehelper是从stater中继承过来的可以在stater中也加一个4.6版本的jsqlparser依赖