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 1320226df31 Refactor DatabaseRuleConfigurationManager (#32921)
1320226df31 is described below
commit 1320226df31d158fa3d4398ebbe66890a39d2651
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Sep 19 00:17:41 2024 +0800
Refactor DatabaseRuleConfigurationManager (#32921)
---
.../mode/metadata/manager/DatabaseRuleConfigurationManager.java | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/DatabaseRuleConfigurationManager.java
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/DatabaseRuleConfigurationManager.java
index cc2dd868410..72e3a1f6fb1 100644
---
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/DatabaseRuleConfigurationManager.java
+++
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/DatabaseRuleConfigurationManager.java
@@ -17,7 +17,6 @@
package org.apache.shardingsphere.mode.metadata.manager;
-import lombok.extern.slf4j.Slf4j;
import org.apache.shardingsphere.infra.config.rule.RuleConfiguration;
import
org.apache.shardingsphere.infra.config.rule.scope.DatabaseRuleConfiguration;
import org.apache.shardingsphere.infra.instance.ComputeNodeInstanceContext;
@@ -42,7 +41,6 @@ import java.util.concurrent.atomic.AtomicReference;
/**
* Database rule configuration manager.
*/
-@Slf4j
public final class DatabaseRuleConfigurationManager {
private final AtomicReference<MetaDataContexts> metaDataContexts;
@@ -75,8 +73,8 @@ public final class DatabaseRuleConfigurationManager {
return;
}
rules.removeIf(each ->
each.getConfiguration().getClass().isAssignableFrom(ruleConfig.getClass()));
- rules.addAll(DatabaseRulesBuilder.build(databaseName,
database.getProtocolType(), database.getRuleMetaData().getRules(),
- ruleConfig, computeNodeInstanceContext,
database.getResourceMetaData()));
+ rules.addAll(DatabaseRulesBuilder.build(
+ databaseName, database.getProtocolType(),
database.getRuleMetaData().getRules(), ruleConfig, computeNodeInstanceContext,
database.getResourceMetaData()));
refreshMetadata(databaseName, database, rules);
}