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 2969e28f1f8 Fix SingleSQLRouterTest (#33146)
2969e28f1f8 is described below
commit 2969e28f1f82af4b3858bd682a77807bae08e8e4
Author: Liang Zhang <[email protected]>
AuthorDate: Mon Oct 7 19:19:57 2024 +0800
Fix SingleSQLRouterTest (#33146)
---
.../org/apache/shardingsphere/single/route/SingleSQLRouterTest.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
diff --git
a/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
b/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
index 762c6eae7e1..e21b72da467 100644
---
a/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
+++
b/kernel/single/core/src/test/java/org/apache/shardingsphere/single/route/SingleSQLRouterTest.java
@@ -55,8 +55,10 @@ import javax.sql.DataSource;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.ArrayList;
+import java.util.Arrays;
import java.util.Collections;
import java.util.HashMap;
+import java.util.HashSet;
import java.util.Iterator;
import java.util.LinkedList;
import java.util.List;
@@ -195,9 +197,7 @@ class SingleSQLRouterTest {
ShardingSphereDatabase database = new
ShardingSphereDatabase(DefaultDatabase.LOGIC_NAME, mock(DatabaseType.class),
mock(ResourceMetaData.class, RETURNS_DEEP_STUBS),
new RuleMetaData(Collections.singleton(rule)),
Collections.emptyMap());
sqlRouter.decorateRouteContext(routeContext, createQueryContext(),
database, rule, new ConfigurationProperties(new Properties()));
- Iterator<String> routedDataSourceNames =
routeContext.getActualDataSourceNames().iterator();
- assertThat(routedDataSourceNames.next(), is("write_ds"));
- assertThat(routedDataSourceNames.next(), is("readwrite_ds"));
+ assertThat(routeContext.getActualDataSourceNames(), is(new
HashSet<>(Arrays.asList("write_ds", "readwrite_ds"))));
}
@Test