我对节点世界很新,并尝试将我们的php应用程序迁移到节点.为了能够返回所有文章数据,必须根据第一个查询的结果完成几个不同的查询.目前我的数据对象是空的,因为它在两个查询运行之前返回.如何使用承诺的方法“链接”这些查询.
我发现了一个库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();
});
};
基于其他查询结果执行查询的最佳方法是什么?任何帮助都非常感谢.
最佳答案 您正在寻找的功能是
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()返回一个promise(也就是说不需要回调函数).使用此功能有利于您 – 它将使您的代码更漂亮.
> connection.query()返回行数组,而不是单个值.您似乎在示例代码中忽略了这一点.
>尝试在使用promises时不将内容保存到变量中,这是没有必要的.要解决这个问题,请阅读Promise API(Promise.resolve(),Promise.reject(),Promise.any(),Promise.catch(),Promise.all())等.
>看起来这些SQL查询可以很容易地组合成一个查询.这将比执行两个操作更有效.不确定您希望使用的其余查询是否属于这种情况,但绝对值得注意.