Spring Boot & JPA 如何实现单张扁平表查询结果聚合映射

纯JPA默认的单行映射规则无法直接自动完成这类嵌套集合聚合——因为单张扁平表查询返回的是按行展开的多组重复公司数据，JPA原生的接口投影默认是1行映射1个投影实例，不会自动按公司维度分组、把员工数据归集到集合中。
但完全可以通过JPA生态的标准扩展能力实现需求，不需要在业务层编写散落的手动转换逻辑，这类实现方案在报表、关联列表等场景下应用非常广泛，具备很高的生产实用价值。

方案1：Hibernate @ParentChild 注解实现（最推荐，零额外转换逻辑） #

如果你的项目底层用Hibernate作为JPA实现（Spring Boot生态99%的项目默认选型），且Hibernate版本在6.0以上（对应Spring Boot 3.0+），可以直接用Hibernate原生支持的父子结果聚合能力，全程只需要写实体、投影和查询语句，不需要写任何遍历分组代码。

1. 首先映射你的扁平表为普通JPA实体：

@Entity
@Table(name = "company_employee_rel") // 对应你的扁平表名
public class CompanyEmployeeFlat {
    // 如果表没有单列主键，可以用companyId+employeeId+employeeRole做联合主键
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;
    private Long companyId;
    private String companyName;
    private Long employeeId;
    private String employeeName;
    private String employeeRole;

    // 省略所有字段的getter、setter
}

2. 定义类形式的投影（注意接口投影不支持该能力，必须用普通类），用@ParentChild标记子集合：

// 父级聚合投影
public class CompanySummary {
    private Long companyId;
    private String companyName;
    @ParentChild // 标记该字段为子级集合，按父级唯一字段自动分组归集
    private List<EmployeeProjection> employees;

    // 构造函数参数顺序必须和JPQL中select的字段顺序完全一致
    public CompanySummary(Long companyId, String companyName, EmployeeProjection employee) {
        this.companyId = companyId;
        this.companyName = companyName;
        this.employees = new ArrayList<>();
        if (employee != null) {
            this.employees.add(employee);
        }
    }

    // 必须写子元素追加方法，Hibernate归集同组数据时会自动调用该方法
    public void addEmployee(EmployeeProjection employee) {
        this.employees.add(employee);
    }

    // 省略getter
}

// 子级员工投影
public class EmployeeProjection {
    private Long id;
    private String name;
    private String role;

    public EmployeeProjection(Long id, String name, String role) {
        this.id = id;
        this.name = name;
        this.role = role;
    }

    // 省略getter
}

3. 在Repository中直接写JPQL查询，不需要自定义结果转换器：

public interface CompanyEmployeeRepository extends JpaRepository<CompanyEmployeeFlat, Long> {
    @Query("""
        select new com.xxx.CompanySummary(
            ce.companyId,
            ce.companyName,
            new com.xxx.EmployeeProjection(ce.employeeId, ce.employeeName, ce.employeeRole)
        )
        from CompanyEmployeeFlat ce
        order by ce.companyId
    """)
    List<CompanySummary> findAllSummaries();
}

注意：调用该方法拿到的结果直接是按公司维度聚合完成的结构，员工数据已经全部归集到对应公司的employees集合中，没有额外转换开销，性能和直接查询全表一致。

方案2：Repository层封装分组逻辑（兼容低版本JPA/Hibernate） #

如果你的项目用的是Hibernate 5及更低版本（对应Spring Boot 2.x），可以把分组聚合逻辑封装在Repository的默认方法中，完全不泄露到业务层，业务层调用仍然是直接拿聚合结果，符合单一职责原则。

public interface CompanyEmployeeRepository extends JpaRepository<CompanyEmployeeFlat, Long> {
    // 定义单行平铺投影，和表字段一一对应
    interface FlatRow {
        Long getCompanyId();
        String getCompanyName();
        Long getEmployeeId();
        String getEmployeeName();
        String getEmployeeRole();
    }

    // JPA自动实现平铺查询
    List<FlatRow> findAllBy();

    // 默认方法完成聚合，业务层直接调用该方法即可
    default List<CompanySummary> findAllSummaries() {
        return findAllBy().stream()
            .collect(Collectors.groupingBy(
                FlatRow::getCompanyId,
                Collectors.collectingAndThen(Collectors.toList(), rows -> {
                    CompanySummary summary = new CompanySummary();
                    summary.setCompanyId(rows.get(0).getCompanyId());
                    summary.setCompanyName(rows.get(0).getCompanyName());
                    List<EmployeeProjection> employees = rows.stream()
                        .map(row -> new EmployeeProjection(row.getEmployeeId(), row.getEmployeeName(), row.getEmployeeRole()))
                        .toList();
                    summary.setEmployees(employees);
                    return summary;
                })
            ))
            .values()
            .stream()
            .toList();
    }
}

• 不要为了实现聚合强行给单张扁平表定义@OneToMany/@ManyToOne虚拟关联，这类写法容易触发N+1查询、级联更新误操作等问题，维护成本极高。
• 不要把结果转换逻辑散落在业务Service层，相同的聚合逻辑多处调用时会产生大量重复代码，后续字段调整很容易出现漏改问题。

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