来自SQL查询的结果没有传递给Node Js Promise中的resolve（）

Question

所以我认为我是这样做的，但我猜不是。我试图将查询结果传递给then()中的函数。我在这两个函数中有一个console.log()日志结果。第一个应该是吐出结果。第二个是给我undefined，我无法弄清楚我做错了什么。

var dbConnect =() => new Promise(
     (res, rej) => { 

      var connection = mysql.createPool(Config.mariaDBCred); 

      connection.getConnection((err, connection) => { 

       if(err) return rej(err); 
       return res(connection); 

      }); 


     } 
    ); 

    var dbQuery = (connection, queryString, paramArray) => new Promise(
     (res, rej) => { 

      var sql = mysql.format(queryString, paramArray); 

      connection.query(sql, 
       (err, results, fields) => { 

        connection.release(); 

        console.log(results); //THIS DISPLAYS RESULTS FROM THE QUERY CORRECTLY 
        if(err) return rej(err); 
        return res(results, fields); 

       } 
      ); 

     } 
    ); 


    //CHECK IF EMAIL EXISTS 
    module.exports.doesEmailExist = (email, callback) => { 

     dbConnect().then(
      (connection) => { 
       dbQuery(
        connection, 
        'SELECT `id`, `password_hash` FROM `users` WHERE email = ?', 
        [email] 
       ) 
      } 
     ).then(
      (results, fields) => { 
       console.log(results); //THIS DISPLAY UNDEFINED 
       if(results.length > 0) return callback(true, results); 
       return callback(false, "Email does not exist."); 
      } 
     ).catch(
      (reason) => { 
       console.log(reason); 
       return callback(false, "Internal Error"); 
      } 
     ); 

    } 

Answer 1

我不知道，如果下面编辑将解决你所有的问题，但你的问题与问候到Promise API来说，他们应该引导你在正确的方向。

首先，在dbQuery函数中，我解析了一个对象，因为您只能解析一个promise中的单个值。

二，要链承诺，你必须返回承诺。在您的第一个then处理程序中，您没有从dbQuery（dbConnect之后）返回Promise。

最后，我将您的第二个then处理程序更改为使用单个解析对象，而不是先前使用的多个参数。之前，一切正常，results应该被定义，但不是fields。在这些情况下，解决Array或Object的做法是很好的做法。如果你使用es6，对象/数组解构使得这一点变得容易。

另一个说明。如果您使用的是Promises，请考虑在您的doesEmailExist函数中放弃实施的回调模式，如果不是这样。这是更一致的，你不会包装catch处理程序，除非针对特定的错误情况。食物的思想。

var dbConnect =() => new Promise(
    (res, rej) => { 

     var connection = mysql.createPool(Config.mariaDBCred); 

     connection.getConnection((err, connection) => { 

      if(err) return rej(err); 
      return res(connection); 

     }); 


    } 
); 

var dbQuery = (connection, queryString, paramArray) => new Promise(
    (res, rej) => { 

     var sql = mysql.format(queryString, paramArray); 

     connection.query(sql, 
      (err, results, fields) => { 

       connection.release(); 

       console.log(results); //THIS DISPLAYS RESULTS FROM THE QUERY CORRECTLY 
       if(err) return rej(err); 
       // return res(results, fields); NOPE, can only resolve one argu 
       return res({ results: results, fields: fields }) // resolve an object 

      } 
     ); 

    } 
); 


//CHECK IF EMAIL EXISTS 
module.exports.doesEmailExist = (email, callback) => { 

    dbConnect().then(
     (connection) => { 
      // Return the promise from `dbQuery` call 
      return dbQuery(
       connection, 
       'SELECT `id`, `password_hash` FROM `users` WHERE email = ?', 
       [email] 
      ) 
     } 
    ).then(
     (response) => { 
      // Can only resolve one argument 
      var results = response.results; 
      var fields = response.fields; 
      console.log(results); //THIS DISPLAY UNDEFINED 
      if(results.length > 0) return callback(true, results); 
      return callback(false, "Email does not exist."); 
     } 
    ).catch(
     (reason) => { 
      console.log(reason); 
      return callback(false, "Internal Error"); 
     } 
    ); 

}