我有两个疑问。
首先,
SELECT auctions.name, wowitemdata.itemName, auctions.itemId,
auctions.buyout, auctions.quantity
FROM auctions
INNER JOIN wowitemdata ON auctions.itemId = wowitemdata.itemID;
返回这样的数据:
{
name: 'somename',
itemName: 'someitemname',
itemId: '0000',
buyout: '0001',
quantity: '5',
}
第二个查询使用来自 #1 的数据来获取比 itemId 便宜的项目的 count()。响应将作为新元素添加到 #1 -> ‘undercut’。
我的功能:
function checkUndercut(data, length){
var Select = 'SELECT COUNT(auctions.itemId) AS cnt ';
var From = 'From `auctions` ';
var Where = 'WHERE auctions.itemId LIKE ? AND buyout < ?';
var sql = Select + From + Where;
for(i = 0, len = length; i < len; i++){
var inserts = [data[i]['itemId'], data[i]['buyout']];
var ssql = mysql.format(sql, inserts);
data[i]['undercut'] = i;
connection.query(ssql, function(err, rows, fields){
if(!err){
console.log("check Undercut: " + rows[0].cnt);
data[i]['undercut'] = rows[0].cnt;
} else {
console.log("Error while performing Query");
};
});
};
}
由于查询的异步性质,我不能使用 for 循环 i var 来附加数据。
我该如何解决这个问题?
编辑:我的新问题:
当我搜索一个名字(searchobj)时,返回的数据落后了一步。
假设我搜索“Tim”,没有任何显示。
假设我接下来搜索“Finn”,我在“Tim”上的数据就会出现。
我怀疑这是因为我从 checkUndercut 函数中获取数据的方式。
我做了一个新的顶级 var,appdata,在使用@simple_programmers 的建议后,我把我的新代码这样写:
function(err){
if(err){
//handle the error if the query throws an error
}else{
appdata = data;
console.log(appdata);
//whatever you wanna do after all the iterations are done
}
});
console.log 发出正确的信息,所以我的问题在于 get 函数过早地发送响应。
我的获取功能:
app.get('/test',function(req, res) {
console.log("app.get "+searchobj);
var sqlSELECT = 'SELECT auctions.name, wowitemdata.itemName, auctions.itemId, auctions.buyout, auctions.quantity ';
var sqlFROM = 'FROM `auctions` ';
var sqlINNER ='INNER JOIN `wowitemdata` ON auctions.itemId = wowitemdata.itemID ';
var sqlWHERE = 'WHERE auctions.name LIKE ?';
var sql = sqlSELECT + sqlFROM + sqlINNER + sqlWHERE;
var inserts = [searchobj];
var sql = mysql.format(sql, inserts);
//console.log("Query: "+sql);
connection.query(sql, function(err, rows, fields) {
if (!err){
var rowLen = rows.length;
checkUndercut(rows, rowLen);
console.log(appdata);
res.send(appdata);
} else {
console.log('Error while performing Query.');
};
});
});
我的问题:
- 从异步函数发送数据的正确方法是什么?
- 有什么方法可以让我的 app.get 或 res.send 等到我的数据被检索后再发送吗?
编辑 2:我可以通过将所有代码放在我的 app.get() 中来让它工作,但是必须有一个更优雅、更易于阅读的解决方案吗?
原文由 Chris 发布,翻译遵循 CC BY-SA 4.0 许可协议
在我看来,最好的方法是使用一个名为
async
的节点模块并行运行,并在一切完成时进行一次回调。在
async
模块中针对此类情况定义了多种方法,我推荐的方法是forEachOf
。鉴于你的
data
参数是一个数组,它是这样的 -所以基本上所做的是,它循环遍历您的
data
数组并对该数组的每个元素运行查询。执行查询后,它会调用该迭代的本地回调方法。一旦完成所有迭代(即调用最后一个本地回调),它会调用最终回调,您可以在其中执行所有查询执行完毕后想做的任何事情。更多关于
forEachOf
在这里 - https://caolan.github.io/async/docs.html#eachOf异步模块 - https://caolan.github.io/async/