Skip to content

Commit d26625f

Browse files
authored
添加nextToken的样例
1 parent 7380b42 commit d26625f

File tree

1 file changed

+12
-5
lines changed

1 file changed

+12
-5
lines changed

src/test/java/examples/OTSMultiDataSample.java

Lines changed: 12 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -154,12 +154,19 @@ private static void getRange(OTSClient client, String tableName)
154154
exclusiveEndKey.addPrimaryKeyColumn(COLUMN_UID_NAME,
155155
PrimaryKeyValue.fromLong(4)); // 范围的边界需要提供完整的PK,若查询的范围不涉及到某一列值的范围,则需要将该列设置为无穷大或者无穷小
156156

157-
criteria.setInclusiveStartPrimaryKey(inclusiveStartKey);
158-
criteria.setExclusiveEndPrimaryKey(exclusiveEndKey);
159157
GetRangeRequest request = new GetRangeRequest();
160-
request.setRangeRowQueryCriteria(criteria);
161-
GetRangeResult result = client.getRange(request);
162-
List<Row> rows = result.getRows();
158+
159+
List<Row> rows = new ArrayList<Row>();
160+
RowPrimaryKey next = inclusiveStartKey;
161+
162+
do {
163+
criteria.setInclusiveStartPrimaryKey(next);
164+
criteria.setExclusiveEndPrimaryKey(exclusiveEndKey);
165+
request.setRangeRowQueryCriteria(criteria);
166+
GetRangeResult result = client.getRange(request);
167+
rows.addAll(result.getRows());
168+
next = result.getNextStartPrimaryKey();
169+
} while (next != null);
163170

164171
System.out.println("GetRange result:");
165172
for (Row row : rows) {

0 commit comments

Comments
 (0)