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