Skip to content

Commit 85d07f2

Browse files
committed
Refactor DatabaseMetaDataPersistFacade
1 parent c9c7b96 commit 85d07f2

File tree

2 files changed

+5
-2
lines changed

2 files changed

+5
-2
lines changed

mode/core/src/main/java/org/apache/shardingsphere/mode/metadata/persist/metadata/DatabaseMetaDataPersistFacade.java

+3-1
Original file line numberDiff line numberDiff line change
@@ -38,6 +38,7 @@
3838

3939
import java.sql.SQLException;
4040
import java.util.Collection;
41+
import java.util.Map;
4142
import java.util.Map.Entry;
4243

4344
/**
@@ -139,7 +140,8 @@ public void unregisterStorageUnits(final String databaseName, final MetaDataCont
139140
GenericSchemaBuilderMaterial material = new GenericSchemaBuilderMaterial(database.getResourceMetaData().getStorageUnits(),
140141
database.getRuleMetaData().getRules(), reloadMetaDataContexts.getMetaData().getProps(), new DatabaseTypeRegistry(database.getProtocolType()).getDefaultSchemaName(databaseName));
141142
try {
142-
for (Entry<String, ShardingSphereSchema> entry : GenericSchemaBuilder.build(database.getProtocolType(), material).entrySet()) {
143+
Map<String, ShardingSphereSchema> schemas = GenericSchemaBuilder.build(database.getProtocolType(), material);
144+
for (Entry<String, ShardingSphereSchema> entry : schemas.entrySet()) {
143145
GenericSchemaManager.getToBeDroppedTables(entry.getValue(), database.getSchema(entry.getKey())).forEach(each -> table.drop(databaseName, entry.getKey(), each.getName()));
144146
}
145147
} catch (final SQLException ex) {

mode/type/standalone/core/src/main/java/org/apache/shardingsphere/mode/manager/standalone/persist/service/StandaloneMetaDataManagerPersistService.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,8 @@ public void unregisterStorageUnits(final ShardingSphereDatabase database, final
189189
for (String each : getToBeDroppedResourceNames(database.getName(), toBeDroppedStorageUnitNames)) {
190190
metaDataPersistFacade.getDataSourceUnitService().delete(database.getName(), each);
191191
metaDataContextManager.getStorageUnitManager().unregister(database.getName(), each);
192-
metaDataPersistFacade.getDatabaseMetaDataFacade().unregisterStorageUnits(database.getName(), metaDataContextManager.getMetaDataContexts());
192+
MetaDataContexts reloadMetaDataContexts = metaDataContextManager.getMetaDataContexts();
193+
metaDataPersistFacade.getDatabaseMetaDataFacade().unregisterStorageUnits(database.getName(), reloadMetaDataContexts);
193194
}
194195
OrderedServicesCache.clearCache();
195196
}

0 commit comments

Comments
 (0)