2016-12-15 47 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中的文件,我能夠插入他們成功,但通過路線/註冊/ index.js我收到實例池被銷燬類似如果我試圖找到文件在服務器.js沒有錯誤,但如果我嘗試從路由/登錄/ index.js做到這一點,然後我得到錯誤,因爲拓撲被破壞。

需要幫助來解決它。

回答

1

如果連接在進程中間以某種方式切斷,則會引發這些錯誤。

因爲users.find()users.insert()函數是異步的,您的server.js文件到達Database.close()函數,並在完成過程之前關閉與數據庫的連接,從而產生錯誤。

+0

我明白了,我刪除了Database.close()語句,它工作正常。謝謝。 –