DynamoDB PutItem条件表达式问题：同一用户仅存一条PENDING记录

问题根源：属性名大小写不匹配 #

你的表哈希键是UserId（首字母大写），但条件表达式中用的是userId（全小写），DynamoDB属性名区分大小写，导致attribute_not_exists(userId)永远为true（因为实际不存在userId这个属性），所以即使已有同一用户的PENDING记录，条件也会满足，插入操作成功，这就是方案不生效的核心原因。

修正方案（单记录场景：同一用户仅一条记录） #

如果你的表仅用UserId作为唯一主键（同一用户只能有一条记录），修正属性名映射即可解决问题：

Expression conditionExpression = Expression.builder()
        .expression("attribute_not_exists(#userId) OR #currentStatus <> :pendingStatus")
        // 映射哈希键的真实名称
        .putExpressionName("#userId", "UserId")
        .putExpressionName("#currentStatus", "status")
        .putExpressionValue(":pendingStatus", 
            AttributeValue.builder().s("PENDING").build())
        .build();

这个表达式的逻辑完全匹配你的需求：

• 当用户不存在时，允许插入任何状态的记录；
• 当用户已存在，仅当现有记录的状态不是PENDING时，允许插入（替换）新记录。

对应你的示例：

• 插入user1,10,PENDING：用户不存在，成功；
• 插入user1,30,PENDING：用户已存在且状态为PENDING，条件不满足，失败；
• 插入user2,10,REDEEMED：用户不存在，成功；
• 插入user2,10,PENDING：用户已存在但状态为REDEEMED，条件满足，成功。

扩展方案（多记录场景：同一用户可有多条记录） #

如果你的表允许同一用户存在多条记录（即包含范围键，比如RecordId），单条记录的条件表达式无法检查该用户所有记录的PENDING状态，需要结合全局二级索引（GSI）+事务实现原子性检查：

1. 创建GSI：

   • 哈希键：UserId
   • 范围键：status
   • 投影类型：选择包含UserId和status（或全部投影）

2. 事务操作示例：
   通过事务先检查该用户是否有PENDING记录，确认无冲突后再插入新记录，避免竞态条件：

// 构建要插入的新记录
YourRecordClass newRecord = // 初始化你的记录对象

// 构建事务请求：先检查冲突，再插入
TransactionWriteRequest transaction = TransactionWriteRequest.builder()
        .addCheckItem(CheckConditionEnhancedRequest.builder(YourRecordClass.class)
                .key(Key.builder().partitionValue(newRecord.getUserId()).build())
                .conditionExpression(Expression.builder()
                        .expression("attribute_not_exists(#userId) OR #status <> :pending")
                        .putExpressionName("#userId", "UserId")
                        .putExpressionName("#status", "status")
                        .putExpressionValue(":pending", AttributeValue.builder().s("PENDING").build())
                        .build())
                .build())
        .addPutItem(PutItemEnhancedRequest.builder(YourRecordClass.class)
                .item(newRecord)
                .build())
        .build();

// 执行事务
dynamoDbEnhancedClient.transactWriteItems(transaction);

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