Future 上的惰性验证是否会阻止实际的数据库调用？

Question

我想进行这样的查询：

1. 查询特定日期的记录；
2. 如果 (1) 失败，则查询某个日期范围内的记录，取最后一个日期。

我现在的处理方式是：

lazy val specific: Future[Option[QueryResponse]] = // some database call

lazy val range: Future[Option[QueryResponse]] = 
  // some database call returning Future[Seq[QueryResponse]]
  .map { qrs =>
    if (qrs.nonEmpty) Some(qrs.maxBy(_.date)(_ compareTo _))
    else None
  }

for {
  s <- specific  
  r <- range
} yield {
 (s, r) // match on combination of Some/None
}

两个问题：

1. 惰性会阻止评估数据库调用吗？我希望尽可能少地拨打电话。这与其他任何问题一样都是语言问题。
2. 认识到无论如何都必须进行 1 次数据库调用，最好对一个范围进行调用，然后在 POJO 上进行本地过滤以查找最新日期，对吗？

Answer 1

就目前而言，您的代码将同时执行specific 和range，尽管它们很懒惰。考虑以下简化的 sn-p

  lazy val specific = Future(Some("specific"))
  lazy val range = Future(Some("range"))

  (for {
    s <- specific
    r <- range
  } yield {
    (s, r)
  }).foreach(println)

哪个输出

(Some(specific),Some(range))

我们看到两者都被执行了。理解的性质意味着尽管被宣布为懒惰，但他们俩都跑了。如果您希望 range 仅在 specific 没有返回结果时执行，请考虑这样做

specific.flatMap {
    case Some(v) => Future(Some(v), None)
    case _ => range.map {
      case Some(v) => (None, Some(v))
      case _ => (None, None)
    }
  }.foreach(println)

哪个输出

(Some(specific),None)

我们看到range 的地方没有运行。

Scalaz 将问题简化为

import scalaz._
import scalaz.std.scalaFuture.futureInstance

OptionT(specific).orElse(OptionT(range)).map(println)

哪个输出

specific

这意味着range 没有运行。