MongoDB与Scala语言

Question

我不熟悉MongoDB和Scala语言

我正在使用scala语言在本地连接mongodb

我正在使用下面的依赖项

// https://mvnrepository.com/artifact/org.mongodb.scala/mongo-scala-driver

libraryDependencies=“org.mongodb.scala”%%“mongo scala驱动程序”%%“4.2.3”

我试过的

object Demo extends App {
  
  val mongoClient: MongoClient = MongoClient("mongodb://127.0.0.1:27017/")
  val database: MongoDatabase = mongoClient.getDatabase("DemoDB")
  println(database)

  val collection: MongoCollection[Document] =database.getCollection("demodata");
  val observable = collection.find();
}

上面的代码以下面的格式返回数据

FindObservable(com.mongodb.reactivestreams.client.internal.FindPublisherImpl@6253c26)

我也试过了

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")
})

我还尝试了printResult（）和printHeaderResult（）方法，但都不起作用

请帮忙，谢谢

Answer 1

我找到了这个链接

它适用于printResult（）和PrintHeaderResult（）方法

使用mongo Scala驱动程序从Scala中的Mongodb打印查询结果

Answer 2

Mongo Scala驱动程序以非阻塞方式工作，返回需要被Subsribed才能使用已发布数据的可观测数据。

当你订阅可观察的时，

object Demo extends App {
  
  val mongoClient: MongoClient = MongoClient("mongodb://127.0.0.1:27017/")
  val database: MongoDatabase = mongoClient.getDatabase("DemoDB")
  println(database)

  val collection: MongoCollection[Document] = database.getCollection("demodata")
  val observable = 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")
  })
}

你的代码并不等待可观察的真正发布任何内容，而是在订阅后立即完成。因此你什么也得不到。

你可以添加一个类似的线程。sleep（5000）在最后阻塞并给obeservable一些时间（希望完成并）发布数据。

或者，您可以添加val结果Seq=observable.collect来阻止和收集单个序列中的所有发布数据。