Kết hợp đầu ra của 2 truy vấn trong REST API

Question

Tôi đang sử dụng mô-đun khôi phục node.js. Tôi có một API REST để xuất kết quả của một truy vấn MySQL đơn lẻ trong json. Đây là mã của API;

var rest_api_get_list = function (app, url_name) { 
    function respond(req, res, next) { 
     var door_mac = req.query.door_mac; 

     var connection = own_mysql.getMySQL_connection(); 

     var query_str = 
       "SELECT doors.mac_addr, " + 
       "sensors.sensor_type " + 
       "FROM sensors " + 
       "WHERE (doors.mac_addr = ?) " 
      ; 

     var query_var = [door_mac]; 

     var query = connection.query(query_str, query_var, function (err, rows, fields) { 
      //if (err) throw err; 
      if (err) { 
       //throw err; 
       console.log(err); 
       logger.info(err); 
      } 
      else { 
       res.send(rows); 
      } 
     }); 
     return next(); 
    } 

    app.get(url_name, respond); 
}; 

Giả sử tôi có một truy vấn trông giống như thế này;

var query_str_2 = 
      "SELECT knobs.mac_addr, " + 
      "furniture.furniture_type " + 
      "FROM furnitures" + 
      "WHERE (knobs.mac_addr = ?) " 
     ; 

Tôi muốn kết hợp đầu ra của 2 MySQL truy vấn query_str và query_str_2 và có REST API trả về kết quả trong json. Điều này có thể giải quyết như thế nào?

Để rõ ràng hơn, tôi đang nghĩ đến mã làm một việc như thế này;

var rest_api_get_list = function (app, url_name) { 
    function respond(req, res, next) { 
     var door_mac = req.query.door_mac; 

     var connection = own_mysql.getMySQL_connection(); 

     var query_str = 
       "SELECT doors.mac_addr, " + 
       "sensors.sensor_type " + 
       "FROM sensors " + 
       "WHERE (doors.mac_addr = ?) " 
      ; 

     var query_var = [door_mac]; 

     var query = connection.query(query_str, query_var, function (err, rows_output_1, fields) { 
      //if (err) throw err; 
     }); 

     var query_str_2 = 
      "SELECT knobs.mac_addr, " + 
      "furniture.furniture_type " + 
      "FROM furnitures" + 
      "WHERE (knobs.mac_addr = ?) " 
     ; 

     var query_2 = connection.query(query_str_2, query_var, function (err, rows_output_2, fields) { 
      //if (err) throw err; 

     }); 

     //How to display json output of rows_output_1 and rows_output_2? 

     return next(); 
    } 

    app.get(url_name, respond); 
}; 

EDIT: Tôi bắt đầu một tiền thưởng để thu hút câu trả lời sử dụng Lời hứa.

Answer 1

Mô-đun để quản lý luồng điều khiển không đồng bộ - như async - có thể giúp bạn với điều này.

Ví dụ:

function respond(req, res, next) { 

    var door_mac = req.query.door_mac; 
    var connection = own_mysql.getMySQL_connection(); 
    var query_var = [door_mac]; 

    async.parallel([ 
     function (callback) { 

      var query_str = 
       "SELECT doors.mac_addr, " + 
       "sensors.sensor_type " + 
       "FROM sensors " + 
       "WHERE (doors.mac_addr = ?) " 
      ; 
      connection.query(query_str, query_var, callback); 
     }, 
     function (callback) { 

      var query_str_2 = 
       "SELECT knobs.mac_addr, " + 
       "furniture.furniture_type " + 
       "FROM furnitures" + 
       "WHERE (knobs.mac_addr = ?) " 
      ; 
      connection.query(query_str_2, query_var, callback); 
     } 
    ], function (error, results) { 

     // results[0] => result for query_str 
     // results[1] => result for query_str_2 
     // ... return next() or whatever 
    })  
} 

Answer 2

Nếu bạn đang yêu cầu xử lý song song, như @cartant nói, bạn có thể sử dụng async hoặc (tốt hơn nhiều) lời hứa (Promise.all(p1, p2).then(...)).

Nhưng nếu bạn đang yêu cầu cách tiếp cận tối ưu (xử lý song song cho kết quả nhanh hơn với chi phí của nhiều nguồn lực hơn cho mỗi tiêu thụ kết quả thực tế), bạn có thể làm điều đó trong một truy vấn duy nhất thay vì:

var query_str = 
    "SELECT doors.mac_addr, " + 
    "sensors.sensor_type as type " + 
    "FROM sensors " + 
    "WHERE (doors.mac_addr = ?) " + 
    "UNION " + 
    "SELECT knobs.mac_addr, " + 
    "furniture.furniture_type as type " + 
    "FROM furnitures" + 
    "WHERE (knobs.mac_addr = ?) " 
; 

Bằng cách này bạn thực hiện duy nhất cơ sở dữ liệu gọi và, tất nhiên, cơ sở dữ liệu sẽ không thực hiện bất kỳ song song, nhưng thay vào đó, nó sẽ làm cho nỗ lực tốt nhất của mình để có được câu trả lời tại thời điểm tốt nhất với mức tiêu thụ tài nguyên thấp hơn. Vì vậy, nếu bạn phải tham dự nhiều yêu cầu hơn, hiệu quả trung bình sẽ tốt hơn, mặt khác, nếu bạn yêu cầu kết quả nhanh hơn trong một môi trường mà tài nguyên không quan tâm nhiều, thì cách tiếp cận song song sẽ tốt hơn.