4

我正在尝试在 Scala 中打印 MongoDB 查询的结果

val mongoClient: MongoClient = MongoClient()
val database: MongoDatabase = mongoClient.getDatabase("tableScala")
val collection: MongoCollection[Document] = database.getCollection("tableScala")

collection.find().printResults()

抛出的错误是：Cannot resolve symbol printResults。建议使用mongo-scala-driverversion的其他一些问题的答案1.2，因为 printResults() 未针对 version1.1及以下版本实现

SBT 文件：

name := "scalaMongoDriver"

version := "1.0"

scalaVersion := "2.11.8"

libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "1.2.0-beta1"

尝试使用手动打印：

collection.find().subscribe(
      (user: Document) => println(user.toJson()),                         // onNext
      (error: Throwable) => println(s"Query failed: ${error.getMessage}"), // onError
      () => println("Done")                                               // onComplete
    )

导致以下信息：

信息：ReadPreferenceServerSelector{readPreference=primary} 从集群描述 ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]} 中没有选择服务器。在超时前等待 30000 毫秒

有没有办法在控制台中查看检索到的结果？

4

3 回答 3

8

您必须包含Helpers.scala文件才能使用该printResults()功能。它位于他们的 github 存储库Helpers.scala中。

这些辅助函数在打印值之前等待可观察对象完成。

于 2017-02-07T13:44:48.567 回答
2

我今天遇到了同样的问题，但我在网上找到了解决方案。

对我有用的方法是在代码末尾添加一个 Thread.sleep ，因此异步调用后的程序结束有机会打印元素。

发生这种情况是因为 Mongo 的 Observables 的反应性质，这意味着您必须使用 Futures 来完成大部分操作。

只是 Thread.sleep 应该工作。

希望能帮助到你！

于 2017-01-12T01:13:40.443 回答
0

MongoDB 驱动程序是异步的，要使其同步，您可以应用一些 monads 运算符

  1. andThen：允许 Observable 的链接。collect ：将所有结果收集到一个序列中。
  2. flatMap：通过对 Observable 的每个结果应用一个函数来创建一个新的 Observable。
  3. foldLeft：创建一个新的 Observable，其中包含应用的累加器函数的单个结果。foreach ：应用应用于每个发出的结果的函数。
  4. head：返回未来 Observable 的头部。
  5. map：通过对 Observable 的每个发出的结果应用一个函数来创建一个新的 Observable。

可观察的完整列表：

例如：

val doc = Await.result(myCollection
          .find(and(regex("date", s"^${date}T.*"), equal("field", fieldValue)))
          .sort(descending("timestamp"))
          .first().head(), Duration(10, SECONDS))
于 2019-10-31T08:13:55.450 回答