Scala Slick分组查询：统计特定值字段数量的问题

首先，我们来拆解你遇到的问题：你的需求是按pageId（对应代码中的pageUrl）分组，统计每组的图片总数、标注为true的图片数量，以及最新的lastAccess时间，但之前的代码存在两个核心问题，导致触发了Slick的查询树转换异常。

错误原因分析 #

1. 分组键错误：你之前的groupBy(a => (a._1, a._3))把pageUrl和isAnnotated同时作为分组键，这会把同一个pageUrl下的isAnnotated=true和isAnnotated=false数据拆成不同分组，完全偏离了“按pageId统一分组统计”的需求。
2. 非法操作调用：第二个版本代码里的a._3.result是错误用法——result是执行查询时获取结果的方法，不能在构建查询阶段使用，Slick无法将这个操作转换为合法的SQL。
3. 聚合语法不兼容：Slick对分组后的聚合操作有严格的语法要求，不能直接用普通Scala条件判断，需要使用Slick支持的聚合函数或CaseWhen表达式。

修正后的Slick代码 #

下面是符合需求的正确实现，我们仅按pageUrl分组，用Slick原生支持的聚合逻辑完成统计：

import slick.jdbc.MySQLProfile.api._ // 根据你的数据库类型调整Profile（如PostgresProfile）

def get = {
  val query = WebImage.webimage
    // 仅按pageUrl（对应数据表的pageId）分组
    .groupBy(image => image.pageUrl)
    .map { case (pageUrl, group) =>
      (
        pageUrl, // 分组的pageId
        group.map(_.lastAccess).max, // 每组最新的lastAccess时间
        group.filter(_.isAnnotated === true).length, // 标注为true的图片数量
        group.length // 每组的图片总数
      )
    }
  
  db.run(query.result)
}

如果你更习惯用原生SQL中CASE WHEN的写法，也可以用Slick的CaseWhen表达式实现等价逻辑：

import slick.jdbc.MySQLProfile.api._
import slick.lifted.CaseWhen

def get = {
  val query = WebImage.webimage
    .groupBy(_.pageUrl)
    .map { case (pageUrl, group) =>
      // 用CaseWhen实现类似SQL的sum(case when ...)逻辑
      val annotatedCount = group.map(img => CaseWhen(img.isAnnotated -> 1, 0)).sum
      (
        pageUrl,
        group.map(_.lastAccess).max,
        annotatedCount.getOrElse(0), // 处理空分组的边界情况
        group.length
      )
    }
  
  db.run(query.result)
}

对应原生SQL逻辑 #

这段Slick代码会生成和你参考的原生SQL逻辑一致的查询：

SELECT 
  pageUrl,
  MAX(lastAccess),
  COUNT(CASE WHEN isAnnotated = true THEN 1 END),
  COUNT(*)
FROM WebImage
GROUP BY pageUrl

这样就能正确得到你期望的结果：按pageId分组，返回每组的图片总数、标注为true的图片数量，同时获取每组的最新访问时间。

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