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 f210453683e Remove duplicated IteratorStreamMergedResultTest (#38273)
f210453683e is described below
commit f210453683e69c550426e64f4b7a548e2a59c9ee
Author: Liang Zhang <[email protected]>
AuthorDate: Sat Feb 28 19:07:16 2026 +0800
Remove duplicated IteratorStreamMergedResultTest (#38273)
---
.../stream/IteratorStreamMergedResultTest.java | 140 ---------------------
1 file changed, 140 deletions(-)
diff --git
a/features/sharding/core/src/test/java/org/apache/shardingsphere/infra/merge/result/impl/stream/IteratorStreamMergedResultTest.java
b/features/sharding/core/src/test/java/org/apache/shardingsphere/infra/merge/result/impl/stream/IteratorStreamMergedResultTest.java
deleted file mode 100644
index ebd0a58b981..00000000000
---
a/features/sharding/core/src/test/java/org/apache/shardingsphere/infra/merge/result/impl/stream/IteratorStreamMergedResultTest.java
+++ /dev/null
@@ -1,140 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.infra.merge.result.impl.stream;
-
-import org.apache.shardingsphere.database.connector.core.type.DatabaseType;
-import
org.apache.shardingsphere.infra.binder.context.statement.type.dml.SelectStatementContext;
-import org.apache.shardingsphere.infra.config.props.ConfigurationProperties;
-import
org.apache.shardingsphere.infra.executor.sql.execute.result.query.QueryResult;
-import org.apache.shardingsphere.infra.merge.result.MergedResult;
-import org.apache.shardingsphere.infra.metadata.ShardingSphereMetaData;
-import
org.apache.shardingsphere.infra.metadata.database.ShardingSphereDatabase;
-import
org.apache.shardingsphere.infra.metadata.database.resource.ResourceMetaData;
-import org.apache.shardingsphere.infra.metadata.database.rule.RuleMetaData;
-import org.apache.shardingsphere.infra.session.connection.ConnectionContext;
-import org.apache.shardingsphere.infra.spi.type.typed.TypedSPILoader;
-import org.apache.shardingsphere.sharding.merge.dql.ShardingDQLResultMerger;
-import
org.apache.shardingsphere.sql.parser.statement.core.segment.dml.item.ProjectionsSegment;
-import
org.apache.shardingsphere.sql.parser.statement.core.statement.type.dml.SelectStatement;
-import org.junit.jupiter.api.BeforeEach;
-import org.junit.jupiter.api.Test;
-import org.junit.jupiter.api.extension.ExtensionContext;
-import org.junit.jupiter.params.ParameterizedTest;
-import org.junit.jupiter.params.provider.Arguments;
-import org.junit.jupiter.params.provider.ArgumentsProvider;
-import org.junit.jupiter.params.provider.ArgumentsSource;
-import org.junit.jupiter.params.support.ParameterDeclarations;
-
-import java.sql.SQLException;
-import java.util.Arrays;
-import java.util.Collections;
-import java.util.List;
-import java.util.stream.Stream;
-
-import static org.junit.jupiter.api.Assertions.assertFalse;
-import static org.junit.jupiter.api.Assertions.assertTrue;
-import static org.mockito.Mockito.RETURNS_DEEP_STUBS;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
-
-class IteratorStreamMergedResultTest {
-
- private final DatabaseType databaseType =
TypedSPILoader.getService(DatabaseType.class, "SQL92");
-
- private SelectStatementContext selectStatementContext;
-
- @BeforeEach
- void setUp() {
- SelectStatement selectStatement = new SelectStatement(databaseType);
- selectStatement.setProjections(new ProjectionsSegment(0, 0));
- selectStatementContext = new SelectStatementContext(selectStatement,
createShardingSphereMetaData(), "foo_db", Collections.emptyList());
- }
-
- private ShardingSphereMetaData createShardingSphereMetaData() {
- ShardingSphereDatabase database = mock(ShardingSphereDatabase.class,
RETURNS_DEEP_STUBS);
- when(database.getName()).thenReturn("foo_db");
- return new ShardingSphereMetaData(Collections.singleton(database),
mock(ResourceMetaData.class), mock(RuleMetaData.class),
mock(ConfigurationProperties.class));
- }
-
- @Test
- void assertNextForResultSetsAllEmpty() throws SQLException {
- List<QueryResult> queryResults = Arrays.asList(mock(QueryResult.class,
RETURNS_DEEP_STUBS), mock(QueryResult.class, RETURNS_DEEP_STUBS),
mock(QueryResult.class, RETURNS_DEEP_STUBS));
- ShardingDQLResultMerger resultMerger = new
ShardingDQLResultMerger(databaseType);
- ShardingSphereDatabase database = mock(ShardingSphereDatabase.class,
RETURNS_DEEP_STUBS);
- when(database.getName()).thenReturn("foo_db");
- MergedResult actual = resultMerger.merge(queryResults,
selectStatementContext, database, mock(ConnectionContext.class));
- assertFalse(actual.next());
- }
-
- @Test
- void assertNextForResultSetsAllNotEmpty() throws SQLException {
- List<QueryResult> queryResults = Arrays.asList(mock(QueryResult.class,
RETURNS_DEEP_STUBS), mock(QueryResult.class, RETURNS_DEEP_STUBS),
mock(QueryResult.class, RETURNS_DEEP_STUBS));
- for (QueryResult each : queryResults) {
- when(each.next()).thenReturn(true, false);
- }
- ShardingDQLResultMerger resultMerger = new
ShardingDQLResultMerger(databaseType);
- ShardingSphereDatabase database = mock(ShardingSphereDatabase.class,
RETURNS_DEEP_STUBS);
- when(database.getName()).thenReturn("foo_db");
- MergedResult actual = resultMerger.merge(queryResults,
selectStatementContext, database, mock(ConnectionContext.class));
- assertTrue(actual.next());
- assertTrue(actual.next());
- assertTrue(actual.next());
- assertFalse(actual.next());
- }
-
- @ParameterizedTest(name = "{0}")
- @ArgumentsSource(TestCaseArgumentsProvider.class)
- void assertNextForNotEmpty(final String name, final int index) throws
SQLException {
- List<QueryResult> queryResults = Arrays.asList(mock(QueryResult.class,
RETURNS_DEEP_STUBS), mock(QueryResult.class, RETURNS_DEEP_STUBS),
mock(QueryResult.class, RETURNS_DEEP_STUBS));
- when(queryResults.get(index).next()).thenReturn(true, false);
- ShardingDQLResultMerger resultMerger = new
ShardingDQLResultMerger(databaseType);
- ShardingSphereDatabase database = mock(ShardingSphereDatabase.class,
RETURNS_DEEP_STUBS);
- when(database.getName()).thenReturn("foo_db");
- MergedResult actual = resultMerger.merge(queryResults,
selectStatementContext, database, mock(ConnectionContext.class));
- assertTrue(actual.next());
- assertFalse(actual.next());
- }
-
- @Test
- void assertNextForMix() throws SQLException {
- List<QueryResult> queryResults = Arrays.asList(mock(QueryResult.class,
RETURNS_DEEP_STUBS), mock(QueryResult.class, RETURNS_DEEP_STUBS),
mock(QueryResult.class, RETURNS_DEEP_STUBS),
- mock(QueryResult.class, RETURNS_DEEP_STUBS),
mock(QueryResult.class, RETURNS_DEEP_STUBS), mock(QueryResult.class,
RETURNS_DEEP_STUBS));
- when(queryResults.get(1).next()).thenReturn(true, false);
- when(queryResults.get(3).next()).thenReturn(true, false);
- when(queryResults.get(5).next()).thenReturn(true, false);
- ShardingDQLResultMerger resultMerger = new
ShardingDQLResultMerger(databaseType);
- ShardingSphereDatabase database = mock(ShardingSphereDatabase.class,
RETURNS_DEEP_STUBS);
- when(database.getName()).thenReturn("foo_db");
- MergedResult actual = resultMerger.merge(queryResults,
selectStatementContext, database, mock(ConnectionContext.class));
- assertTrue(actual.next());
- assertTrue(actual.next());
- assertTrue(actual.next());
- assertFalse(actual.next());
- }
-
- private static final class TestCaseArgumentsProvider implements
ArgumentsProvider {
-
- @Override
- public Stream<? extends Arguments> provideArguments(final
ParameterDeclarations parameters, final ExtensionContext context) {
- return Stream.of(
- Arguments.of("first", 0),
- Arguments.of("middle", 1),
- Arguments.of("last", 2));
- }
- }
-}
