(shardingsphere) branch master updated: Refactor SchemaChangedHandler (#34894)

[zhangliang]

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 1e5508eeff6 Refactor SchemaChangedHandler (#34894)
1e5508eeff6 is described below

commit 1e5508eeff6d1cf91385ac81b9146a78149a8522
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Thu Mar 6 01:19:54 2025 +0800

    Refactor SchemaChangedHandler (#34894)
---
 .../dispatch/handler/database/metadata/SchemaChangedHandler.java       | 3 +--
 .../dispatch/handler/database/metadata/TableChangedHandler.java        | 3 +--
 .../cluster/dispatch/handler/database/metadata/ViewChangedHandler.java | 3 +--
 3 files changed, 3 insertions(+), 6 deletions(-)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
index 486121bf0fa..c502eaf98da 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/SchemaChangedHandler.java
@@ -47,8 +47,7 @@ public final class SchemaChangedHandler implements 
DatabaseChangedHandler {
     
     @Override
     public void handle(final String databaseName, final DataChangedEvent 
event) {
-        String eventKey = event.getKey();
-        Optional<String> schemaName = NodePathSearcher.find(eventKey, 
TableMetadataNodePath.createSchemaSearchCriteria(databaseName, false));
+        Optional<String> schemaName = NodePathSearcher.find(event.getKey(), 
TableMetadataNodePath.createSchemaSearchCriteria(databaseName, false));
         if (!schemaName.isPresent()) {
             return;
         }
diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
index 12d3dee648e..d7a5081fc50 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/TableChangedHandler.java
@@ -55,8 +55,7 @@ public final class TableChangedHandler implements 
DatabaseChangedHandler {
     
     @Override
     public void handle(final String databaseName, final DataChangedEvent 
event) {
-        String eventKey = event.getKey();
-        Optional<String> schemaName = NodePathSearcher.find(eventKey, 
TableMetadataNodePath.createSchemaSearchCriteria(databaseName, true));
+        Optional<String> schemaName = NodePathSearcher.find(event.getKey(), 
TableMetadataNodePath.createSchemaSearchCriteria(databaseName, true));
         if (!schemaName.isPresent()) {
             return;
         }
diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
index c3ecd3aa46e..d52d073c77b 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/handler/database/metadata/ViewChangedHandler.java
@@ -56,8 +56,7 @@ public final class ViewChangedHandler implements 
DatabaseChangedHandler {
     
     @Override
     public void handle(final String databaseName, final DataChangedEvent 
event) {
-        String eventKey = event.getKey();
-        Optional<String> schemaName = NodePathSearcher.find(eventKey, 
TableMetadataNodePath.createSchemaSearchCriteria(databaseName, true));
+        Optional<String> schemaName = NodePathSearcher.find(event.getKey(), 
TableMetadataNodePath.createSchemaSearchCriteria(databaseName, true));
         if (!schemaName.isPresent()) {
             return;
         }