(shardingsphere) branch master updated: Refactor ShardingSQLRouterIT (#40328)

[zhangliang]

This is an automated email from the ASF dual-hosted git repository.

terrymanu 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 27591ff6ad6 Refactor ShardingSQLRouterIT (#40328)
27591ff6ad6 is described below

commit 27591ff6ad62c3d6051735f8dd93be87081067a6
Author: Liang Zhang <zhangli...@apache.org>
AuthorDate: Thu Oct 22 12:24:40 2026 +0800

    Refactor ShardingSQLRouterIT (#40328)
---
 .../test/it/router/ShardingSQLRouterIT.java             | 17 +++++------------
 1 file changed, 5 insertions(+), 12 deletions(-)

diff --git 
a/test/it/router/src/test/java/org/apache/shardingsphere/test/it/router/ShardingSQLRouterIT.java
 
b/test/it/router/src/test/java/org/apache/shardingsphere/test/it/router/ShardingSQLRouterIT.java
index 50728d8dd1a..d380d7f1b4b 100644
--- 
a/test/it/router/src/test/java/org/apache/shardingsphere/test/it/router/ShardingSQLRouterIT.java
+++ 
b/test/it/router/src/test/java/org/apache/shardingsphere/test/it/router/ShardingSQLRouterIT.java
@@ -71,6 +71,7 @@ import java.util.Map;
 import java.util.Properties;
 import java.util.Set;
 import java.util.TreeSet;
+import java.util.stream.Collectors;
 import java.util.stream.Stream;
 
 import static org.hamcrest.MatcherAssert.assertThat;
@@ -161,8 +162,8 @@ class ShardingSQLRouterIT {
     void assertRouteDatabaseOnlyJoin() {
         RouteContext actual = routeDatabaseOnlyJoin("SELECT i.* FROM t_order 
o, t_order_item i WHERE o.order_id = i.order_id AND o.user_id = i.user_id", 
Collections.emptyList());
         assertThat(actual.getRouteUnits().size(), is(3));
-        assertThat(getRouteUnitSignatures(actual), 
is(createRouteUnits("ds_0:t_order=t_order,t_order_item=t_order_item", 
"ds_1:t_order=t_order,t_order_item=t_order_item",
-                "ds_2:t_order=t_order,t_order_item=t_order_item")));
+        assertThat(getRouteUnitSignatures(actual), is(createRouteUnits(
+                "ds_0:t_order=t_order,t_order_item=t_order_item", 
"ds_1:t_order=t_order,t_order_item=t_order_item", 
"ds_2:t_order=t_order,t_order_item=t_order_item")));
     }
     
     @Test
@@ -286,21 +287,13 @@ class ShardingSQLRouterIT {
     private static List<Set<String>> getOriginalDataNodeSignatures(final 
RouteContext routeContext) {
         List<Set<String>> result = new LinkedList<>();
         for (Collection<DataNode> each : routeContext.getOriginalDataNodes()) {
-            Set<String> dataNodes = new TreeSet<>();
-            for (DataNode dataNode : each) {
-                dataNodes.add(dataNode.getDataSourceName() + "." + 
dataNode.getTableName());
-            }
-            result.add(dataNodes);
+            result.add(each.stream().map(dataNode -> 
dataNode.getDataSourceName() + "." + 
dataNode.getTableName()).collect(Collectors.toCollection(TreeSet::new)));
         }
         return result;
     }
     
     private static List<Set<String>> createOriginalDataNodes(final String... 
dataNodes) {
-        List<Set<String>> result = new LinkedList<>();
-        for (String each : dataNodes) {
-            result.add(Collections.singleton(each));
-        }
-        return result;
+        return 
Arrays.stream(dataNodes).map(Collections::singleton).collect(Collectors.toList());
     }
     
     private static Set<String> createRouteUnits(final String... routeUnits) {