本人最近在学习研究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); });

运行结果

数据库截图:

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。