(shardingsphere) branch master updated: Refactor StorageUnitManager (#37137)

[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 cfd8b17770a Refactor StorageUnitManager (#37137)
cfd8b17770a is described below

commit cfd8b17770aea489c3e48c502ce20d37186724b1
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Tue Nov 18 23:28:33 2025 +0800

    Refactor StorageUnitManager (#37137)
---
 .../mode/metadata/manager/resource/StorageUnitManager.java         | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java
 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java
index b3d701a44dc..0bdef7fa50a 100644
--- 
a/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java
+++ 
b/mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/manager/resource/StorageUnitManager.java
@@ -115,8 +115,11 @@ public final class StorageUnitManager {
     }
     
     private Collection<ShardingSphereSchema> buildSchemas(final 
ShardingSphereDatabase originalDatabase) {
-        return originalDatabase.getAllSchemas().stream().map(each -> new 
ShardingSphereSchema(
-                each.getName(), each.getAllTables(), 
metaDataPersistFacade.getDatabaseMetaDataFacade().getView().load(originalDatabase.getName(),
 each.getName()))).collect(Collectors.toList());
+        return originalDatabase.getAllSchemas().stream().map(each -> 
buildSchema(originalDatabase, each)).collect(Collectors.toList());
+    }
+    
+    private ShardingSphereSchema buildSchema(final ShardingSphereDatabase 
originalDatabase, final ShardingSphereSchema schema) {
+        return new ShardingSphereSchema(schema.getName(), 
schema.getAllTables(), 
metaDataPersistFacade.getDatabaseMetaDataFacade().getView().load(originalDatabase.getName(),
 schema.getName()));
     }
     
     @SneakyThrows(Exception.class)