Slick update操作在数据库中刷新对象之前返回

问题是你没有考虑内心 Future 由返回 update 方法

签字人: findById :

def findById(id: Long): Future[Option[MyObject]]

代码段:

dao.findById(objectId.get).map { objectOption: Option[MyObject] =>
  dao.update(objectOption.get.copy(processingStep = "third-step"))
}

will给了类型为的对象 Future[Future[Int]] .

你应该改为 flatMap 而不是 map 超过 findById 未来,就像这样:

dao.findById(objectId.get).flatMap { objectOption: Option[MyObject] =>
  dao.update(objectOption.get.copy(processingStep = "third-step"))
}

这将简化为一个单一的未来( Future[Int] ),因此您可以确保仅在插入对象后检索该对象。

此外,您可以将其重写为:

def processObject = {
  for {
    objectId: Option[Long] <- saveObjectInDb

    objectOption <- dao.findById(objectId.get)

    _ <- dao.update(objectOption.get.copy(processingStep = "third-step"))

    mostRecentMyObject <- dao.findById(objectId.get)
  } yield mostRecentMyObject
}

因为,为了理解 <- 是 平面图