本人最近在学习研究nodejs,下面我来记录一下,有需要了解nodejs连接MysqL数据库简单封装的朋友可参考。希望此文章对各位有所帮助。
安装MysqL模块
MysqL
测试是否连接成功
MysqL = require('MysqL');
var connection = MysqL.createConnection({
host : 'localhost',user : 'root',password : '123456',database : 'nodejs'
});
connection.connect();
connection.query('SELECT 1 + 1 AS solution',function(err,rows,fields) {
if (err) {
console.log(err);
return;
};
console.log('The solution is: ',rows[0].solution);
});
connection.end();
结果 : 连接成功
封装连接数据库代码
MysqL = require('MysqL');
var pool = MysqL.createPool({
connectionLimit : 10,host : 'localhost',user : 'root',password : '123456',database : 'nodejs'
});
db.query = function(sql,callback){
if (!sql) {
callback();
return;
}
pool.query(sql,fields) {
if (err) {
console.log(err);
callback(err,null);
return;
};
callback(null,fields);
});
}
module.exports = db;
测试封装
dbtest.js:
MysqL.js');
var sql = 'SELECT count(*) as count from user';
db.query(sql,fields){
if (err) {
console.log(err);
return;
}
console.log('用户数量 : ',rows[0].count);
});
运行结果
数据库截图:
