Skip to content

Commit

Permalink
Refactor StandaloneMetaDataManagerPersistService
Browse files Browse the repository at this point in the history
  • Loading branch information
terrymanu committed Feb 11, 2025
1 parent 194f3a0 commit 3713e39
Showing 1 changed file with 2 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ public void dropTable(final ShardingSphereDatabase database, final String schema
}

@Override
public void registerStorageUnits(final String databaseName, final Map<String, DataSourcePoolProperties> toBeRegisteredProps) throws SQLException {
public void registerStorageUnits(final String databaseName, final Map<String, DataSourcePoolProperties> toBeRegisteredProps) {
MetaDataContexts originalMetaDataContexts = new MetaDataContexts(metaDataContextManager.getMetaDataContexts().getMetaData(), metaDataContextManager.getMetaDataContexts().getStatistics());
metaDataPersistFacade.getDataSourceUnitService().persist(databaseName, toBeRegisteredProps);
afterStorageUnitsRegistered(databaseName, originalMetaDataContexts, toBeRegisteredProps);
Expand All @@ -164,8 +164,7 @@ public void alterStorageUnits(final ShardingSphereDatabase database, final Map<S
clearServiceCache();
}

private void afterStorageUnitsAltered(final String databaseName, final MetaDataContexts originalMetaDataContexts,
final Map<String, DataSourcePoolProperties> toBeRegisteredProps) {
private void afterStorageUnitsAltered(final String databaseName, final MetaDataContexts originalMetaDataContexts, final Map<String, DataSourcePoolProperties> toBeRegisteredProps) {
metaDataContextManager.getStorageUnitManager().alter(databaseName, toBeRegisteredProps);
metaDataPersistFacade.persistReloadDatabaseByAlter(databaseName, metaDataContextManager.getMetaDataContexts().getMetaData().getDatabase(databaseName),
originalMetaDataContexts.getMetaData().getDatabase(databaseName));
Expand Down

0 comments on commit 3713e39

Please sign in to comment.