Nodejs学习笔记-Mysql连接池

安装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

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容