节点JS异步数据库调用

Question

尽管数据库函数没有返回值,但是在获取节点以进行数据库调用而不进行操作时遇到问题.

这是基本的http服务器代码:

var http = require('http');

http.createServer(function (request, response) {

response.writeHead(200, {
    'Content-Type': 'text/plain',
    'Access-Control-Allow-origin': '*' // implementation of CORS
});

response.end("ok");
;
}).listen(8080,'0.0.0.0');

使用request.on('data')函数,我能够从请求中解码JSON并继续进行数据库调用:

request.on('data', function (chunk) {
    var json = JSON.parse(chunk);
    var id = parseInt(json["id"]);
    response.end(callDatabase(id));
});

数据库函数如下所示:

function callDatabase(id) {
    var result;
    var connection = mysql.createConnection(
        {
            host        :   '192.168.1.14',
            user        :   'root',
            password    :   '',
            database    :   'test'
        }
    );

    connection.connect();
    var queryString = 'SELECT name FROM test WHERE id = 1';

    connection.query(queryString, function(err, rows, fields) {
        if (err) throw err;

        for (var i in rows) {
            result = rows[i].name;
        }
    });
    connection.end();
    return result;
    }
}

然而,在测试中,这证明我做错了.我知道我可能想要使用节点异步模块,我已经厌倦了.我也尝试过使用瀑布方法,以及在线并行和许多其他教程.我觉得request.on函数应该是并行的,然后数据库调用async,所以当node等待来自数据库服务器的响应时,它可以继续使用任何其他请求,将排队时间保持在最低限度.

如果我错过了解节点js的任何概念,请通知我.

Answer 1

result在查询从db返回值之前,您将返回并关闭连接.将该代码放在回调中.

修复你的代码,它应该是这样的:

function callDatabase(id) {
    var result;
    var connection = mysql.createConnection(
        {
            host        :   '192.168.1.14',
            user        :   'root',
            password    :   '',
            database    :   'test'
        }
    );

    connection.connect();
    var queryString = 'SELECT name FROM test WHERE id = 1';

    connection.query(queryString, function(err, rows, fields) {
        if (err) throw err;

        for (var i in rows) {
            result = rows[i].name;
        }

        connection.end();
        return result;
    });
}

虽然,这只会解决部分问题,因为现在您response.end(callDatabase(id));在等待查询响应之前仍在调用.

为了解决这个问题,你需要返回某种回调.

function callDatabase(id, callback) {
    // the method code here...
    connection.query(queryString, function(err, rows, fields) {
        // code...

        // instead of returning the result, invoke the callback!
        callback(rows);
    });
}

现在你可以像这样调用它:

request.on('data', function (chunk) {
    var json = JSON.parse(chunk);
    var id = parseInt(json["id"]);
    callDatabase(id, function(res) {
        response.end(res);
    });
});