nodejs进阶(6)—连接MySQL数据库示例
更新时间：2017年01月07日 16:01:29 作者：方帅
本篇文章主要介绍了nodejs进阶(6)—连接MySQL数据库示例，详细的介绍了NodeJS操作MySQL数据库，作为应用最为广泛的开源数据库则成为我们的首选，有兴趣的可以了解一下。
1. 建库连库
连接MySQL数据库需要安装支持
npm install mysql
我们需要提前安装按mysql sever端
建一个数据库mydb1
mysql> CREATE DATABASE mydb1; mysql> SHOW DATABASES; +--------------------+ | Database | +--------------------+ | information_schema | | mysql | | mydb1 | | performance_schema | +--------------------+ 4 rows in set (0.00 sec)
然后建一张表user如下
create table user( id int not null primary key auto_increment, name VARCHAR(100) not null, pwd VARCHAR(100) not null, create_date TIMESTAMP NULL DEFAULT now() )ENGINE=InnoDB DEFAULT CHARSET=utf8; CREATE UNIQUE INDEX t_quiz_IDX_0 on user(name);
接下来我们利用nodejs连接mysql数据库
var mysql = require('mysql'); //调用MySQL模块
//创建一个connection
var connection = mysql.createConnection({
host: 'localhost', //主机
user: 'root', //MySQL认证用户名
password: 'root', //MySQL认证用户密码
database: 'mydb1',
port: '3306' //端口号
});
//创建一个connection
connection.connect(function(err){
if(err){
console.log('[query] - :'+err);
return;
}
console.log('[connection connect] succeed!');
});
//----插入
var userAddSql = 'insert into user (name,pwd) values(?,?)';
var param = ['fff','123'];
connection.query(userAddSql,param,function(err,rs){
if(err){
console.log('insert err:',err.message);
return;
}
console.log('insert success');
});
//执行查询
connection.query('SELECT * from user where id=?',[2], function(err, rs) {
if (err) {
console.log('[query] - :'+err);
return;
}
for(var i=0;i<rs.length;i++){
console.log('The solution is: ', rs[i].uname);
}
});
//关闭connection
connection.end(function(err){
if(err){
console.log(err.toString());
return;
}
console.log('[connection end] succeed!');
});
但是实际每次创建连接都需要一定的开销，执行效率就会有影响。下面介绍一种连接池连mysql的方法：node-mysql
2. 连接池配置使用
node-mysql是目前最火的node下的mysql驱动，是mysqlpool的一个模块。
下面的代码是提供一个连接池，getPool函数返回createPool创建的数据库连接池对象。
var mysql = require('mysql'); //调用MySQL模块
function OptPool(){
this.flag=true; //是否连接过
this.pool = mysql.createPool({
host: 'localhost', //主机
user: 'root', //MySQL认证用户名
password: 'root', //MySQL认证用户密码
database: 'test',
port: '3306' //端口号
});
this.getPool=function(){
return this.pool;
}
};
module.exports = OptPool;
下面的代码展示如何使用这个连接池，插入和查询的使用。需要注意的是conn.release(); //释放一个连接放回连接池 需要再操作结束后再执行，否则后面的数据库操作会报错。
var OptPool = require('./models/OptPool');
var optPool = new OptPool();
var pool = optPool.getPool();
//执行SQL语句
//从连接池中获取一个连接
pool.getConnection(function(err,conn){
//----插入
var userAddSql = 'insert into user (uname,pwd) values(?,?)';
var param = ['eee','eee'];
conn.query(userAddSql,param,function(err,rs){
if(err){
console.log('insert err:',err.message);
return;
}
console.log('insert success');
//conn.release(); //放回连接池
})
//查询
conn.query('SELECT * from user', function(err, rs) {
if (err) {
console.log('[query] - :'+err);
return;
}
for(var i=0;i<rs.length;i++){
console.log(rs[i].uname);
}
conn.release(); //放回连接池
});
});
下面介绍一个复杂一点的增删查改的数据库操作，因相互之间有依赖，所以代码可读性就变得特别差。
var OptPool = require('./models/OptPool');
var optPool = new OptPool();
var pool = optPool.getPool();
var insertSQL = 'insert into table1(name,pwd) values("conan","123"),("fens.me","456")';
var selectSQL = 'select * from table1 limit 10';
var deleteSQL = 'delete from table1';
var updateSQL = 'update table1 set name="conan update" where name="conan"';
pool.getConnection(function(err,conn){
//delete
conn.query(deleteSQL, function (err0, res0) {
if (err0) console.log(err0);
console.log("DELETE Return ==> ");
console.log(res0);
//insert
conn.query(insertSQL, function (err1, res1) {
if (err1) console.log(err1);
console.log("INSERT Return ==> ");
console.log(res1);
//query
conn.query(selectSQL, function (err2, rows) {
if (err2) console.log(err2);
console.log("SELECT ==> ");
for (var i in rows) {
console.log(rows[i]);
}
//update
conn.query(updateSQL, function (err3, res3) {
if (err3) console.log(err3);
console.log("UPDATE Return ==> ");
console.log(res3);
//query
conn.query(selectSQL, function (err4, rows2) {
if (err4) console.log(err4);
console.log("SELECT ==> ");
for (var i in rows2) {
console.log(rows2[i]);
}
});
});
});
});
});
})
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
这篇文章主要为大家介绍了详解如何使用Node.js连接数据库ORM示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-12-12
node作为中间服务层如何发送请求(发送请求的实现方法详解)
node作为中间服务层如何发送请求？下面小编就为大家分享一下发送请求的实现方法，具有很好的参考价值，希望对大家有所帮助2018-01-01
windows 下安装nodejs 了,也安装了npm, 但是有时候切不能直接用request(‘ws’)这一类的东西.我觉得是确实环境变量或其他设置有问题,能否给个完整的设置方案:2017-02-02
这篇文章主要介绍了Node.js 操作本地文件及深入了解fs内置模块，node.js作为服务端应用，肯定少不了对本地文件的操作，像创建一个目录、创建一个文件、读取文件内容等都是我们开发中经常需要用到的功能2022-09-09
这篇文章主要介绍了Nodejs excel(.xlsx) 文件的读写方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-09-09
node gyp安装canvas原生模块编译node pregyp详解
这篇文章主要为大家介绍了Nodejs关于原生模块编译node-gyp + node-pre-gyp (以安装canvas为例)示例详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2022-11-11
这篇文章主要介绍了nodejs中转换URL字符串与查询字符串详解,需要的朋友可以参考下2014-11-11
这篇文章主要介绍了Nodejs处理Json文件并将处理后的数据写入新文件中，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-10-10
node.js的http.createServer过程深入解析
这篇文章主要给大家介绍了关于node.js的http.createServer过程的相关资料，文中通过示例代码介绍的非常详细，对大家学习或者使用node.js具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧2019-06-06
这篇文章主要介绍了使用Node.js构建微服务,将介绍微服务架构、优势以及如何使用Node.js开发微服务，需要的朋友可以参考下2022-08-08
最新评论