Node-mysql 无法正常工作...需要调试思路

Question

我是第一次使用node-mysql，我有一个程序没有错误，没有警告，但是不能正常工作......这是程序的代码，很简单：

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database:  'nodetest',
  port: 8080
});

connection.connect();
var usr = "BLASHDASD"
var userId = usr;
var sql = 'UPDATE userlist SET user1= ' + connection.escape(userId) + ' WHERE id=1 ';
console.log(sql);

connection.query('sql', function(err, rows, fields) {
  console.log(err);
  console.log("BLAHSDBKASD");
});

connection.end();

这是控制台输出：

C:\wamp\www\nodePHP-master\js>node nodeTest.js
UPDATE userlist SET user1= 'BLASHDASD' WHERE id=1

但是我的 MySQL 表中什么都没有发生...我什至复制并粘贴了上面的 UPDATE 行，然后将其作为 SQL 代码运行，它运行良好...需要一些关于正在发生的事情的想法。非常感谢

编辑：

回答了我自己的问题...正在侦听错误的端口，因此连接失败。下面是更新后的代码供有兴趣/搜索的人参考：

//TEST

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '',
  database:  'nodetest',
  port: 3306,
});

connection.connect(function(err){
    if(err) {
        console.log(err)
    } else {
        console.log("connected");
    }
});
var usr = "BLASHDASD"
var userId = usr;
var sql = 'UPDATE userlist SET user1= ' + connection.escape(userId) + ' WHERE id=1 ';
console.log(sql);

connection.query(sql, function(err, rows, fields) {
  console.log(err);
});

connection.end();

Answer 1

您遇到了 node 的异步特性问题，这是使用 Node.js 时非常常见的问题。您的代码中还有一个小但重要的错误（您将 'sql' 作为引号字符串），但这里有一些结构相似的内容，应该为您指明正确的方向。

var mysql      = require('mysql');
var connection = mysql.createConnection({
    host     : 'locahost',
    user     : 'foo',
    password : 'bar',
    database : 'test'
});

// the callback inside connect is called when the connection is good
connection.connect(function(err){
    var sql = "select 'Joe' as name from dual";

    connection.query(sql, function(err, rows, fields) {
        if (err) return console.log(err);
        //  you need to end your connection inside here.
        connection.end();
        console.log(rows[0].name);
    });
});

您可能会开始想知道如何避免所有这些回调。您可能希望查看我对this question 的回答，以获得更扩展的 mysql 示例以及提供回调狂热的替代方案的替代实现。