1 获取表名

@Component
public class MybatisInterceptor implements Interceptor {private static final List<String> EXCLUDE_TABLE = new ArrayList<>();static {EXCLUDE_TABLE.add("test");}private static final Pattern DELETE_REG = Pattern.compile("from\\s+(\\w+)\\s+where");private static final Pattern INSERT_REG = Pattern.compile("into\\s+(\\w+)\\s+\\(");private static final Pattern UPDATE_REG = Pattern.compile("update\\s+(\\w+)\\s+set");@Overridepublic Object intercept(Invocation invocation) throws Throwable {MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];// 获取执行SQLString sql = mappedStatement.getBoundSql(invocation.getArgs()[1]).getSql();getTableName(sql);}private String getTableName(String sql) {if (StrUtil.isBlank(sql)) {return null;}sql = sql.toLowerCase(Locale.ROOT);if (StrUtil.startWith(sql, "update")) {Matcher matcher = UPDATE_REG.matcher(sql);return matcher.find() ? matcher.group(1) : null;} else if (StrUtil.startWith(sql, "insert")) {Matcher matcher = INSERT_REG.matcher(sql);return matcher.find() ? matcher.group(1) : null;} else if (StrUtil.startWith(sql, "delete")) {Matcher matcher = DELETE_REG.matcher(sql);return matcher.find() ? matcher.group(1) : null;}return null;}}

2 获取SQL

@Component
public class MybatisInterceptor implements Interceptor {private static final List<String> EXCLUDE_TABLE = new ArrayList<>();static {EXCLUDE_TABLE.add("test");}private static final Pattern DELETE_REG = Pattern.compile("from\\s+(\\w+)\\s+where");private static final Pattern INSERT_REG = Pattern.compile("into\\s+(\\w+)\\s+\\(");private static final Pattern UPDATE_REG = Pattern.compile("update\\s+(\\w+)\\s+set");@Overridepublic Object intercept(Invocation invocation) throws Throwable {MappedStatement mappedStatement = (MappedStatement) invocation.getArgs()[0];// 获取执行SQLString sql = mappedStatement.getBoundSql(invocation.getArgs()[1]).getSql();showSql(mappedStatement.getConfiguration(),mappedStatement.getBoundSql(invocation.getArgs()[1]));}private static String showSql(Configuration conf, BoundSql boundSql) {Object param = boundSql.getParameterObject();List<ParameterMapping> mappings = boundSql.getParameterMappings();String sql = boundSql.getSql().replaceAll("[\\s]+", " ");if (param != null && !mappings.isEmpty()) {TypeHandlerRegistry typeHandlerRegistry = conf.getTypeHandlerRegistry();if (typeHandlerRegistry.hasTypeHandler(param.getClass())) {sql = sql.replaceFirst("\\?", getParameterValue(param));} else {MetaObject metaObject = conf.newMetaObject(param);for (ParameterMapping parameterMapping : mappings) {String propertyName = parameterMapping.getProperty();if (metaObject.hasGetter(propertyName)) {Object obj = metaObject.getValue(propertyName);sql = sql.replaceFirst("\\?", getParameterValue(obj));} else if (boundSql.hasAdditionalParameter(propertyName)) {Object obj = boundSql.getAdditionalParameter(propertyName);sql = sql.replaceFirst("\\?", getParameterValue(obj));}}}}return sql;}private static String getParameterValue(Object obj) {String value;if (obj instanceof String) {value = "'" + obj + "'";} else if (obj instanceof Date) {DateFormat formatter = DateFormat.getDateTimeInstance(DateFormat.DEFAULT, DateFormat.DEFAULT, Locale.CHINA);value = "'" + formatter.format(new Date()) + "'";} else {if (obj != null) {value = obj.toString();} else {value = "";}}return value.replace("$", "\\$");}\
}