Node + Mysql：如何根据另一个查询执行更多查询

Question

我是节点世界的新手，正在尝试将我们的 php 应用程序迁移到节点。为了能够 return 所有文章数据，必须根据第一个查询的结果执行几个不同的查询。目前我的数据对象是空的，因为它在两个查询运行之前 returned。我如何使用基于承诺的方法 "chain" 这些查询。

我找到了一个库 https://github.com/lukeb-uk/node-promise-mysql，我认为它可以提供帮助，但我不知道如何用我的代码实现它。

exports.getArticleData = function(req, done) {
  pool.getConnection(function(error, connection) {
    if (error) throw error;

    var data = {
        article: {},
        listicles: []
    };

    // Inital query
    connection.query(
        `SELECT article_id, title, is_listicle_article, FROM com_magazine_articles AS article WHERE article_id = ${req
            .params.articleId}`,
        function(error, results) {
            data.article = results;
        }
    );

    // This query should only be excuted if is_listicle_article = true
    if (data.article.is_listicle_article) {
        connection.query(
            `SELECT * FROM com_magazine_article_listicles WHERE article_id = ${req.params
                .articleId}`,
            function(error, results) {
                data.listicle = results;
            }
        );
    }

    // More queries depending on the result of the first one
    // ....
    // ....

    // Callback with the data object
    done(data);

    connection.release();
  });
};

根据其他查询结果执行查询的最佳方法是什么？非常感谢任何帮助。

Answer 1

您正在寻找的功能是 Promise chaining，它允许您构建一系列承诺，每个承诺都取决于前一个值的结果。将此应用到您的代码中，您将得到如下内容：

exports.getArticleData = function(req, done) {
  pool.getConnection(function(error, connection) {
    if (error) throw error;

    // Inital query
    return connection.query(
        `SELECT article_id, title, is_listicle_article, FROM com_magazine_articles AS article WHERE article_id = ${req
            .params.articleId}`
    ).then((rows) => {
    
       return Promise.all(rows.map((article) => {
          if (article.is_listicle_article) {
            return connection.query(
                `SELECT * FROM com_magazine_article_listicles WHERE article_id = ${req.params
                    .articleId}`
             );
          } else {
             return Promise.resolve(null);
          }
       }));
    }).then((res) => {
     connection.release();
     done(res.filter(function(i){ return i != null; }));
    })

    // This query should only be excuted if is_listicle_article = true
    

    // More queries depending on the result of the first one
    // ....
    // ....

    // Callback with the data object
    connection.release();
  });
};

显然，由于我没有您的所有代码，因此无法验证此示例，但这应该大致就是您要查找的功能。也就是说，我认为您应该在示例代码中注意一些错误：

connection.query() returns 一个承诺（又名不需要回调函数）。使用此功能对您有利 - 它会使您的代码更漂亮。
connection.query() returns 行数组，而不是单个值。您似乎在示例代码中忽略了这一点。
尽量不要在使用promises的时候把东西存到变量里，没必要。要解决这个问题，请阅读 Promise API (Promise.resolve(), Promise.reject(), Promise.any(), Promise.catch(), Promise.all()) 等
这些 SQL 查询似乎可以很容易地组合成一个查询。这将比执行两个操作更有效。不确定您希望使用的其余查询是否属于这种情况，但绝对需要注意。

Node + Mysql：如何根据另一个查询执行更多查询

Node + Mysql: How to execute more queries based on another query

mysql

node.js

mysqljs