node.js - 不嵌套多次用Mongoose查询

Question

我正在尝试使用 node.js 生成一个文档，该文档需要从 mongo 数据库运行多个不相关的数据库查询。

这是我当前的代码:

Data.find({}, function(err, results) {
  if (err) return next(err);
  //finished getting data
    res.render('page');
  }
}

问题是，如果我尝试运行另一个查询，我似乎必须将它嵌套在第一个查询中，以便它在开始之前等待第一个查询完成，然后我必须将 res.render() 放在其中最里面的嵌套查询(如果我不这样做，res.render() 将在数据库完成抓取数据之前被调用，并且它不会随页面一起呈现)。

我必须做的:

Data.find({}, function(err, results) {
  if (err) return next(err);
  //finished getting data

    Data2.find({}, function(err, results2) {
      if (err) return next(err);
      //finished getting data 2
        res.render('page');
      }
    }
  }
}

我将有 2 个以上的查询，所以如果我继续嵌套它们，它很快就会变得非常困惑。是否有更简洁的方法来执行此操作，例如让代码等待所有数据返回并运行函数，然后再继续执行脚本？

Answer 1

对于 Mongoose ，你可能只需要做一个 Promise.all()并使用 .concat()在每个查询的结果数组上。

作为一个完整的演示:

var async = require('async'),
  mongoose = require('mongoose'),
  Schema = mongoose.Schema;

var d1Schema = new Schema({ "name": String });
var Data1 = mongoose.model("Data1", d1Schema);

var d2Schema = new Schema({ "title": String });
var Data2 = mongoose.model("Data2", d2Schema);

mongoose.set('debug',true);
mongoose.connect('mongodb://localhost/test');

async.series(
  [
    // Clean
    function(callback) {
      async.each([Data1,Data2],function(model,callback) {
        model.remove({},callback)
      },callback);
    },
    // Setup some data
    function(callback) {
      async.each([
        { "name": "Bill", "model": "Data1" },
        { "title": "Something", "model": "Data2" }
      ],function(data,callback) {
        var model = data.model;
        delete data.model;
        mongoose.model(model).create(data,callback);
      },callback);
    },
    // Actual Promise.all demo
    function(callback) {
      Promise.all([
        Data1.find().exec(),
        Data2.find().exec()
      ]).then(function(result) {
        console.log([].concat.apply([],result));
        callback()
      }).catch(callback);
    }
  ],
  function(err) {
    if (err) throw err;
    mongoose.disconnect();
  }
)

我只是在混入 async这里只是为了简单起见，但它的核心在于:

  Promise.all([
    Data1.find().exec(),
    Data2.find().exec()
  ]).then(function(result) {
    console.log([].concat.apply([],result));
  })

Promise.all() 基本上等待并组合两个结果，这里是“数组的数组”，但 .concat() 需要照顾那个。结果将是:

[ 
  { _id: 59420fd33d48fa0a490247c8, name: 'Bill', __v: 0 },
  { _id: 59420fd43d48fa0a490247c9, title: 'Something', __v: 0 }
]

显示每个集合中的对象，并在一个数组中连接在一起。

您还可以使用 async.concat方法作为替代方法，但除非您已经在使用该库，否则最好坚持 promise 。