node-mysql_Nodejs与MySQL交互（felixge/node-mysql）
简介和安装
我选择了felixge/node-mysql，用的人比较多，先随大溜看看它的使用，暂时没有太过纠结于各库之间的执行性能问题，对其它库有研究的筒子也可以分享一下性能要求较高时的选择^_^!
This is a node.js driver for mysql. It is written in JavaScript, does not require compiling, and is 100% MIT licensed
用纯JavaScript实现。MIT 100%!
安装
npm install mysql
注意：安装前先把目录cd到node.exe所在目录下，这样执行安装命令时，会找到目录下node_modules，并安装在此目录下，否则使用mysql时，你会出现 Error: Cannot find module 'mysql'
测试MySQL
MySQL版本：5.5
在官方示例的基础下修改一下并测试：
var mysql = require('mysql'); //调用MySQL模块
//创建一个connection
var connection = mysql.createConnection({
host : '192.168.0.200', //主机
user : 'root', //MySQL认证用户名
password : 'abcd', //MySQL认证用户密码
port: '3306', //端口号
});
//创建一个connection
connection.connect(function(err){
if(err){
console.log('[query] - :'+err);
return;
}
console.log('[connection connect] succeed!');
});
//执行SQL语句
connection.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {
if (err) {
console.log('[query] - :'+err);
return;
}
console.log('The solution is: ', rows[0].solution);
});
//关闭connection
connection.end(function(err){
if(err){
return;
}
console.log('[connection end] succeed!');
});
测试示例源码
var mysql = require('mysql'); //调用MySQL模块
//创建一个connection
var connection = mysql.createConnection({
host : '192.168.0.200', //主机
user : 'root', //MySQL认证用户名
password : 'abcd', //MySQL认证用户密码
port: '3306', //端口号
});
//创建一个connection
connection.connect(function(err){
if(err){
console.log('[query] - :'+err);
return;
}
console.log('[connection connect] succeed!');
});
//执行SQL语句
connection.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {
if (err) {
console.log('[query] - :'+err);
return;
}
console.log('The solution is: ', rows[0].solution);
});
//关闭connection
connection.end(function(err){
if(err){
return;
}
console.log('[connection end] succeed!');
});
成功执行！
认识一下Connection Options
要想创建一个数据库连接，先就要认识清楚Options
host：主机地址 (默认：localhost)
user：用户名
password：密码
port：端口号 (默认：3306)
database：数据库名
charset：连接字符集(默认：'UTF8_GENERAL_CI'，注意字符集的字母都要大写)
localAddress：此IP用于TCP连接(可选)
socketPath：连接到unix域路径，当使用 host 和 port 时会被忽略
timezone：时区(默认：'local')
connectTimeout：连接超时(默认：不限制；单位：毫秒)
typeCast：是否将列值转化为本地JavaScript类型值 (默认：true)
supportBigNumbers：数据库支持bigint或decimal类型列时，需要设此option为true (默认：false)
bigNumberStrings：supportBigNumbers和bigNumberStrings启用 强制bigint或decimal列以JavaScript字符串类型返回(默认：false)
dateStrings：强制timestamp,datetime,data类型以字符串类型返回，而不是JavaScript Date类型(默认：false)
debug：开启调试(默认：false)
multipleStatements：是否许一个query中有多个MySQL语句 (默认：false)
ssl：使用ssl参数(与crypto.createCredenitals参数格式一至)或一个包含ssl配置文件名称的字符串，目前只捆绑Amazon RDS的配置文件
其它：
可以使用URL形式的加接字符串，不多介绍了，不太喜欢那种格式，觉得可读性差，也易出错，想了解的可以去主页上看。
MYSQL CURD
首先创建一个测试数据库nodesample，在数据库中建一个userinfo表
CREATE DATABASE IF NOT EXISTS nodesample CHARACTER SET UTF8;
USE nodesample;
SET FOREIGN_KEY_CHECKS=0;
DROP TABLE IF EXISTS `userinfo`;
CREATE TABLE `userinfo` (
`Id` int(11) NOT NULL AUTO_INCREMENT COMMENT '主键',
`UserName` varchar(64) NOT NULL COMMENT '用户名',
`UserPass` varchar(64) NOT NULL COMMENT '用户密码',
PRIMARY KEY (`Id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户信息表';
1.向UserInfo表中插入一条数据
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userAddSql = 'INSERT INTO userinfo(Id,UserName,UserPass) VALUES(0,?,?)';
var userAddSql_Params = ['Wilson', 'abcd'];
//增
connection.query(userAddSql,userAddSql_Params,function (err, result) {
if(err){
console.log('[INSERT ERROR] - ',err.message);
return;
}
console.log('--------------------------INSERT----------------------------');
//console.log('INSERT ID:',result.insertId);
console.log('INSERT ID:',result);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
插入示例源码
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userAddSql = 'INSERT INTO userinfo(Id,UserName,UserPass) VALUES(0,?,?)';
var userAddSql_Params = ['Wilson', 'abcd'];
//增
connection.query(userAddSql,userAddSql_Params,function (err, result) {
if(err){
console.log('[INSERT ERROR] - ',err.message);
return;
}
console.log('--------------------------INSERT----------------------------');
//console.log('INSERT ID:',result.insertId);
console.log('INSERT ID:',result);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
从执行结果可以看出，result中包含一些有用的信息，affectedRows(受影响的行数) insertId(插入的主键ID)等等。。。
有受影响的行数和插入数据的ID，就可以很方便进行后续的一些操作(比如判断是否成功或者继续根据插入数据的ID进行其它操作)
下面，我去数据库服务器中使用Navicate for MySQL工具查询一下UserInfo表
插入成功！
2.更新1操作中插入的数据信息
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userModSql = 'UPDATE userinfo SET UserName = ?,UserPass = ? WHERE Id = ?';
var userModSql_Params = ['钟慰', '5678',1];
//改
connection.query(userModSql,userModSql_Params,function (err, result) {
if(err){
console.log('[UPDATE ERROR] - ',err.message);
return;
}
console.log('--------------------------UPDATE----------------------------');
console.log('UPDATE affectedRows',result.affectedRows);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
更新示例源码
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userModSql = 'UPDATE userinfo SET UserName = ?,UserPass = ? WHERE Id = ?';
var userModSql_Params = ['钟慰', '5678',1];
//改
connection.query(userModSql,userModSql_Params,function (err, result) {
if(err){
console.log('[UPDATE ERROR] - ',err.message);
return;
}
console.log('--------------------------UPDATE----------------------------');
console.log('UPDATE affectedRows',result.affectedRows);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
从返回受影响行数来看，更新应该是正确的，下面我们用一个SELECT查询示例去验证更新是否成功！
3.查询
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userGetSql = 'SELECT * FROM userinfo';
//查
connection.query(userGetSql,function (err, result) {
if(err){
console.log('[SELECT ERROR] - ',err.message);
return;
}
console.log('--------------------------SELECT----------------------------');
console.log(result);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
查询示例源码
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userGetSql = 'SELECT * FROM userinfo';
//查
connection.query(userGetSql,function (err, result) {
if(err){
console.log('[SELECT ERROR] - ',err.message);
return;
}
console.log('--------------------------SELECT----------------------------');
console.log(result);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
从查询出来的结果可以看出，result返回了一个JSON格式的数据，同时表示第二步中更新是成功!
4.删除
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userDelSql = 'DELETE FROM userinfo';
//删
connection.query(userDelSql,function (err, result) {
if(err){
console.log('[DELETE ERROR] - ',err.message);
return;
}
console.log('--------------------------DELETE----------------------------');
console.log('DELETE affectedRows',result.affectedRows);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
删除示例源码
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample',
});
connection.connect();
var userDelSql = 'DELETE FROM userinfo';
//删
connection.query(userDelSql,function (err, result) {
if(err){
console.log('[DELETE ERROR] - ',err.message);
return;
}
console.log('--------------------------DELETE----------------------------');
console.log('DELETE affectedRows',result.affectedRows);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
去数据库服务器里查询看一下
查询userinfo表中已没有数据，删除成功！
到此Node.js结合MySQL的增、删、改、查操作应会部完成了！
Nodejs 调用带out参数的存储过程，并得到out参数返回值
Nodejs调用存储过程没什么特别，只是调用带out参数存储过程并得到out参数返回值可能有些人比较疑惑，下面用个示例来介绍一下
先创建一个带out参数的存储过程 P_UserInfo
-- ----------------------------
-- Procedure structure for `P_UserInfo`
-- ----------------------------
DROP PROCEDURE IF EXISTS `P_UserInfo`;
DELIMITER ;;
CREATE DEFINER=`root`@`localhost` PROCEDURE `P_UserInfo`(IN ExtId INT,IN ExtUserName VARCHAR(64),IN ExtUserPass VARCHAR(64),OUT ExtReturnVal INT)
TOP: BEGIN
DECLARE EXIT HANDLER FOR SQLEXCEPTION
BEGIN
ROLLBACK;
SET ExtReturnVal = 0; -- Failed
END;
START TRANSACTION;
INSERT INTO userinfo(Id,UserName,UserPass) VALUES(ExtId,ExtUserName,ExtUserPass);
SET ExtReturnVal = 1;
SELECT ExtReturnVal;
COMMIT;
END
;;
DELIMITER ;
下面，来写个示例来调用
var mysql = require('mysql');
var connection = mysql.createConnection({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample'
});
connection.connect();
var userProc = 'call P_UserInfo(?,?,?,@ExtReturnVal);';
var userProc_Params = [0,'Wilson Z','abcd'];
//调用存储过程
connection.query(userProc,userProc_Params,function (err, retsult) {
if(err){
console.log('[EXEC PROC ERROR] - ',err.message);
return;
}
console.log('--------------------------PROC----------------------------');
console.log(retsult);
console.log(retsult[0][0].ExtReturnVal);
console.log('-----------------------------------------------------------------\n\n');
});
connection.end();
去数据为中看一下
在表中正确插入此数据，而且正确的得到了out参数的值，细心的可能会发现我存储过程中在SET ExtReturnVal = 1表示成功后，多了一句SELECT ExtReturnVal;
这样就可以通地查询得到out参数的值了！(有别的方法可以分享一下^_^!)
结束数据库连接两种方法和区别
前面的示例中我在结尾处都会调用一个connection.end()方法,这个方法connection.connect()对应，一个开始，一个结束！
结束连接其实有两种方法end()，destory()；
end()
end()方法在queries都结束后执行，end()方法接收一个回调函数，queries执行出错，仍然后结束连接，错误会返回给回调函数err参数，可以在回调函数中处理！
destory()
比较暴力，没有回调函数，即刻执行，不管queries是否完成！
连接池Pooling connections
1.连接池的创建，使用createPool方法，options和createConntion一致，可以监听connection事件。
var mysql = require('mysql');
//创建连接池
var pool = mysql.createPool({
host : '192.168.0.200',
user : 'root',
password : 'abcd'
});
//监听connection事件
pool.on('connection', function(connection) {
connection.query('SET SESSION auto_increment_increment=1');
});
连接池可以直接使用，也可以共享一个连接或管理多个连接(引用官方示例)
//直接使用
pool.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {
if (err) throw err;
console.log('The solution is: ', rows[0].solution);
});
//共享
pool.getConnection(function(err, connection) {
// connected! (unless `err` is set)
});
2.其它连接池配置选项
waitForConnections
当连接池没有连接或超出最大限制时，设置为true且会把连接放入队列，设置为false会返回error
connectionLimit
连接数限制，默认：10
queueLimit
最大连接请求队列限制，设置为0表示不限制，默认：0
3.释放
调用connection.release()方法，会把连接放回连接池，等待其它使用者使用!
4.使用示例
var mysql = require('mysql');
var pool = mysql.createPool({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample'
});
pool.getConnection(function(err, connection) {
connection.query( 'SELECT * FROM userinfo;', function(err, result) {
console.log(result);
connection.release();
});
connection.query( 'SELECT * FROM userinfo;', function(err, result) {
console.log(result);
connection.release();
});
});
连接池使用示例源码
var mysql = require('mysql');
var pool = mysql.createPool({
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample'
});
pool.getConnection(function(err, connection) {
connection.query( 'SELECT * FROM userinfo;', function(err, result) {
console.log(result);
connection.release();
});
connection.query( 'SELECT * FROM userinfo;', function(err, result) {
console.log(result);
connection.release();
});
});
在实际开发过程中，应该还是使用连接池的方式比较好！
断线重连
数据库可以因为各种原因导致连接不上，这种就必须有重连接机制！
主要判断errorcode:PROTOCOL_CONNECTION_LOST
1.首先去数据库服务器停止MySQL服务
2.运行断线重连代码
代码中在error事件中，判断返回errorcode是否为：PROTOCOL_CONNECTION_LOST ，如果是用setTimeout定时2秒重连！
从执行结果可以看出，大约2-3秒会输出重连输出信息，不断在尝试重新连接！
3.去数据为服务器，开启mysql服务器，再看看执行结果
当数据库服务器mysql服务重新启动后，执行结果输出连接成功，不再输出断线重连日志^_^!
var mysql = require('mysql');
var db_config = {
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample'
};
var connection;
function handleDisconnect() {
connection = mysql.createConnection(db_config);
connection.connect(function(err) {
if(err) {
console.log("进行断线重连：" + new Date());
setTimeout(handleDisconnect, 2000); //2秒重连一次
return;
}
console.log("连接成功");
});
connection.on('error', function(err) {
console.log('db error', err);
if(err.code === 'PROTOCOL_CONNECTION_LOST') {
handleDisconnect();
} else {
throw err;
}
});
}
handleDisconnect();
断线重连示例源码
var mysql = require('mysql');
var db_config = {
host : '192.168.0.200',
user : 'root',
password : 'abcd',
port: '3306',
database: 'nodesample'
};
var connection;
function handleDisconnect() {
connection = mysql.createConnection(db_config);
connection.connect(function(err) {
if(err) {
console.log("进行断线重连：" + new Date());
setTimeout(handleDisconnect, 2000); //2秒重连一次
return;
}
console.log("连接成功");
});
connection.on('error', function(err) {
console.log('db error', err);
if(err.code === 'PROTOCOL_CONNECTION_LOST') {
handleDisconnect();
} else {
throw err;
}
});
}
handleDisconnect();
其它...
１. escape()
防止SQL注入，可以使用pool.escape()和connect.escape()，不多说了，自已可以试试，我提供一个示例
var mysql = require('mysql');
var pool = mysql.createPool({
host: '192.168.0.200',
user: 'root',
password:'abcd',
port:'3306',
database:'nodesample'
});
pool.getConnection(function(err,connection){
connection.query('SELECT * FROM userinfo WHERE id = ' + '5 OR ID = 6',function(err,result){
//console.log(err);
console.log(result);
connection.release();
});
connection.query('SELECT * FROM userinfo WHERE id = ' + pool.escape('5 OR ID = 6') ,function(err,result){
//console.log(err);
console.log(result);
connection.release();
});
})
escape() 示例源码
var mysql = require('mysql');
var pool = mysql.createPool({
host: '192.168.0.200',
user: 'root',
password:'abcd',
port:'3306',
database:'nodesample'
});
pool.getConnection(function(err,connection){
connection.query('SELECT * FROM userinfo WHERE id = ' + '5 OR ID = 6',function(err,result){
//console.log(err);
console.log(result);
connection.release();
});
connection.query('SELECT * FROM userinfo WHERE id = ' + pool.escape('5 OR ID = 6') ,function(err,result){
//console.log(err);
console.log(result);
connection.release();
});
})
结果可以看出，第1个query拼接条件可以被执行，而通过escape方法转义后的忽略了后面的拼接的部分！
大家可以看到我前面用的？占位的方式，简单的试了一下，好处并没有这种危险，这里就不提供示例了，在我上面提供的代码上改一下就可以试出来^_^!
2.mysql.escapeId(identifier)
如果不能信任由用户提示的SQL标识符(数据库名，列名，表名)，可以使用此方法，官方提供有示例(最常见的是通过列名来排序什么的...)
3.mysql.format
准备查询，该函数会选择合适的转义方法转义参数
....
还有一些安全相关的方法可以自行查看一下官方说明
本次也未讲到连接池集群，以后有时间再把这次漏掉的一些补一篇当提高篇吧，现在基础的和MySQL交互应该问题不大了^_^!
node-mysql_Nodejs与MySQL交互（felixge/node-mysql）相关推荐
- 〖Python 数据库开发实战 - Python与MySQL交互篇③〗- MySQL Connector的事务控制与异常处理
订阅 Python全栈白宝书-零基础入门篇 可报销!白嫖入口-请点击我.推荐他人订阅,可获取扣除平台费用后的35%收益,文末名片加V! 说明:该文属于 Python全栈白宝书专栏,免费阶段订阅数量43 ...
- 〖Python 数据库开发实战 - Python与MySQL交互篇⑤〗- MySQL Connector 模块的删除数据
万叶集
- js mysql query_node.js的mysql模块query方法里的字符串拼接问题
我写了一个和mysql交互的Node.js.大致功能是,在浏览器端提交用户信息表单后,会在现有的表userInfo里插入一条用户记录:然后针对这条用户记录自动再生成一个表,该表的名称是根据这条记录的i ...
- 性能追击：万字长文30+图揭秘8大主流服务器程序线程模型 | Node.js,Apache,Nginx,Netty,Redis,Tomcat,MySQL,Zuul
本文为<高性能网络编程游记>的第六篇"性能追击:万字长文30+图揭秘8大主流服务器程序线程模型". 最近拍的照片比较少,不知道配什么图好,于是自己画了一个,凑合着用,让 ...
- Node.js数据库与身份验证（MySQL，前后端身份认证：Session 认证机制，JWT认证机制）
目录 MySQL SQL 语句语法 where 条件.and 和 or 运算符.order by 排序.count(*) 函数 在express项目中操作 MySQL 安装与配置 mysql 模块 1 ...
- node与mysql开源_node与mysql的相互使用————node+mysql
node与mysql的相互使用----node+mysql 为什么选node???因为我是个前端. 为什么选mysql???因为成熟,稳定,听说容易学. 一.mysql数据库: mysql下载和使用我 ...
- mysql语句在node.js中的写法
总结一下mysql语句在node.js中的各种写法,参考了npm网站mysql模块给的实例. 查询 select //1 db.query('select * from tuanshang_users ...
- node php mysql 性能_使用mysql池对node.js(集群)的性能进行基准测试：Lighttpd PHP？
编辑(2):现在使用db- mysql和generic-pool模块.错误率显着下降,徘徊在13%,但吞吐量仍然在100 req / sec左右. 编辑(1):在有人建议ORDER BY RAND() ...
- vue+node.js前后端交互中的token令牌验证
这篇文章分享一下本人学习vue+node.js前后端交互中的登录token令牌的心得 最近准备写一个个人博客网站,前端采用的是vue+element,后端用node.js 在做用户登录的时候就想到 如 ...
- 第一节、Alex 讲解 python+mysql 交互；
Python Mysql 交互 A.Alex 的语法展示: import MySQLdb try: conn=MySQL.connect(host='localhost',user='root',pa ...
最新文章
- Python热文Top10，精选自1000篇文章
- 数梦工场联手阿里云 推出大数据一体机
- 启用邮箱提示访问特权不够
- 【音乐App】—— Vue-music 项目学习笔记：播放器内置组件开发（一）
- 科大星云诗社动态20210410
- 天天象棋 残局闯关 第17关
- 【转】0.SharePoint服务器端对象模型 之 序言
- ue4 迁移模型_UE4换装系统（合并骨骼模型）
- SENTINEL Missions 哨兵卫星任务
- JVM上篇：内存与垃圾回收篇--运行时数据区四-程序计数器
- 开关电源电路图讲解。多图！！！
- 用Python物理建模的第一本书终于来啦
- 列宁名言、警句、格言、语录
- Python基础--魔法方法()运算符重载)
- .NET高级工程师面试题之SQL篇
- SSH框架 Bean property * is not writable or has an invalid setter method错误分析与解决方法
- 生成在线图片地址，用于测试
- 天大青医堂第十期报告会之二
- (附源码)计算机毕业设计ssm毕业生就业管理系统
- PHP 开发环境搭建