DynamoDB中TransactWriteItems的Update为何表现为覆盖而非更新？

你的问题出在**addUpdate(userEntity)的使用方式**上：当直接把实体对象传给addUpdate时，DynamoDBMapper默认会将实体中的所有属性（包括你未修改、可能被设为null的属性）都作为更新项写入，相当于执行了类似Put的全量覆盖操作。而version字段能正常自增，是因为它被标记为版本属性，Mapper会单独处理自增逻辑，不受其他属性的覆盖行为影响。

解决方法 #

方法1：用DynamoDBUpdateExpression精准控制更新字段 #

通过构建更新表达式，明确指定要修改的属性，完全避免误覆盖其他字段。示例代码如下：

private TransactionWriteRequest buildTransactionWriteRequest(List<UserEntity> userEntities) {
    TransactionWriteRequest transactionWriteRequest = new TransactionWriteRequest();

    userEntities.forEach(userEntity -> {
        if (userEntity.getVersion() != null) {
            // 构建更新表达式，只更新需要修改的属性（比如name和email）
            DynamoDBUpdateExpression updateExpr = new DynamoDBUpdateExpression()
                    .withUpdateExpression("set #name = :n, #email = :e")
                    .withNameMap(new NameMap()
                            .with("#name", "name")
                            .with("#email", "email"))
                    .withValueMap(new ValueMap()
                            .withString(":n", userEntity.getName())
                            .withString(":e", userEntity.getEmail()))
                    // 加上乐观锁校验，确保更新的是当前版本的条目
                    .withConditionExpression("version = :v")
                    .withValueMap(new ValueMap().withNumber(":v", userEntity.getVersion()));
            
            transactionWriteRequest.addUpdate(userEntity, updateExpr);
        } else {
            transactionWriteRequest.addPut(userEntity);
        }
    });

    return transactionWriteRequest;
}

方法2：配置SaveBehavior忽略null属性 #

如果希望只更新实体中非null的属性（前提是未修改的属性保留查询时的原值，不要设为null），可以通过DynamoDBMapperConfig设置跳过null属性的更新行为：

private TransactionWriteRequest buildTransactionWriteRequest(List<UserEntity> userEntities) {
    TransactionWriteRequest transactionWriteRequest = new TransactionWriteRequest();
    // 配置更新时跳过null属性
    DynamoDBMapperConfig updateConfig = DynamoDBMapperConfig.builder()
            .withSaveBehavior(DynamoDBMapperConfig.SaveBehavior.UPDATE_SKIP_NULL_ATTRIBUTES)
            .build();

    userEntities.forEach(userEntity -> {
        if (userEntity.getVersion() != null) {
            transactionWriteRequest.addUpdate(userEntity, updateConfig);
        } else {
            transactionWriteRequest.addPut(userEntity);
        }
    });

    return transactionWriteRequest;
}

注意：这种方式要求你查询出实体后，仅修改需要更新的属性，其他属性保持原有值（不要设为null），否则null值还是会被写入覆盖原有数据。

内容的提问来源于stack exchange，提问作者Yunhan Zou