Запуск нескольких запросов MySQL в этой функции node.js

Question

У меня есть эта функция node.js, которая возвращает Promise после выполнения одного запроса MySQL.

function deletePoint(PointObj, door_id) { 

return new Promise(function(resolve, reject) { 
    try { 
     var connection = jonMySQL.getMySQL_connection(); 

     var mysql_query = '`DELETE FROM table1 WHERE user_id=? and door_id=?`'; 

     var mysql_query_placeholder_arr = [PointObj.user_id, door_id]; 

     connection.query(mysql_query, mysql_query_placeholder_arr, function(err, rows, fields) { 
      if (err) { 
       return reject(err); 
      } else { 
       resolve(rows); 
      } 
     }); 
    } catch (err) { 
     reject(err); 
    } 
}); 

} Вышеуказанная функция работает нормально. Однако, что, если я хочу, чтобы функция завершила выполнение 2 запросов MYSQL?

Второй запрос будет выглядеть примерно так:

var mysql_query2 = '`DELETE FROM table2 WHERE user_id=? and door_id=?`'; 
var mysql_query2_placeholder_arr = [PointObj.user_id, door_id]; 

Как я могу интегрировать этот второй запрос MySQL в функцию таким образом, что обещание будет возвращать только после того, как оба запроса были выполнены?

EDIT: Было бы предпочтительнее, если предоставленный ответ может обрабатывать до нескольких запросов (скажем, до 5) без обратного ад. Может ли кто-нибудь дать ответ, используя асинхронный модуль?

Answer 1

Я хотел бы предложить создать обобщенный метод для выполнения запросов, вы можете изменить его в соответствии с вашими требованиями.

Примечание: выполняется последовательно, вы должны управлять строкой, возвращаемой в resolve(rows). Параллельно все строки получаются в конечном успехеCallback result как массив объектов.

function deletePoint(PointObj, door_id){ 
    var query = { 
    text : '`DELETE FROM table1 WHERE user_id=? and door_id=?`', 
    placeholder_arr : [PointObj.user_id, door_id], 

    }; 
    var query2 = { 
    text : '`DELETE FROM table2 WHERE user_id=? and door_id=?`', 
    placeholder_arr : [PointObj.user_id, door_id], 

    }; 

    //do this if you want to execute the queries sequentially 
    mySQLQuery(query).then(mySQLQuery(query2)).then(successCallback).catch(errorCallback); 

    //do this if you want to execute the queries parallely 
    var query_arr = [mySQLQuery(query),mySQLQuery(query2),...];     
    Promise.all(query_arr).then(successCallback,errorCallback) 


    function successCallback(result){ 
    console.log('done',result); 
    } 
    function errorCallback(err){ 
    console.log('Error while executing SQL Query',err); 
    } 

} 


function mySQLQuery(query) { 

var connection = jonMySQL.getMySQL_connection(); 
return new Promise(function(resolve, reject) { 
    try { 
     connection.query(query.text, query.placeholder_arr, function(err, rows, fields) { 
      if (err) { 
       return reject(err); 
      } else { 
       return resolve(rows); 
      } 
     }); 
    } catch (err) { 
     return reject(err); 
    } 
}); 

Кроме того, вы всегда можете использовать async модуль,

• async.parallel для параллельного выполнения,
• async.waterfall для последовательного выполнения с значениями, передаваемыми от одной функции к другой или
• async.series, если нет значений должны быть переданы между последовательными функциями.

Answer 2

Попробуйте как этот

function deletePoint(PointObj, door_id) { 

    return new Promise(function(resolve, reject) { 
     try { 
      var connection = jonMySQL.getMySQL_connection(); 

      var mysql_query = 'DELETE FROM table1 WHERE user_id = ? and door_id = ?'; 

      var mysql_query_placeholder_arr = [PointObj.user_id, door_id]; 

      connection.query(mysql_query, mysql_query_placeholder_arr, function(err, rows1, fields) { 
       if (err) { 
        return reject(err); 
       } else { 
        var mysql_query2 = 'DELETE FROM table2 WHERE user_id = ? and door_id = ?'; 
        var mysql_query2_placeholder_arr = [PointObj.user_id, door_id]; 
        connection.query(mysql_query, mysql_query_placeholder_arr, function(err, rows2, fields) { 
         if (err) { 
          return reject(err); 
         } else { 
          resolve({ 
           rows1: rows1, 
           rows2: rows2 
          }); 
         } 
        }); 

       } 
      }); 
     } catch (err) { 
      reject(err); 
     } 
    }); 
} 

---

внушения

Это не лучший подход к написанию нескольких запросов в функции обратного вызова.

Для решения такого типа случая использования async модуля с parallel или waterfall методов, основанных на сценариях