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));
-    }
 }

Reply via email to