安裝mysqlpool模塊

npm install -g node-mysql

代碼

https://github.com/fengchunjian/nodejs_examples/tree/master/mysql

//models/OptPool.js
var mysql = require("mysql");

function OptPool() {
    this.flag = false;
    this.pool = mysql.createPool({
        host : "localhost",
        user : "root",
        password : "123456",
        database : "test",
        port : "3306"
    });

    this.getPool = function() {
        if (!this.flag) {
            this.pool.on("connection", function(connection) {
                connection.query("SET SESSION auto_increment_increment=1");
                this.flag = true;
            });
        }
        return this.pool;
    }
}

module.exports = OptPool;

//mysqlPool.js
var OptPool = require("./models/OptPool");

var optPool = new OptPool();
var pool = optPool.getPool();

pool.getConnection(function(err, conn) {
    var userAddSql = "insert into user(uname, pwd) values(?, ?)";
    var param = ["eee", "eee"];
    conn.query(userAddSql, param, function(err, rs) {
        if (err) {
            console.log("insert failed:" + err);
            return;
        }
        console.log("insert ok");
    });

    conn.query("select * from user", function(err, rs) {
        if (err) {
            console.log("select failed:" + err);
            return;
        }

        for (var i=0; i<rs.length; i++) {
            console.log(rs[i].uname);
        }

        conn.release();
    });
});

參考文檔

node.js教程15_連接池連mysql
http://edu.51cto.com/center/course/lesson/index?id=124541
nodejs_連接池連mysql(n15_mysqlPool)
http://www.yuankuwang.com/web/index.php?r=respool/resview&rpid=49