Quering GSI of DynamoDB using QueryEnhancedRequest

Question

Can some one help in letting me know how I can create query to GSI of DynamoDB using QueryEnhancedRequest in Java??

In most of the AWS documentation I see that they provided examples with QueryRequest but not with QueryEnhancedRequest and DynamoDbTable is only accepting the query of type QueryEnhancedRequest in Jva

Leeroy Hannigan · Accepted Answer

Here's an example:

```
        DynamoDbTable moviesTable = enhancedClient.table("Movies", TableSchema.fromBean(Movie.class));

QueryConditional condition = QueryConditional.sortBetween(Key.builder()
                .partitionValue(1958)
                .sortValue("1920")
                .build(), Key.builder()
                .partitionValue(1958)
                .sortValue("1950")
                .build());

QueryEnhancedRequest request = QueryEnhancedRequest.builder()
                .queryConditional(condition)
                .scanIndexForward(false)
                .build();

SdkIterable> movieWithName = moviesTable.index("my-index").query(request);

movieWithName.forEach(page-> {
            List allMovies = page.items();
            for( Movie myMovie: allMovies){
                System.out.println(myMovie.getTitle());
            }
        });
```

Yvaraj Periyasamy · Answer

Hi @Leeroy Hannigan,
We are tried with limit but query returns all items.

Key	startKey=Key.builder().partitionValue(Messages.YES.getCode()).sortValue(startDate).build();
				Key	endKey=Key.builder().partitionValue(Messages.YES.getCode()).sortValue(endDate).build();
				QueryConditional queryConditional = QueryConditional.sortBetween(startKey, endKey);

Expression expressions= Expression.builder().expression(expressionStr.toString()).expressionValues(filterParamMap).build();

QueryEnhancedRequest.Builder queryRequest = QueryEnhancedRequest.builder()
					.queryConditional(queryConditional)
		            .filterExpression(expressions)
		            .scanIndexForward(false).limit(50);

SdkIterable> recordsListIterable =dynamoDbRecordTable.index("ByScheduleDate").query(queryRequest.build());
			   
			   recordsListIterable.stream().forEach(rec -> {
				   totalRecordsList.addAll(rec.items());
			   });

So i posted the questions here. Could you please hlep us?

for Ref :
https://stackoverflow.com/questions/62417472/limit-method-in-queryenhancedrequest-for-dynamodb-java-v2-sdk-doesnt-limit-as-e

Yvaraj Periyasamy · Answer

@Leeroy Hannigan , Thank you for your post and how to use limit  here? and we trying use limit but getting all items.. please help me to fix this issue? 
and 
Most of person telling limit is not supported in QueryEnhancedRequest

QueryEnhancedRequest.Builder queryRequest = QueryEnhancedRequest.builder()
					.queryConditional(queryConditional)
		            .filterExpression(expressions)
		            .scanIndexForward(false)
		            .limit(50);

SdkIterable> recordsListIterable =dynamoDbRecordTable.index("ByScheduleDate").query(queryRequest.build());

for Ref:
https://stackoverflow.com/questions/62417472/limit-method-in-queryenhancedrequest-for-dynamodb-java-v2-sdk-doesnt-limit-as-e

Quering GSI of DynamoDB using QueryEnhancedRequest

관련 콘텐츠