Skip to content

Commit d9be133

Browse files
authored
Update BasicSearchableEncryptionExample.java
Adding GetNumberOfQueries and defaultNumberOfPartitions.
1 parent 02cd1db commit d9be133

1 file changed

Lines changed: 16 additions & 13 deletions

File tree

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

Lines changed: 16 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -212,6 +212,7 @@ public static void PutItemQueryItemWithBeacon(
212212
.standardBeacons(standardBeaconList)
213213
.version(1) // MUST be 1
214214
.maximumNumberOfPartitions(8)
215+
.defaultNumberOfPartitions(1) //For beacons that do not require partitioning, only a single partition is used.
215216
.keyStore(keyStore)
216217
.keySource(
217218
BeaconKeySource
@@ -365,26 +366,17 @@ public static void PutItemQueryItemWithBeacon(
365366
expressionAttributesNames.put("#last4", "inspector_id_last4");
366367
expressionAttributesNames.put("#unit", "unit");
367368

368-
// In this simple example, we know there are two buckets,
369-
// but in general the number can be obtained using transformClient.getNumberOfQueries(query)
370-
int numQueries = 2;
371-
//We need to query for all possible parttions
372-
373-
for (int partition = 0; partition < numQueries; partition++) {
374-
Map<String, AttributeValue> expressionAttributeValues = new HashMap<>();
375-
expressionAttributeValues.put(
369+
Map<String, AttributeValue> expressionAttributeValues = new HashMap<>();
370+
expressionAttributeValues.put(
376371
":last4",
377372
AttributeValue.builder().s("4321").build()
378373
);
379374
expressionAttributeValues.put(
380375
":unit",
381376
AttributeValue.builder().s("123456789012").build()
382377
);
383-
expressionAttributeValues.put(":aws_dbe_partition",
384-
AttributeValue.builder().n(Integer.toString(partition)).build()
385-
);
386-
387-
QueryRequest queryRequest = QueryRequest
378+
379+
QueryRequest queryRequest = QueryRequest
388380
.builder()
389381
.tableName(ddbTableName)
390382
.indexName(GSI_NAME)
@@ -393,6 +385,17 @@ public static void PutItemQueryItemWithBeacon(
393385
.expressionAttributeValues(expressionAttributeValues)
394386
.build();
395387

388+
389+
// The number can be obtained using transformClient.getNumberOfQueries(query)
390+
int numQueries = transformClient.GetNumberOfQueries(queryRequest);
391+
392+
//We need to query for all possible parttions
393+
394+
for (int partition = 0; partition < numQueries; partition++) {
395+
396+
queryRequest.ExpressionAttributeValues.Add(":aws_dbe_partition", N(i.to_string())
397+
398+
396399
// GSIs do not update instantly
397400
// so if the results come back empty
398401
// we retry after a short sleep

0 commit comments

Comments
 (0)