scala slick 一对多集合

我有一个数据库，其中包含具有一对多注册关系的活动。 目标是获取所有活动及其注册列表。

通过创建带有注册的活动的笛卡尔积，获取该数据所需的所有数据都已存在。 但我似乎找不到一个好的方法来将它正确地放入 scala 集合中； 让我们输入：Seq[(Activity, Seq[Registration])]

case class Registration(
  id: Option[Int],
  user: Int,
  activity: Int
)

case class Activity(
  id: Option[Int],
  what: String,
  when: DateTime,
  where: String,
  description: String,
  price: Double
)

假设存在适当的光滑表和表查询，我会写：

val acts_regs = (for {
   a <- Activities
   r <- Registrations if r.activityId === a.id
} yield (a, r))
  .groupBy(_._1.id)
  .map { case (actid, acts) => ??? }
}

但我似乎无法做出适当的映射。这样做的惯用方法是什么？我希望它比使用原始笛卡尔积更好......

In Scala

在 scala 代码中，这很简单，看起来像这样：

  val activities = db withSession { implicit sess =>
    (for {
      a <- Activities leftJoin Registrations on (_.id === _.activityId)
    } yield a).list
  }

  activities
    .groupBy(_._1.id)
    .map { case (id, set) => (set(0)._1, set.map(_._2)) }

但这似乎效率相当低，因为表映射器将为您创建不必要的 Activity 实例。 看起来也不是很优雅...

获取注册计数

当只对注册计数感兴趣时，scala 方法甚至更糟，如下所示：

val result: Seq[Activity, Int] = ???

In Slick

我在光滑方面的最佳尝试如下：

  val activities = db withSession { implicit sess =>
    (for {
      a <- Activities leftJoin Registrations on (_.id === _.activityId)
    } yield a)
      .groupBy(_._1.id)
      .map { case (id, results) => (results.map(_._1), results.length) }
  }

但这会导致错误，即 slick 无法映射“map”行中的给定类型。

我会建议：

  val activities = db withSession { implicit sess =>
    (for {
      a <- Activities leftJoin Registrations on (_.id === _.activityId)
    } yield a)
      .groupBy(_._1)
      .map { case (activity, results) => (activity, results.length) }
  }

问题在于

  val activities = db withSession { implicit sess =>
    (for {
      a <- Activities leftJoin Registrations on (_.id === _.activityId)
    } yield a)
      .groupBy(_._1.id)
      .map { case (id, results) => (results.map(_._1), results.length) }
  }

是你不能在 group by 中产生嵌套结果。results.map(_._1)是项目的集合。在某些情况下，SQL 会执行从集合到单行的隐式转换，但类型安全的 Slick 不会这样做。你想在 Slick 中做的事情是这样的results.map(_._1).head，但目前不支持。你能得到的最接近的东西是这样的(results.map(_.id).max, results.map(_.what).max, ...)，这非常乏味。因此，按整个活动行分组可能是目前最可行的解决方法。