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 40d70c093b3 Refactor NativeStorageContainer (#36611)
40d70c093b3 is described below
commit 40d70c093b3bf410ce5ec330fac57fa21cc67075
Author: Liang Zhang <[email protected]>
AuthorDate: Thu Sep 18 14:00:52 2025 +0800
Refactor NativeStorageContainer (#36611)
---
.../atomic/storage/type/natived/NativeStorageContainer.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/type/natived/NativeStorageContainer.java
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/type/natived/NativeStorageContainer.java
index 50aa0e56113..f65c0e12d21 100644
---
a/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/type/natived/NativeStorageContainer.java
+++
b/test/e2e/env/src/test/java/org/apache/shardingsphere/test/e2e/env/container/atomic/storage/type/natived/NativeStorageContainer.java
@@ -92,8 +92,13 @@ public final class NativeStorageContainer implements
StorageContainer {
private Map<String, DataSource> getDataSourceMap(final Collection<String>
databaseNames) {
DataSourceEnvironment dataSourceEnvironment =
DatabaseTypedSPILoader.getService(DataSourceEnvironment.class, databaseType);
- return databaseNames.stream().collect(Collectors.toMap(each -> each,
each -> StorageContainerUtils.generateDataSource(
- dataSourceEnvironment.getURL(env.getNativeStorageHost(),
env.getNativeStoragePort(), each), env.getNativeStorageUsername(),
env.getNativeStoragePassword(), 2)));
+ Map<String, DataSource> result = new HashMap<>(databaseNames.size(),
1F);
+ for (String each : databaseNames) {
+ DataSource dataSource = StorageContainerUtils.generateDataSource(
+ dataSourceEnvironment.getURL(env.getNativeStorageHost(),
env.getNativeStoragePort(), each), env.getNativeStorageUsername(),
env.getNativeStoragePassword(), 2);
+ result.put(each, dataSource);
+ }
+ return result;
}
/**
