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 5fefb645ef5 Refactor StandaloneMetaDataManagerPersistService (#34516) 5fefb645ef5 is described below commit 5fefb645ef521dd03ced1c540e992b41263884b0 Author: Haoran Meng <menghaora...@gmail.com> AuthorDate: Sun Jan 26 21:17:55 2025 +0800 Refactor StandaloneMetaDataManagerPersistService (#34516) --- .../persist/service/StandaloneMetaDataManagerPersistService.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java index 9875dd65ba0..bab8b79d215 100644 --- a/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java +++ b/mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java @@ -208,8 +208,8 @@ public final class StandaloneMetaDataManagerPersistService implements MetaDataMa metaDataPersistService.getDatabaseMetaDataFacade().getSchema().drop(databaseName, schemaName); ShardingSphereMetaData metaData = metaDataContextManager.getMetaDataContexts().getMetaData(); ShardingSphereDatabase database = metaData.getDatabase(databaseName); - database.dropSchema(schemaName); Collection<String> tobeRemovedTables = database.getSchema(schemaName).getAllTables().stream().map(ShardingSphereTable::getName).collect(Collectors.toSet()); + database.dropSchema(schemaName); removeDataNode(database.getRuleMetaData().getAttributes(MutableDataNodeRuleAttribute.class), Collections.singleton(schemaName.toLowerCase()), tobeRemovedTables); metaData.getGlobalRuleMetaData().getRules().forEach(each -> ((GlobalRule) each).refresh(metaData.getAllDatabases(), GlobalRuleChangedType.SCHEMA_CHANGED)); }