(shardingsphere) branch master updated: Rrefactor MaskRuleStatementConverter (#30610)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

zhangliang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git


The following commit(s) were added to refs/heads/master by this push:
     new 95e3baf9e3a Rrefactor MaskRuleStatementConverter (#30610)
95e3baf9e3a is described below

commit 95e3baf9e3a7f138973fef2048de97d3b58c2cd1
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Sat Mar 23 00:36:27 2024 +0800

    Rrefactor MaskRuleStatementConverter (#30610)
---
 .../handler/converter/MaskRuleStatementConverter.java    | 16 +++++++---------
 1 file changed, 7 insertions(+), 9 deletions(-)

diff --git 
a/features/mask/distsql/handler/src/main/java/org/apache/shardingsphere/mask/distsql/handler/converter/MaskRuleStatementConverter.java
 
b/features/mask/distsql/handler/src/main/java/org/apache/shardingsphere/mask/distsql/handler/converter/MaskRuleStatementConverter.java
index 1ded28b74b2..211d1c36164 100644
--- 
a/features/mask/distsql/handler/src/main/java/org/apache/shardingsphere/mask/distsql/handler/converter/MaskRuleStatementConverter.java
+++ 
b/features/mask/distsql/handler/src/main/java/org/apache/shardingsphere/mask/distsql/handler/converter/MaskRuleStatementConverter.java
@@ -30,6 +30,7 @@ import java.util.Collection;
 import java.util.HashMap;
 import java.util.LinkedList;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 /**
  * Mask rule statement converter.
@@ -54,13 +55,15 @@ public final class MaskRuleStatementConverter {
     }
     
     private static MaskTableRuleConfiguration 
createMaskTableRuleConfiguration(final MaskRuleSegment ruleSegment) {
-        Collection<MaskColumnRuleConfiguration> columns = new LinkedList<>();
-        for (MaskColumnSegment each : ruleSegment.getColumns()) {
-            
columns.add(createMaskColumnRuleConfiguration(ruleSegment.getTableName(), 
each));
-        }
+        Collection<MaskColumnRuleConfiguration> columns = 
ruleSegment.getColumns().stream()
+                .map(each -> 
createMaskColumnRuleConfiguration(ruleSegment.getTableName(), 
each)).collect(Collectors.toList());
         return new MaskTableRuleConfiguration(ruleSegment.getTableName(), 
columns);
     }
     
+    private static MaskColumnRuleConfiguration 
createMaskColumnRuleConfiguration(final String tableName, final 
MaskColumnSegment columnSegment) {
+        return new MaskColumnRuleConfiguration(columnSegment.getName(), 
getAlgorithmName(tableName, columnSegment));
+    }
+    
     private static Map<String, AlgorithmConfiguration> 
createMaskAlgorithmConfigurations(final MaskRuleSegment ruleSegment) {
         Map<String, AlgorithmConfiguration> result = new 
HashMap<>(ruleSegment.getColumns().size(), 1F);
         for (MaskColumnSegment each : ruleSegment.getColumns()) {
@@ -69,11 +72,6 @@ public final class MaskRuleStatementConverter {
         return result;
     }
     
-    private static MaskColumnRuleConfiguration 
createMaskColumnRuleConfiguration(final String tableName, final 
MaskColumnSegment columnSegment) {
-        String maskColumnRuleName = getAlgorithmName(tableName, columnSegment);
-        return new MaskColumnRuleConfiguration(columnSegment.getName(), 
maskColumnRuleName);
-    }
-    
     private static String getAlgorithmName(final String tableName, final 
MaskColumnSegment columnSegment) {
         return String.format("%s_%s_%s", tableName, columnSegment.getName(), 
columnSegment.getAlgorithm().getName()).toLowerCase();
     }