本人最近在学习研究nodejs,下面我来记录一下,有需要了解nodejs连接mysql数据库简单封装的朋友可参考。希望此文章对各位有所帮助。
安装mysql模块
npm install mysql
测试是否连接成功
mysql.js代码:
var 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.js:
var db = {}; var 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, function(err, rows, fields) { if (err) { console.log(err); callback(err, null); return; }; callback(null, rows, fields); }); } module.exports = db;
测试封装
dbtest.js:
var db = require('./mysql.js'); var sql = 'SELECT count(*) as count from user'; db.query(sql, function(err, rows, fields){ if (err) { console.log(err); return; } console.log('用户数量 : ', rows[0].count); });
运行结果
数据库截图:
