数据库加密组件

matrix-datasource/matrix-datasource-security/matrix-datasource-security-druid/src/main/java/com/secoo/mall/datasource/security/filter/SecurityFilter.java

@@ -306,13 +306,15 @@ public class SecurityFilter extends SecurityFilterEventAdapter {
                 continue;
             }
 
-            List<Parameter> encryptParameters = new ArrayList<>();
-            MySqlSecurityParameterVisitor visitor = new MySqlSecurityParameterVisitor(tableRuleMap,encryptParameters);
+            MySqlSecurityParameterVisitor visitor = new MySqlSecurityParameterVisitor(tableRuleMap);
             stmt.accept(visitor);
+            List<Parameter> encryptParameters = visitor.getEncryptParameters();
 
             // 加密
-            for(Parameter parameter : encryptParameters){
-                encrypt(parameter.getColumnRule(), preparedStatement, parameter.getJdbcIndex());
+            if(encryptParameters != null && !encryptParameters.isEmpty()){
+                for(Parameter parameter : encryptParameters){
+                    encrypt(parameter.getColumnRule(), preparedStatement, parameter.getJdbcIndex());
+                }
             }
         }
     }

matrix-datasource/matrix-datasource-security/matrix-datasource-security-druid/src/main/java/com/secoo/mall/datasource/security/visitor/MySqlSecurityParameterVisitor.java

@@ -30,6 +30,10 @@ public class MySqlSecurityParameterVisitor extends MySqlSchemaStatVisitor {
         this.encryptParameters = encryptParameters;
     }
 
+    public MySqlSecurityParameterVisitor(Map<String,Map<String,ColumnRule>> tableRuleMap) {
+        this(tableRuleMap,new ArrayList<>());
+    }
+
     public Map<String, Map<String, ColumnRule>> getTableRuleMap() {
         return tableRuleMap;
     }