如何使用Java DynamoDB SDK仅获取单个字段？解决查询时ValidationException异常问题

首先，你的代码抛出ValidationException主要有几个核心问题，我们一步步来修复：

1. 核心问题分析 #

（1）使用了过时的KeyConditions API #

DynamoDB已经弃用了KeyConditions参数，当前要求使用KeyConditionExpression来指定主键查询条件，旧API的参数校验逻辑会触发ValidationException。

（2）主键字段大小写不匹配 #

你的查询代码中用的是小写的pk和sk作为字段名，但实体类PkSkPair里的注解指定的是大写PK和SK，这会导致DynamoDB无法匹配主键字段，直接触发参数校验错误。

（3）实体类注解冲突 #

Entity类同时定义了@Id复合主键对象dynamoId，又单独声明了pk、sk字段，这种重复映射会让DynamoDB映射器无法正确解析数据结构，反序列化时也会出问题。

2. 分步修复方案 #

方案一：更新查询代码（使用推荐的KeyConditionExpression） #

替换过时的KeyConditions，改用KeyConditionExpression和ExpressionAttributeValues来构建查询：

// 构建参数映射
Map<String, AttributeValue> attrValues = new HashMap<>();
attrValues.put(":pkVal", new AttributeValue().withS(pk));
attrValues.put(":skVal", new AttributeValue().withS(sk));

// 构建查询请求
QueryRequest queryRequest = new QueryRequest()
    .withTableName(tableName)
    // 用表达式指定主键条件
    .withKeyConditionExpression("pk = :pkVal AND sk = :skVal")
    .withExpressionAttributeValues(attrValues)
    // 指定只返回photos字段
    .withProjectionExpression("photos");

// 执行查询
QueryResult result = client.query(queryRequest);

// 如果需要手动解析结果（不使用映射器）
if (!result.getItems().isEmpty()) {
    Map<String, AttributeValue> item = result.getItems().get(0);
    return item.get("photos").getSS(); // 提取字符串列表
}
return Collections.emptyList();

方案二：修复实体类注解（解决映射冲突） #

调整实体类的主键映射，统一字段大小写，避免重复定义：

public class Entity {
    // 用复合主键对象统一管理主键
    @Id
    private PkSkPair dynamoId;

    // GSI映射通过复合主键的sk属性实现，避免重复字段
    @DynamoDBIndexHashKey(globalSecondaryIndexName = "gsi.bySk", attributeName = "sk")
    public String getSkForGsi() {
        return dynamoId != null ? dynamoId.getSk() : null;
    }

    private String blaBla;
    private List<String> photos;

    // 添加必要的getter/setter（或用Lombok简化）
    public PkSkPair getDynamoId() { return dynamoId; }
    public void setDynamoId(PkSkPair dynamoId) { this.dynamoId = dynamoId; }
    public String getBlaBla() { return blaBla; }
    public void setBlaBla(String blaBla) { this.blaBla = blaBla; }
    public List<String> getPhotos() { return photos; }
    public void setPhotos(List<String> photos) { this.photos = photos; }
}

public class PkSkPair implements Serializable {
    private String pk;
    private String sk;

    // 这里的attributeName要和查询中的字段名完全一致（小写pk）
    @DynamoDBHashKey(attributeName = "pk")
    public String getPk() { return pk; }
    public void setPk(String pk) { this.pk = pk; }

    // 同样用小写sk匹配查询字段
    @DynamoDBRangeKey(attributeName = "sk")
    public String getSk() { return sk; }
    public void setSk(String sk) { this.sk = sk; }
}

方案三：用DynamoDBMapper简化查询和映射 #

如果你希望直接将结果映射到Entity类，推荐使用DynamoDBMapper，它会自动处理反序列化：

// 初始化映射器
DynamoDBMapper mapper = new DynamoDBMapper(client);

// 构建查询表达式
DynamoDBQueryExpression<Entity> queryExpr = new DynamoDBQueryExpression<Entity>()
    .withHashKeyValues(new Entity() {{
        setDynamoId(new PkSkPair() {{
            setPk(pk);
            setSk(sk);
        }});
    }})
    // 指定只返回photos字段
    .withProjectionExpression("photos");

// 执行查询并获取结果
List<Entity> results = mapper.query(Entity.class, queryExpr);
return results.isEmpty() ? Collections.emptyList() : results.get(0).getPhotos();

3. 关键注意事项 #

• 始终确保查询中使用的字段名和实体类注解的attributeName完全一致（包括大小写），DynamoDB是大小写敏感的。
• 避免混用过时API和当前推荐的API，KeyConditions已经被官方标记为过时，优先使用KeyConditionExpression。
• 如果使用DynamoDBMapper，尽量让实体类的映射逻辑清晰，避免重复定义主键相关字段。

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