Remove useless StorageUnit.storageNode

apache · Oct 4, 2023 · a0f28b8 · a0f28b8
1 parent 14d2274
commit a0f28b8
Showing 1 changed file with 2 additions and 5 deletions.
diff --git a/...ain/java/org/apache/shardingsphere/infra/metadata/database/resource/unit/StorageUnit.java b/...ain/java/org/apache/shardingsphere/infra/metadata/database/resource/unit/StorageUnit.java
@@ -43,26 +43,23 @@ public final class StorageUnit {
 
     private final DataSourcePoolProperties dataSourcePoolProperties;
 
-    private final StorageNode storageNode;
-
     private final DatabaseType storageType;
 
     private final ConnectionProperties connectionProperties;
 
     public StorageUnit(final String databaseName, final DataSource dataSource, final DataSourcePoolProperties dataSourcePoolProperties, final StorageNode storageNode) {
         this.dataSource = new CatalogSwitchableDataSource(dataSource, storageNode.getCatalog(), storageNode.getUrl());
         this.dataSourcePoolProperties = dataSourcePoolProperties;
-        this.storageNode = storageNode;
         boolean isDataSourceEnabled = !DataSourceStateManager.getInstance().getEnabledDataSources(databaseName, Collections.singletonMap(storageNode.getName().getName(), dataSource)).isEmpty();
         storageType = createStorageType(isDataSourceEnabled);
-        connectionProperties = createConnectionProperties(isDataSourceEnabled);
+        connectionProperties = createConnectionProperties(isDataSourceEnabled, storageNode);
     }
 
     private DatabaseType createStorageType(final boolean isDataSourceEnabled) {
         return DatabaseTypeEngine.getStorageType(isDataSourceEnabled ? Collections.singleton(dataSource) : Collections.emptyList());
     }
 
-    private ConnectionProperties createConnectionProperties(final boolean isDataSourceEnabled) {
+    private ConnectionProperties createConnectionProperties(final boolean isDataSourceEnabled, final StorageNode storageNode) {
         if (!isDataSourceEnabled) {
             return null;
         }