NodeJS и mysql: дождаться результата запроса

Question

У меня есть небольшой проект с узлом nodejs + express, и я также сделал небольшой сервис для совместного использования на некоторых его страницах.

var mysql = require('mysql'); 

var pool = mysql.createPool({ 
     connectionLimit : 100, 
     host  : 'host', 
     user  : 'user', 
     password : 'password', 
     database : 'database', 
     debug : false 
}); 

function executeQuery(query, callback) { 
    pool.getConnection(function (err, connection) { 
     if (err) { 
      return callback(err, null); 
     } 
     else if (connection) { 
      connection.query(query, function (err, rows, fields) { 
       connection.release(); 
       if (err) { 
        return callback(err, null); 
       } 
       return callback(null, rows); 
      }) 
     } 
     else { 
      return callback("No connection", null); 
     } 
    }); 
} 


function getResult(query) { 
    return executeQuery(query, function (err, rows) { 
       if (!err) { 
        return rows; 
       } 
       else { 
        console.log(err); 
       } 
      }); 
} 

function getServers() 
{ 
    var list = getResult("select * from table"); 
    return list; 
} 

exports.getList = getList; 

Теперь моя проблема: когда я вызываю module.GetServers(); из другого модуля результат всегда неопределен, потому что pool.getConnection является асинхронным (я полагаю, я совершенно новый), поэтому executeQuery не дает результата. Как заставить execQuery ждать получения результата connection.query?

Answer 1

В вашей функции executeQuery вы использовали обратные вызовы для ожидания результатов. Точно так же, реализуя их в функции getResult, вы можете дождаться результатов после выполнения запроса. Что-то вроде этого.

var mysql = require('mysql'); 
var pool = mysql.createPool({ 
    connectionLimit : 100, 
    host  : 'host', 
    user  : 'user', 
    password : 'password', 
    database : 'database', 
    debug : false 
}); 

function executeQuery(query, callback) { 
pool.getConnection(function (err, connection) { 
    if (err) { 
     return callback(err, null); 
    } 
    else if (connection) { 
     connection.query(query, function (err, rows, fields) { 
      connection.release(); 
      if (err) { 
       return callback(err, null); 
      } 
      return callback(null, rows); 
     }) 
    } 
    else { 
     return callback(true, "No Connection"); 
    } 
}); 
} 


function getResult(query,callback) { 
    executeQuery(query, function (err, rows) { 
    if (!err) { 
     callback(null,rows); 
    } 
    else { 
     callback(true,err); 
    } 
    }); 
} 

function getServers() 
    { 
getResult("select * from table",function(err,rows){ 
    if(!err){ 
     return rows; 
    }else{ 
     console.log(err); 
    } 
    }); 

} 

exports.getList = getList;