使用mongo-scala-driver在Scala中打印来自Mongodb的查询结果

Question

我试图用Scala打印MongoDB查询的结果

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

collection.find().printResults()

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=Connectioning}]}。超时前等待30000毫秒

有什么方法可以在控制台中查看检索到的结果吗？

Answer 1

必须包含helpers.scala文件才能使用printresults()函数。它位于他们的github存储库helpers.scala中。

这些helper函数等待observable完成后才打印值。