猫鼬查询完数据库后返回一个函数[重复]

Question

编辑

我已经成功做到了。我使用了很棒的异步模块。解决办法如下：

async.each(req.body.users, function(userId, next) {
  User.count( { _id: userId } ).exec(function(err, count) {
    if(count === null) {
      next("Doesn't exist);
    } else {
      next();
    }
}, function(err) {
  if(err) {
    console.log(err);
  } else {
    console.log("success");
  }
});

问题

我的场景如下。我正在向数据库控制器发出发布请求，以便在数据库中创建文档。该请求显然包含表单中的数据，存储在 req.body 中。我想在将数据推送到数据库之前检查数据是否正确，我通过调用函数来检查它。

其中一个字段是 user._id 数组，我想检查所有这些是否都属于某个用户。

我的实现方式如下：

req.body.users.forEach(function(userId) {
  User.count({ _id: userId }).exec(function(err, count) {
    if(count === 0) {
      return false;
    }
  }
}
return true;

所以基本上，我调用 mongoose 来计算数据库中有多少文档具有给定的 id，如果答案为零，则该字段不包含有效值，并且该函数返回 false。否则，它应该返回 true。

问题是对数据库的所有调用都是异步的，因此该函数在检查所有用户的 id 之前返回 true。

我想过使用 Promise，但我不知道从哪里开始。 大家有什么想法或建议吗？

提前致谢！ 干杯。 :)

Answer 1

您想要做的是检查每个给定的 idUser 是否正常。

在我的示例中，我执行一个请求，该请求将返回具有其中一个 id 的每个用户

req.body.users

。

最后我检查我想要检查的用户数量是否与我获取数据的用户数量相同。如果不匹配，则意味着我们有一个 idUser 不在数据库中。

  User.find({
      _id: {
        $in: req.body.users,
      },
    }, '_id')
    .then((rets) => {
      if (rets.length !== req.body.users.length) {
        //
        //  /!\ Unknown idUser
        // 

        throw new Error('...');
      }

      // All is alright
    })
    .catch((err) => {
      ...
    });

在我的示例中，我使用了

Promise

对象和 投影。