11

我是 DynamoDB 的新手，正在尝试使用事务支持的示例场景。我正在使用dynamodb-transaction库中提供的相同实体。唯一的区别是我添加了一个带有哈希键的范围键。这是表定义：

  • ItemId--> 哈希键，字符串
  • ItemName--> 范围键，字符串
@DynamoDBTable(tableName = "Item")
public static class ExampleItem {
    private String itemId;
    private String value;
    private String itemName;
    private Long version;
    @DynamoDBHashKey(attributeName = "ItemId")
    public String getItemId() {
        return itemId;
    }
    public void setItemId(String itemId) {
        this.itemId = itemId;
    }
    @DynamoDBRangeKey(attributeName="ItemName")
    public String getItemName() {
        return itemName;
    }
    public void setItemName(String itemName) {
        this.itemName = itemName;
    }
    public String getValue() {
        return value;
    }
    public void setValue(String value) {
        this.value = value;
    }
    @DynamoDBVersionAttribute
    public Long getVersion() {
        return version;
    }
    public void setVersion(Long version) {
        this.version = version;
    }
}

如您所见，我也在使用版本属性。现在，我正在尝试使用事务/dbmapper 执行一个简单的创建或更新方案。这是代码片段。

Transaction t1 = txManager.newTransaction();
ExampleItem keyItem = new ExampleItem();
keyItem.setItemId("Item1");
keyItem.setItemName("USA");
ExampleItem item = t1.load(keyItem);
if (item != null) {
    item.setValue("Magenta");
    item.setItemName("UK");
    t1.save(item);
} else {
    item = new ExampleItem();
    item.setItemId(keyItem.getItemId());
    item.setItemName("USA");
    item.setValue("Violet");
    t1.save(item);
}
t1.commit();
t1.delete();

我可以毫无问题地添加记录，但是当我尝试读取记录并更新任何属性时遇到问题。我收到以下异常：

Uncaught exception:com.amazonaws.services.dynamodbv2.model.ConditionalCheckFailedException: Status Code: 0, AWS Service: null, AWS Request ID: null, AWS Error Code: null, AWS Error Message: Item {ItemId={S: Item1,}, ItemName={S: UK,}} had unexpected attributes: Status Code: 0, AWS Service: null, AWS Request ID: null, AWS Error Code: null, AWS Error Message: expected attribute(s) {version={Value: {N: 1,},Exists: true}} but found null
com.amazonaws.services.dynamodbv2.model.ConditionalCheckFailedException: Status Code: 0, AWS Service: null, AWS Request ID: null, AWS Error Code: null, AWS Error Message: Item {ItemId={S: Item1,}, ItemName={S: UK,}} had unexpected attributes: Status Code: 0, AWS Service: null, AWS Request ID: null, AWS Error Code: null, AWS Error Message: expected attribute(s) {version={Value: {N: 1,},Exists: true}} but found null

看起来它与版本有关，但不确定我哪里出错了。任何指针将不胜感激。

-谢谢

沙米克

4

3 回答 3

3

Dynamodb 有这个Optimistic Locking的概念，是一种确保您正在更新（或删除）的客户端项目与 DynamoDB 中的项目相同的策略。

  1. 第一次保存：

如果是第一次更新，则必须遵循此格式

DynamodbSaveExpression saveExpression = 
       new DynamodbSaveExpression()
       .withExpectedEntry("ItemId", new ExpectedAttributeValue().withExists(false)
       .withConditionalOperator(AND)
       .withExpectedEntry("ItemName", new ExpectedAttributeValue().withExists(false));
// saving the item to dynamodb 
dynamodbmapper.save(itemToSave, saveExpression);

解释：我们告诉只有当“ItemId”、“ItemValue”组合在dynamodb中都不存在时才应该保存 itemToSave。

  1. 更新现有项目：

要更新 dynamodb 中的现有项目，您必须遵循此格式

// Step1: Do a GET
ExampleItem itemInDynamo = dynamoDBMapper.load(ExampleItem.class, "item_id_value", "item_name_value");
// Step2: Get the version in Dynamo
Long versionInDynamo = itemInDynamo.getVersion();
DynamodbSaveExpression saveExpression = 
       new DynamodbSaveExpression()
       .withExpectedEntry("version", 
       new ExpectedAttributeValue(new AttributeValue().withN(versionInDynamodb.toString())));
// Step3: Update the item
dynamodbmapper.save(itemToSave, saveExpression);

仅当您保存的版本在 Dynamodb 中相同时，保存才会成功，如果不保存将失败并出现ConditionalCheckFailedException ，那么您必须从步骤 1 重试。这是先读后写。

于 2017-07-19T14:45:25.750 回答
2

看起来您需要在创建项目类时设置版本。它期待 1 但发现为空。versionedAttribute 需要一个值，并且似乎在第一次创建项目时需要 1。

如果您将来更新此项目，它应该注意在内部增加版本。

于 2015-05-12T19:31:37.340 回答
1

通常，当您的密钥与 dynamodb 中多个元素的密钥相同时，就会发生这种情况。例如，如果您有id 为 hashKey 且文件夹名称为 rangeKey 的文件夹，您将不会再次将文件夹保存在您的哈希(hashkey+rangeKey) 相同的位置。

于 2016-10-05T11:40:05.130 回答