DynamoDB-查询而不是扫描-如何使用随机生成的密钥实现

Question

安装程序

我在java和DynamoDB（DynamoDB Mapper）注释中有下表：

@DynamoDBTable(tableName="myentity")
public class MyEntity {
@DynamoDBHashKey
@DynamoDBAutoGeneratedKey
private String id;

@DynamoDBIndexHashKey()
//@DynamoDBIndexRangeKey
private String userId;

private Date eventDate;

保存时会随机生成id，多个实体可能会出现相同的用户id。

通过Web GUI定义的表如下：主分区键：id（String）主排序键：userId（String）

问题

我想用一个查询而不是扫描获得一个用户ID的所有实体。

查询-不是这样工作的：

public List<MyEntity> findByUserIdQuery(String userId) {
    Map<String, AttributeValue> eav = new HashMap<String, AttributeValue>();
    eav.put(":val1", new AttributeValue().withS(userId));

    DynamoDBQueryExpression<MyEntity> queryExpression = new DynamoDBQueryExpression<MyEntity>()
        .withKeyConditionExpression("userId = :val1").withExpressionAttributeValues(eav);

    List<MyEntity> list = mapper.query(MyEntity.class, queryExpression);

我当然得到：

com.amazonaws.AmazonServiceException: Query condition missed key schema element: id (Service: AmazonDynamoDBv2; Status Code: 400; Error Code: ValidationException; Request ID: 123) at com.amazonaws.http.AmazonHttpClient.handleErrorResponse(AmazonHttpClient.java:1305)

因为我想读取数据时不知道生成的id。

工作区

相反，我使用：

public List<MyEntity> findByOwner(String userId){

    Map<String, AttributeValue> eav = new HashMap<String, AttributeValue>();
    eav.put(":val1", new AttributeValue().withS(userId));

    DynamoDBScanExpression scanExpression = new DynamoDBScanExpression()
        .withFilterExpression("userId = :val1").withExpressionAttributeValues(eav);

    List<MyEntity> list = mapper.scan(MyEntity.class, scanExpression);

可能的解决方案

问题是我从来都不知道随机生成的元素键。当我想阅读时，我只知道用户ID，我想拥有他们的所有实体。

我观看了以下示例：https://docs.aws.amazon.com/amazondynamodb/latest/developerguide/DynamoDBMapper.QueryScanExample.html ...但他们总是知道他们在寻找什么的关键。他们使用如下组合键：

String partitionKey = forumName + "#" + threadSubject;*
eav.put(":val1", new AttributeValue().withS(partitionKey))
Map<String, AttributeValue> eav = new HashMap<String, AttributeValue>();
DynamoDBQueryExpression<Reply> queryExpression = new DynamoDBQueryExpression<Reply>()
            .withKeyConditionExpression("Id = :val1 and ReplyDateTime > :val2").withExpressionAttributeValues(eav);

问题

• 我可以使用这个组合分区键的通配符吗？（类似: "* # myGreatUser"）
• 关于db设置和其他注释作为关键元素的其他建议？
• 也许是一个可以使用查询而不是扫描的索引？
• 也许有人有这种用例的工作示例？

Answer 1

您只需切换分区键和排序键即可。

@DynamoDBTable(tableName="myentity")
public class MyEntity {

@DynamoDBRangeKey
@DynamoDBAutoGeneratedKey
private String id;

@DynamoDBHashKey
private String userId;

private Date eventDate;

然后使用

public List<MyEntity> findByUserIdQuery(String userId) {
    Map<String, AttributeValue> eav = new HashMap<String, AttributeValue>();
    eav.put(":val1", new AttributeValue().withS(userId));

DynamoDBQueryExpression<MyEntity> queryExpression = new DynamoDBQueryExpression<MyEntity>()
    .withKeyConditionExpression("userId = :val1").withExpressionAttributeValues(eav);

List<MyEntity> list = mapper.query(MyEntity.class, queryExpression);

顺便说一句，您提到您认为您的排序键是userId，但在提供的示例中，您有一个id的主哈希键和一个userid的全局二级索引哈希键。没有排序键。