Refactor RefreshDatabaseMetaDataExecutor (apache#33940)

dongzl · Dec 6, 2024 · c3154ea · c3154ea
1 parent 3ca3299
commit c3154ea
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...ngsphere/proxy/backend/handler/distsql/ral/updatable/RefreshDatabaseMetaDataExecutor.java b/...ngsphere/proxy/backend/handler/distsql/ral/updatable/RefreshDatabaseMetaDataExecutor.java
@@ -24,8 +24,8 @@
 import org.apache.shardingsphere.mode.manager.ContextManager;
 
 import java.sql.SQLException;
+import java.util.Collection;
 import java.util.Collections;
-import java.util.Map;
 
 /**
  * Refresh database meta data executor.
@@ -34,9 +34,9 @@ public final class RefreshDatabaseMetaDataExecutor implements DistSQLUpdateExecu
 
     @Override
     public void executeUpdate(final RefreshDatabaseMetaDataStatement sqlStatement, final ContextManager contextManager) throws SQLException {
-        Map<String, ShardingSphereDatabase> databases = sqlStatement.getDatabaseName().map(optional -> Collections.singletonMap(optional, contextManager.getDatabase(optional)))
-                .orElseGet(() -> contextManager.getMetaDataContexts().getMetaData().getDatabases());
-        for (ShardingSphereDatabase each : databases.values()) {
+        Collection<ShardingSphereDatabase> databases = sqlStatement.getDatabaseName().map(optional -> (Collection<ShardingSphereDatabase>) Collections.singleton(contextManager.getDatabase(optional)))
+                .orElseGet(() -> contextManager.getMetaDataContexts().getMetaData().getAllDatabases());
+        for (ShardingSphereDatabase each : databases) {
             if (!SystemSchemaUtils.isSystemSchema(each)) {
                 if (sqlStatement.isForce()) {
                     contextManager.getMetaDataContextManager().forceRefreshDatabaseMetaData(each);