javascript - NodeJS + Mongoose 等待子查询

Question

我有两个模型:ModelA 和 ModelB，我正在尝试从 ModelB 复制 tags = Array() 列 到 ModelA 中，如下所示:

function run() {

  ModelA.find({}).limit(500).cursor()
    .on('data', function(doc) {
      let refID = doc.ref_id;

      ModelB.findOne({_id: refID}).exec(function(err, modelb) {
        if (err) {
          console.log(`[Error]: Getting modelb ${refID}`);
        }
        if (modelb) {
          if (modelb.tags.length > 0) {
            doc.tags = modelb.tags;
          }
        }
      });

      doc.processed = true;
      doc.save(function(err, hackAlert) {
        if (err) {
          console.log('[Error]: Saving ModelA: ' + err);
        }
        console.log(`Saved: ${doc._id}`);
      });
    })
    .on('error', function(err){
      console.log('[Error]');
    })
    .on('end', function(){
      console.log('Done');
    });
}

该脚本显然使用 processed = true 保存所有 ModelA 实例，但考虑到 Node 的异步特性，ModelA 文档最终没有 >标签。

如果你不知道的话，我是新手。我想知道在保存 ModelA 之前完成 ModelB.findOne() 查询的最佳、现代方式是什么？

Answer 1

您只需移动要在第一个查询的回调中调用的代码即可:

function run() {

  ModelA.find({}).limit(500).cursor()
    .on('data', function(doc) {
      let refID = doc.ref_id;

      ModelB.findOne({_id: refID}).exec(function(err, modelb) {
        if (err) {
          console.log(`[Error]: Getting modelb ${refID}`);
        }
        if (modelb) {
          if (modelb.tags.length > 0) {
            doc.tags = modelb.tags;
          }
        }
        doc.processed = true;
        doc.save(function(err, hackAlert) {
          if (err) {
            console.log('[Error]: Saving ModelA: ' + err);
          }
          console.log(`Saved: ${doc._id}`);
        });
      });
    })
    .on('error', function(err){
      console.log('[Error]');
    })
    .on('end', function(){
      console.log('Done');
    });
}

有关使用 async/await 和 Promises 的最新方法:

async function run () {

  ModelA.find({}).limit(500).cursor()
    .on('data', async function (doc) {
      let refID = doc.ref_id;
      const modelb = await ModelB.findOne({_id: refID}).exec()
        .catch(() => console.log(`[Error]: Getting modelb ${refID}`));

      if (modelb) {
        if (modelb.tags.length > 0) {
          doc.tags = modelb.tags;
        }
      }
      doc.processed = true;
      await doc.save().exec()
        .catch(err => console.log('[Error]: Saving ModelA: ' + err))

      console.log(`Saved: ${doc._id}`);
    })
    .on('error', function (err){
      console.log('[Error]');
    })
    .on('end', function () {
      console.log('Done');
    });
}