为什么mongodb find()从来没有得到我的回调

Question

我正在尝试使用mongodb(使用mogoose)和node.js使用restify构建类似rest的API.我是mongo世界的绝对新手,我不确定问题出在哪里.这是数据库连接的问题,还是其他什么？

所以,我这样做: rest-server.js

//start server
var restify = require('restify');
var server = restify.createServer();
server.use(restify.bodyParser());

//connect db
var config = require('./Config.js');
var mongoose = require('mongoose'),   
db = mongoose.createConnection('localhost', 'travelers'),
Schema = mongoose.Schema,
ObjectId = mongoose.SchemaTypes.ObjectId;

db.on('error', console.error.bind(console, 'DB connection error:'));
db.once('open', function callback() {
    console.log('db connection open');
});

var LoginModel = require('./models/LoginModel.js').make(Schema, mongoose);
var LoginResource = require('./resource/LoginResource.js')(server, LoginModel);

LoginModel.js

function make(Schema, mongoose) {
    var LoginSchema = new Schema({
        //id: (?)
        username: String,
        password: String,
        traveler_id: Number,
        contact_id: Number,
        last_login: Date,
        token: String
});
    return mongoose.model('Login', LoginSchema);
}

module.exports.make = make;

LoginResource.js

exports = module.exports = function (server, LoginModel) {
    var LoginRepository = require('../repository/LoginRepository.js');

    server.get('/login/:username/:password', function (req, res, next) {    
        LoginRepository.getLogin(req, res, next, LoginModel);
    });
}

LoginRepository.js

function getLogin(req, res, next, LoginModel) {
    var query = LoginModel.find({ username: req.params.username, password: req.params.password});

    query.exec(function (err, docs) {
        console.log('got it!');
        res.send(docs);
    });
}

测试查询 curl localhost:8080/login/qqq/www

所以我从来没有res.send(docs); 实际上,我没有添加任何东西到数据库.我只是想知道查询没有找到任何东西.

更新: 我不明白为什么,但如果我更改这样的数据库连接代码,这个问题可以解决:

//connect db
var config = require('./Config.js');
var mongoose = require('mongoose/');
db = mongoose.connect(config.creds.mongoose_auth),
Schema = mongoose.Schema;

(使用mongoose.connect并将db和Schema变量定义为全局)

但在这种情况下,db.on()和db.once()会抛出异常"没有这样的方法".

换句话说 - 问题嗯......解决但我仍然不知道为什么.这看起来像一个有用的链接:github上的server.js示例

Answer 1

您mongoose.model()在执行查询时通过调用创建的模型使用Mongoose的默认连接池.默认连接池是通过调用创建的mongoose.connect(),使用创建的模型进行的任何查询都将排队,直到您调用它并完成为止.

你也可以db = mongoose.createConnection()像你原来那样通过调用创建单独的连接池(可以拥有自己的模型!),但你必须为它创建模型,db.model()这就是为什么事情本来不适合你的原因.