对数据库的异步调用循环不等待

Question

我只是在解析 json 时尝试访问数据库。这段小代码让我的生活变得地狱

function loopColumns(val, cb){
    db.one('select tag_name from t_tag where tag_id = $1', val)
    .then(function (data) {
        //console.log(data.tag_name)
        cb(null, data.tag_name)
    });

}

var value = {"旅行活动":[1,2], "旅行方式":[3,4]};

for( i in value){ 
    //console.log(value[i], i)
    var output = '';
    var outcome = '';
    var str = value[i];
    for(j in str){
        loopColumns(str[j], function(err,res){
            if(outcome=='') outcome= res;
            else outcome= outcome+' , '+res;
            console.log(outcome);
        })

    }

    var output = i+' : '+outcome+' \n';
    console.log('output \n'+output);
};

这是输出
输出 旅游活动：
输出 旅游方式：
好食物
美味的食物，希金
美食 , 希克 , xyz
美食 , Hicking , xyz , 测试

我喜欢输出为
旅行方式：美食，Hicking
旅行活动：xyz，测试

请救救我的命

Answer 1

使用Promise.all

Promise.all(iterable) 方法返回一个 promise，当 iterable 参数中的所有 promise 都已解析时，该 promise 将解析。

使用for-loop 代替for-in 循环迭代array

function loopColumns(val, cb) {
  db.one('select tag_name from t_tag where tag_id = $1', val)
    .then(function(data) {
      cb(null, data.tag_name)
    });
}
var value = {
  "Travel Activity": [1, 2],
  "Travel style": [3, 4]
};
for (var i in value) {
  var output = '';
  var promiseArr = [];
  for (var j = 0, len = value[i].length; j < len; j++) {
    var promise = new Promise(function(resolve) {
      loopColumns(value[i], function(err, res) {
        resolve(res);
      });
    });
    promiseArr.push(promise);
  }
  Promise.all(promiseArr).then(function(arr) {
    var op = arr.join(', ');
    output += i + ' : ' + op + ' \n';
    console.log('output \n' + output);
  });
}

Answer 2

使用来自async 实用程序模块的each，而不是使用for 循环。