mysql - query.on 在 Node.js 中不返回任何结果

Question

我正在尝试使用以下代码验证用户:

function validateUser(adminEmailId, adminPassword) {
    try{
        console.log('email id: '+adminEmailId+' password: '+ adminPassword);
        var connection = mysql.createConnection({
                                                host: 'localhost',
                                                user: 'root',
                                                password: 'somePassword',
                                                database: 'someDatabase'
                                                });

        var query = connection.query('select id from AdminData where adminEmail = "'+adminEmailId+'" AND adminPassword = "'+adminPassword+'"');
        console.log('query: ' + query);

        query.on('error', function(error){
                 console.log('A db error occurred: '+error);
                 });
        query.on('result', function(result){
                 console.log('some result: '+ result);
                 if(result.id === null) {
                 console.log('user not found');
                 }
                 else
                 {
                 console.log('user found :)');
                 }
                 });
    }
    catch (ex) {
        console.log('some exception ' + ex);
    }

}

它在控制台中打印的最后两个日志是 -

email id: d@g.com password: gfdgdf 
query: [object Object]

它应该打印 -

user not found 
// OR
user found :)

我尝试通过在命令行中触发来验证 SQL 是否正常运行:

mysql -h127.0.0.1 -uroot -p

它告诉我错误:

Command not found

所以我使用以下命令更新了路径:

export PATH="/usr/local/mysql/bin:$PATH"

然后我可以从命令行使用 mysql，但在 Node.js 代码中仍然没有成功:(

有什么建议吗？

Answer 1

如果您的查询结果没有error 或result 事件，那么这意味着查询结果为空集。您应该监听 end 事件，以便知道查询何时执行完毕。然后您可以在 result 事件处理程序中设置一些条件，您在 end 上检查该事件处理程序以查看是否找到了用户。

可能更简单的方法是将回调传递给 query()，因为在这种情况下您似乎不需要流式传输行。像这样的东西:

connection.query('select id from AdminData where adminEmail = "'+adminEmailId+'" AND adminPassword = "'+adminPassword+'"', function(err, rows) {
    if (err) {
      console.log('A db error occurred: ' + err);
      return;
    }
    if (rows && rows.length)
      console.log('user found :)');
    else
      console.log('user not found');
});

另外我要指出一些其他的事情:

• 您不应将用户提交的数据连接到 SQL 查询字符串中，因为这会使您容易受到 SQL 注入(inject)攻击。您应该至少 对这些值进行转义，但建议使用真正的准备好的语句。 mysql 模块目前不支持真正的准备语句，但 mysql2 支持。 mysql2 与 mysql API 兼容，并且总体上速度更快。
• 您可能应该在 validateUser() 参数列表的末尾有一个回调参数，以便您可以在查询完成时调用回调，从而适本地继续执行您的代码。否则调用 validateUser() 的地方将不知道查询何时结束以及结果是什么。