检查请求是否返回到数据库

Question

我有一个查询数据库的方法。 我想明白。如何检查表中是否有符合我条件的行？

def getMessage() = {
  val query = messages.filter(_.status === true)
  val action = query.result.head
  val result = db.run(action)
  //val sql = action.statements.head
  val temp = result.map(_.phone)
  Thread.sleep(3000)
  println(temp.toString)
 }

例如，我需要一个关于该方法如何工作的示例逻辑。

    def getMessage():String = {
     val query = messages.filter(_.status === true)
     val action = query.result.head
     val result = db.run(action)
     //val sql = action.statements.head
     val temp = result.map(_.phone)
     Thread.sleep(3000)
     
     if (temp != "null") return temp
     else return "null"
 }

Answer 1

db.run 返回一个Future，因此您需要在完成时检查结果：

db.run(action).onComplete{
  case Success(res) =>
    // Process result in res
  case Failure(e) =>
    // Handle error case
}

您永远不应该Sleep 或等待Future，所以getMessage 应该返回Future[String] 并且调用代码可以在它准备好时处理结果。

def getMessage(): Future[String] = {
 val query = messages.filter(_.status === true)
 val action = query.result.head
 
 db.run(action)
}

更一般地，您需要查看Future 的工作原理以及如何修改结果 (map)、链接多个 Futures (flatMap) 或将多个 Futures 作为单个 @ 处理987654334@(Future.sequence)。

一般来说，您应该尽可能长时间地在Future 中进行处理。