Slick 3 交易如何

Question

试图用光滑的 3 api 来解决我的问题。

我有这些方法签名：

  def findById(id: Long): DBIO[Option[Project]] =
Projects.filter(_.id === id).result.headOption

  def insert(Task: Task): DBIO[Long] =
Tasks returning Tasks.map(_.id) += Task

我想在我的控制器中的单个事务中运行。

我的代码目前看起来像这样并且不是事务性的：

def addTaskToProject(taskName: String, projectId: Long) = Action.async { implicit rs =>

  val query = for {
    Some(project) <-  projectDAO.findById(projectId)
    id <- taskDAO.insert(Task(0, "blue", project.id))
  }yield id

  val result = dbConfig.db.run(query)

  result.map{ taskId =>
    Ok("I have created a new task: " + taskId)
  }
}

1) 我试着这样做：

val result = dbConfig.db.run(query).transactionally

但这给了我这个错误：

... value transactionally is not a member of scala.concurrent.Future[Long]

2）然后我尝试了这个：

val result = dbConfig.db.run(query.transactionally)

得到了这个错误：

... value transactionally is not a member of slick.dbio.DBIOAction[Long,slick.dbio.NoStream,slick.dbio.Effect.All with slick.dbio.Effect.All]

我怎样才能让这个简单的例子运行？

Answer 1

事务性是 DBIO 的功能， 试试这个：

val result = dbConfig.db.run(query.transactionally)

附：实际上有一个从 DBIOAction 到 JdbcActionExtensionMethods 的隐式转换，它具有 transactionally 函数