nodejs连接mysql数据库简单封装示例-mysql模块

2019-11-19 16:52:22

字体：大中小

来源：转载

供稿：网友

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

运行结果