Невозможно установить соединение с MongoDB с помощью драйвера MongoDB Scala - PullRequest
Новая
       23

Невозможно установить соединение с MongoDB с помощью драйвера MongoDB Scala

0 голосов
/ 20 апреля 2019

Я использую драйвер Scala для MongoDB, чтобы установить соединение и вставить документ в класс.Я следую за их официальной документацией, как указано в этой ссылке.(http://mongodb.github.io/mongo-scala-driver/2.6/getting-started/quick-tour/)

Я запускаю MongoDB в Windows 10 и автономно не в настройках кластера. Когда я запускаю код Scala, я вижу следующую запись в журнале и ошибку, и ничего не происходит.

Информация журнала: 

373 [main] INFO org.mongodb.driver.cluster - Cluster created with settings {hosts=[localhost:27017], mode=SINGLE, requiredClusterType=UNKNOWN, serverSelectionTimeout='30000 ms', maxWaitQueueSize=500}

510 [main] INFO org.mongodb.driver.cluster - No server chosen by com.mongodb.async.client.ClientSessionHelper$1@702657cc from cluster description ClusterDescription{type=UNKNOWN, connectionMode=SINGLE, serverDescriptions=[ServerDescription{address=localhost:27017, type=UNKNOWN, state=CONNECTING}]}. Waiting for 30000 ms before timing out

Файл Sbt: 

ame := "TestModule"

version := "0.1"

scalaVersion := "2.12.8"

libraryDependencies += "org.apache.kafka" %% "kafka" % "2.1.0"
libraryDependencies += "org.slf4j" % "slf4j-simple" % "1.7.0"
libraryDependencies += "org.mongodb.scala" %% "mongo-scala-driver" % "2.6.0"

Код Scala: 

import org.mongodb.scala._

object MongoDBManager {

  def main(args: Array[String]): Unit ={


    // Making connection with a database made in the MongoDB
    // Use a Connection String
    val mongoClient: MongoClient = MongoClient("mongodb://localhost")

    // Connect with the Database
    val database: MongoDatabase = mongoClient.getDatabase("poc")

    //Get the Collection
    val collection: MongoCollection[Document] = database.getCollection("poc_json")

    //make a sample json document
    val doc: Document = Document("_id" -> 2, "name" -> "MongoDB", "type" -> "database", "count" -> 1)

    // Insert the Document into the MongoDB.

    val observable: Observable[Completed] = collection.insertOne(doc)
    //Explicitly subscribe:
    observable.subscribe(new Observer[Completed] {

      override def onNext(result: Completed): Unit = println("Inserted")

      override def onError(e: Throwable): Unit = println("Failed")

      override def onComplete(): Unit = println("Completed")
    })



  }
}

Кто-нибудь указывает на то, что я делаю неправильно?

...