使用DynamoDBMapper Java AWS SDK进行分页

Question

从API文档来看，dynamo db确实支持扫描和查询操作的分页。这里的关键是将当前请求的ExclusiveStartIndex设置为上一个请求的LastEvaluatedIndex的值，以获得下一组（逻辑页面）结果。

我试图实现同样的功能，但我使用的是DynamoDBMapper，它似乎有很多优点，比如与数据模型紧密耦合。因此，如果我想做上述工作，我假设我会做如下工作：

// Mapping of hashkey of the last item in previous query operation
Map<String, AttributeValue> lastHashKey = .. 
DynamoDBQueryExpression expression = new DynamoDBQueryExpression();

...
expression.setExclusiveStartKey();
List<Table> nextPageResults = mapper.query(Table.class, expression);

我希望我的上述理解是正确的分页使用DynamoDBMapper。其次，我怎么知道我已经达到了结果的终点。如果我使用以下api，请参阅文档：

QueryResult result = dynamoDBClient.query((QueryRequest) request);
boolean isEndOfResults = StringUtils.isEmpty(result.getLastEvaluatedKey());

回到使用DynamoDBMapper，我如何知道在这种情况下我是否达到了最终结果。

Answer 1

使用DynamoDBMapper，您有两个不同的选项，具体取决于您想走哪条路。

• query-返回一个PaginatedQueryList
• queryPage-返回QueryResultPage
• scan-返回一个PaginatedScanList
• scanPage-返回scanpresultpage

这里的部分是理解方法之间的区别，以及它们返回的对象封装了什么功能。

我将介绍PaginatedScanList和ScanResultPage，但是这些方法/对象基本上是相互镜像的。

PaginatedScanList显示了以下内容，我的重点是：

在AWS DynamoDB中实现表示扫描结果的列表接口。分页结果在用户执行需要它们的操作时按需加载。某些操作（如size（））必须获取整个列表，但在可能的情况下会逐页延迟获取结果。

这表示在遍历列表时加载结果。当您完成第一个页面时，第二个页面将自动获取，而无需显式地发出另一个请求。延迟加载结果是默认方法，但如果调用重载方法并使用不同的DynamoDBMapperConfig.PaginationLoadingStrategy提供DynamoDBMapperConfig，则可以重写该方法。

这与扫描结果页不同。您将获得一页结果，这取决于您自己处理分页。

下面是一个快速代码示例，显示了两种方法的示例用法，我使用DynamoDBLocal运行了一个包含5项的表：

final DynamoDBMapper mapper = new DynamoDBMapper(client);

// Using 'PaginatedScanList'
final DynamoDBScanExpression paginatedScanListExpression = new DynamoDBScanExpression()
        .withLimit(limit);
final PaginatedScanList<MyClass> paginatedList = mapper.scan(MyClass.class, paginatedScanListExpression);
paginatedList.forEach(System.out::println);

System.out.println();
// using 'ScanResultPage'
final DynamoDBScanExpression scanPageExpression = new DynamoDBScanExpression()
        .withLimit(limit);
do {
    ScanResultPage<MyClass> scanPage = mapper.scanPage(MyClass.class, scanPageExpression);
    scanPage.getResults().forEach(System.out::println);
    System.out.println("LastEvaluatedKey=" + scanPage.getLastEvaluatedKey());
    scanPageExpression.setExclusiveStartKey(scanPage.getLastEvaluatedKey());

} while (scanPageExpression.getExclusiveStartKey() != null);

以及输出：

MyClass{hash=2}
MyClass{hash=1}
MyClass{hash=3}
MyClass{hash=0}
MyClass{hash=4}

MyClass{hash=2}
MyClass{hash=1}
LastEvaluatedKey={hash={N: 1,}}
MyClass{hash=3}
MyClass{hash=0}
LastEvaluatedKey={hash={N: 0,}}
MyClass{hash=4}
LastEvaluatedKey=null