使用 mongoDB 调用/node.js 的 Foreach 循环

debugcn 发表于 Dev

cs家伙

  result.forEach(element => {
    //Get each element
    console.log("LOOP");
    dbo.collection("users").findOne({email: emailGiven, "friends.email": element.email},function(errT, resultT) {
      if (errT){
        console.log("Query Error Inside!");
        res.status(errT.status); // or use err.statusCode instead 
        console.log(errT);
        //db.close();
        //return res.send(errT.message);
      }
      else {
        if (resultT) {
          var oneUser = {
            email: element.email,
            username: element.username,
            fullName: element.fullName,
            status: resultT
          };
          //console.log(resultT);
          foundUsers.push(oneUser);
        } else {
          //Not found means not added or pending
          var oneUser = {
            email: element.email,
            username: element.username,
            fullName: element.fullName,
            status: 0
          };
          foundUsers.push(oneUser);
          //console.log(emailGiven +  " " + element.email)
          console.log(oneUser);                  
        }
      }
    });
  });

我为每个元素都有一个对象数组我想为每个元素调用 mongoDB 并根据结果我想像我一样将结果推送到数组中，问题是 mongoDb 是异步的，所以我的主线程在我可以之前完成将结果推送到数组 foundUsers，我该如何解决这个问题？

佩兹曼·帕萨伊

正如你所说，需要将异步操作处理成同步循环。为此，您可以使用异步库。它在这样的操作中非常有用。

只需先在您的项目中安装 async 模块 npm install --save async

之后，你可以这样做：

// for use with Node-style callbacks...
var async = require("async");

var obj = {dev: "/dev.json", test: "/test.json", prod: "/prod.json"};
var configs = {};

async.forEachOf(obj, (value, key, callback) => {
    fs.readFile(__dirname + value, "utf8", (err, data) => {
        if (err) return callback(err);
        try {
            configs[key] = JSON.parse(data);
        } catch (e) {
            return callback(e);
        }
        callback();
    });
}, err => {
    if (err) console.error(err.message);
    // configs is now a map of JSON data
    doSomethingWith(configs);
});

为了使用这个库，它使用async.forEachOf函数而不是简单的 forEach 循环。三个参数被发送到这个函数。