node集成mysql——pool连接池

安装 mysql

npm install mysql

or

cnpm install mysql

 

创建db.js,实现mysql操作模块

var mysql = require(‘mysql‘);var db = {};var pool = mysql.createPool({ host: ‘localhost‘, port: 3306, user: ‘root‘, password: ‘root‘, database: ‘demo‘});var exec = function (sql, params, callback) { pool.getConnection(function (err, con) { if (err) { callback(err, null, null); } else { if (params === null || params.length == 0) { con.query(sql, function (err, results, fields) { con.release(); callback(err, results, fields); }) } else { con.query(sql, params, function (err, results, fields) { con.release(); callback(err, results, fields); }) } } });}db.exec = exec;module.exports = db;

 

引用

var db = require(‘./db‘);db.exec("select * from table_name",function(err, results, fields){ console.log(results); });

 

相关文章