Mybatis interceptor

package com.pab.bloan.capv.server.common.changemonitor.enumerate;


public enum DBActionTypeEnum {
    
    UPDATE("UPDATE","更新"),
    INSERT("INSERT","新增"),
    DELETE("DELETE","删除");
    
    private String key;
    private String value;
    
    private DBActionTypeEnum(String key, String value) {
        this.key = key;
        this.value = value;
    }
    
    public String getKey() {
        return key;
    }

    public String getValue() {
        return value;
    }
    
}

package com.pab.bloan.capv.server.common.changemonitor.interceptor;

import com.alibaba.druid.pool.DruidPooledPreparedStatement;
import com.alibaba.druid.proxy.jdbc.JdbcParameter;
import com.alibaba.druid.proxy.jdbc.PreparedStatementProxy;
import com.alibaba.druid.sql.SQLUtils;
import com.pab.bloan.capv.server.common.changemonitor.listener.DBObjectChangeEventListener;
import com.pab.bloan.capv.server.common.changemonitor.model.ChangeMonitorBo;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.executor.statement.StatementHandler;
import org.apache.ibatis.logging.jdbc.PreparedStatementLogger;
import org.apache.ibatis.plugin.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.springframework.util.ReflectionUtils;

import java.lang.reflect.Field;
import java.sql.Statement;
import java.util.*;

@Slf4j
@Component
@Intercepts({
    @Signature(type = StatementHandler.class, method = "update", args = {Statement.class})
})
public class ChangeMinitorInterceptor implements Interceptor {

    @Autowired
    private DBObjectChangeEventListener changeEventListener;
    @Value("${capv.minitor.plugin.enable:true}")
    private Boolean changeMinitorSwitch;

    @Override
    public Object intercept(Invocation invocation) throws Throwable {
        Object proceedResult = null;

        // 解析拦截到的sql 并进行更新前处理
        ChangeMonitorBo changeMonitorBo = null;
        try {
            String realSql = parseRealSql((Statement) invocation.getArgs()[0]);
            log.info("解析后的sql为: {}", realSql);
            changeMonitorBo = new ChangeMonitorBo(realSql);

            // 更新前处理
            changeEventListener.beforeChange(changeMonitorBo);
        }catch (Throwable err){
            log.error(err.getMessage());
        }

        // 执行拦截的方法
        proceedResult = invocation.proceed();

        // 更新后处理
        try {
            if(changeMonitorBo != null) {
                changeEventListener.afterChange(changeMonitorBo);
            }
        }catch (Throwable err){
            log.error(err.getMessage());
        }

        // 返回执行结果
        return proceedResult;
    }

    @Override
    public Object plugin(Object target) {
        if(changeMinitorSwitch) {
            if (target instanceof StatementHandler) {
                return Plugin.wrap(target, this);
            }
        }
        return target;
    }

    @Override
    public void setProperties(Properties arg0) {
    }

    private Object getField(Object obj, String fieldName) {
        Field field = ReflectionUtils.findField(obj.getClass(),fieldName);
        ReflectionUtils.makeAccessible(field);
        return ReflectionUtils.getField(field,obj);
    }

    public String parseRealSql(Statement statement) {
        DruidPooledPreparedStatement druidPooledPreparedStatement = null;
        if(statement instanceof DruidPooledPreparedStatement) {
            druidPooledPreparedStatement = (DruidPooledPreparedStatement) statement;
        }else{
            PreparedStatementLogger preparedStatementLogger = (PreparedStatementLogger) getField(statement, "h");
            druidPooledPreparedStatement = (DruidPooledPreparedStatement) preparedStatementLogger.getPreparedStatement();
        }
        PreparedStatementProxy preparedStatementProxy = (PreparedStatementProxy)druidPooledPreparedStatement.getStatement();

        int parametersSize = preparedStatementProxy.getParametersSize();
        List