回調，直到循環查詢完成

Question

我之前發佈了一個問題，並意識到我的問題實際上是異步函數。我設法解決了大部分問題，但我還有一個小問題。使用異步I用來瀑布創造了一些查詢訂單...

exports.getMenu = function(id_restaurant, callback){ 
    async.waterfall([ 
     async.apply(firstQuery, id_restaurant), 
     secondQuery, 
     thirdQuery, 
     fourthQuery, 
     formMenu 
    ], function(err, result){ 
     if(err){ 
      console.log(err); 
     } 

     callback(result); 
    }); 
}; 

一切正常，直到fourthQuery，在那裏我有循環得到一個菜單的所有菜餚。

function fourthQuery(array_totalP, array_nombresSecc, array_secciones, callback){ 
    var size = array_nombresSecc.length; 
    var array_secciones = array_secciones; 
    var array_nombresSecc = array_nombresSecc; 

    var dishes = []; 

    pool.getConnection(function(err, connection) { 

     if(err) { 
      console.log(err); 
      callback(true); 
      return; 
     } 
     for (var i = 0; i < size; i++) { 
      connection.query("SELECT name, price FROM menu_product WHERE id_seccion = ? AND active = 1", [array_secciones[i]], 
       function(err, results2) { 
        if(err) { 
         console.log(err); 
         callback(true); 
         return; 
        } 

        console.log("Result query 4 " + JSON.stringify(results2)); 
        dishes[i] = results2; 
        console.log("VALOR PLATILLOS EN i : " + JSON.stringify(dishes[i])); 
        // this prints the result but only if it has a value over 2 
      }); 
     }; 
    }); // pool 

    console.log("I'm sending " + dishes); // this logs an empty array 

    callback(null, dishes, array_nombresSecc); 
}; 

所以，我可以看到，從打印的「i」的每個循環的是，它始終爲2的值，因爲這是「大小」值的值發生。此外，即使它保存了索引'2'的結果，我相信回調仍在for循環完成之前完成，因爲我的第五個函數正在接收一個空數組。

如何讓我的代碼等待回調，直到我的for循環完成？

注意：對不起，我的部分代碼是西班牙文，試圖翻譯它的重要部分。

Answer 1

有幾種方法可以解決這個問題，一種方法是查看承諾架構。 Promise.all將允許您提供一個回調來處理每個子承諾的值。然而，爲了使用你已經得到的東西，我會將值推入你的盤子數組，而不是專門將它們分配給i索引，然後在每個連接結束時檢查該數組的大小。當數組長度匹配大小時，觸發回調。 （如下圖所示）

如果您需要一種方法來每個結果綁定到特定i價值，我建議推動他們爲對象

dishes.push({'index': i, 'dish': results2}) 

之後，如果你需要的只是菜的陣列，您可以通過該索引值對數組進行排序並運行映射函數。

dishes.sort(function(a,b){ return a.index - b.index; }) 
dishes = dishes.map(function(a){ return a.dish }) 

這裏的調整代碼：

function fourthQuery(array_totalP, array_nombresSecc, array_secciones, callback) { 
 
    var size = array_nombresSecc.length; 
 
    var array_secciones = array_secciones; 
 
    var array_nombresSecc = array_nombresSecc; 
 

 
    var dishes = []; 
 

 
    pool.getConnection(function(err, connection) { 
 

 
    if (err) { 
 
     console.log(err); 
 
     callback(true); 
 
     return; 
 
    } 
 
    for (var i = 0; i < size; i++) { 
 
     connection.query("SELECT name, price FROM menu_product WHERE id_seccion = ? AND active = 1", [array_secciones[i]], 
 
     function(err, results2) { 
 
      if (err) { 
 
      console.log(err); 
 
      callback(true); 
 
      return; 
 
      } 
 

 
      console.log("Result query 4 " + JSON.stringify(results2)); 
 
     
 
     
 
      dishes.push(results2) 
 
      
 
      if(dishes.length == size){ 
 
      console.log("I'm sending " + dishes); 
 
      callback(null, dishes, array_nombresSecc) 
 
      } 
 
     
 
     
 
      console.log("VALOR PLATILLOS EN i : " + JSON.stringify(dishes[i])); 
 
      // this prints the result but only if it has a value over 2 
 
     }); 
 
    }; 
 
    }); // pool 
 

 
    ; 
 
};

Answer 2

既然你已經在使用異步，我會建議與async.each()替換fourthQuery的for()循環。

更新fourthQuery應該是這樣的：

function fourthQuery(array_totalP, array_nombresSecc, array_secciones, callback){ 
 
    var size = array_nombresSecc.length; 
 
    var array_secciones = array_secciones; 
 
    var array_nombresSecc = array_nombresSecc; 
 

 
    var dishes = []; 
 

 
    pool.getConnection(function(err, connection) { 
 
     if(err) { 
 
      console.log(err); 
 
      callback(true); 
 
      return; 
 
     } 
 
     async.each(array_secciones, 
 
      function(item, itemCallback) { 
 
       // Function fun for each item in array_secciones 
 
       connection.query("SELECT name, price FROM menu_product WHERE id_seccion = ? AND active = 1", [item], 
 
        function(err, results2) { 
 
         if(err) { 
 
          console.log(err); 
 
          return itemCallback(true); 
 
         } 
 

 
         console.log("Result query 4 " + JSON.stringify(results2)); 
 
         dishes.push(results2); 
 
         console.log("VALOR PLATILLOS EN i : " + JSON.stringify(dishes[dishes.length-1])); 
 
         // this prints the result but only if it has a value over 2 
 
         return itemCallback(); 
 
        }); 
 
      }, 
 
      function(err) { 
 
       // Function run after all items in array are processed or an error occurs 
 
       console.log("I'm sending " + dishes); // this logs an empty array 
 
       callback(null, dishes, array_nombresSecc); 
 
      }); 
 
    }); // pool 
 
};

或者，你可以使用async.map()，它處理收集最終回調的結果，因此不依賴於dishes變量。