如何在 Foreach 中同步运行 Mongoose Find

Question

我有一个集合“Case”的查询，对于每条记录，我需要匹配另一个集合“CustomerAgreement”。 所以我正在使用 forEach 并在其中调用第二个查询。问题是查询在 forEach 结束后运行。

假设有 5 个案例。

Case.find({},{case_id:1}).then(recs=>{
     recs.forEach(function(rec){
         console.log("x");
         CustomerAgreement.findOne({case_id:rec.case_id}).then(t=>{
             console.log("y");
         });
     });

     console.log("z");
});

我得到的结果是（假设有 5 个案例） X X X X X z 是的 是的 是的 是的 是的

我想要的结果是 X 是的 X 是的 X 是的 X 是的 X 是的 z

Answer 1

如果你能够使用 async / await 你可以使用 for of 循环

const recs = await Case.find({}, {case_id: 1});

for (const rec of recs) {
  console.log("x");

  const t = await CustomerAgreement.findOne({ case_id: rec.case_id }).exec();
  console.log("y");
}

console.log("z");

如果没有，您可以使用async，这是一个允许您执行此类操作的库。

Case.find({}, { case_id: 1 }).then((recs) => {
  async.each(recs, (rec, callback) => {
    console.log("x");
    CustomerAgreement.findOne({ case_id : rec.case_id }).then((t) => {
      console.log("y");
      callback();
    });
  }, (err) => {
    if (err) {
      console.log(err);
    } else {
      console.log('all records found successfully');
      console.log("z");
    }
  });
});

PD：我没有测试上面的代码，但理论上应该可以工作。

Answer 2

您可以在循环中使用 async 函数和 await 每个查询：

Case
  .find({}, { case_id: 1 })
  .then(async (recs) => {

    for (const rec of recs) {
      console.log("x");

      const t = await CustomerAgreement
        .findOne({ case_id: rec.case_id })
        .exec();

      console.log("y");
    }

    console.log("z");
  });

我希望这会有所帮助。