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 7609eb5  fixes TODO for load global rules from registry center (#11504)
7609eb5 is described below

commit 7609eb5653dd6b61cf3aad9030240213f74ea5af
Author: Haoran Meng <[email protected]>
AuthorDate: Mon Jul 26 12:52:13 2021 +0800

    fixes TODO for load global rules from registry center (#11504)
---
 .../governance/context/metadata/GovernanceMetaDataContexts.java   | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git 
a/shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/metadata/GovernanceMetaDataContexts.java
 
b/shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/metadata/GovernanceMetaDataContexts.java
index 01bdeb8..654889e 100644
--- 
a/shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/metadata/GovernanceMetaDataContexts.java
+++ 
b/shardingsphere-governance/shardingsphere-governance-context/src/main/java/org/apache/shardingsphere/governance/context/metadata/GovernanceMetaDataContexts.java
@@ -360,7 +360,6 @@ public final class GovernanceMetaDataContexts implements 
MetaDataContexts {
                 configCenter.getDataSourceService().load(schemaName)));
         MetaDataContextsBuilder metaDataContextsBuilder = new 
MetaDataContextsBuilder(dataSourcesMap,
                 Collections.singletonMap(schemaName, 
configCenter.getSchemaRuleService().load(schemaName)),
-                // TODO load global schema from reg center
                 configCenter.getGlobalRuleService().load(), 
                 metaDataContexts.getProps().getProps());
         return 
metaDataContextsBuilder.build(configCenter).getMetaDataMap().get(schemaName);
@@ -372,9 +371,8 @@ public final class GovernanceMetaDataContexts implements 
MetaDataContexts {
     }
     
     private ShardingSphereMetaData getChangedMetaData(final 
ShardingSphereMetaData oldMetaData, final Collection<RuleConfiguration> 
ruleConfigs) throws SQLException {
-        // TODO load global schema from reg center
         MetaDataContextsBuilder builder = new 
MetaDataContextsBuilder(Collections.singletonMap(oldMetaData.getName(), 
oldMetaData.getResource().getDataSources()),
-                Collections.singletonMap(oldMetaData.getName(), ruleConfigs), 
new LinkedList<>(), metaDataContexts.getProps().getProps());
+                Collections.singletonMap(oldMetaData.getName(), ruleConfigs), 
configCenter.getGlobalRuleService().load(), 
metaDataContexts.getProps().getProps());
         return 
builder.build(configCenter).getMetaDataMap().values().iterator().next();
     }
     
@@ -385,8 +383,8 @@ public final class GovernanceMetaDataContexts implements 
MetaDataContexts {
         oldMetaData.getResource().close(modifiedDataSources.keySet());
         Map<String, Map<String, DataSource>> dataSourcesMap = 
Collections.singletonMap(oldMetaData.getName(), 
                 getNewDataSources(oldMetaData.getResource().getDataSources(), 
getAddedDataSources(oldMetaData, newDataSourceConfigs), modifiedDataSources, 
deletedDataSources));
-        // TODO load global schema from reg center
-        return new MetaDataContextsBuilder(dataSourcesMap, 
Collections.singletonMap(oldMetaData.getName(), 
oldMetaData.getRuleMetaData().getConfigurations()), new LinkedList<>(),
+        return new MetaDataContextsBuilder(dataSourcesMap, 
Collections.singletonMap(oldMetaData.getName(), 
+                oldMetaData.getRuleMetaData().getConfigurations()), 
configCenter.getGlobalRuleService().load(),
                 
metaDataContexts.getProps().getProps()).build(configCenter).getMetaDataMap().get(oldMetaData.getName());
     }
     

Reply via email to