使用Node.js调用MongoDB操作

Question

出于组织目的，我将源代码分为多个模块，例如，我在node.js应用程序上有user模块，它负责从MongoDB数据库中检索用户信息。我正在做这样的事情：

var mongo = require("mongodb"),
    Server = mongo.Server,
    Db = mongo.Db;
var server = new Server("localhost", 27017, { auto_reconnect: true });
var db = new Db("users", server);
module.exports = {
    login: function(user, pass, callback) {
        var reg_result = null;
        db.open(function (err, db) {
            if(!err) {
                db.collection("users", function(err, collection) {
                    collection.findOne(
                        {
                            "username": user,
                            "password": pass
                        },
                        function(err, item) {
                            if(!err) {
                                reg_result = item;
                            } else {
                                reg_result = "error";
                            }
                        }
                    );
                });
            } else {
                reg_result = "error";
                console.log("ERROR: " + err);
            }
        });
        callback(reg_result);
    }
}

在我的测试脚本上执行它，如下所示：

var user = require("./user.js");
user.log("test", "test", function(msg) {
    console.log(msg);
});

它执行数据库操作并检索值，但每次只返回null，当我不初始化reg_result变量时，它返回undefined。我应该怎么做才能纠正这个问题？

我在user.js上使用console.log进行调试，并输出了item，但我希望有回调，这样我就可以在其他源上使用该项，比如我的测试脚本

Answer 1

您正在立即调用回调函数，但转到数据库需要时间，因此是异步完成的。相反，请在适当的时候使用作为最后一个参数传递给.findOne()函数的函数的结果参数来调用回调。回调应该得到一个错误参数和一个结果参数：

login: function(user, pass, callback) {
    db.open(function (err, db) {
        if(!err) {
            db.collection("users", function(err, collection) {
                collection.findOne(
                    {
                        "username": user,
                        "password": pass
                    },
                    function(err, item) {
                        if(!err) {
                            callback(null,item);
                        } else {
                            callback("error");
                        }
                    }
                );
            });
        } else {
            callback("error",null);
        }
    });
}

user.login("test", "test", function(err,msg) {
    if( err ) {
      //error occured above;
    } else {
      //success
      console.log(msg);
    }
});

这只是通过mongodb驱动程序使用的相同模式。希望能有所帮助。