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

duanzhengqiang 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 0d213c732 Minor improve for MetaDataContextsBuilder (#11506)
0d213c732 is described below

commit 0d213c732a68899fe1d879bb92f66c9693ff538f
Author: Haoran Meng <[email protected]>
AuthorDate: Mon Jul 26 14:46:44 2021 +0800

    Minor improve for MetaDataContextsBuilder (#11506)
---
 .../infra/metadata/schema/builder/SchemaBuilderTest.java   |  6 +++---
 .../infra/context/metadata/MetaDataContextsBuilder.java    | 14 +++++++-------
 2 files changed, 10 insertions(+), 10 deletions(-)

diff --git 
a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java
 
b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java
index 9248198..d16ca1d 100644
--- 
a/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java
+++ 
b/shardingsphere-infra/shardingsphere-infra-common/src/test/java/org/apache/shardingsphere/infra/metadata/schema/builder/SchemaBuilderTest.java
@@ -111,9 +111,9 @@ public final class SchemaBuilderTest {
         when(resultSet.next()).thenReturn(true, true, true, true, true, true, 
false);
         String[] mockReturnTables = {singleTableNames[1], 
"data_node_routed_table1_0", "data_node_routed_table1_1", 
"data_node_routed_table2_0", "data_node_routed_table2_1"};
         when(resultSet.getString(TABLE_NAME)).thenReturn(singleTableNames[0], 
mockReturnTables);
-        Map<TableMetaData, TableMetaData> tableMetaDatas = 
SchemaBuilder.build(schemaBuilderMaterials);
-        assertThat(tableMetaDatas.keySet().size(), is(4));
-        assertActualOfShardingTablesAndSingleTables(tableMetaDatas.keySet());
+        Map<TableMetaData, TableMetaData> tableMetaData = 
SchemaBuilder.build(schemaBuilderMaterials);
+        assertThat(tableMetaData.keySet().size(), is(4));
+        assertActualOfShardingTablesAndSingleTables(tableMetaData.keySet());
     }
     
     private void assertActualOfShardingTablesAndSingleTables(final 
Collection<TableMetaData> actual) {
diff --git 
a/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/metadata/MetaDataContextsBuilder.java
 
b/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/metadata/MetaDataContextsBuilder.java
index b0078ff..63f9022 100644
--- 
a/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/metadata/MetaDataContextsBuilder.java
+++ 
b/shardingsphere-infra/shardingsphere-infra-context/src/main/java/org/apache/shardingsphere/infra/context/metadata/MetaDataContextsBuilder.java
@@ -98,21 +98,21 @@ public final class MetaDataContextsBuilder {
             Collection<RuleConfiguration> ruleConfigs = 
schemaRuleConfigs.get(each);
             DatabaseType databaseType = 
DatabaseTypeRecognizer.getDatabaseType(dataSourceMap.values());
             Collection<ShardingSphereRule> rules = 
ShardingSphereRulesBuilder.buildSchemaRules(each, ruleConfigs, databaseType, 
dataSourceMap);
-            Map<TableMetaData, TableMetaData> tableMetaDatas = 
SchemaBuilder.build(new SchemaBuilderMaterials(databaseType, dataSourceMap, 
rules, props));
+            Map<TableMetaData, TableMetaData> tableMetaData = 
SchemaBuilder.build(new SchemaBuilderMaterials(databaseType, dataSourceMap, 
rules, props));
             ShardingSphereRuleMetaData ruleMetaData = new 
ShardingSphereRuleMetaData(ruleConfigs, rules);
             ShardingSphereResource resource = buildResource(databaseType, 
dataSourceMap);
-            ShardingSphereSchema actualSchema = new 
ShardingSphereSchema(tableMetaDatas.keySet().stream().filter(Objects::nonNull).collect(Collectors.toMap(TableMetaData::getName,
 v -> v)));
+            ShardingSphereSchema actualSchema = new 
ShardingSphereSchema(tableMetaData.keySet().stream().filter(Objects::nonNull).collect(Collectors.toMap(TableMetaData::getName,
 v -> v)));
             actualMetaDataMap.put(each, new ShardingSphereMetaData(each, 
resource, ruleMetaData, actualSchema));
-            metaDataMap.put(each, new ShardingSphereMetaData(each, resource, 
ruleMetaData, buildSchema(tableMetaDatas)));
+            metaDataMap.put(each, new ShardingSphereMetaData(each, resource, 
ruleMetaData, buildSchema(tableMetaData)));
         }
         OptimizeContextFactory optimizeContextFactory = new 
OptimizeContextFactory(actualMetaDataMap);
         return new StandardMetaDataContexts(persistService, metaDataMap, 
buildGlobalSchemaMetaData(metaDataMap), executorEngine, props, 
optimizeContextFactory);
     }
     
-    private ShardingSphereSchema buildSchema(final Map<TableMetaData, 
TableMetaData> tableMetaDatas) {
-        Map<String, TableMetaData> tables = new 
HashMap<>(tableMetaDatas.size(), 1);
-        
tables.putAll(tableMetaDatas.keySet().stream().collect(Collectors.toMap(TableMetaData::getName,
 v -> v)));
-        
tables.putAll(tableMetaDatas.values().stream().collect(Collectors.toMap(TableMetaData::getName,
 v -> v)));
+    private ShardingSphereSchema buildSchema(final Map<TableMetaData, 
TableMetaData> tableMetaData) {
+        Map<String, TableMetaData> tables = new 
HashMap<>(tableMetaData.size(), 1);
+        
tables.putAll(tableMetaData.keySet().stream().collect(Collectors.toMap(TableMetaData::getName,
 v -> v)));
+        
tables.putAll(tableMetaData.values().stream().collect(Collectors.toMap(TableMetaData::getName,
 v -> v)));
         return new ShardingSphereSchema(tables);
     }
 

Reply via email to