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 485c39bafff9c..2ec6fe94a5b0c 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 @@ -140,7 +140,7 @@ public void dropTable(final ShardingSphereDatabase database, final String schema } @Override - public void registerStorageUnits(final String databaseName, final Map toBeRegisteredProps) throws SQLException { + public void registerStorageUnits(final String databaseName, final Map toBeRegisteredProps) { MetaDataContexts originalMetaDataContexts = new MetaDataContexts(metaDataContextManager.getMetaDataContexts().getMetaData(), metaDataContextManager.getMetaDataContexts().getStatistics()); metaDataPersistFacade.getDataSourceUnitService().persist(databaseName, toBeRegisteredProps); afterStorageUnitsRegistered(databaseName, originalMetaDataContexts, toBeRegisteredProps); @@ -164,8 +164,7 @@ public void alterStorageUnits(final ShardingSphereDatabase database, final Map toBeRegisteredProps) { + private void afterStorageUnitsAltered(final String databaseName, final MetaDataContexts originalMetaDataContexts, final Map toBeRegisteredProps) { metaDataContextManager.getStorageUnitManager().alter(databaseName, toBeRegisteredProps); metaDataPersistFacade.persistReloadDatabaseByAlter(databaseName, metaDataContextManager.getMetaDataContexts().getMetaData().getDatabase(databaseName), originalMetaDataContexts.getMetaData().getDatabase(databaseName));