dynamodb java

在上一篇文章中，我們有機(jī)會(huì)發(fā)布了一些基本的DynamoDB查詢操作。

但是，除了基本操作之外，DynamoDB api還為我們提供了一些額外的功能。

投影是具有類似選擇功能的功能。
您選擇應(yīng)從DynamoDB項(xiàng)中提取哪些屬性。 請(qǐng)記住，使用投影不會(huì)對(duì)您的查詢帳單產(chǎn)生任何影響。

public Map<String,AttributeValue> getRegisterDate(String email) {Map<String,String> expressionAttributesNames = new HashMap<>();expressionAttributesNames.put("#email","email");Map<String,AttributeValue> expressionAttributeValues = new HashMap<>();expressionAttributeValues.put(":emailValue",new AttributeValue().withS(email));QueryRequest queryRequest = new QueryRequest().withTableName(TABLE_NAME).withKeyConditionExpression("#email = :emailValue").withExpressionAttributeNames(expressionAttributesNames).withExpressionAttributeValues(expressionAttributeValues).withProjectionExpression("registerDate");QueryResult queryResult = amazonDynamoDB.query(queryRequest);List<Map<String,AttributeValue>> attributeValues = queryResult.getItems();if(attributeValues.size()>0) {return attributeValues.get(0);} else {return null;}}

除了選擇屬性，我們還可以根據(jù)我們的范圍鍵指定順序。 我們將使用scanIndexForward以降序查詢登錄表。

public List<Map<String,AttributeValue>> fetchLoginsDesc(String email) {List<Map<String,AttributeValue>> items = new ArrayList<>();Map<String,String> expressionAttributesNames = new HashMap<>();expressionAttributesNames.put("#email","email");Map<String,AttributeValue> expressionAttributeValues = new HashMap<>();expressionAttributeValues.put(":emailValue",new AttributeValue().withS(email));QueryRequest queryRequest = new QueryRequest().withTableName(TABLE_NAME).withKeyConditionExpression("#email = :emailValue").withExpressionAttributeNames(expressionAttributesNames).withExpressionAttributeValues(expressionAttributeValues).withScanIndexForward(false);Map<String,AttributeValue> lastKey = null;do {QueryResult queryResult = amazonDynamoDB.query(queryRequest);List<Map<String,AttributeValue>> results = queryResult.getItems();items.addAll(results);lastKey = queryResult.getLastEvaluatedKey();} while (lastKey!=null);return items;}

數(shù)據(jù)庫(kù)的常見(jiàn)功能是對(duì)集合中保留的項(xiàng)目進(jìn)行計(jì)數(shù)。 在我們的情況下，我們要計(jì)算特定用戶的登錄次數(shù)。 但是，請(qǐng)?zhí)貏e注意，因?yàn)橛?jì)數(shù)功能只不過(guò)是對(duì)已獲取的項(xiàng)目總數(shù)進(jìn)行計(jì)數(shù)，因此，這將使您好像在獲取項(xiàng)目一樣花費(fèi)很多。

public Integer countLogins(String email) {List<Map<String,AttributeValue>> items = new ArrayList<>();Map<String,String> expressionAttributesNames = new HashMap<>();expressionAttributesNames.put("#email","email");Map<String,AttributeValue> expressionAttributeValues = new HashMap<>();expressionAttributeValues.put(":emailValue",new AttributeValue().withS(email));QueryRequest queryRequest = new QueryRequest().withTableName(TABLE_NAME).withKeyConditionExpression("#email = :emailValue").withExpressionAttributeNames(expressionAttributesNames).withExpressionAttributeValues(expressionAttributeValues).withSelect(Select.COUNT);Map<String,AttributeValue> lastKey = null;QueryResult queryResult = amazonDynamoDB.query(queryRequest);List<Map<String,AttributeValue>> results = queryResult.getItems();return queryResult.getCount();}

DynamoDB的另一個(gè)功能是批量獲取項(xiàng)目，即使它們屬于不同的表也是如此。 在屬于特定上下文的數(shù)據(jù)通過(guò)不同的表分布的情況下，這確實(shí)很有用。 每個(gè)獲取項(xiàng)都作為DynamoDB讀取操作進(jìn)行處理和收費(fèi)。 如果是批處理獲取項(xiàng)目，則應(yīng)指定所有表鍵，因?yàn)锽atchGetItem的每個(gè)查詢的目的都是獲取單個(gè)項(xiàng)目。

public Map<String,List<Map<String,AttributeValue>>> getMultipleInformation(String email,String name) {Map<String,KeysAndAttributes> requestItems = new HashMap<>();List<Map<String,AttributeValue>> userKeys = new ArrayList<>();Map<String,AttributeValue> userAttributes = new HashMap<>();userAttributes.put("email",new AttributeValue().withS(email));userKeys.add(userAttributes);requestItems.put(UserRepository.TABLE_NAME,new KeysAndAttributes().withKeys(userKeys));List<Map<String,AttributeValue>> supervisorKeys = new ArrayList<>();Map<String,AttributeValue> supervisorAttributes = new HashMap<>();supervisorAttributes.put("name",new AttributeValue().withS(name));supervisorKeys.add(supervisorAttributes);requestItems.put(SupervisorRepository.TABLE_NAME,new KeysAndAttributes().withKeys(supervisorKeys));BatchGetItemRequest batchGetItemRequest = new BatchGetItemRequest();batchGetItemRequest.setRequestItems(requestItems);BatchGetItemResult batchGetItemResult = amazonDynamoDB.batchGetItem(batchGetItemRequest);Map<String,List<Map<String,AttributeValue>>> responses = batchGetItemResult.getResponses();return responses;}

您可以在github上找到源代碼

翻譯自: https://www.javacodegeeks.com/2016/07/query-dynamodb-items-java-part-2.html

dynamodb java

總結(jié)

以上是生活随笔為你收集整理的dynamodb java_使用Java第2部分查询DynamoDB项的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。