使用 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 请求中查询数据库没有什么不同。