未对mongoose架构对象调用save（）回调

Question

我试图在我的数据库中保存一个json对象。未调用save（）函数，但从未保存json对象。帮我解决这个问题。我想这是猫鼬的连接问题。这是我的密码。。

    var config = require('../config');
    var user = require('../user');
api.post('/addUser',function(req,res) {
    var userID;
    //creating a sample user under Model collection User.. so this becomes a document!!
    console.log("addition of new user api hit!!");
    //sending a query to retrieve the no of users served
    MongoClient.connect(dbURL, function (err, db) {
        var UserCountCursor = db.collection("ourusers").find({"docName": "userCount"}).limit(1);

        UserCountCursor.each(function (err, doc) {
            if (err)
                console.log("did not get the count");
            else
            // var countString= JSON.stringify(doc);
            //var docJson=JSON.parse(countString);
                console.log("the json content is:" + doc.iparkoUserCount);

            //increase the user count by 1 in the db.
            var incCount = parseInt(doc.iparkoUserCount) + 1;
            console.log("no of userrs:" + incCount);
            // making an userId
            userID = "ipkoID_C" + incCount.toString();
            //updating using MOngoClient
            db.collection("ourusers").update({"docName": "userCount"}, {$set: {"iparkoUserCount": incCount}});
            console.log("the user count in the db has been updated!!");
            console.log("generated id for this guy is:" + userID);

            if (userID != null) {
                console.log("calling the save function");
                //closing the mongoclient connection
                db.close();
                signUpUser(userID);
            }
        });
    });


    function signUpUser(userIDD) {
        var me = new user({
            name: req.body.new_name,
            password: req.body.new_pswd,
            username: req.body.new_username,
            phno: req.body.new_phn,
            userId: userIDD
        });

        console.log("the obj ::" + JSON.stringify(me));
        console.log("obj created and ready to be stored");
//connecting to the db using mongoose
        mongoose.connect(config.database, function (err) {
            if (err)
                console.log("The error is :"+err);
            else {
                console.log("WE ARE CONNECTED USING MONGOOSE");
                //saving the sample user document
                me.save(function (err) {
                    console.log("in the save func");
                    if (err) throw err;
                    else {
                        console.log('User saved Successfully!!!!!');
                        res.json({
                            'whatStatus': 'user saved in the database!!',
                            'userID': userIDD
                        });
                        mongoose.connection.close();
                    }
                });
            }
        });
    }
});

我的控制台日志：：

新增用户api命中！！json的内容是： 143没有userrs： 144 db中的用户计数已更新！！这个人生成的id是：ipkoID_C144调用保存函数obj::{"name"："Abhi"，"密码"："jio"，"username"："abhijio"，"phno"："45142545"，"userId"："ipkoID_C144"，"_id"："583295bfa0f9f8342035d3b9"}obj创建并准备存储C：\用户##########################################################################################################################################################################################

TypeError：无法读取属性'iparkoUserCount'的空在C：\用户\shivenra\WebstormProjects\iParko\路由\注册ParkingLots.js:76： 57在HandleCallback（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\lib\utils.js:96： 12）在C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\lib\cursor.js:742： 16 at handleCallback（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\lib\utils.js:96： 12）at C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\lib\cursor.js:676： 5 at handleCallback（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\node_modules\mongob-core\lib\cursor.js:156： 5）在setCursorDeadAndNotify（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\node_modules\mongob-core\lib\cursor.js:496： 3）在nextFunction（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\node_modules\mongob-core\lib\cursor.js:588： 12）在Cursor.next[作为_next]（C：\用户\希文德拉\WebstormProjects\iParko\node_modules\mongodb\node_modules\mongodb-core\lib\cursor.js:681： 3）在下一个对象（C：\用户\希文德拉\WebstormProjects\iParko\node_modules\mongob\lib\cursor.js:673： 8）在Cursor.next（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongodb\lib\cursor.js:262： 12）在_each（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongodb\lib\cursor.js:738： 10）在C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongodb\lib\cursor.js:746： 7在HandleCallback（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongodb\lib\utils.js:96： 12）在C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\lib\cursor.js:676： 5在HandleCallback（C：\用户\shivenra\WebstormProjects\iParko\node_modules\mongob\node_modules\mongob-core\lib\cursor.js:156： 5）

退出代码1的过程结束

Answer 1

在UserCountCursor中。每个（…） 循环，在检查err之后，还应该检查doc。那么你有这个：

UserCountCursor.each(function (err, doc) {
   if (err)
     console.log("did not get the count");
   else 

     // var countString= JSON.stringify(doc);

     //...

})

改为这样做：

UserCountCursor.each(function (err, doc) {
   if (err){
     console.log("did not get the count");
   }else if(doc){ 

     // var countString= JSON.stringify(doc);

     //...

   }

})

然后，您将避免无法读取属性'iparkoUserCount'的null错误，并进入save（）函数。

Answer 2

您似乎打开了两次db连接，一次使用mongoose.connect，另一次使用mongoose.connection.open（）。这就是为什么你会出错。

尝试使用这个只有一个连接，如下所示。

mongoose.connect(config.database, function(err, db) {
            //var dbcon=mongoose.connection.open();

            //dbcon.on('error',function(){console.log('connction error:')});
            //dbcon.once('open',function(){
   if(err) {
      console.log(err);
   } else {
                console.log("WE ARE CONNECTED USING MONGOOSE");
                //saving the sample user document
                me.save(function (err) {
                    console.log("in the save func");
                    if (err) throw err;
                    else {
                        console.log('User saved Successfully!!!!!');
                        res.json({
                            'whatStatus': 'user saved in the database!!',
                            'userID': userIDD
                        });
                        //mongoose.connection.close();
                    }
                });
          }
    });