试图把我的头绕在光滑的3API上。
我有这些方法签名:
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]如何才能运行这个简单的示例?
发布于 2015-11-21 13:13:18
事务是DBIO的功能,尝试如下:
val result = dbConfig.db.run(query.transactionally)实际上,有一个从DBIOAction到JdbcActionExtensionMethods的隐式转换,它具有transactionally函数。
https://stackoverflow.com/questions/33843555
复制相似问题