dynamodb分页查询_使用DynamoDBMapper查询DynamoDB项目

dynamodb分页查询

在上一篇文章中，我们使用底层Java api在DynamoDB数据库上发出了查询。

使用DynamoDBMapper进行查询非常简单。

使用哈希键发出查询非常简单。这样的查询的最佳候选者是通过使用电子邮件哈希键进行搜索的Users表。

public User getUser(String email) {User user = dynamoDBMapper.load(User.class,email);return user;}

由于我们仅对用户表使用哈希键，因此结果将被限制为一个。

加载功能也可用于复合键。因此，查询登录表项将需要哈希键和范围键。

public Login getLogin(String email,Long date) {Login login =  dynamoDBMapper.load(Login.class,email,date);return login;}

下一步是使用条件发出更复杂的查询。我们将发出一个查询，该查询将获取两个日期之间的登录尝试。

public List<Login> queryLoginsBetween(String email, Long from, Long to) {Map<String,String> expressionAttributesNames = new HashMap<>();expressionAttributesNames.put("#email","email");expressionAttributesNames.put("#timestamp","timestamp");Map<String,AttributeValue> expressionAttributeValues = new HashMap<>();expressionAttributeValues.put(":emailValue",new AttributeValue().withS(email));expressionAttributeValues.put(":from",new AttributeValue().withN(Long.toString(from)));expressionAttributeValues.put(":to",new AttributeValue().withN(Long.toString(to)));DynamoDBQueryExpression<Login> queryExpression = new DynamoDBQueryExpression<Login>().withKeyConditionExpression("#email = :emailValue and #timestamp BETWEEN :from AND :to ").withExpressionAttributeNames(expressionAttributesNames).withExpressionAttributeValues(expressionAttributeValues);return dynamoDBMapper.query(Login.class,queryExpression);}

我们使用DynamoDBQueryExpression，其方式与在低级api中使用的方式相同。
主要区别在于我们根本不需要处理分页。 DynamoDBMapper会将DynamoDB项映射到对象，但还将返回“延迟加载”集合。它最初仅返回一页结果，然后在需要时对下一页进行服务调用。

最后但并非最不重要的是，对索引的查询是基本操作之一。对于本地或全局二级索引，它是相同的例程。
请记住，获取的结果取决于创建表后指定的投影类型。在我们的情况下，投影类型适用于所有字段。

public Supervisor getSupervisor(String company,String factory) {Map<String,String> expressionAttributesNames = new HashMap<>();expressionAttributesNames.put("#company","company");expressionAttributesNames.put("#factory","factory");Map<String,AttributeValue> expressionAttributeValues = new HashMap<>();expressionAttributeValues.put(":company",new AttributeValue().withS(company));expressionAttributeValues.put(":factory",new AttributeValue().withS(factory));DynamoDBQueryExpression<Supervisor> dynamoDBQueryExpression = new DynamoDBQueryExpression<Supervisor>().withIndexName("FactoryIndex").withKeyConditionExpression("#company = :company and #factory = :factory ").withExpressionAttributeNames(expressionAttributesNames).withExpressionAttributeValues(expressionAttributeValues).withConsistentRead(false);List<Supervisor> supervisor = dynamoDBMapper.query(Supervisor.class,dynamoDBQueryExpression);if(supervisor.size()>0) {return supervisor.get(0);} else {return null;}}

要特别注意一致读取设置为false的事实。 DynamoDBQueryExpression使用默认的一致读取。使用全局二级索引时，无法发出一致的读取。

您可以在github上找到带有单元测试的完整源代码。