26

我无法理解新的 Slick DBIOActionAPI，文档中似乎没有很多示例。我正在使用 Slick 3.0.0，我需要执行一些数据库操作以及一些从数据库接收到的数据的计算，但所有这些操作都必须在单个事务中完成。我正在尝试执行以下操作：

  1. types对数据库（表）执行查询。
  2. 对查询结果做一些聚合和过滤（这个计算不能在数据库上完成）。
  3. 根据第 2 步中的计算执行另一个查询（messages表 - 由于某些限制，此查询必须使用原始 SQL）。
  4. 将步骤 2 和 3 中的数据连接到内存中。

我希望第 1 步和第 3 步的查询在事务中执行，因为它们的结果集中的数据必须是一致的。

我试图以单子连接方式做到这一点。这是我的代码的过度简化版本，但我什至无法编译它：

  val compositeAction = (for {
    rawTypes <- TableQuery[DBType].result
    (projectId, types) <- rawTypes.groupBy(_.projectId).toSeq.map(group => (group._1, group._2.slice(0, 10)))
    counts <- DBIO.sequence(types.map(aType => sql"""select count(*) from messages where type_id = ${aType.id}""".as[Int]))
  } yield (projectId, types.zip(counts))).transactionally
  1. for理解的第一行从types表中选择数据。
  2. 第二行for理解应该对结果进行一些分组和切片，从而产生一个Seq[(Option[String], Seq[String])]
  3. 第三行for理解必须对上一步中的每个元素执行一组查询，特别是，它必须对 . 中的每个值执行单个 SQL 查询Seq[String]。所以在第三行中，我构建了一个DBIOActions 序列。
  4. 第二步和第三步的yield子句zips 。typescounts

但是，这种构造不起作用，并给出了两个编译时错误：

Error:(129, 16) type mismatch;
 found   : slick.dbio.DBIOAction[(Option[String], Seq[(com.centreit.proto.repiso.storage.db.models.DBType#TableElementType, Vector[Int])]),slick.dbio.NoStream,slick.dbio.Effect]
    (which expands to)  slick.dbio.DBIOAction[(Option[String], Seq[(com.centreit.proto.repiso.storage.db.models.TypeModel, Vector[Int])]),slick.dbio.NoStream,slick.dbio.Effect]
 required: scala.collection.GenTraversableOnce[?]
        counts <- DBIO.sequence(types.map(aType => sql"""select count(*) from messages where type_id = ${aType.id}""".as[Int]))
               ^
Error:(128, 28) type mismatch;
 found   : Seq[Nothing]
 required: slick.dbio.DBIOAction[?,?,?]
        (projectId, types) <- rawTypes.groupBy(_.projectId).toSeq.map(group => (group._1, group._2.slice(0, 10)))
                           ^

我试图DBIOAction通过 using将第二行包装在 a 中DBIO.successful，这应该将一个常量值提升到DBIOActionmonad 中：

(projectId, types) <- DBIO.successful(rawTypes.groupBy(_.projectId).toSeq.map(group => (group._1, group._2.slice(0, 10))))

但是在这段代码中，types变量被推断为Any，因此代码无法编译。

4

1 回答 1

18

试试这种方式：

val compositeAction = (for {
  rawTypes <- TableQuery[DBType].result
  pair <- DBIO.sequence(rawTypes.groupBy(_.projectId).toSeq.map(group => DBIO.successful(group)))
  counts <- DBIO.sequence(pair.head._2.map(aType => sql"""select count(*) from messages where type_id = ${aType.id}""".as[Int]))
} yield (pair.head._1, pair.head._2.zip(counts))).transactionally
于 2015-07-02T20:29:23.733 回答