как удалить MongoInternalException?

Question

Я пытаюсь выполнить операции CRUd в mongodb и scala .. Я написал следующий код. Этот код успешно компилируется, но дает исключение времени выполнения. Я использую scala 2.8.Может ли что-нибудь мне помочь?

Ошибка при выполнении:

Исключение в потоке "main" com.mongodb.MongoInternalException: DBPort.findOne не удалось на com.mongodb.DBPort.findOne (DBPort.java:153) на com.mongodb.DBPort.runCommand (DBPort.java:159) на com.mongodb.DBTCPConnector.testMaster (DBTCPConnector.java:369) на com.mongodb.Mongo. (Mongo.java:140) на com.mongodb.Mongo. (Mongo.java:124) на com.mongodb.Mongo. (Mongo.java:81) на QuickTour.main (QuickTour.java:16) Причины: java.io.IOException: не удалось подключиться к [/127.0.0.1:8005] bc: java.net.ConnectException: соединение отказано: соединение на com.mongodb.DBPort._open (DBPort.java:205) на com.mongodb.DBPort.go (DBPort.java:85) на com.mongodb.DBPort.findOne (DBPort.java:145) ... еще 6

// crud.scala

import com.mongodb.BasicDBObject;
import com.mongodb.DB;
import com.mongodb.DBCollection;
import com.mongodb.DBCursor;
import com.mongodb.Mongo;

object crud
{
  def main(args:Array[String])
  {
    while(true)
    {
      println("")
      println("1.Insert ")
      println("2. Retriever ")
      println("3. Update")
      println("4. Delete")
      println("5. Exit")
      println("")
      println("Enter choice : ")

      val ch=Console.readInt

      ch match
      {
        case 1=>
          insert();
        case 2=>
          retrieve() ;
        case 3=>
          update();
        case 4=>
          delete();
        case 5=>
          System.exit(0)
      }
    }
  } //main

  def insert()
  {
    println("Enter the rollno")
    var roll=Console.readInt

    println("Enter the name")
    var name=Console.readLine

    println("Enter the age")
    var age=Console.readInt

    println("Enter the city")
    var city=Console.readLine

    println("Enter the marks")
    var marks=Console.readInt

    val mongo = new Mongo();

    var databaseName = mongo.getDB("mydb")
    var collectionName = databaseName.getCollection("student")
    val dbObject = new BasicDBObject()
    dbObject.put("rollno", "roll")
    dbObject.put("name", "name")
    dbObject.put("age", "age")        
    dbObject.put("city", "city")        
    collectionName.insert(dbObject);
    println("Inserted succesfully");
  }

  def retrieve()
  {
    println("Enter the rollno")
    var r=Console.readInt
    val mongo = new Mongo()

    var databaseName = mongo.getDB("mydb")
    var collectionName = databaseName.getCollection("student")

    val query=new BasicDBObject();
    val query1=new BasicDBObject();
    query.put("marks",new BasicDBObject("$gt","70"));
    var cursor = new DBCursor(collectionName,query,query1)
    println("The list of students is")
    while(cursor.hasNext)
    {
      println(cursor.next());
    }
  } //retrieve

  def update()
  {
    println("Enter the rollno of student to be updated")
    var no=Console.readInt

    val mongo = new Mongo()

    var databaseName = mongo.getDB("mydb")
    var collectionName = databaseName.getCollection("student")
    val query=new BasicDBObject();
    val query1=new BasicDBObject();
    query.put("rollno",new BasicDBObject("$eq",no));
    var cursor = new DBCursor(collectionName,query,query1)
  }

  def delete()
  {
    println("Enter the rollno of student to be deleted")
    var no=Console.readInt

    val mongo = new Mongo()
    var databaseName = mongo.getDB("mydb")
    var collectionName = databaseName.getCollection("student")
    val query=new BasicDBObject();
    val query1=new BasicDBObject();
    query.put("rollno",new BasicDBObject("$eq",no));
    var cursor = new DBCursor(collectionName,query,query1)

    while(cursor.hasNext)
    {
      collectionName.remove(cursor.next())
    }
  } //delete
}

Answer 1

Ошибка говорит о том, что «не удалось подключиться к [/127.0.0.1:8005]», вы можете начать с проверки того, что MongoDB запущен и работает на этом порту.Стандартный порт MongoDB - 27017.