fix 配置了ignoredTableColumns:table_name1.* ,insert时DataChangeRecorderInnerInterceptor仍然打印相关字段的bug (#6165)

mybatis-plus-extension/src/main/java/com/baomidou/mybatisplus/extension/plugins/inner/DataChangeRecorderInnerInterceptor.java

@@ -196,7 +196,14 @@ public class DataChangeRecorderInnerInterceptor implements InnerInterceptor {
     public OperationResult processInsert(Insert insertStmt, BoundSql boundSql) {
         OperationResult result = new OperationResult();
         result.setOperation("insert");
-        result.setTableName(insertStmt.getTable().getName());
+        final Table table = insertStmt.getTable();
+        final Set<String> ignoredColumns = ignoredTableColumns.get(table.getName().toUpperCase());
+        if (ignoredColumns != null && ignoredColumns.stream().anyMatch("*"::equals)) {
+            result.setTableName(table.getName() + ":*");
+            result.setRecordStatus(false);
+            return result;
+        }
+        result.setTableName(table.getName());
         result.setRecordStatus(true);
         Map<String, Object> updatedColumnDatas = getUpdatedColumnDatas(result.getTableName(), boundSql, insertStmt);
         result.buildDataStr(compareAndGetUpdatedColumnDatas(result.getTableName(), null, updatedColumnDatas));

mybatis-plus-extension/src/test/java/com/baomidou/mybatisplus/test/extension/plugins/inner/DataChangeRecorderInnerInterceptorTest.java

@@ -0,0 +1,59 @@
+package com.baomidou.mybatisplus.test.extension.plugins.inner;
+
+import com.baomidou.mybatisplus.extension.plugins.inner.DataChangeRecorderInnerInterceptor;
+import net.sf.jsqlparser.schema.Table;
+import net.sf.jsqlparser.statement.insert.Insert;
+import org.junit.jupiter.api.Assertions;
+import org.junit.jupiter.api.BeforeEach;
+import org.junit.jupiter.api.Test;
+
+import java.lang.reflect.Field;
+import java.util.Map;
+import java.util.Properties;
+import java.util.Set;
+
+/**
+ * @author miemie
+ * @since 2020-06-28
+ */
+class DataChangeRecorderInnerInterceptorTest {
+
+    private final DataChangeRecorderInnerInterceptor interceptor = new DataChangeRecorderInnerInterceptor();
+
+    @BeforeEach
+    public void initProperties() {
+        Properties properties = new Properties();
+        properties.put("ignoredTableColumns", "table_name1.column1,column2; h2user.*; *.column1,COLUMN2");
+        interceptor.setProperties(properties);
+    }
+    @Test
+    void setProperties() throws Exception {
+        final Object ignoreAllColumns = getFieldValue(interceptor, "ignoreAllColumns");
+        Assertions.assertTrue(Set.of("COLUMN1", "COLUMN2").equals(ignoreAllColumns));
+
+        final Object ignoredTableColumns = getFieldValue(interceptor, "ignoredTableColumns");
+        Assertions.assertTrue(Map.of("H2USER", Set.of("*"), "TABLE_NAME1", Set.of("COLUMN1", "COLUMN2")).equals(ignoredTableColumns));
+    }
+
+
+
+    private Object getFieldValue(Object obj, String fieldName) throws NoSuchFieldException, IllegalAccessException {
+        final Field field = DataChangeRecorderInnerInterceptor.class.getDeclaredField(fieldName);
+        field.setAccessible(true);
+        final Object fieldValue = field.get(obj);
+        field.setAccessible(false);
+        return fieldValue;
+    }
+
+    @Test
+    void processInsert() throws Exception{
+        final Insert insert = new Insert();
+        insert.setTable(new Table("H2USER"));
+        final DataChangeRecorderInnerInterceptor.OperationResult operationResult = interceptor.processInsert(insert, null);
+        Assertions.assertEquals(operationResult.getTableName(), "H2USER:*");
+        Assertions.assertFalse(operationResult.isRecordStatus());
+        Assertions.assertEquals(operationResult.getChangedData(), null);
+
+    }
+
+}