mongodb - Scala MongoDB : result of query as list

Question

我成功地将数据插入到 mongodb 数据库中，但我不知道如何从查询中提取数据。我使用默认的 scala mongodb 驱动器:

"org.mongodb.scala" %% "mongo-scala-driver" % "1.1.1"

documentation顺便说一句，似乎包含错误。当这是从文档复制粘贴时，此行会引发编译错误:

collection.find().first().printHeadResult()

这是我查询集合的方式:

collection.find()

如何将它转换为我可以迭代和处理的对象的 scala 集合？谢谢

Answer 1

是的，我同意编译错误。我认为“collection.find().first().printHeadResult()”不是 scala 驱动程序 1.1.1 版本的一部分。当前使用此代码的scala驱动github是“1.2.0-SNAPSHOT”版本。

您可以使用以下代码获得结果。但是，您可能会在使用以下代码时遇到一些异步行为。请参阅驱动程序文档。

val observable: FindObservable[Document] = collection.find();
observable.subscribe ( new Observer[Document] {
  override def onNext(result: Document): Unit = println(result.toJson())
  override def onError(e: Throwable): Unit = println("Failed" + e.getMessage)
  override def onComplete(): Unit = println("Completed")
})

Mongo driver Observables link