This is an automated email from the ASF dual-hosted git repository.
menghaoran 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 7cab7fb8e1f Refactor ClusterMetaDataManagerPersistService (#36827)
7cab7fb8e1f is described below
commit 7cab7fb8e1f15756a8d5c7703c31ec215764194b
Author: Haoran Meng <[email protected]>
AuthorDate: Thu Oct 9 16:17:42 2025 +0800
Refactor ClusterMetaDataManagerPersistService (#36827)
---
.../cluster/persist/service/ClusterMetaDataManagerPersistService.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java
index e40d4289b88..191bdfd9992 100644
---
a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java
+++
b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java
@@ -70,8 +70,8 @@ public final class ClusterMetaDataManagerPersistService
implements MetaDataManag
MetaDataContexts originalMetaDataContexts = new
MetaDataContexts(metaDataContextManager.getMetaDataContexts().getMetaData(),
metaDataContextManager.getMetaDataContexts().getStatistics());
metaDataPersistFacade.getDatabaseMetaDataFacade().getDatabase().add(databaseName);
clusterDatabaseListenerPersistCoordinator.persist(databaseName,
ClusterDatabaseListenerCoordinatorType.CREATE);
-
metaDataPersistFacade.getDatabaseMetaDataFacade().persistReloadDatabaseByAlter(databaseName,
getReloadedMetaDataContexts(originalMetaDataContexts).getMetaData().getDatabase(databaseName),
-
originalMetaDataContexts.getMetaData().getDatabase(databaseName));
+ ShardingSphereDatabase reloadDatabase =
getReloadedMetaDataContexts(originalMetaDataContexts).getMetaData().getDatabase(databaseName);
+
metaDataPersistFacade.getDatabaseMetaDataFacade().getSchema().add(databaseName,
reloadDatabase.getAllSchemas().iterator().next().getName());
}
@Override