异步调用数据库for循环不等

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值= { “旅行活动”：[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); 
}; 

这是以输出
输出 旅游活动：
输出 旅行风格：
好吃
好食物，Hicking
良好的食物，Hicking，XYZ
良好的食物，Hicking，XYZ ，测试

我想获得输出
旅行风格：良好的食物，Hicking
旅游活动：XYZ，测试

PLZ救我的命

Answer 1

使用Promise.all

的Promise.all（ 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

使用each从async实用模块，而不是使用for循环。