我已经实现了以下两个测试用例来测试dynamodb增强库。
测试用例1:使用表“digital#form”上的get item,pk=“form#123”和sk=“info#123”。它可以返回结果
@Test
public void testGetItemWithPKSK() throws ExecutionException, InterruptedException {
DynamoDbAsyncTable<DigitalFormDao> digitalformTable = dynamoDbEnhancedAsyncClient
.table("digital_form", TableSchema.fromBean(DigitalFormDao.class));
DigitalFormDao form = digitalformTable.getItem(
Key.builder().partitionValue("FORM#ABC123").sortValue("INFO#ABC123").build()).get();
System.out.println(form.getSk());
}
测试用例2:对同一个表使用query,pk=“form#123”,sk以“info”开头。假设它将返回一组包含测试用例1的结果。然而,没有结果是回报。
@Test
public void testQueryWithPKandSKBegin(){
DynamoDbAsyncTable<DigitalFormDao> digitalformTable = dynamoDbEnhancedAsyncClient
.table("digital_form", TableSchema.fromBean(DigitalFormDao.class));
PagePublisher<DigitalFormDao> digitalForms = digitalformTable.query(
r -> r.queryConditional(
sortBeginsWith(k -> k.partitionValue("FORM#ABC123").sortValue("INFO"))));
AtomicInteger atomicInteger = new AtomicInteger();
atomicInteger.set(0);
digitalForms.subscribe(page -> {
DigitalFormDao digitalFormDao = (DigitalFormDao) page.items().get(atomicInteger.get());
System.out.println(digitalFormDao.getSk());
atomicInteger.incrementAndGet();
});
}
我的查询语句有什么问题吗?
暂无答案!
目前还没有任何答案,快来回答吧!