MySQL NodeJs - 让行.each工作的正确方法

Question

当我寻找简单的例子时，每个人的风格似乎都大不相同。 我尝试了 2 种不同的风格，并遇到了 2 个不同的问题。 在下面的代码中，我已经确定了代码的来源及其在注释中出现的错误。 我注释掉或取消注释掉每个部分并单独运行，但每个部分都有自己的错误。 "console.log(rows); "语句显示数据，因此查询本身正在运行并正常工作。

// get the client
const mysql = require('mysql2');
const dashline = '---------------------------------';  
console.log (dashline); 
console.log ("Starting test"); 
// create the connection to database
const connection = mysql.createConnection({
host: 'myhost',
user: 'myuser',
password: 'mypass',
database: 'myDatabase'
});

console.log ("Got the database connection"); 

query = "select ID, user_nicename, user_email from wp_users where user_login = 'admin' limit 3 ";
console.log ("Starting query"); 
// Attempt 1
/*
connection.query(query, function(err, rows, fields){
if (err) throw err;
// from: https://html5hive.org/node-js-quickies-working-with-mysql/ 
// error: SyntaxError: Unexpected token { (on the rows.each line below) 
rows.each(element, index) {
console.log(element.ID+ " " + element.user_nicename);
}
console.log (dashline); 
console.log ("Query End"); 
process.exit();   // Else Node hangs and must hit cntl-break to exit 
});
*/


// Attempt 2 
connection.query(query, function(err, rows, fields){
if (err) throw err;
console.log(rows); 
// Roughly based on example on this page: 
// https://datatables.net/reference/api/each()
// TypeError: rows.each is not a function 
rows.each( function(element, index) {
console.log(element.ID + " " + element.user_nicename);
});
console.log (dashline); 
console.log ("The end"); 
process.exit();   // Else Node hangs and must hit cntl-break to exit 
});

Answer 1

数组的方法.each不存在，你应该改用.forEach(function (element, index) {...})

Answer 2

使用以下命令：

rows.forEach( function(element, index) {
console.log(element.ID + " " + element.user_nicename);
});

它们当然相似，但存在差异。例如，"forEach"是一个数组方法，但"$.each"可用于任何类型的集合。"forEach"是内置的，而"$.each"需要加载jQuery库。

Answer 3

在这里得到答案：[https://github.com/sidorares/node-mysql2/issues/999[1]。 .forEach，.each或.map的问题在于你位于另一个不是异步函数的函数中，这意味着你不能使用"await"来调用另一个异步例程。

for (let r=0; r < rows.length; ++r) {
console.log(rows[r].ID + " " + rows[r].user_nicename);
await UpdatePassword(connection, rows[r].ID);
}

他还提供了以下替代方案：

一种类似于映射的顺序迭代的"功能"方式(imo 的可读性略低于 for 循环)：

await rows.reduce( async (previousPromise, row) => {
await previousPromise;
return UpdatePassword(row.ID);
}, Promise.resolve());