如何解决DynamoDB查询中myList字段为空问题并标准化数据结构？

你遇到的核心问题是DynamoDB中存在两种不一致的myList结构：

1. 嵌套结构：数组元素包含M字段，内部属性带类型标识（如{"N":"1.06"}）
2. 扁平化结构：数组元素直接存储键值对（如"rt":"1.06"）

而你当前的查询代码因为错误的投影配置，加上SDK默认映射无法兼容两种结构，导致myList始终为null。

步骤1：修正查询投影配置 #

首先移除addNestedAttributesToProject的限制，确保完整获取myList字段，否则SDK无法拿到完整数据进行映射：

final SdkIterable<Page<MyTable>> pageResult = indexResult.query(q -> q
    .queryConditional(queryConditional)
    .attributesToProject("cDate", "type", "myList") // 直接投影完整的myList字段
);

步骤2：兼容两种结构的映射处理 #

针对两种不同的myList元素结构，有两种可行的处理方式：

方式一：自定义Attribute转换器（推荐）

通过自定义转换器让SDK自动识别并转换两种结构，需要给MyList类添加转换器：

// 自定义转换器类
public class MyListConverter implements AttributeConverter<MyList> {

    @Override
    public AttributeValue transformFrom(MyList myList) {
        // 写入DynamoDB时的转换逻辑（可选，按需实现）
        Map<String, AttributeValue> attrMap = new HashMap<>();
        attrMap.put("rt", AttributeValue.builder().s(myList.getRt()).build());
        attrMap.put("sDt", AttributeValue.builder().s(myList.getsDt()).build());
        attrMap.put("c", AttributeValue.builder().s(myList.getC()).build());
        attrMap.put("t", AttributeValue.builder().s(myList.getT()).build());
        return AttributeValue.builder().m(attrMap).build();
    }

    @Override
    public MyList transformTo(AttributeValue attributeValue) {
        MyList myList = new MyList();
        Map<String, AttributeValue> elemMap = attributeValue.m();
        
        // 处理两种结构：判断是否包含"M"嵌套字段
        Map<String, AttributeValue> targetMap = elemMap.containsKey("M") 
            ? elemMap.get("M").m() 
            : elemMap;

        // 处理rt字段：兼容N（数字）和S（字符串）类型
        AttributeValue rtAttr = targetMap.get("rt");
        myList.setRt(rtAttr.n() != null ? rtAttr.n() : rtAttr.s());
        
        // 处理其他字符串字段
        myList.setsDt(targetMap.get("sDt").s());
        myList.setC(targetMap.get("c").s());
        myList.setT(targetMap.get("t").s());

        return myList;
    }

    @Override
    public EnhancedType<MyList> type() {
        return EnhancedType.of(MyList.class);
    }

    @Override
    public AttributeValueType attributeValueType() {
        return AttributeValueType.M;
    }
}

然后在MyTable类的myList字段上指定转换器：

class MyTable {
    private String cDate;
    private String type;
    @AttributeConverted(converter = MyListConverter.class)
    private List<MyList> myList;

    // 必须添加getter/setter方法，DynamoDB增强SDK需要访问器
    // getter和setter代码省略
}

class MyList {
    private String rt;
    private String sDt;
    private String c;
    private String t;

    // 必须添加getter/setter方法
    // getter和setter代码省略
}

方式二：手动解析原始AttributeValue

如果不想自定义转换器，可以直接读取原始的Map<String, AttributeValue>，手动转换为实体类：

// 改用原始查询API获取未映射的原始数据
final SdkIterable<Page<Map<String, AttributeValue>>> pageResult = indexResult.query(q -> q
    .queryConditional(queryConditional)
    .attributesToProject("cDate", "type", "myList")
);

List<MyTable> collectedItems = new ArrayList<>();
pageResult.stream().forEach(page -> page.items().stream().forEach(item -> {
    MyTable myTable = new MyTable();
    // 映射基础字段
    myTable.setcDate(item.get("cDate").s());
    myTable.setType(item.get("type").s());

    // 手动解析myList
    List<MyList> myList = new ArrayList<>();
    AttributeValue myListAttr = item.get("myList");
    if (myListAttr.l() != null) {
        for (AttributeValue elem : myListAttr.l()) {
            MyList listItem = new MyList();
            Map<String, AttributeValue> targetMap = elem.m().containsKey("M")
                ? elem.m().get("M").m()
                : elem.m();

            // 处理rt字段
            AttributeValue rtVal = targetMap.get("rt");
            listItem.setRt(rtVal.n() != null ? rtVal.n() : rtVal.s());
            
            // 处理其他字段
            listItem.setsDt(targetMap.get("sDt").s());
            listItem.setC(targetMap.get("c").s());
            listItem.setT(targetMap.get("t").s());

            myList.add(listItem);
        }
    }
    myTable.setMyList(myList);
    collectedItems.add(myTable);
}));

你使用的addNestedAttributesToProject(NestedAttributeName.create("myList","M"))仅会提取myList数组元素中的M字段，对于扁平化结构的记录，因为没有M字段，会导致数据被过滤；同时，即使是嵌套结构的记录，投影后的结构也无法和MyList实体类的字段匹配，最终导致SDK无法映射出myList数据。

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