mysql - 连接 MYSQL 数据库时出错(NodeJS、socket.io、express)

Question

我和一个 friend 刚刚开始开发一个小应用程序。它使用 NodeJS(以及 Socket.io 和 Express)。我们是 NodeJS 的新手，因此无法真正理解为什么会出现错误。感谢每一寸帮助:)

代码如下:

var express = require('express');
var app = express();
var serv = require('http').Server(app);

app.get('/', function(req, res) {
    res.sendFile(__dirname + '/client/index.html');
});
app.use('/client', express.static(__dirname + '/client'));

serv.listen(2000);
console.log("Server started!");
var io = require('socket.io')(serv,{});


var md5 = require('md5');
var mysql = require('mysql');
var dbconn = mysql.createConnection({
    host: "mySERVER",
    user: "myUSER",
    password: "myPASSWORD",
    database: "myDBNAME"
});


dbconn.connect(function(err) {
    if (err) throw err; //THE ERROR IS THROWN HERE
});

io.sockets.on("connection", function(socket) {

    socket.on("register", function(obj){
        var sql = 'INSERT INTO users (name, password) VALUES ("' + obj.name + '", "' + md5(obj.password) + '")';

        dbconn.query(sql, function (err, result) {
            if (err) throw err;
            console.log("Result: " + result);

        });

    });
});

这是错误消息:

Error: connect ECONNREFUSED mySERVER:3306
at Object.exports._errnoException (util.js:1018:11)
at exports._exceptionWithHostPort (util.js:1041:20)
at TCPConnectWrap.afterConnect [as oncomplete] (net.js:1086:14)
--------------------
at Protocol._enqueue (PROJECTPATH\node_modules\mysql\lib\protocol\Protocol.js:145:48)
at Protocol.handshake (PROJECTPATH\node_modules\mysql\lib\protocol\Protocol.js:52:23)
at Connection.connect (PROJECTPATH\node_modules\mysql\lib\Connection.js:130:18)
at Object.<anonymous> (PROJECTPATH\app.js:32:8)
at Module._compile (module.js:570:32)
at Object.Module._extensions..js (module.js:579:10)
at Module.load (module.js:487:32)
at tryModuleLoad (module.js:446:12)
at Function.Module._load (module.js:438:3)
at Module.runMain (module.js:604:10)

提前谢谢您!

Answer 1

数据库连接错误。你的 mysql 主机和/或端口是错误的。

确保以下代码中传递给 mysq.createConnection 函数的信息正确:

var dbconn = mysql.createConnection({
    host: "mySERVER",
    user: "myUSER",
    password: "myPASSWORD",
    database: "myDBNAME"
});