This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang 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 f5b2683dddf Remove StorageUnitMetaData.storageTypes (#28210)
f5b2683dddf is described below
commit f5b2683dddf3fab9f0a67ec7d3a3b81a15b84b52
Author: Liang Zhang <[email protected]>
AuthorDate: Mon Aug 21 22:50:02 2023 +0800
Remove StorageUnitMetaData.storageTypes (#28210)
---
.../metadata/database/resource/storage/StorageUnitMetaData.java | 9 ---------
1 file changed, 9 deletions(-)
diff --git
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/resource/storage/StorageUnitMetaData.java
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/resource/storage/StorageUnitMetaData.java
index f998d941d12..854ea7edb33 100644
---
a/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/resource/storage/StorageUnitMetaData.java
+++
b/infra/common/src/main/java/org/apache/shardingsphere/infra/metadata/database/resource/storage/StorageUnitMetaData.java
@@ -18,7 +18,6 @@
package org.apache.shardingsphere.infra.metadata.database.resource.storage;
import lombok.Getter;
-import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
import
org.apache.shardingsphere.infra.datasource.pool.props.domain.DataSourcePoolProperties;
import javax.sql.DataSource;
@@ -41,9 +40,6 @@ public final class StorageUnitMetaData {
// TODO zhangliang: should refactor
private final Map<String, DataSource> dataSources;
- // TODO zhangliang: should refactor
- private final Map<String, DatabaseType> storageTypes;
-
public StorageUnitMetaData(final String databaseName, final
Map<StorageNode, DataSource> storageNodeDataSources,
final Map<String, DataSourcePoolProperties>
dataSourcePoolPropertiesMap, final Map<String, StorageUnitNodeMapper>
unitNodeMappers) {
this.unitNodeMappers = unitNodeMappers;
@@ -52,7 +48,6 @@ public final class StorageUnitMetaData {
storageUnits.put(entry.getKey(), new StorageUnit(databaseName,
storageNodeDataSources, dataSourcePoolPropertiesMap.get(entry.getKey()),
entry.getValue()));
}
dataSources = createDataSources();
- storageTypes = createStorageTypes();
}
/**
@@ -72,8 +67,4 @@ public final class StorageUnitMetaData {
}
return result;
}
-
- private Map<String, DatabaseType> createStorageTypes() {
- return
storageUnits.entrySet().stream().collect(Collectors.toMap(Entry::getKey, entry
-> entry.getValue().getStorageType(), (oldValue, currentValue) -> oldValue,
LinkedHashMap::new));
- }
}