Node.js MySQL 查询无法将 MySQL 结果分配给变量

Question

我正在尝试将 MySQL 查询结果分配给一个变量，然后在脚本中多次使用它。我想这样做是因为我有 PHP 背景并且我喜欢以这种方式工作。我知道 Node.js 是异步工作的，所以这是我的问题。

在下面的代码中，我想将 MySQL 结果分配给 sql_results 变量，但 connection.query 函数异步工作并且代码以不同的顺序工作。在这种情况下，在我的代码末尾console.log(sql_results) 它返回我undefined。这是正常的，因为当我检查控制台输出时，我清楚地看到 console.log(sql_results) 在 console.log(results) 之前工作。

var mysql = require('mysql');

var connection = mysql.createConnection({
  host: "localhost",
  user: "root",
  password: "1234",
  database: "db_progress"
});

var sql_query = "SELECT * FROM db_progress.tblresults res WHERE res.id < 3";
var sql_results; // This is my variable

connection.connect();

connection.query(sql_query, function (error, results, fields) {
  if (error) throw error;
  console.log(results); // This is mysql results
  sql_results = results; // I am sure this works but I can't see
});

connection.end();

console.log(sql_results); // This returns undefined because works before query

我如何将 MySQL 结果分配给一个变量，或者是否有不同的方法用于此目的。请详细说明。

谢谢。

Answer 1

Node js 函数以异步方式工作，因此我建议您将查询与 promise 一起使用。

class Database {
            constructor( config ) {
                this.connection = mysql.createConnection( config );
            }
            query( sql, args ) {
                return new Promise( ( resolve, reject ) => {
                    this.connection.query( sql, args, ( err, rows ) => {
                        if ( err )
                            return reject( err );
                        resolve( rows );
                    } );
                } );
            }
            close() {
                return new Promise( ( resolve, reject ) => {
                    this.connection.end( err => {
                        if ( err )
                            return reject( err );
                        resolve();
                    } );
                } );
            }
        }

Answer 2

可能会尝试替换此代码，

connection.query(sql_query, function (error, results, fields) {
  if (error) throw error;
  console.log(results); // This is mysql results
  sql_results = results; // I am sure this works but I can't see
});

connection.end();

有了这个，

connection.query(sql_query)
    .then( results=> {
        sql_results = results;
        return connection.close();
    } );

Danmoreng 已经提到了关于Promises 和async/await 的文章。他们将帮助您了解上述代码的工作原理。

Answer 3

您的查询结果将在回调函数中返回，该函数在调用代码之后执行。在设置 sql_results 之前，您正在调用代码的上下文中记录结果。

试试这个：

var mysql = require('mysql');

var connection = mysql.createConnection({
  host: "localhost",
  user: "root",
  password: "1234",
  database: "db_progress"
});

var sql_query = "SELECT * FROM db_progress.tblresults res WHERE res.id < 3";
var sql_results; // This is my variable

connection.connect();

connection.query(sql_query, function (error, results, fields) {
  if (error) throw error;
  console.log(results); // This is mysql results
  sql_results = results; // I am sure this works but I can't see
  console.log(sql_results);
});

connection.end();