我在 Mongodb 中有以下文档:
{ "index_column" : "site_id", "mapped_column":"site_name"}
我正在使用 scala 代码中的 mongo-scala-driver 来查询服务器。如何将mapped_column 获取到scala 字符串变量？我尝试使用以下代码:
val result = mongocollection.find(equal("index_column", data)).first()
它返回一个org.mongodb.scala.ObservableImplicits$BoxedObservable@207c9b87
是否可以将 Observable 转换为 Iterator？我只需要 scala 字符串变量中的mapped_column 值。
最佳答案
Scala 驱动程序是完全异步的，因此您可以订阅结果。最简单的方法是使用 foreach:
val result = mongocollection.find(equal("index_column", data)).first()
result.foreach { value => ... }
另一种选择是将 Observable 转换为 Future:
Await.result(result.toFuture(), 3 seconds)
关于mongodb-query - mongo-scala-driver:获取结果，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35642580/