From 3713e39f172cdb075ae492b3978994fd8075bf17 Mon Sep 17 00:00:00 2001 From: zhangliang Date: Tue, 11 Feb 2025 19:22:50 +0800 Subject: [PATCH] Refactor StandaloneMetaDataManagerPersistService --- .../service/StandaloneMetaDataManagerPersistService.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) 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));