express js中的async.waterfall方法

async.waterfall method in express js

本文关键字:waterfall 方法 async 中的 js express      更新时间:2024-03-31

问题:

我使用express.js从数据库中获取数据并以json格式显示。

但是当在node js中运行代码时,会显示一个空数组(ganttrault),当我再次刷新浏览器时,我会得到所需的结果。

所以,我使用了async.waterfall方法来顺序执行我的代码,但同样的问题仍然存在。

请告知

var ganttresult= new Array();
    app.get('/get',cors(), function(request,response) {
    async.waterfall([
     function(result) {
    connection.query("SELECT id FROM Gantt",function(err, rows) {
        if (err) {
        console.log('error in fetching  ' + err);   
      }
      else{  
      var all_id=rows;  
      for(var j=0;j<all_id.length;j++){
        connection.query("SELECT id,tailName FROM Gantt where id= '"+all_id[j].id+"'",function(err, rows) {
         if (err) {
        console.log('error in fetching  ' + err);   
      }
      else{  
          var jsonString1=rows;
        var set_id=jsonString1[0].id;

        connection.query("SELECT itemId,name,start,end FROM GanttFlight  where id= '"+set_id+"'",function(err, rows) {
             if (err) {
        console.log('error in fetching  ' + err);   
      }
      else{  
        var jsonString2=rows;
         var gantt1=new Object();
        gantt1.id=jsonString1[0].id;
        gantt1.name=jsonString1[0].tailName;
        var series = new Array();
        if(jsonString2.length>0){   
        for(var i=0;i<jsonString2.length;i++){
         var gantt2=new Object();    
        gantt2.item=jsonString2[i];
        series.push(gantt2);
    gantt1.series=series;
        }
        }
        else{
        gantt1.series=[];
        }

    ganttresult.push(gantt1);
          }    
     });

    }  
     });
     }
    var result= JSON.stringify(ganttresult);
    ganttresult=[];
    response.send('{'"data'":'+result+'}');
    response.end();
     }
     });
    }
     ],   function(err) {
          if(err){
          console.log(err);
          }
        }
);
});

我正在重新编写您的代码,以便在async.map中正确使用async.waterfall但我在上面花了太多时间。

以下是我的做法https://gist.github.com/bulkan/7800715

请注意,它并不完整。