我正在使用构建在 einaros/ws 上的 Node ws 服务器. 该服务器必须向数据库发送查询。为此,我正在使用 felixge/node-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 - 数据库结果缩写:未定义
行作为字符串 - [{"name":"lukas"}]
有谁明白,为什么函数返回undefined? 我还尝试使用简单的 setTimout 等待数据库连接完成,但没有任何改变!
最佳答案
您不能像 query
使用的那样从异步回调中返回值。您需要重写 queryToDatabase,使其将回调作为其第二个参数,并在查询成功时使用 rows
调用它。那么您的主要代码需要如下所示:
queryToDatabase(query, function(result) {
console.log(getTime() + "DB-Result Abfrage: " + result);
});
实际上,所有依赖于查询结果的代码都需要进入该回调。
实际上,您希望回调采用两个参数:错误状态 和结果,错误状态为null
如果查询成功。
关于javascript - node-mysql connection.query() 返回未定义,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11796823/