Skip to content

Commit 8ecff56

Browse files
committed
Refactor StandaloneMetaDataManagerPersistService
1 parent f3a2177 commit 8ecff56

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

+6
Original file line numberDiff line numberDiff line change
@@ -105,6 +105,12 @@ public void alterSchema(final ShardingSphereDatabase database, final String sche
105105
databaseMetaDataFacade.getView().persist(database.getName(), schemaName, alteredViews);
106106
droppedTables.forEach(each -> databaseMetaDataFacade.getTable().drop(database.getName(), schemaName, each));
107107
droppedViews.forEach(each -> databaseMetaDataFacade.getView().drop(database.getName(), schemaName, each));
108+
afterAlterSchema(database, schemaName, alteredTables, alteredViews, droppedTables, droppedViews);
109+
}
110+
111+
private void afterAlterSchema(final ShardingSphereDatabase database, final String schemaName,
112+
final Collection<ShardingSphereTable> alteredTables, final Collection<ShardingSphereView> alteredViews,
113+
final Collection<String> droppedTables, final Collection<String> droppedViews) {
108114
alteredTables.forEach(each -> metaDataContextManager.getDatabaseMetaDataManager().alterTable(database.getName(), schemaName, each));
109115
alteredViews.forEach(each -> metaDataContextManager.getDatabaseMetaDataManager().alterView(database.getName(), schemaName, each));
110116
droppedTables.forEach(each -> metaDataContextManager.getDatabaseMetaDataManager().dropTable(database.getName(), schemaName, each));

0 commit comments

Comments
 (0)