//连接数据库池 安装之前是需要安装 npm install -g node-mysql 这个包的 //mysql_mode.js var mysql = require("mysql"); //创建一个连接池的模块 然后导出 function OptPool(){ this.flag = true; this.pool = createPool({ host:'localhost', user:'root', password:'mysql', database:'cms', port:'3306', }) this.getPool = function(){ if(this.flag){ this.pool.on('connection',function(){ // 这是不太完整 connection.query('set session auto_increment_increment') }) } } } module.exports = OptPool;//导出模块 //另起一个页面 引入 var outpool = require("mysql_mode.js"); var optpool = new outpool(); var pool = optpool.getpool(); pool.getConnection(function(err,connection){ //增 var userAddSql = "insert into wp_user(nickname,mobile) values(?,?)"; var param = ['tom','18201262635']; connection.query(userAddSql,param,function(err,res){ if(err){ console.log("错误是"+err.message) }else{ console.log(res) } }) // 查 var select = "select nickname,mobile from wp_user"; connection.query(select,function(err,res){ if(err){ console.log("错误是"+err.message) return; } console.log(res) }) // 改 var update = "update wp_user set nickname=?,mobile=? where uid=2"; var param = ['bob','13492458551']; connection.query(update,param,function(err,res){ if(err){ console.log("错误是"+err.message) return; } console.log(res) }) // 删 var select = "delete from wp_user where uid = 5"; connection.query(select,function(err,res){ if(err){ console.log("错误是"+err.message) return; } console.log(res) }) connection.release()//放回连接池 })
nodejs连接数据库二--连接数据库池
猜你喜欢
转载自blog.csdn.net/enjoy_sun_moon/article/details/80482945
今日推荐
周排行