This is an automated email from the ASF dual-hosted git repository. zhangliang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push: new 9f9215ab052 Code format for ClusterMetaDataManagerPersistService (#34606) 9f9215ab052 is described below commit 9f9215ab052ee26a60bb9ea17f15cfc54fb8fdb7 Author: Liang Zhang <zhangli...@apache.org> AuthorDate: Sat Feb 8 16:29:22 2025 +0800 Code format for ClusterMetaDataManagerPersistService (#34606) --- .../persist/service/ClusterMetaDataManagerPersistService.java | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java index 7e7a398861d..81313496419 100644 --- a/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java +++ b/mode/type/cluster/core/src/main/java/org/apache/shardingsphere/mode/manager/cluster/persist/service/ClusterMetaDataManagerPersistService.java @@ -38,7 +38,6 @@ import org.apache.shardingsphere.mode.spi.repository.PersistRepository; import org.apache.shardingsphere.single.config.SingleRuleConfiguration; import org.apache.shardingsphere.single.rule.SingleRule; -import java.sql.SQLException; import java.util.Collection; import java.util.Collections; import java.util.Map; @@ -123,23 +122,22 @@ public final class ClusterMetaDataManagerPersistService implements MetaDataManag } @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); afterStorageUnitsAltered(databaseName, originalMetaDataContexts); } @Override - public void alterStorageUnits(final ShardingSphereDatabase database, final Map<String, DataSourcePoolProperties> toBeUpdatedProps) throws SQLException { + public void alterStorageUnits(final ShardingSphereDatabase database, final Map<String, DataSourcePoolProperties> toBeUpdatedProps) { MetaDataContexts originalMetaDataContexts = new MetaDataContexts(metaDataContextManager.getMetaDataContexts().getMetaData(), metaDataContextManager.getMetaDataContexts().getStatistics()); DataSourceUnitPersistService dataSourceService = metaDataPersistFacade.getDataSourceUnitService(); - metaDataPersistFacade.getMetaDataVersionService() - .switchActiveVersion(dataSourceService.persist(database.getName(), toBeUpdatedProps)); + metaDataPersistFacade.getMetaDataVersionService().switchActiveVersion(dataSourceService.persist(database.getName(), toBeUpdatedProps)); afterStorageUnitsAltered(database.getName(), originalMetaDataContexts); } @Override - public void unregisterStorageUnits(final ShardingSphereDatabase database, final Collection<String> toBeDroppedStorageUnitNames) throws SQLException { + public void unregisterStorageUnits(final ShardingSphereDatabase database, final Collection<String> toBeDroppedStorageUnitNames) { for (String each : getToBeDroppedResourceNames(database.getName(), toBeDroppedStorageUnitNames)) { MetaDataContexts originalMetaDataContexts = new MetaDataContexts(metaDataContextManager.getMetaDataContexts().getMetaData(), metaDataContextManager.getMetaDataContexts().getStatistics()); metaDataPersistFacade.getDataSourceUnitService().delete(database.getName(), each);