嘿，这个问题我刚好有实操经验，咱们来聊聊怎么搞定Java和Kotlin DNQ里的Group By聚合查询——就拿你说的按公司名称分组统计发票销售额总和这个场景举例，一步步来。

Java 实现方案 #

假设你的发票实体类Invoice定义了companyName（公司名称）和salesAmount（销售额）两个核心字段，这里提供两种常用的实现方式：

1. JPA Criteria API（类型安全推荐） #

这种方式不需要写硬编码的SQL，能更好地适配实体类的映射关系：

// 先获取EntityManager（根据你的ORM框架配置，比如Spring的@PersistenceContext注入）
EntityManager em = ...;
CriteriaBuilder cb = em.getCriteriaBuilder();
CriteriaQuery<Tuple> query = cb.createTupleQuery();

// 关联发票实体作为查询根
Root<Invoice> invoiceRoot = query.from(Invoice.class);

// 指定查询结果：分组字段+聚合函数
query.multiselect(
    invoiceRoot.get("companyName").alias("companyName"),
    cb.sum(invoiceRoot.get("salesAmount")).alias("totalSales")
)
// 设置分组条件
.groupBy(invoiceRoot.get("companyName"));

// 执行查询并处理结果
List<Tuple> results = em.createQuery(query).getResultList();
for (Tuple tuple : results) {
    String company = (String) tuple.get("companyName");
    BigDecimal totalSales = (BigDecimal) tuple.get("totalSales");
    System.out.printf("公司：%s，总销售额：%s%n", company, totalSales);
}

2. 原生SQL（灵活度高） #

如果你的查询逻辑复杂，或者需要用到数据库特定的语法，原生SQL会更直接：

EntityManager em = ...;
String sql = "SELECT company_name, SUM(sales_amount) AS total_sales FROM invoice GROUP BY company_name";
Query nativeQuery = em.createNativeQuery(sql);

List<Object[]> results = nativeQuery.getResultList();
for (Object[] row : results) {
    String company = (String) row[0];
    BigDecimal totalSales = (BigDecimal) row[1];
    // 这里可以添加自定义业务逻辑
}

Kotlin DNQ 实现方案 #

如果是用Kotlin结合DNQ（比如基于DataNucleus或Kotlin专属ORM框架），写法会更简洁，同时保留类型安全特性：

1. Kotlin + JPA Criteria API #

val em: EntityManager = ... // 注入或获取EntityManager
val cb = em.criteriaBuilder
val query = cb.createTupleQuery()

val invoiceRoot = query.from(Invoice::class.java)

query.apply {
    multiselect(
        invoiceRoot.get<String>("companyName").alias("companyName"),
        cb.sum(invoiceRoot.get<BigDecimal>("salesAmount")).alias("totalSales")
    )
    groupBy(invoiceRoot.get("companyName"))
    // 可选：添加排序，比如按总销售额降序
    orderBy(cb.desc(cb.sum(invoiceRoot.get("salesAmount"))))
}

val results = em.createQuery(query).resultList
results.forEach { tuple ->
    val company = tuple.get<String>("companyName")
    val totalSales = tuple.get<BigDecimal>("totalSales")
    println("公司：$company，总销售额：$totalSales")
}

2. Kotlin Exposed（假设你用的是JetBrains的Exposed ORM） #

如果你的DNQ指的是Kotlin的Exposed框架，分组聚合的写法会更简洁：

// 先定义发票表结构
object InvoiceTable : Table("invoice") {
    val companyName = varchar("company_name", 255)
    val salesAmount = decimal("sales_amount", 18, 2)
}

// 执行分组查询
val result = InvoiceTable
    .slice(InvoiceTable.companyName, InvoiceTable.salesAmount.sum())
    .selectAll()
    .groupBy(InvoiceTable.companyName)
    .map { row ->
        Pair(row[InvoiceTable.companyName], row[InvoiceTable.salesAmount.sum()])
    }

// 遍历结果
result.forEach { (company, totalSales) ->
    println("公司：$company，总销售额：$totalSales")
}

关键注意事项 #

• 字段映射一致性：确保实体类字段和数据库列的映射名称完全匹配（比如companyName对应数据库的company_name），避免因名称不匹配导致的查询失败。
• 聚合类型匹配：sum函数的返回类型要和实体字段类型一致（比如用BigDecimal存储销售额，聚合结果也要用BigDecimal接收）。
• 过滤条件添加：如果需要筛选特定范围的数据（比如某时间段的发票），可以在groupBy之前添加where子句，比如Java中query.where(cb.greaterThan(invoiceRoot.get("invoiceDate"), LocalDate.of(2024, 1, 1)))。
• 空值处理：如果存在公司名称为null的发票，分组时会单独归为一组，你可以根据业务需求决定是否过滤这类数据。

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