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 55c48593fcb Refactor NativeStorageContainer (#36451) 55c48593fcb is described below commit 55c48593fcbec22033491d0a146d67c21b37ecf7 Author: Liang Zhang <zhangli...@apache.org> AuthorDate: Tue Sep 2 12:19:22 2025 +0800 Refactor NativeStorageContainer (#36451) --- .../atomic/storage/StorageContainerFactory.java | 3 +- .../storage/impl/NativeStorageContainer.java | 34 +++++++++++----------- 2 files changed, 18 insertions(+), 19 deletions(-) diff --git a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/StorageContainerFactory.java b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/StorageContainerFactory.java index 32ff6fca9c4..1a29d1e3157 100644 --- a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/StorageContainerFactory.java +++ b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/StorageContainerFactory.java @@ -55,8 +55,7 @@ public final class StorageContainerFactory { * @return created instance * @throws RuntimeException runtime exception */ - public static StorageContainer newInstance(final DatabaseType databaseType, final String storageContainerImage, - final StorageContainerConfiguration storageContainerConfig) { + public static StorageContainer newInstance(final DatabaseType databaseType, final String storageContainerImage, final StorageContainerConfiguration storageContainerConfig) { switch (databaseType.getType()) { case "MySQL": return new MySQLContainer(storageContainerImage, storageContainerConfig); diff --git a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/impl/NativeStorageContainer.java b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/impl/NativeStorageContainer.java index 6b94094f1a9..858d0f0b950 100644 --- a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/impl/NativeStorageContainer.java +++ b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/impl/NativeStorageContainer.java @@ -85,7 +85,7 @@ public final class NativeStorageContainer implements StorageContainer { } private Map<String, DataSource> getDataSourceMap(final Collection<String> databaseNames) { - Map<String, DataSource> result = new HashMap<>(); + Map<String, DataSource> result = new HashMap<>(databaseNames.size(), 1F); for (String each : databaseNames) { DataSource dataSource = StorageContainerUtils.generateDataSource(DataSourceEnvironment.getURL(databaseType, E2ETestEnvironment.getInstance().getNativeStorageHost(), Integer.parseInt(E2ETestEnvironment.getInstance().getNativeStoragePort()), each), @@ -95,22 +95,6 @@ public final class NativeStorageContainer implements StorageContainer { return result; } - @Override - public String getAbbreviation() { - return databaseType.getType().toLowerCase(); - } - - @Override - public Map<String, String> getLinkReplacements() { - Map<String, String> result = new HashMap<>(); - for (String each : getNetworkAliases()) { - result.put(each + ":" + getExposedPort(), E2ETestEnvironment.getInstance().getNativeStorageHost() + ":" + E2ETestEnvironment.getInstance().getNativeStoragePort()); - } - result.put(StorageContainerConstants.USERNAME, E2ETestEnvironment.getInstance().getNativeStorageUsername()); - result.put(StorageContainerConstants.PASSWORD, E2ETestEnvironment.getInstance().getNativeStoragePassword()); - return result; - } - /** * Get exposed port. * @@ -132,4 +116,20 @@ public final class NativeStorageContainer implements StorageContainer { @Override public void start() { } + + @Override + public String getAbbreviation() { + return databaseType.getType().toLowerCase(); + } + + @Override + public Map<String, String> getLinkReplacements() { + Map<String, String> result = new HashMap<>(getNetworkAliases().size() + 2, 1F); + for (String each : getNetworkAliases()) { + result.put(each + ":" + getExposedPort(), E2ETestEnvironment.getInstance().getNativeStorageHost() + ":" + E2ETestEnvironment.getInstance().getNativeStoragePort()); + } + result.put(StorageContainerConstants.USERNAME, E2ETestEnvironment.getInstance().getNativeStorageUsername()); + result.put(StorageContainerConstants.PASSWORD, E2ETestEnvironment.getInstance().getNativeStoragePassword()); + return result; + } }