2016-12-15 6 views
1

Node.js、Express、およびMongodbでREST APIを構築しようとしています。私は、データベースに接続するためのMongoDB NPMパッケージを使用しています、以下の私のsever.jsファイルコードMongoError:トポロジが破棄されました(ドキュメントを見つけるとき)、インスタンスプールが破棄されました(ドキュメントを挿入するとき)

var express = require("express"); 
var app = express(); 
var bodyParser = require("body-parser"); 
var port = process.env.PORT || 8080; 
var mongo = require("mongodb"); 
var Server = mongo.Server; 
var Db = mongo.Db; 
var ObjectID = mongo.ObjectID; 
try{  
    var config = require('./configure.js'); 
}catch(e){ 
    console.log("configuration file is hidden on github for security"); 
    config = null; 
} 
var usersCollection = config.usersCollection; 
var login = require('./routes/login/index.js'); 
var signup = require('./routes/signup/index.js'); 
var Database = new Db(process.env.DBNAME || config.DBNAME , new Server(process.env.DBHOST || config.DBHOST, process.env.DBPORT || config.DBPORT, {'native_parser': true})); 


Database.open(function (err, mongoclient) { 
     if(err){ 
      console.log("Failed to connect to the database. Please Check the connection"); 
      throw err; 
     }else{ 
      Database.authenticate(process.env.DBUSER || config.DBUSER, process.env.DBPASS || config.DBPASS, function(err, res) { 
       if (err) { 
        console.log("Authentication Failed"); 
        throw err; 
       }else{ 
        console.log("Connected to the database Successfully"); 
        app.use(bodyParser.urlencoded({ extended: true })); 
        app.use(bodyParser.json()); 
        var users = Database.collection(usersCollection); 
        login(app,users); 
        signup(app,users); 

        Database.close(); 
       } 
      }); 
     } 
    }); 

app.listen(port,function(){ 
    console.log("Server Started Listening to port : "+port); 
}); 

ルート/ログイン/ index.js

module.exports = function(app,users){ 
app.route('/login') 
    .post(function(req,res){ 
     var username = req.body.username; 
     var password = req.body.password; 
     var query = {'FirstName':username}; 

     users.find().toArray(function(err,docs){ 
      if(err){ 
       throw err; 
      }else{ 
       console.log("no err"); 
       if(doc.LastName == password){ 
        res.send({status : true}); 
       }else{ 
        res.send({status : false}); 
       } 
      } 
     }); 
    }); 

}

とルート/あります申し込み/ index.js

module.exports = function(app,users){ 
app.route('/signup') 
    .post(function(req,res){ 
     var doc = { EmpNo:"1", 
        FirstName:"Andrew", 
        LastName:"Neil", 
        Age:"30", 
        Gender:"Male", 
        Skill:"MongoDB", 
        Phone:"408-1234567", 
        Email:"[email protected]", 
        Salary:"80000" 
     }; 

     users.insert(doc,function(err,info){ 
      if(err){ 
       throw err; 
      }else{ 
       console.log('Successfully inserted ' + JSON.stringify(info)); 
       res.send({result: 'done'}); 
      } 
     }); 
    }); 

}

私はserver.jsに文書を挿入しようとしていますが、それらを挿入することはできますが、route/signup/index.jsを使っても可能です。サーバで文書を検索しようとすると、 .jsエラーはありませんが、routes/login/index.jsから実行しようとすると、トポロジが破棄されてエラーが発生します。

解決には援助が必要です。

答えて

1

プロセスの途中で接続が切断された場合は、これらのエラーがスローされます。

users.find()users.insert()の両方の関数が非同期であるため、server.jsファイルはDatabase.close()関数に達し、処理が完了してエラーが発生する前にデータベースへの接続が閉じられます。

+0

私はポイントを得た、私はDatabase.close()ステートメントを削除し、それは正常に動作しています。ありがとうございました。 –

関連する問題