mysql - 使用 Node.js 和 mySQL

Question

我想使用socket.io从node.js查询mySQL DB， 尽可能模块化的最佳方法是什么？

这就是我到目前为止所做的:(它工作正常，但是有更好的方法吗？)

var app = require('http').createServer(handler)
, io = require('socket.io').listen(app)
, mysql = require('mysql')
, http = require('http');   
var query = "SELECT * FROM table";

app.listen(88);  
io.sockets.on('connection', function (socket) 
{ 
     socket.on('queryReq', function(){queryFunc(query, socket);
});

function queryFunc(query, socket){  
var connection = mysql.createConnection({
  host : 'localhost',
  user : 'admin',
  password : '1234'
});
    connection.query(query, function(err, rows){
    if(err != null) {
        socket.emit("DBnews", "Error in Query: " + err);
    }else{// Shows the results:
    for (var i=0; i<rows.length; i++){
       console.log(rows[i]);
       socket.emit("DBnews", '\n'+JSON.stringify(rows[i]));
    }
    }    
    connection.end();// Close connection
console.log("Disconnected!");
});
}

Answer 1

不要为每个查询持续创建/结束数据库连接。您可以在应用程序启动时连接到数据库，然后在退出时将其关闭[process.on('exit',...)]。除此之外，您的代码看起来适合从套接字事件查询数据库。这实际上与通过 GET 或 POST 请求查询数据库没有什么不同。