在 sequlize 结果集中迭代

Question

我需要从 sequelize 结果迭代结果集。我有一个有效的代码，但我认为它有问题，不应该这样做。我有一种感觉，这是一个阻塞代码。这是有效的代码：

 models.Project.findAll({
            where: {ProjectId: projectId}
        })
        .then(function (projects) {
            //Iteration is here
            var projectList = [];
            projects.forEach(function (res) {
                projectList.push(res.dataValues.PartId);
            });
             //then bulk lookup for the result
            models.Customers.findAll({
                where: {'id': {in: [projectList]}}
            }).then(function (customers) {
                reply(customers).code(200);
            }, function (rejectedPromiseError) {
                reply(rejectedPromiseError).code(401);
            });

            //reply(sameparts).code(200);
        }, function (rejectedPromiseError) {
            reply(rejectedPromiseError).code(401);
        });

此迭代部分已完成：

projects.forEach(function (res) {
                projectList.push(res.dataValues.PartId);
            });

然后这段代码作为另一个查询执行：

models.Customers.findAll({
                where: {'id': {in: [projectList]}}
            }).then(function (customers) {
                reply(customers).code(200);
            }, function (rejectedPromiseError) {
                reply(rejectedPromiseError).code(401);
            });

我如何重新排列它以便它使用 Promises？

编辑（可能的解决方案）：玩了一下，我相信我已经实现了承诺。

getAll: function (request, reply) {
    var projectId = request.params.projectid;

    var promises = [];
    var post;

    models.SamePart.findAll({
            where: {ProjectId: projectId}
        })
        .then(function (sameparts) {
            //Iteration is here                
            sameparts.forEach(function (res) {
                promises.push(
                    Promise.all([               
                        models.Parts.findAll({where: {id: res.dataValues.PartId}})
                    ]))
            });
            //Bulk lookup for the parts that were marked as identical

            return Promise.all(promises);
        }).then(function (completepartslist) {
        reply(completepartslist).code(200);
    });

这是正确的做法吗？似乎 completepartslist 包含许多不需要的对象，包括 Promise 的东西。我怎样才能展平它，以避免复杂的 for 循环？

Answer 1

如果您正在使用 .then()，那么您很可能已经在使用 promise。

您原来的工作代码似乎没有阻塞。

您的最终 getAll() 看起来应该简化为：

getAll: function (request, reply) {
    models.SamePart.findAll({
        where: { ProjectId: request.params.projectid }
    }).then(function (sameparts) {
        return Promise.all(sameparts.map(function (res) {
            return models.Parts.findAll({ where: { id: res.dataValues.PartId } });
        }));
    }).then(function (completepartslist) {
        reply(completepartslist).code(200);
    });
}

但是，您需要重新添加错误处理。

Answer 2

更简单

getAll: function (request, reply) {
    models.SamePart.findAll({
        where: { ProjectId: request.params.projectid }
    }).reduce(function (completepartslist, sameparts) {
        return models.Parts.findAll({ where: { id: sameparts.PartId } }).
          then(function(res){
            completepartslist.concat(res)
          });
        }), []);
    }).then(function (completepartslist) {
        reply(completepartslist).code(200);
    });
}

在 sequlize 结果集中迭代

Iterate inside the sequlize result set

promise

sequelize.js

hapijs