製作多個MySQL調用

Question

目標：

我試圖讓使用這樣一個查詢的結果作爲「mysql的」模塊中的Node.js多個SQL查詢輸入下一個語句。

sql1 = SELECT id FROM users WHERE email=? // get user id from email 
val1 = test@email.com 

sql2 = SELECT something FROM profiles WHERE user_id=? 
val2 = user_id // result of sql1 

做法：

我使用的是JS 「承諾」 來實現這一目標：

var run_query = function(conn,sql){ 

return new Promise(function (fulfill, reject){ 

    conn.query(sql, val, function(err, res) { 

     if(err) reject(err); 
     else fulfill(res); 

    }); 

}); 

} 

var conn = db.config(mysql); 

run_query(conn,[ 'SELECT id FROM users WHERE email=?' , ['test@email.com'] ]).then(function(result){ 

    console.log(result.id); // result of 1st query 

    return run_query(conn,[ 'SELECT something FROM profiles WHERE user_id=?' , [result.id] ]); 

}).then(function(result){ 

    console.log(result.something); // result of 2nd query 

}).catch(function(err){ 

    console.log('there was an error', err); 

}); 

conn.end(); 

問題：

首屆查詢返回正確的結果，但第二個查詢從mysql模塊中引發以下錯誤：

Error: Cannot enqueue Query after invoking quit. 
~blah blah blah~ 
code: 'PROTOCOL_ENQUEUE_AFTER_QUIT', fatal: false 

我試圖解析：

我相信這事做多次調用被製成，而連接是打開和conn.end（）;被稱爲最後。我把它移動了一下，但沒有奏效。

我試圖打開多個語句mysql的模塊

var conn = mysql.createConnection({multipleStatements: true}); 

..但沒有工作要麼。

如何用JS承諾結構使用mysql節點模塊？

Answer 1

您使用的是承諾，但承諾代碼是同步的，而外部代碼是異步的。所以conn.end在第二個查詢之前運行。

使用conn.end秒。然後塊內像這樣 和刪除外conn.end：

var conn = db.config(mysql); 

run_query(conn,[ 'SELECT id FROM users WHERE email=?' , 
['test@email.com'] ]).then(function(result){ 

console.log(result.id); // result of 1st query 

return run_query(conn,[ 'SELECT something FROM profiles WHERE 
user_id=?' , [result.id] ]); 

}).then(function(result){ 

    console.log(result.something); // result of 2nd query 
    conn.end(); 
}).catch(function(err){ 

    console.log('there was an error', err); 

}); 

Answer 2

承諾明確是用來寫乾淨的代碼，但你正在做的正好相反。

什麼Himanshu說是正確的，你的conn.end()首先執行。鑑於你的用例，我建議你使用Async模塊​​。瀏覽一次可用的功能。

我認爲Async.series將服務你的權利，雖然有多個異步功能，可以幫助你的情況下，特別是隊列。

async.series([ 
    function(callback) { 
    //Your First SQL Query based on response send success or failure callback 
     callback(null, 'one'); 
    }, 
    function(callback) { 
    //Your Second SQL Query based on response send success or failure callback 
     callback(null, 'two'); 
    } 
], 
// optional callback 
function(err, results) { 
    //listen to results from your codes and put some logic based on what you want and close the connection here 
conn.close(); 
}); 

懷疑：你爲什麼要一個接一個地執行它們？