首页 文章

Sequelize Promises - Chaining Promises和Bluebird Promise.each，Promise.map，Promise.all等

提问于
浏览 次
3

我在我的用户控制器中有一个索引操作，其中我尝试连续做两件事，而不是执行所需的res.json（）方法，直到他们都有机会完成 .

我有一个加入用户的友情加入模型 . 一列是frienderId，一列是friendedId . 在下面的索引函数中，期望的结果是我最终会得到一个SINGLE用户对象，这是一个朋友 . 以下承诺的原因是因为用户可能位于frienderId列或friendedId列中，因此我必须基本解析req.user的朋友的两种可能情况 .

问题是归还的最后一件事，I.E . res.json（result），总是返回正确的朋友，但是，它始终在所需对象之前或之后返回一个空数组[] . 我知道这个空数组来自两个没有找到结果的承诺场景之一 . 是否有某种类型的方法而不是像sayyy..reject那样的解决方法？如果调用，整个承诺将不会被推送到promise数组？然后我可以测试if（！friended）或if（！friender）

我理解 . 每个承诺都会列出每个承诺并给出每个承诺的结果 . 但是，我不希望每个承诺的结果，我只想访问每个承诺运行的副作用 .

谢谢！

index: function(req, res) {
    var promiseArray = [];

    promiseArray.push(new Promise(function(resolve) {
      user.findById(req.user.id).then(function(user) {
        user.getFrienders({
          where: {
            username: req.body.username
          }
        }).then(function(friender) {
          resolve(friender[0])
        })
      })
    }));

    promiseArray.push(new Promise(function(resolve) {
      user.findById(req.user.id).then(function(user) {
        user.getFriendeds({
          where: {
            username: req.body.username
          }
        }).then(function(friended) {
          resolve(friended[0])
        })
      })
    }));

    Sequelize.Promise.map(promiseArray, function(result) {
      res.json(result);
    });
}
sql node.js promise sequelize.js bluebird

1 回答

  • 2

    首先，你使用 Promise 有点多余 . 由于 findById() 函数返回一个promise，所以你需要做的就是处理它 . 您无需创建 new Promise . 你可以说 promiseArray.push(user.findById ...) . 你几乎正在使用 then . 传递到 then 的函数是在解析promise时调用的函数，在这种情况下，在 findById 函数完成并返回一个值之后 . then 本身返回一个使用其回调返回的值解析的promise . 因此，无论你希望在完成所有操作后最终在promiseArray中获得什么值，我都会假设 friended[0] 或 friender[0] 你需要在最后一个 then 函数中返回该值 . 在第一个 then 函数中，您还应该说 return user.findFriends( ...

    接下来需要做的是处理从 findById 函数返回的promise被拒绝的情况 . 你可以用两种方式做到这一点 . 首先，您可以将第二个回调传递给 then ，在拒绝承诺的情况下将调用该回调，并将拒绝的原因作为其参数 . 而不是将两个函数传递到 then ，您可以使用 then 跟随 then ，这是我个人喜欢做的，并将拒绝回调传递给 catch . catch 还返回一个使用其回调返回的值解析的promise . 您可以选择返回传入的原因，或者您想要的任何值 . 因此，在错误被拒绝的情况下，无论 catch 返回什么都将在你的promises数组中结束 .

    对于承诺，阅读the documentation可能对你有好处 . 不可否认，我知道在我刚开始时我的承诺有些困难，但是在完成文档并编写示例之后，你就可以了解它，看看有多么有用的承诺 .

    如果是我，这就是我重构代码的方式

    var frienderPromise = user.findById(req.user.id)
          .then(function(user) {
            return user.getFrienders({
              where: { username: req.body.username }
            });
          })
          .then(function (friender) {
            return friender[0];
          })
          .catch(function (reason) {
            return reason; // or whatever else you want to end up in the promisesArray on rejection
          });

    var friendedPromise = user.findById(req.user.id)
          .then(function(user) {
            return user.getFriendeds({
              where: { username: req.body.username }
            });
          })
          .then(function (friended) {
            return friended[0];
          })
          .catch(function (reason) {
            return reason;
          });

    promiseArray.push(frienderPromise);
    promiseArray.push(friendedPromise);

    你可以保持其他一切 . 最后，您仍然可以像当前一样调用 Sequalize . 虽然它应该是 return Sequalize... . 如果您不想保留不良结果，也可以考虑使用 Promise.filter 而不是 .map . 所以你可以做点什么

    return Sequelize.Promise.filter(promiseArray, function(result) {
      if (/* make sure it's result you want */)
        res.json(result);
    });

    就个人而言，我会更进一步，将所有的承诺业务移除到另一个与 res 无关的函数中并完成它

    return Sequelize.Promise.filter(promiseArray, function(result) {
      return result === /* result you want */;
    });

    一旦进入你的 index 功能，你就可以打电话了

    return friendsPromiseFunction().then(function (results) {
      res.json(results);
    })

    它会让事情变得更加清洁 . 希望这可以帮助 . 如果您有疑问，请告诉我 .

    回复于

相关问题