重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
本人最近在学习研究nodejs,下面我来记录一下,有需要了解nodejs连接MySQL数据库简单封装的朋友可参考。希望此文章对各位有所帮助。
创新互联建站成立于2013年,我们提供高端成都网站建设、网站制作、网站设计、网站定制、营销型网站建设、微信小程序开发、微信公众号开发、成都网站营销服务,提供专业营销思路、内容策划、视觉设计、程序开发来完成项目落地,为成都PVC花箱企业提供源源不断的流量和订单咨询。
安装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); });
运行结果
数据库截图:
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持创新互联。