我对节点世界很陌生,正在尝试将我们的php应用程序迁移到节点。为了能够返回所有商品数据,必须根据第一个查询的结果进行几个不同的查询。目前,我的数据对象为空,因为在运行两个查询之前已将其返回。如何使用基于承诺的方法“链接”这些查询。
我找到了一个库https://github.com/lukeb-cn/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链,它允许您构造一个Promise序列,每个Promise都取决于前一个值的结果。将其应用到您的代码中,您将获得如下内容:
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()
返回行的数组,而不是单个值。您似乎在示例代码中忽略了这一点。本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句