0

MongoDB と Scala 言語は初めてです

私はscala言語を使用してmongodbをローカルに接続しています

以下の依存関係を使用しています

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

libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "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()、printHeadResult()方法はどれも機能していません

事前に感謝を助けてください

4

2 に答える 2

0

このリンクを見つけました

printResult() および printHeadResult() メソッドで機能します

mongo-scala-driver を使用して Scala で Mongodb からのクエリ結果を出力する

于 2021-05-29T08:26:58.947 に答える