|
39 | 39 | import org.apache.shardingsphere.mode.metadata.manager.SwitchingResource;
|
40 | 40 | import org.apache.shardingsphere.mode.metadata.persist.MetaDataPersistService;
|
41 | 41 | import org.apache.shardingsphere.mode.metadata.persist.config.database.DataSourceUnitPersistService;
|
| 42 | +import org.apache.shardingsphere.mode.metadata.persist.metadata.DatabaseMetaDataPersistFacade; |
42 | 43 | import org.apache.shardingsphere.mode.metadata.refresher.metadata.util.TableRefreshUtils;
|
43 | 44 | import org.apache.shardingsphere.mode.persist.service.MetaDataManagerPersistService;
|
44 | 45 | import org.apache.shardingsphere.mode.spi.rule.item.RuleChangedItem;
|
@@ -96,10 +97,11 @@ public void createSchema(final String databaseName, final String schemaName) {
|
96 | 97 | public void alterSchema(final String databaseName, final String schemaName, final String logicDataSourceName,
|
97 | 98 | final Collection<ShardingSphereTable> alteredTables, final Collection<ShardingSphereView> alteredViews,
|
98 | 99 | final Collection<String> droppedTables, final Collection<String> droppedViews) {
|
99 |
| - metaDataPersistService.getDatabaseMetaDataFacade().getTable().persist(databaseName, schemaName, alteredTables); |
100 |
| - metaDataPersistService.getDatabaseMetaDataFacade().getView().persist(databaseName, schemaName, alteredViews); |
101 |
| - droppedTables.forEach(each -> metaDataPersistService.getDatabaseMetaDataFacade().getTable().drop(databaseName, schemaName, each)); |
102 |
| - droppedViews.forEach(each -> metaDataPersistService.getDatabaseMetaDataFacade().getView().delete(databaseName, schemaName, each)); |
| 100 | + DatabaseMetaDataPersistFacade databaseMetaDataFacade = metaDataPersistService.getDatabaseMetaDataFacade(); |
| 101 | + databaseMetaDataFacade.getTable().persist(databaseName, schemaName, alteredTables); |
| 102 | + databaseMetaDataFacade.getView().persist(databaseName, schemaName, alteredViews); |
| 103 | + droppedTables.forEach(each -> databaseMetaDataFacade.getTable().drop(databaseName, schemaName, each)); |
| 104 | + droppedViews.forEach(each -> databaseMetaDataFacade.getView().delete(databaseName, schemaName, each)); |
103 | 105 | ShardingSphereMetaData metaData = metaDataContextManager.getMetaDataContexts().getMetaData();
|
104 | 106 | ShardingSphereDatabase database = metaData.getDatabase(databaseName);
|
105 | 107 | addDataNode(database, logicDataSourceName, schemaName, alteredTables, alteredViews);
|
|
0 commit comments