This is an automated email from the ASF dual-hosted git repository.
wuweijie 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 887bfdf99f0 Refactor MaskTable (#30568)
887bfdf99f0 is described below
commit 887bfdf99f01b958bb6ece3ebcc1889eac5af92d
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Mar 20 21:46:48 2024 +0800
Refactor MaskTable (#30568)
---
.../main/java/org/apache/shardingsphere/mask/rule/MaskTable.java | 7 +++----
1 file changed, 3 insertions(+), 4 deletions(-)
diff --git
a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java
b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java
index 853fd9a1095..b2aa82d634e 100644
---
a/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java
+++
b/features/mask/core/src/main/java/org/apache/shardingsphere/mask/rule/MaskTable.java
@@ -24,6 +24,7 @@ import org.apache.shardingsphere.mask.spi.MaskAlgorithm;
import java.util.Map;
import java.util.Optional;
+import java.util.stream.Collectors;
/**
* Mask table.
@@ -33,10 +34,8 @@ public final class MaskTable {
private final Map<String, MaskColumn> columns;
public MaskTable(final MaskTableRuleConfiguration config, final
Map<String, MaskAlgorithm<?, ?>> maskAlgorithms) {
- columns = new CaseInsensitiveMap<>();
- for (MaskColumnRuleConfiguration each : config.getColumns()) {
- columns.put(each.getLogicColumn(), new
MaskColumn(each.getLogicColumn(), maskAlgorithms.get(each.getMaskAlgorithm())));
- }
+ columns =
config.getColumns().stream().collect(Collectors.toMap(MaskColumnRuleConfiguration::getLogicColumn,
+ each -> new MaskColumn(each.getLogicColumn(),
maskAlgorithms.get(each.getMaskAlgorithm())), (oldValue, currentValue) ->
oldValue, CaseInsensitiveMap::new));
}
/**