通过 java aws sdk 的 DynamoDb 增强客户端,如何使用复合 keyConditionExpression 进行查询?

Bre*_*rds 6 java amazon-dynamodb aws-sdk dynamodb-queries

我有一个 DynamoDb 表,其中包含两个键的 GSI - 字符串字段“id”(分区键)和数字字段“count”(排序键)。

我正在尝试弄清楚如何使用 SDK 中的 DynamoDbEnhancedClient 通过 Spring Java 应用程序运行查询(而不是扫描),以获取关键条件表达式:

#id = :idValue and #count between :minCount and :maxCount
Run Code Online (Sandbox Code Playgroud)

我可以为此复合表达式的每个部分构建两个单独的 QueryConditional 对象,例如:

var partitionKeyConditional = QueryConditional.keyEqualTo(Key.builder()
      .partitionValue("myIdValue")
      .build());
var sortKeyConditional = QueryConditional.sortBetween(Key.builder()
      .sortValue(0)
      .build(), Key.builder()
      .sortValue(100)
      .build());
Run Code Online (Sandbox Code Playgroud)

但我不知道如何将这些组合到实际的查询请求中:

dynamoDbEnhancedClient.table(myTableName, TableSchema.fromBean(TableObject.class)) 
   .query(QueryEnhancedRequest.builder()
        .queryConditional(SomeJoinFunction??(partitionKeyConditional, sortKeyConditional))
        .build())
   .items();
Run Code Online (Sandbox Code Playgroud)

我可以看到我可以使用 filterExpression,但我假设这会在查询中应用关键条件来选择结果之后发生,因此排序键定义的优势基本上消失了。然而,它与我想要的功能最相似:

    var expressionAttributeNames = new HashMap<String, String>() {{
        put("#id", ID_PROPERTY_NAME);
        put("#count", COUNT_PROPERTY_NAME);
    }};
    var expressionAttributeValues = new HashMap<String, AttributeValue>() {{
        put(":idValue", AttributeValue.builder().s("myId").build());
        put(":minCount", AttributeValue.builder().n("0").build());
        put(":maxCount", AttributeValue.builder().n("100").build());
    }};

    var queryExpression = Expression.builder()
            .expressionNames(expressionAttributeNames)
            .expressionValues(expressionAttributeValues)
            .expression("#id = :idValue and #count between :minCount and :maxCount")
            .build();
Run Code Online (Sandbox Code Playgroud)

我可能错过了一些明显的东西,有什么建议吗?

小智 9

所使用的密钥生成器QueryConditionals可以同时使用 apartitionKeysortKeyvalue 来构建其表达式。因此,当您构建QueryConditional.sortBetween对象时,您可以在那里定义匹配partitionKey

var partitionKeyValue = "myIdValue"
var sortKeyConditional = QueryConditional.sortBetween(Key.builder()
  .partitionValue(partitionKeyValue)
  .sortValue(0)
  .build(), Key.builder()
  .partitionValue(partitionKeyValue)
  .sortValue(100)
  .build());
Run Code Online (Sandbox Code Playgroud)