主页 / 问题 / 1361418
Accepted
devoid
Asked:2022-05-15 23:23:23 +0800 CST2022-05-15 23:23:23 +0800 CST

如何将 Future[Seq[Option[Long]]] 转换为 Long

  • 772

我刚开始使用 Scala，但我无法以任何方式弄清楚。

def setReg(sid: String, reg: String) = {

// Получаю Id из БД
val userId = sidDAO.findUserIdBySid(sid).map(us => us.map(_.userId))

// Вношу изменения по полученному Id
userDAO.updateReg(userId, reg)

}

问题是userId有Future[Seq[Option[Long]]]格式，我需要传Long。如何将其转换为正确的类型？

scala

1 个回答

  1. Best Answer

    简短的回答是您不必这样做。可以立即转移。

    sidDAO.findUserIdBySid(sid).map(us =>
  us.map(u => 
    u.userId.map(id =>
      userDAO.updateReg(id, reg)
    )
  )
)

    但通常我们需要等待一个成功的结果Future。要做到这一点，需要从层和内部Future拉出内部。SeqOption

    a) 您可以使用任一Option从集合中删除。flattenflatMap

    val userIds: Seq[Long] = users.map(_.userId).flatten
val userIds: Seq[Long] = users.flatMap(_.userId)

    b) 浏览收集和处理过程，每个人Future都会对我们有所帮助Future.traverse。

    val updates: Future[Seq[Unit]] = 
  Future.traverse(userIds)(userId => siDAO.updateReg(userId, reg))

    c) 嵌套Future[Future[Long]]的也使用flattenor删除flatMap。

    一起来看看吧：

    sidDAO.findUserIdBySid(sid).flatMap{us =>
  val userIds = us.flatMap(_.userId)

  Future.traverse(userIds)(userId => siDAO.updateReg(userId, reg))
}

    与for语法相同：

    for {
  us <- siDAO.findUserIdBySid(sid)

  userIds = us.flatMap(_.userId)

  _ <- Future.traverse(userIds)(userId => siDAO.updateReg(userId, reg))
} yield ()
    • 1

相关问题