如何在 slick 中使用事务

Question

我有这样的插入方法（权重是索引）

implicit def run[A](action: DBIOAction[A, NoStream, _ <: slick.dbio.Effect]): Future[A] = {
    db.run(action)
  }

def insert(newCategory: CategoryExtractor): Future[Either[String, CategoryResponse]] = {
        category.map(_.weight).max.result.flatMap {
          case Some(weight) =>
            val temp = newCategory.copy(weight = weight+1)
            (category += temp).andThen(DBIO.successful(Right(toCategoryExtractor(temp))))
          case None =>
            val temp = newCategory.copy(weight = 1)
            (category += temp).andThen(DBIO.successful(Right(toCategoryExtractor(temp))))
        }
  }

我称它为 2 次​​p>

insert(CategoryExtractor("1", "name", "scala every where", 0, 0, 0, None)) onComplete {
    case Success(data) => println(data)
  }

insert(CategoryExtractor("2", "name", "haskell every where", 0, 0, 0, None)) onComplete {
    case Success(data) => println(data)
  }

它返回异常（唯一索引）。

如何解决这个问题，我不使用理解或插入第一个 onComplete。只需调用 2 次即可。

谢谢。

Answer 1

这是一个常见的错误 - 将 Future 转换为 early（换句话说，将 db.run(...) 调用为 early）。

您需要做的是删除此方法，因为它（可能有点不直观）弊大于利：

implicit def run[A](action: DBIOAction[A, NoStream, _ <: slick.dbio.Effect]): Future[A] = {
    db.run(action)
  }

经验法则基本上是您通常希望严格控制您的实际数据库交互（和事务边界），因此我建议不要在该领域使用任何类型的implicits。毕竟它是这个库背后的驱动思想之一 - Slick 试图在应用程序和 db 之间的交互中非常明确（与经典 ORM 相反 - 其中使用访问器可能实际上触发了对 db 的延迟调用或通过 mutator 设置值可能会导致实际的数据库更新）。

那你需要把返回类型改成这个（把Future改成DBIO）：

def insert(newCategory: CategoryExtractor): DBIO[Either[String, CategoryResponse]] = {
...
  }

比你这样做：

val firstInsert = insert(CategoryExtractor("1", "name", "scala every where", 0, 0, 0, None)) map {
    data => println(data)
}

val secondInsert = insert(CategoryExtractor("2", "name", "haskell every where", 0, 0, 0, None)) map {
    data => println(data)
}

db.run(DBIO.seq(firstInsert, secondInsert).transactionally))

基本上事情是：一旦你将DBIO 转换为Future，你就失去了将动作捆绑到单个事务中的能力。所以你基本上可以使用不同的 DBIO 转换来做所有事情（通常的东西：map、flatMap、seq 等），并且仅作为您触发 db.run(yourComposedDbio.transactionally) 的最后一步。

编辑： 以下是我几周前的演示文稿中有关处理交易和DBIO 组合的更多信息。相关幻灯片：http://slides.com/pdolega/slick-101#/85（以及更多）。

Dave Gurnell 还举办了一个很棒的研讨会，他在 01:05:00 左右谈到了这个问题（链接在这里：https://vimeo.com/148074461）