You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@shardingsphere.apache.org by qi...@apache.org on 2021/01/13 06:59:55 UTC
[shardingsphere] branch master updated: Refactor
SchemaChangedListener (#9010)
This is an automated email from the ASF dual-hosted git repository.
qiulu 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 5553da6 Refactor SchemaChangedListener (#9010)
5553da6 is described below
commit 5553da686ea1ac99ad3f34ab3a2132ddadc49021
Author: Haoran Meng <me...@gmail.com>
AuthorDate: Wed Jan 13 14:59:30 2021 +0800
Refactor SchemaChangedListener (#9010)
---
.../governance/core/config/listener/SchemaChangedListener.java | 3 +++
1 file changed, 3 insertions(+)
diff --git a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/SchemaChangedListener.java b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/SchemaChangedListener.java
index 854908b..f24045f 100644
--- a/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/SchemaChangedListener.java
+++ b/shardingsphere-governance/shardingsphere-governance-core/src/main/java/org/apache/shardingsphere/governance/core/config/listener/SchemaChangedListener.java
@@ -86,6 +86,9 @@ public final class SchemaChangedListener extends PostGovernanceRepositoryEventLi
return Optional.of(createUpdatedEvent(schemaName, event));
}
if (Type.DELETED == event.getType()) {
+ if (event.getKey().startsWith(configurationNode.getCachePath(configurationNode.getRulePath(schemaName)))) {
+ return Optional.empty();
+ }
existedSchemaNames.remove(schemaName);
return Optional.of(new MetaDataDeletedEvent(schemaName));
}