如何从三个DynamoDB表获取所有数据并按公共列排序？

一、用DTO模式实现多表数据查询 #

1. 定义DTO类 #

创建包含所有需要字段的非实体类，对应三个表的查询结果：

public class MultiTableDTO {
    private Long commonId; // 三个表的公共列
    private String tableAField; // 表A独有字段
    private Integer tableBField; // 表B独有字段
    private Date tableCField; // 表C独有字段

    // 全参构造函数（用于JPA查询映射）
    public MultiTableDTO(Long commonId, String tableAField, Integer tableBField, Date tableCField) {
        this.commonId = commonId;
        this.tableAField = tableAField;
        this.tableBField = tableBField;
        this.tableCField = tableCField;
    }

    // getter、setter方法
    // ...
}

2. 编写查询逻辑 #

基于MyBatis的实现

在Mapper接口中定义查询方法，通过联表SQL将结果映射到DTO：

@Mapper
public interface MultiTableMapper {
    @Select("SELECT " +
            "a.common_id as commonId, " +
            "a.field_a as tableAField, " +
            "b.field_b as tableBField, " +
            "c.field_c as tableCField " +
            "FROM table_a a " +
            "JOIN table_b b ON a.common_id = b.common_id " +
            "JOIN table_c c ON a.common_id = c.common_id")
    List<MultiTableDTO> queryMultiTableData();
}

基于Spring Data JPA的实现

在Repository接口中使用自定义JPQL查询，直接返回DTO：

public interface MultiTableRepository extends JpaRepository<TableA, Long> {
    @Query("SELECT new com.example.dto.MultiTableDTO(a.commonId, a.fieldA, b.fieldB, c.fieldC) " +
           "FROM TableA a " +
           "JOIN a.tableB b " +
           "JOIN a.tableC c")
    List<MultiTableDTO> findMultiTableData();
}

3. 业务层调用 #

在Service中调用上述Mapper/Repository方法，获取DTO列表后返回给前端即可。

二、基于公共列的跨表排序 #

1. 数据库层面排序（推荐） #

直接在SQL中添加ORDER BY子句，指定公共列的排序规则，效率最高：

SELECT ... 
FROM ... 
JOIN ... 
ORDER BY common_id ASC; -- ASC升序，DESC降序

对应MyBatis的Mapper可以修改为带排序参数的版本：

@Select("SELECT ... FROM ... JOIN ... ORDER BY common_id #{sortDirection}")
List<MultiTableDTO> queryMultiTableData(@Param("sortDirection") String sortDirection);

Spring Data JPA方式

使用Sort参数动态指定排序规则：

@Query("SELECT new com.example.dto.MultiTableDTO(a.commonId, a.fieldA, b.fieldB, c.fieldC) " +
       "FROM TableA a JOIN a.tableB b JOIN a.tableC c")
List<MultiTableDTO> findMultiTableData(Sort sort);

// 调用示例
Sort sort = Sort.by(Sort.Direction.DESC, "commonId");
List<MultiTableDTO> sortedData = multiTableRepository.findMultiTableData(sort);

2. 内存层面排序（仅小数据量适用） #

如果无法在数据库层排序，可以在内存中通过Stream API处理：

List<MultiTableDTO> data = multiTableService.getMultiTableData();
// 按公共列升序排序
List<MultiTableDTO> sortedData = data.stream()
    .sorted(Comparator.comparing(MultiTableDTO::getCommonId))
    .collect(Collectors.toList());
// 降序则用Comparator.comparing(MultiTableDTO::getCommonId).reversed()

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