This is an automated email from the ASF dual-hosted git repository.
zhonghongsheng 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 f31d8791e8f Refactor Range constructor (#37539)
f31d8791e8f is described below
commit f31d8791e8f4253c4f041fe051878ba02937d0f9
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Fri Dec 26 17:28:12 2025 +0800
Refactor Range constructor (#37539)
---
.../table/MatchingTableInventoryChecker.java | 8 +++---
.../ingest/dumper/inventory/InventoryDumper.java | 2 +-
.../core/ingest/dumper/inventory/query/Range.java | 14 +++++++++-
.../AbstractRecordTableInventoryCalculator.java | 2 +-
.../PipelineInventoryCalculateSQLBuilderTest.java | 20 +++++++--------
.../RecordTableInventoryCheckCalculatorTest.java | 30 +++++++++++-----------
6 files changed, 44 insertions(+), 32 deletions(-)
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/MatchingTableInventoryChecker.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/MatchingTableInventoryChecker.java
index cdab31588e8..dc856cb2dbb 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/MatchingTableInventoryChecker.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/MatchingTableInventoryChecker.java
@@ -77,8 +77,8 @@ public abstract class MatchingTableInventoryChecker
implements TableInventoryChe
TableInventoryCalculateParameter sourceParam = new
TableInventoryCalculateParameter(param.getSourceDataSource(),
param.getSourceTable(),
param.getColumnNames(), param.getUniqueKeys(),
QueryType.RANGE_QUERY, param.getQueryCondition());
TableCheckRangePosition checkRangePosition =
param.getProgressContext().getTableCheckRangePositions().get(param.getSplittingItem());
- sourceParam.setRange(new Range(null !=
checkRangePosition.getSourcePosition() ? checkRangePosition.getSourcePosition()
: checkRangePosition.getSourceRange().getBeginValue(),
- true, checkRangePosition.getSourceRange().getEndValue()));
+ sourceParam.setRange(Range.closed(null !=
checkRangePosition.getSourcePosition() ? checkRangePosition.getSourcePosition()
: checkRangePosition.getSourceRange().getBeginValue(),
+ checkRangePosition.getSourceRange().getEndValue()));
TableInventoryCalculateParameter targetParam =
getTableInventoryCalculateParameter(param, checkRangePosition);
TableInventoryCalculator<TableInventoryCheckCalculatedResult>
sourceCalculator = buildSingleTableInventoryCalculator();
this.sourceCalculator = sourceCalculator;
@@ -132,8 +132,8 @@ public abstract class MatchingTableInventoryChecker
implements TableInventoryChe
private TableInventoryCalculateParameter
getTableInventoryCalculateParameter(final TableInventoryCheckParameter param,
final TableCheckRangePosition checkRangePosition) {
TableInventoryCalculateParameter result = new
TableInventoryCalculateParameter(param.getTargetDataSource(),
param.getTargetTable(),
param.getColumnNames(), param.getUniqueKeys(),
QueryType.RANGE_QUERY, param.getQueryCondition());
- result.setRange(new Range(null !=
checkRangePosition.getTargetPosition() ? checkRangePosition.getTargetPosition()
: checkRangePosition.getTargetRange().getBeginValue(),
- true, checkRangePosition.getTargetRange().getEndValue()));
+ result.setRange(Range.closed(null !=
checkRangePosition.getTargetPosition() ? checkRangePosition.getTargetPosition()
: checkRangePosition.getTargetRange().getBeginValue(),
+ checkRangePosition.getTargetRange().getEndValue()));
return result;
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
index f2118cc1f60..18902dfa804 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
@@ -124,7 +124,7 @@ public final class InventoryDumper extends
AbstractPipelineLifecycleRunnable imp
List<String> columnNames = dumperContext.getQueryColumnNames();
TableInventoryCalculateParameter calculateParam = new
TableInventoryCalculateParameter(dataSource, table,
columnNames, dumperContext.getUniqueKeyColumns(),
QueryType.RANGE_QUERY, null);
- Range range = new Range(((PrimaryKeyIngestPosition<?>)
initialPosition).getBeginValue(), true, ((PrimaryKeyIngestPosition<?>)
initialPosition).getEndValue());
+ Range range = Range.closed(((PrimaryKeyIngestPosition<?>)
initialPosition).getBeginValue(), ((PrimaryKeyIngestPosition<?>)
initialPosition).getEndValue());
calculateParam.setRange(range);
RecordTableInventoryDumpCalculator dumpCalculator = new
RecordTableInventoryDumpCalculator(dumperContext.getBatchSize(),
StreamingRangeType.SMALL);
long rowCount = 0L;
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/Range.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/Range.java
index 158a401176c..a3dbb60f90d 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/Range.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/Range.java
@@ -17,13 +17,14 @@
package
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.inventory.query;
+import lombok.AccessLevel;
import lombok.Getter;
import lombok.RequiredArgsConstructor;
/**
* Range.
*/
-@RequiredArgsConstructor
+@RequiredArgsConstructor(access = AccessLevel.PRIVATE)
@Getter
public final class Range {
@@ -43,4 +44,15 @@ public final class Range {
public static Range closed(final Object lowerBound, final Object
upperBound) {
return new Range(lowerBound, true, upperBound);
}
+
+ /**
+ * Create open-closed range.
+ *
+ * @param lowerBound lower bound
+ * @param upperBound upper bound
+ * @return open-closed range
+ */
+ public static Range openClosed(final Object lowerBound, final Object
upperBound) {
+ return new Range(lowerBound, false, upperBound);
+ }
}
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
index e523fd2b187..3c28cf3b80e 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/query/calculator/AbstractRecordTableInventoryCalculator.java
@@ -76,7 +76,7 @@ public abstract class
AbstractRecordTableInventoryCalculator<S, C> extends Abstr
}
Object maxUniqueKeyValue =
getFirstUniqueKeyValue(records.get(records.size() - 1),
param.getFirstUniqueKey().getName());
if (QueryType.RANGE_QUERY == param.getQueryType()) {
- param.setRange(new Range(maxUniqueKeyValue, false,
param.getRange().getUpperBound()));
+ param.setRange(Range.openClosed(maxUniqueKeyValue,
param.getRange().getUpperBound()));
}
return Optional.of(convertRecordsToResult(records, maxUniqueKeyValue));
}
diff --git
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineInventoryCalculateSQLBuilderTest.java
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineInventoryCalculateSQLBuilderTest.java
index 92420ff48c2..e87bbe25795 100644
---
a/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineInventoryCalculateSQLBuilderTest.java
+++
b/kernel/data-pipeline/core/src/test/java/org/apache/shardingsphere/data/pipeline/core/sqlbuilder/sql/PipelineInventoryCalculateSQLBuilderTest.java
@@ -44,38 +44,38 @@ class PipelineInventoryCalculateSQLBuilderTest {
@Test
void assertBuildRangeQueryOrderingSQLPageQuery() {
String actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(1, true, 5), true, SHARDING_COLUMNS_NAMES);
+ Range.closed(1, 5), true, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id>=? AND order_id<=? ORDER BY order_id ASC, status ASC, user_id
ASC LIMIT ?"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(1, false, 5), true, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(1, 5), true, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id>? AND order_id<=? ORDER BY order_id ASC, status ASC, user_id ASC
LIMIT ?"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(1, false, null), true, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(1, null), true, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id>? ORDER BY order_id ASC, status ASC, user_id ASC LIMIT ?"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(null, false, 5), true, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(null, 5), true, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id<=? ORDER BY order_id ASC, status ASC, user_id ASC LIMIT ?"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(null, false, null), true, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(null, null), true, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
ORDER BY order_id ASC, status ASC, user_id ASC LIMIT ?"));
}
@Test
void assertBuildRangeQueryOrderingSQLNotPageQuery() {
String actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(1, true, 5), false, SHARDING_COLUMNS_NAMES);
+ Range.closed(1, 5), false, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id>=? AND order_id<=? ORDER BY order_id ASC, status ASC, user_id
ASC"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(1, false, 5), false, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(1, 5), false, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id>? AND order_id<=? ORDER BY order_id ASC, status ASC, user_id
ASC"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(1, false, null), false, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(1, null), false, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id>? ORDER BY order_id ASC, status ASC, user_id ASC"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(null, false, 5), false, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(null, 5), false, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
WHERE order_id<=? ORDER BY order_id ASC, status ASC, user_id ASC"));
actual = sqlBuilder.buildRangeQueryOrderingSQL(new
QualifiedTable(null, "t_order"), COLUMN_NAMES, UNIQUE_KEYS,
- new Range(null, false, null), false, SHARDING_COLUMNS_NAMES);
+ Range.openClosed(null, null), false, SHARDING_COLUMNS_NAMES);
assertThat(actual, is("SELECT order_id,user_id,status FROM t_order
ORDER BY order_id ASC, status ASC, user_id ASC"));
}
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
index e9d1016440e..47e6e6852e0 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/data/pipeline/core/consistencycheck/table/calculator/RecordTableInventoryCheckCalculatorTest.java
@@ -21,8 +21,8 @@ import org.apache.commons.text.RandomStringGenerator;
import
org.apache.shardingsphere.data.pipeline.core.consistencycheck.result.RecordTableInventoryCheckCalculatedResult;
import
org.apache.shardingsphere.data.pipeline.core.consistencycheck.result.TableInventoryCheckCalculatedResult;
import
org.apache.shardingsphere.data.pipeline.core.datasource.PipelineDataSource;
-import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.inventory.query.Range;
import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.inventory.query.QueryType;
+import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.inventory.query.Range;
import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.inventory.query.StreamingRangeType;
import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.inventory.query.calculator.TableInventoryCalculateParameter;
import
org.apache.shardingsphere.data.pipeline.core.metadata.model.PipelineColumnMetaData;
@@ -99,7 +99,7 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(4,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildOrderIdUniqueKey(),
QueryType.RANGE_QUERY, null);
- assertRangeQueryCalculatedResult(calculator, param, new Range(0,
false, null), 4, 4);
+ assertRangeQueryCalculatedResult(calculator, param,
Range.openClosed(0, null), 4, 4);
}
@ParameterizedTest
@@ -108,7 +108,7 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(4,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildOrderIdUniqueKey(),
QueryType.RANGE_QUERY, null);
- assertRangeQueryCalculatedResult(calculator, param, new Range(4,
false, null), 4, 8);
+ assertRangeQueryCalculatedResult(calculator, param,
Range.openClosed(4, null), 4, 8);
}
@ParameterizedTest
@@ -117,8 +117,8 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(1000,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildMultiColumnUniqueKeys(),
QueryType.RANGE_QUERY, null);
- assertRangeQueryCalculatedResult(calculator, param, new Range(3, true,
6), 8, 6);
- assertRangeQueryCalculatedResult(calculator, param, new Range(3,
false, 6), 3, 6);
+ assertRangeQueryCalculatedResult(calculator, param, Range.closed(3,
6), 8, 6);
+ assertRangeQueryCalculatedResult(calculator, param,
Range.openClosed(3, 6), 3, 6);
}
private void assertRangeQueryCalculatedResult(final
RecordTableInventoryCheckCalculator calculator, final
TableInventoryCalculateParameter param, final Range range,
@@ -145,9 +145,9 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(1000,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null, "test3"),
Collections.emptyList(), buildMultiColumnUniqueKeys(),
QueryType.RANGE_QUERY, null);
- assertRangeQueryCalculatedResult(calculator, param, new Range(3, true,
4), 4, 4);
- assertRangeQueryCalculatedResult(calculator, param, new Range(5, true,
6), 4, 6);
- assertRangeQueryCalculatedResult(calculator, param, new Range(5, true,
7), 5, 7);
+ assertRangeQueryCalculatedResult(calculator, param, Range.closed(3,
4), 4, 4);
+ assertRangeQueryCalculatedResult(calculator, param, Range.closed(5,
6), 4, 6);
+ assertRangeQueryCalculatedResult(calculator, param, Range.closed(5,
7), 5, 7);
}
@ParameterizedTest
@@ -156,7 +156,7 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(1000,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildMultiColumnUniqueKeys(),
QueryType.RANGE_QUERY, null);
- param.setRange(new Range(3, true, 2));
+ param.setRange(Range.closed(3, 2));
Optional<TableInventoryCheckCalculatedResult> calculatedResult =
calculator.calculateChunk(param);
QuietlyCloser.close(param.getCalculationContext());
assertFalse(calculatedResult.isPresent());
@@ -171,7 +171,7 @@ class RecordTableInventoryCheckCalculatorTest {
}
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null, "test1"),
Collections.emptyList(), buildUserIdUniqueKey(),
QueryType.RANGE_QUERY, null);
- param.setRange(new Range(0, false, null));
+ param.setRange(Range.openClosed(0, null));
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(5,
StreamingRangeType.valueOf(streamingRangeType));
Optional<TableInventoryCheckCalculatedResult> calculateResult =
calculator.calculateChunk(param);
QuietlyCloser.close(param.getCalculationContext());
@@ -187,7 +187,7 @@ class RecordTableInventoryCheckCalculatorTest {
}
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null, "test2"),
Collections.emptyList(), buildMultiColumnUniqueKeys(),
QueryType.RANGE_QUERY, null);
- param.setRange(new Range(null, false, null));
+ param.setRange(Range.openClosed(null, null));
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(5,
StreamingRangeType.valueOf(streamingRangeType));
Optional<TableInventoryCheckCalculatedResult> calculateResult =
calculator.calculateChunk(param);
QuietlyCloser.close(param.getCalculationContext());
@@ -200,7 +200,7 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(3, streamingChunkCount,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildOrderIdUniqueKey(),
QueryType.RANGE_QUERY, null);
- param.setRange(new Range(null, false, null));
+ param.setRange(Range.openClosed(null, null));
Iterator<TableInventoryCheckCalculatedResult> resultIterator =
calculator.calculate(param).iterator();
RecordTableInventoryCheckCalculatedResult actual =
(RecordTableInventoryCheckCalculatedResult) resultIterator.next();
assertThat(actual.getRecordsCount(), is(3));
@@ -238,7 +238,7 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(50, 100,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildMultiColumnUniqueKeys(),
QueryType.RANGE_QUERY, null);
- param.setRange(new Range(null, false, null));
+ param.setRange(Range.openClosed(null, null));
Iterator<TableInventoryCheckCalculatedResult> resultIterator =
calculator.calculate(param).iterator();
RecordTableInventoryCheckCalculatedResult actual =
(RecordTableInventoryCheckCalculatedResult) resultIterator.next();
assertThat(actual.getRecordsCount(), is(10));
@@ -264,7 +264,7 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(3, streamingChunkCount,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildMultiColumnUniqueKeys(),
QueryType.RANGE_QUERY, null);
- param.setRange(new Range(null, false, null));
+ param.setRange(Range.openClosed(null, null));
Iterator<TableInventoryCheckCalculatedResult> resultIterator =
calculator.calculate(param).iterator();
RecordTableInventoryCheckCalculatedResult actual =
(RecordTableInventoryCheckCalculatedResult) resultIterator.next();
assertThat(actual.getRecordsCount(), is(3));
@@ -302,7 +302,7 @@ class RecordTableInventoryCheckCalculatorTest {
RecordTableInventoryCheckCalculator calculator = new
RecordTableInventoryCheckCalculator(2, streamingChunkCount,
StreamingRangeType.valueOf(streamingRangeType));
TableInventoryCalculateParameter param = new
TableInventoryCalculateParameter(dataSource, new QualifiedTable(null,
"t_order"),
Collections.emptyList(), buildMultiColumnUniqueKeys(),
QueryType.RANGE_QUERY, null);
- param.setRange(new Range(null, false, null));
+ param.setRange(Range.openClosed(null, null));
Iterator<TableInventoryCheckCalculatedResult> resultIterator =
calculator.calculate(param).iterator();
RecordTableInventoryCheckCalculatedResult actual =
(RecordTableInventoryCheckCalculatedResult) resultIterator.next();
assertThat(actual.getRecordsCount(), is(2));
