node.js + sequelize + 顺序执行

Question

在我的节点应用程序中，我必须依次执行 2 个查询 1（即）我必须根据第一个查询的结果执行第二个查询。

我的代码：

 var levels;
        try {
            sequelize.query("Select * from levels where country_id = " + level0 + "").success(function(results) {
                levels = results;               
            }).failure(function(err) {
                if (err) {
                    logger.error(err.stack);
                    throw (err);
                }
                else {
                    if (callback) {
                        callback(err, null);
                    }
                }
            });
        }
        catch (err) {
        }


if (level == 2) {
        query = "select *from xxxxxx where " + query + " and leveltype = "+levels[0].name_2+"";-----------------------------------------------------------> this is from 1st query

        try {
            sequelize.query(query).success(function(results) {
                results = tsv.stringify(results);
                onSuccess(results, callback)
            }).failure(function(err) {
                if (err) {
                    logger.error(err.stack);
                    throw (err);
                }
                else {
                    if (callback) {
                        callback(err, null);
                    }
                }
            });
        }
        catch (err) {
            logger.error(err.stack)
        }
    }

请帮我解决这个问题。提前致谢。

Answer 1

Sequelize 使用 Bluebird 承诺：

sequelize.query("Select * from levels where country_id = " + level0 + "").success(function(results) {
                levels = results;               
            }).failure(function(err) {
                if (err) {
                    logger.error(err.stack);
                    throw (err);
                }
                else {
                    if (callback) {
                        callback(err, null);
                    }
                }
            });
        }

可以变成：

sequelize.query("Select * from levels where country_id = " + level0 + "")
         .then(function(results)  {
            levels = results;               
        });

承诺链：

sequelize.query("Select * from levels where country_id = " + level0 + "")
.then(function(levels)  {
     var query = "select *from xxxxxx where " + query + 
                 " and leveltype = "+levels[0].name_2+""
     return sequelize.query(query);
 }).nodeify(callback); // turn back from promise API to callback API

这段代码基本上完成了上面代码所做的一切:)

• 您不需要 try/catch 和 if(err) 检查承诺 - 他们会为您处理。如果你在一个承诺处理程序中抛出你是安全的。
• Promises 链，如果你从 . 中返回一个 Promise 的值，那么它将使用该 Promise 解决它（这意味着你可以添加一个 .then 处理程序）

不过，您可以做得更好，您可以返回 promise 的值（即 - return sequelize.query）并完全切换到 promise API。