Node.js MySQL连接池化

Question

我正在使用node-mysql模块(https://github.com/felixge/node-mysql)或(http://utahjs.com/2010/09/22/nodejs-and-mysql-introduction/)。

这个API是否也处理连接池呢？

我的意思是，每个用户请求都会调用Client.connect()来查询MySQL并释放连接：Client.end()。

这样做正确吗，还是应该在代码中仅连接/断开一次？

我是从这份文档中学习的：https://github.com/felixge/node-mysql/blob/master/Readme.md

- Omer Aslam

Answer 1

更新：2013年2月 - node-mysql 已添加了连接池支持，请参阅文档

使用内置连接池的示例：

var pool = require('mysql').createPool(opts);

pool.getConnection(function(err, conn) {
  conn.query('select 1+1', function(err, res) {
    conn.release();
  });
});

2013年之前的解决方案:

你可以使用node-pool或mysql-pool，或者使用自己编写的简单轮询池。

function Pool(num_conns)
{
    this.pool = [];
    for(var i=0; i < num_conns; ++i)
        this.pool.push(createConnection()); // your new Client + auth
    this.last = 0;
}

Pool.prototype.get = function()
{
    var cli = this.pool[this.last];
    this.last++;
    if (this.last == this.pool.length) // cyclic increment
       this.last = 0;
    return cli;
}

现在你可以希望所有查询回调在1秒钟内执行：

var p = new Pool(16);
for (var i=0; i < 10; ++i)
{
    p.get().query('select sleep(1)', function() { console.log('ready'); } ); // server blocks for 1 second
}

- Andrey Sidorov

---

Andrey，您是否介意在此更新您已接受的答案。node-mysql现在支持连接池。 - Manatax

Answer 2

我相信同样的node-mysql包提供了连接池。可以看一下。

var express   =    require("express");
var mysql     =    require('mysql');
var app       =    express();

var pool      =    mysql.createPool({
    connectionLimit : 100, //important
    host     : 'localhost',
    user     : 'root',
    password : '',
    database : 'address_book',
    debug    :  false
});

function handle_database(req,res) {

    pool.getConnection(function(err,connection){
        if (err) {
          connection.release();
          res.json({"code" : 100, "status" : "Error in connection database"});
          return;
        }   

        console.log('connected as id ' + connection.threadId);

        connection.query("select * from user",function(err,rows){
            connection.release();
            if(!err) {
                res.json(rows);
            }           
        });

        connection.on('error', function(err) {      
              res.json({"code" : 100, "status" : "Error in connection database"});
              return;     
        });
  });
}

app.get("/",function(req,res){-
        handle_database(req,res);
});

app.listen(3000);

阅读完整的案例研究（有和没有池）: http://codeforgeek.com/2015/01/nodejs-mysql-tutorial/

该案例涉及IT技术，介绍了如何在Node.js中使用MySQL数据库。如果您对此感兴趣，可以点击链接查看完整的案例研究。

- Shaikh Shahid

---

如何在路由中重用代码，例如carvendor.js或customers.js！因为上面的代码仅用于概念验证，而不是生产就绪实现，在生产就绪环境中，没有人会在app.js文件中编写所有功能。 - Rizwan Patel

我处理了下面的场景，来自以下堆栈网址http://stackoverflow.com/a/26552965/1333794。 - Rizwan Patel

如果在获取连接时出现错误，为什么要释放连接？ - Awadesh