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 5f90d2dc6d1 Refactor
ClusterMetaDataManagerPersistService.registerStorageUnits() (#34529)
5f90d2dc6d1 is described below
commit 5f90d2dc6d13ad0616efc5e212122c57ce245f9e
Author: Liang Zhang <[email protected]>
AuthorDate: Wed Jan 29 12:13:19 2025 +0800
Refactor ClusterMetaDataManagerPersistService.registerStorageUnits()
(#34529)
---
.../cluster/persist/service/ClusterMetaDataManagerPersistService.java | 3 +--
1 file changed, 1 insertion(+), 2 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 8e4608356db..44d313f6ee3 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
@@ -129,9 +129,8 @@ public final class ClusterMetaDataManagerPersistService
implements MetaDataManag
metaDataPersistService.getDatabaseMetaDataFacade().getTable().drop(databaseName,
schemaName, tableName);
}
- @SneakyThrows
@Override
- public void registerStorageUnits(final String databaseName, final
Map<String, DataSourcePoolProperties> toBeRegisteredProps) {
+ public void registerStorageUnits(final String databaseName, final
Map<String, DataSourcePoolProperties> toBeRegisteredProps) throws SQLException {
MetaDataContexts originalMetaDataContexts =
buildOriginalMetaDataContexts();
Map<StorageNode, DataSource> newDataSources = new
HashMap<>(toBeRegisteredProps.size());
try {