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 e4c15d5d006 Refactor DatabaseMetaDataChangedListener (#34900)
e4c15d5d006 is described below

commit e4c15d5d00682e83fd0e45aec5de1b0abff2204a
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Thu Mar 6 14:02:32 2025 +0800

    Refactor DatabaseMetaDataChangedListener (#34900)
---
 .../cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
index 8886ac2e4fe..be3f5eb8487 100644
--- 
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
+++ 
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/dispatch/listener/type/DatabaseMetaDataChangedListener.java
@@ -65,6 +65,7 @@ public final class DatabaseMetaDataChangedListener implements 
DataChangedEventLi
             if (each.isSubscribed(databaseName.get(), event)) {
                 try {
                     each.handle(databaseName.get(), event);
+                    break;
                 } catch (final SQLException ex) {
                     throw new SQLWrapperException(ex);
                 }

Reply via email to