Skip to content

Commit 94191f1

Browse files
authored
Update BasicSearchableEncryptionExample.java
Adding updatedQueryRequest
1 parent 396c1a3 commit 94191f1

1 file changed

Lines changed: 15 additions & 4 deletions

File tree

Examples/runtimes/java/DynamoDbEncryption/src/main/java/software/amazon/cryptography/examples/searchableencryption/BasicSearchableEncryptionExample.java

Lines changed: 15 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -392,15 +392,26 @@ public static void PutItemQueryItemWithBeacon(
392392
//We need to query for all possible parttions
393393

394394
for (int partition = 0; partition < numQueries; partition++) {
395-
396-
queryRequest.ExpressionAttributeValues.Add(":aws_dbe_partition", N(partition.to_string())
397-
398395

396+
expressionAttributeValues.put(
397+
":aws_dbe_partition",
398+
AttributeValue.builder().n(partition.to_string()).build()
399+
);
400+
401+
QueryRequest updatedQueryRequest = QueryRequest
402+
.builder()
403+
.tableName(ddbTableName)
404+
.indexName(GSI_NAME)
405+
.keyConditionExpression("#last4 = :last4 and #unit = :unit")
406+
.expressionAttributeNames(expressionAttributesNames)
407+
.expressionAttributeValues(expressionAttributeValues)
408+
.build();
409+
399410
// GSIs do not update instantly
400411
// so if the results come back empty
401412
// we retry after a short sleep
402413
for (int i = 0; i < 10; ++i) {
403-
final QueryResponse queryResponse = ddb.query(queryRequest);
414+
final QueryResponse queryResponse = ddb.query(updatedQueryRequest);
404415
List<Map<String, AttributeValue>> attributeValues = queryResponse.items();
405416
// Validate query was returned successfully
406417
assert 200 == queryResponse.sdkHttpResponse().statusCode();

0 commit comments

Comments
 (0)