Mongoose Async 查找所有并更新每个

Question

我的小费游戏很少。游戏完成后，我从猫鼬数据库中获取所有提示，然后使用 forEach 迭代这些提示。

对于这些提示中的每一个，我都会获取用户名并从 mongoose db 加载用户以增加该用户的积分，然后将用户更改保存回 db。

一个用户可以拥有多个提示。

Tips.find({...}).exec(function(err, gameTips) {

   gameTips.forEach(tip, i) => {

      User.findOne({

         username: tip.username

      }).exec(function(err, user) {

          user.points = user.points + 1;

          user.save(function(err) {

             console.log("Points were increased");

          });

      });

   });

}

现在我的问题是用户的 findOne 是在保存上一个提示处理之前完成的。所以积分不会正确增加。

用户：testUser 有 4 个提示 | 预期：testUser.points = 4; | 当前：testUser.points = 2;

是否有可能异步执行此操作，以便为所有用户查找和保存将一个接一个地完成，以便每次我这样做：

user.points = user.points +1;

我会在增加之前有更新的积分吗？

Answer 1

发生的情况是您使用前面的点来计算下一个分数，而不是使用 mongoDB$inc运算符选项 1 使用回调，丑陋且根本不可读Tips.find({})  .exec(function(err, gameTips) {    if(err) {      console.error(err);      return;    }    gameTips.forEach(tip => {      User.findOneAndUpdate(        { username: tip.username },        { $inc: { points: tip.points }}      ).exec(function(err, user) {        if(err) {          console.error(err);          return;        }        console.log("Points were increased");      })    })  })选项 2 使用Promises，更具可读性Promise.all()Tips.find({})  .then(gameTips => Promise.all(gameTips.map(tip => User.updateOne(    { username: tip.username},    { $inc: { points: tip.points } }  )))  .then(() => {    console.log("Points were increased");  })  .catch(console.error)选项 3 使用async/await，我最喜欢的，简单易读async function run() {  try {    const gameTips = await Tips.find({});    await Promise.all(gameTips.map(tip => User.updateOne(      { username: tip.username},      { $inc: { points: tip.points } }    )));    console.log("Points were increased");  } catch (err) {    console.error(err);  }}

Answer 2

您不能像在 中使用异步代码那样使用它forEach，它不会产生所需的结果。您可以使用for ofwithasync await来获得更清晰的代码： async function updateTips() { try {    const tips = await Tips.find({condition: 'condition'})    if (tips.length) { // check for empty result        for (const tip of tips) {            let user = await User.findOne({ username: tip.username })            if (user) {                user.points = user.points + 1                await user.save()                console.log('Points were increased')            }        }    } } catch (err) {     // handle errors here }}updateTips()