ノードJsのpromiseでresolve（）にSQLクエリの結果が渡されない

Question

だから私はこれをやっていると思ったが、私はそうは思わない。クエリの結果をthen()の関数に渡そうとしています。私はconsole.log()の2つの機能の中から結果をログに記録しています。最初の人は結果を吐き出す必要があります。 2番目のものは私に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関数では、約束事の中で1つの値しか解決できないため、オブジェクトを解決します。

第2に、約束を守るには、約束を返さなければなりません。最初のthenハンドラでは、PromiseをdbQuery（dbConnectの後）から返信していませんでした。

最後に、以前に使用された複数のパラメータではなく、単一の解決オブジェクトで処理するように2番目のthenハンドラを変更しました。以前はすべてが機能していましたが、resultsが定義されていましたが、fieldsは定義されていませんでした。このような場合は、ArrayまたはObjectを解決することをおすすめします。 es6を使用している場合は、オブジェクト/配列の非構造化が容易になります。

別のメモ。プロミスを使用している場合は、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"); 
     } 
    ); 

}