Scala mongodb：查询结果列表

发布时间：2020-12-16 18:34:33 所属栏目：安全来源：网络整理

导读：我成功地将数据插入到 mongodb数据库中,但我不知道如何从查询中提取数据.我使用默认的 scala mongodb驱动器： “org.mongodb.scala” %% “mongo-scala-driver” % “1.1.1” 顺便说一句,documentation似乎包含错误.这行是从文档中复制粘贴时出现编译错误：

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

“org.mongodb.scala” %% “mongo-scala-driver” % “1.1.1”

顺便说一句,documentation似乎包含错误.这行是从文档中复制粘贴时出现编译错误：

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

这是我查询集合的方式：

collection.find()

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

解决方法

是的,我同意编译错误.我认为“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

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!