node-mysql connection.query() returns undefined

node-mysql connection.query() returns undefined

本文关键字：returns undefined connection query node-mysql      更新时间：2023-09-26

我使用的是一个基于einaros/ws构建的节点ws服务器。该服务器必须向数据库发送查询。为此，我使用了felixge/note-mysql。

当用户连接到服务器时，应检查数据库中是否仍存在客户端。

下面是一段有趣的代码：

console.log("client-liste ist leer");
var query = "SELECT name FROM spieler WHERE name='"+id+"' AND passwort='"+passwort+"'";
var result = queryToDatabase(query);
console.log(getTime() + "DB-Result Abfrage: " + result);

以及完成查询的代码：

var mysql = require('mysql');
var mysqlConnection = mysql.createConnection({
    host: dbHost,
    user: dbUser,
    password: dbPassword,
});
function queryToDatabase(anfrage) {
    mysqlConnection.connect();
mysqlConnection.query("USE " + db, function(err, rows, fields) {
    if (err) throw err;
});
mysqlConnection.query(anfrage, function(err, rows, fields) {
        if (err) throw err;
        console.log("rows as String - " + JSON.stringify(rows));
        return rows;
    });
    mysqlConnection.end();
}

控制台中的日志为：

客户端列表3.8.2012-15:29:0-DB结果Abfrage:未定义
行作为字符串-〔｛"name"："lukas"｝〕



有人明白为什么函数返回undefined吗？我也试着用一个简单的setTimout来等待数据库连接完成，但什么都没有改变！

不能从query使用的异步回调中返回值。您需要重写queryToDatabase，以便它将回调作为第二个参数，并在查询成功时使用rows调用它。然后你的主要代码需要看起来像：

queryToDatabase(query, function(result) {
     console.log(getTime() + "DB-Result Abfrage: " + result);
   });

实际上，所有依赖于查询结果的代码都需要进入回调。

在实践中，您希望回调采用两个参数：错误状态和结果，如果查询成功，则错误状态为null。

相关文章：