スリック。選択した行を選択して更新します

Question

いくつかの行を選択して更新し、更新された値を返したいのですが、どのようにSlickで行えるのか分かりません。ここに例があります。

object Test { 

    case class Task(id: Int, status: String) 

    class TaskTable(tag: Tag) extends Table[Task](tag, "tasks") { 
    def id = column[Int]("id") 
    def status = column[String]("status") 

    def * = (id, status) <>(Task.tupled, Task.unapply) 
    } 

    val tasks = TableQuery[TaskTable] 

    def selectWaitingTasksAndChangeStatus(): Seq[Task] = { 
    tasks.filter(_.status === "awaitingExecution").forUpdate 
    // Here I want to change status to "inProgress" and 
    // return tasks to client code with "inProgress" status 
    } 

} 

Answer 1

これはあなたが探しているものです：私は、実行を待っているすべてのタスクを選択し、進行中にそれら、変更ステータスをロックし、更新されたタスクを返すようにしたいですか？

import scala.concurrent.Await 
import scala.concurrent.duration.Duration 

def selectWaitingTasksAndChangeStatus(): Seq[Task] = { 
    val selectAction = tasks.filter(_.status === "inProgress").result 
    val updateAction = tasks.filter(_.status === "awaitingExecution").map(_.status).update("inProgress") 
    val combinedAction = for { 
    tasksBeforeUpdate <- selectAction 
    _     <- updateAction 
    tasksAfterUpdate <- selectAction 
    } yield tasksAfterUpdate.diff(tasksBeforeUpdate) 

    Await.result(db.run(combinedAction.transactionally), Duration.Inf) 
} 

あなたがそのメソッドからSeq[Task]を取得したいのですので、あなたは同期データベースからの結果を待つ必要が。非同期ソリューションでは、返される型としてFuture[Seq[Task]]が必要です。