2

我正在尝试与 nodeJs 服务器和 mysql 数据库聊天。

我决定在这里制作一个模块（名为 Mysqler）：

var mysql = require('mysql');

var Mysqler = function(query) {
    var connection = mysql.createConnection({
            host     : 'localhost',
            user     : 'root',
            password : '',
            database : 'watchat',
        });

    connection.connect();
    Mysqler.prototype.query = function (query) {
        var res = mysql.query(query, function(err, result, fields) {
                console.log(result);
                if (err) throw err;
                else return result;
            });

        console.log(res);
        return res;
    };

};

module.exports.Mysqler = Mysqler

但是当我用我的函数调用它时：

mysql = require("./mysqler");

function connection(clients, socket, data) {
    var username = usefull.deleteBreakLine(data[1]);
    var password = usefull.deleteBreakLine(data[2]);

    var result = mysql.Mysqler("SELECT * FROM Users");
    for (var i in result)
        {
            var user = result[i];
            socket.write(user.username);
        }
}

但是没有任何东西返回到我的结果变量中。当我将 console.log() 放在我的模块中时，没有打印任何内容。

4

2 回答 2

1

也许你可以尝试这样的事情：

var mysql = require('mysql');

var Mysqler = (function() {
    var connection = mysql.createConnection({
            host     : 'localhost',
            user     : 'root',
            password : '',
            database : 'watchat',
        });

    connection.connect();

    return {
        query: function (query,cb) {
            var res = mysql.query(query, function(err, result, fields) {
                console.log(result);
                if (err) throw err;
                else cb(result);
            });
        };
    }

})();

module.exports = Mysqler;

和：

var mysql = require("./mysqler");

function connection(clients, socket, data) {
    var username = usefull.deleteBreakLine(data[1]);
    var password = usefull.deleteBreakLine(data[2]);

    mysql.query("SELECT * FROM Users",function(result){
        for (var i in result)
        {
            var user = result[i];
            socket.write(user.username);
        }
    });

}
于 2012-10-12T20:25:27.690 回答
1
  1. Mysqlquery方法是异步的。您试图从回调返回结果。这是绝对错误的方式。您需要通过将结果作为参数传递给回调函数来返回结果。
  2. 您试图调用对象的方法query而mysql不是connection.
于 2012-10-12T20:14:18.893 回答