如何从 find 方法返回 Mongoose 结果？

Question

我能找到的所有内容都可以用来渲染带有猫鼬结果的页面：

users.find({}, function(err, docs){
    res.render('profile/profile', {
        users:     docs
    });
});

我怎样才能从查询中返回结果，更像这样？

var a_users = users.find({}); //non-working example

这样我就可以在页面上发布多个结果？

喜欢：

/* non working example */
var a_users    = users.find({});
var a_articles = articles.find({});

res.render('profile/profile', {
      users:    a_users
    , articles: a_articles
});

这个可以吗？

Answer 1

简单的方法：

var userModel = mongoose.model('users');
var articleModel = mongoose.model('articles');
userModel.find({}, function (err, db_users) {
  if(err) {/*error!!!*/}
  articleModel.find({}, function (err, db_articles) {
    if(err) {/*error!!!*/}
    res.render('profile/profile', {
       users: db_users,
       articles: db_articles
    });
  });
});

实际上，Node.js 中的每个函数都是异步的。猫鼬的发现也是如此。如果你想连续调用它，你应该使用Slide library 之类的东西。

但在您的情况下，我认为最简单的方法是嵌套回调（这允许 f.e. 为选定的先前用户查询文章）或在异步库的帮助下完全并行（参见 Flow control / Async goodies）。

Answer 2

您正在尝试强制使用同步范式。就是行不通。 node.js 在大多数情况下是单线程的——当 io 完成时，会产生执行上下文。信令通过回调进行管理。这意味着您要么拥有嵌套回调、命名函数或流控制库，以使事情看起来更漂亮。

https://github.com/caolan/async#parallel

async.parallel([
   function(cb){
      users.find({}, cb);
   },
   function(cb){
      articles.find({}, cb);
   }
], function(results){
   // results contains both users and articles
});

Answer 3

我有一个函数，我经常使用它作为对 Node 函数的返回。

function freturn (value, callback){
    if(callback){
        return callback(value); 
    }
    return value; 
}; 

然后我在所有签名中都有一个可选的回调参数。

Answer 4

我正在处理一个非常相似的事情，但使用来自客户端的 socket.io 和 DB 访问。我的发现是在数据库有机会获取数据之前将我的数据库内容扔回客户端......所以我将在这里分享我的发现：

我检索数据库的函数：

//读板-完整的DB

var readBoards = function() {
        var callback = function() {
            return function(error, data) {
                if(error) {
                    console.log("Error: " + error);
                }
                console.log("Boards from Server (fct): " + data);

            }
        };

        return boards.find({}, callback());
    };

我的套接字事件监听器：

socket.on('getBoards', function() {
        var query = dbConnection.readBoards();
        var promise = query.exec();
        promise.addBack(function (err, boards) {
            if(err)
                console.log("Error: " + err);
            socket.emit('onGetBoards', boards);
        });
    });

所以为了解决这个问题，我们使用猫鼬给我们的承诺，然后一旦我们从数据库接收到数据，我的套接字就会将它发送回客户端......

为了它的价值......

Answer 5

我将在这里扮演死灵法师，因为我仍然看到另一种更好的方法。

使用美妙的 promise 库 Bluebird 及其 promisifyAll() 方法：

var Promise = require('bluebird');
var mongoose = require('mongoose');

Promise.promisifyAll(mongoose); // key part - promisification

var users, articles; // load mongoose models "users" and "articles" here

Promise.props({
    users: users.find().execAsync(),
    articles: articles.find().execAsync()
  })
  .then(function(results) {
    res.render('profile/profile', results);
  })
  .catch(function(err) {
    res.send(500); // oops - we're even handling errors!
  });

关键部分如下：

Promise.promisifyAll(mongoose);

使所有 mongoose（及其模型）方法可用作返回 Promise 的函数，带有 Async 后缀（.exec() 变为 .execAsync()，等等）。 .promisifyAll() 方法在 Node.JS 世界中几乎是通用的——你可以在任何提供异步函数的东西上使用它，将回调作为最后一个参数。

Promise.props({
    users: users.find().execAsync(),
    articles: articles.find().execAsync()
  })

.props() bluebird 方法接收带有 Promise 作为其属性的对象，并返回集体 Promise，当两个数据库查询（此处为 Promise）返回其结果时，该 Promise 将得到解决。解析出来的值就是我们在最终函数中的results对象：

• results.users - 由猫鼬在数据库中找到的用户
• results.articles - mongoose (d'uh) 在数据库中找到的文章

如您所见，我们甚至还没有接近缩进回调地狱。两个数据库查询是并行执行的——其中一个不需要等待另一个。代码简短易读 - 实际上在长度和复杂性（或者说缺乏它）上与问题本身中发布的一厢情愿的“非工作示例”相对应。

承诺很酷。使用它们。

Answer 6

您可以通过以下代码获得所需的结果。希望这会对你有所帮助。

var async = require('async');

// custom imports
var User = require('../models/user');
var Article = require('../models/article');

var List1Objects = User.find({});
var List2Objects = Article.find({});
var resourcesStack = {
    usersList: List1Objects.exec.bind(List1Objects),
    articlesList: List2Objects.exec.bind(List2Objects),
};

async.parallel(resourcesStack, function (error, resultSet){
    if (error) {
        res.status(500).send(error);
        return;
    }
    res.render('home', resultSet);
});