nodejs使用sequelize操作mysql实例

sequelize是node操作mysql的一款npm包，包含很多特性：数据库模型映射、事务处理、模型属性校验、关联映射等，花了两天时间学习了下基本的一些操作，特别是关联映射部分的操作，包含1:1、1:N、N:N部分，利用express框架实现简单的rest服务。

关于项目结构：

其中，routes存放各种路由，models配置各种数据库模型类，ref.js用来配置相关的数据模型关联关系，主要关系为：user和loginInfo是1:1、user和address是1:N、user和role是N:N关系，index.js主要是加载路由：

module.exports = function(app) { app.use("/api/users", require("./user.js")); app.use("/api/addresses", require("./address.js")); app.use("/api/loginInfos", require("./loginInfo.js")); app.use("/api/roles", require("./role.js"));};

ref.js映射关系配置类：

/** * 模型关联类 */var { sequelize } = require("../config/db");var User = sequelize.import("./user");var LoginInfo = sequelize.import("./loginInfo");var Address = sequelize.import("./address");var Role = sequelize.import("./role");//建立模型之间关联关系User.hasOne(LoginInfo);LoginInfo.belongsTo(User);User.hasMany(Address, { foreignKey: ‘user_id‘, targetKey: ‘id‘, as: "Addresses" //别名，目标模型会混入到源模型后会使用该名称,存在getAddresses、setAddresses等方法});Address.belongsTo(User); //address想反查user必须加这个，否则只能实现user查询addressUser.belongsToMany(Role, { through: "userRoles"});Role.belongsToMany(User, { through: ‘userRoles‘});//创建表sequelize.sync({ force: false });

数据库配置类：

const Sequelize = require(‘sequelize‘);const sequelize = new Sequelize(‘node-sequelize‘, ‘admin‘, ‘admin‘, { host: ‘localhost‘, dialect: ‘mysql‘, pool: { max: 5, min: 0, idle: 10000 }});//测试数据库链接sequelize.authenticate().then(function() { console.log("数据库连接成功");}).catch(function(err) { //数据库连接失败时打印输出 console.error(err); throw err;});exports.sequelize = sequelize;exports.Sequelize = Sequelize;

当然，app.js要做的就是加载路由、加载映射关系配置文件，使数据模型和数据库同步：

//加载主外键关系及创建数据库require(‘./models/ref‘);Router(app);

详细代码已上传至github：https://github.com/caiya/node-sequelize

nodejs使用sequelize操作mysql实例

标签：exp   lan   highlight   one   简单   asm   mod   mysq   routes   

小编还为您整理了以下内容，可能对您也有帮助：

Node.jsSequelize如何实现数据库的读写分离

一、前言

在构建高并发的Web应用时，除了应用层要采取负载均衡方案外，数据库也要支持高可用和高并发性。使用较多的数据库优化方案是：通过主从复制(Master-Slave)的方式来同步数据，再通过读写分离(MySQL-Proxy)来提升数据库的并发负载能力。

1. replication选项与读写分离

Sequelize 支持读/写分离，要实现读/写分离可以分别为读和写各创建一个Sequelize实例，更方便的使用方式是在创建实例时，通过replication选项分别指定读/写数据库。

要在Sequelize中使用读/写复制，可以在初始化Sequelize时有时向其replication选项传递一个对象.这个对象read、write两个属性。write是一个单一的对象(即：由单台服务器处理写入)，而read是一个包含对象的数组(即：由多台服务器处理读取)。每台read、write服务器都可以包含以下属性：

· host - 数据库服务器的主机

· port - 数据库服务器的主机端口

· username - 验证用户名

· password - 验证密码

· database - 要连接的数据库

2. Sequelize读/写分离示例

在使用主从复制的多台数据库集群中，可以通过在replication对象的read属性中设置，该属性是一个数组，可以在其中传入一个或多个服务器连接副本。读操作相当于对数据库集群中的从节点进行操作，它会处理所有SELECT查询操作(读操作)。而replication对象的write属性是一个表示服务器连接的对象，写操作相当于主节点，它会处理所有插入、更新、删除操作(写操作)。

var sequelize = new Sequelize('database', null, null, {

dialect: 'mysql',

port: 3306

replication: {

read: [

{ host: '192.168.1.33', username: 'itbilu.com', password: 'pwd' },

{ host: 'localhost', username: 'root', password: null }

],

write: { host: 'localhost', username: 'root', password: null }

},

pool: { // 如果需要重写链接池，请在 pool 选项中修改

maxConnections: 20,

maxIdleTime: 30000

},

})所有的整体性设置，都会适用于所有节点副本，所以并不需要为每个实例单独指定。在上例中，数据库名和端口号会应用于所有节点副本，用户名和密码选项也同样适用。如果某一节点副本不使用全局设置，则需要在replication选项中单独指定。

注意：Sequelize 并不会设置主从复制节点及节点间的数据同步(复制)，这些操作实际由MySQL(或你所使用的数据库)完成。而 Sequelize 只负责从主从节点写入或读取数据。

Sequelize 会使用连接池来管理节点副本。

默认选项是：

{

maxConnections: 10,

minConnections: 0,

maxIdleTime:1000

}总结

nodejs简单访问及操作mysql数据库的方法示例

本文实例讲述了nodejs简单访问及操作mysql数据库的方法。分享给大家供大家参考，具体如下：
var
mysql
=
require('mysql');
//调用MySQL模块
mysql模块要安装
$
npm
install
mysql
//创建一个connection
var
connection
=
mysql.createConnection({
host
:
'127.0.0.1',
//主机
user
:
'root',
//MySQL认证用户名
password
:
'',
//MySQL认证用户密码
port:
'3306',
//端口号
database:''
//数据库名
});
//创建一个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!');
});
注：nodejs在操作数据库的时候不用设置数据库的编码格式
set
names
utf8
希望本文所述对大家nodejs程序设计有所帮助。
您可能感兴趣的文章:nodejs连接mysql数据库简单封装示例-mysql模块nodejs进阶(6)—连接MySQL数据库示例nodejs实现的连接MySQL数据库功能示例Nodejs连接mysql并实现增、删、改、查操作的方法详解nodeJs实现基于连接池连接mysql的方法示例nodejs中操作mysql数据库示例NodeJS链接MySql数据库的操作方法Nodejs使用mysql模块之获得更新和删除影响的行数的方法NodeJs使用Mysql模块实现事务处理实例nodejs连接mysql数据库及基本知识点详解

nodejs简单访问及操作mysql数据库的方法示例

本文实例讲述了nodejs简单访问及操作mysql数据库的方法。分享给大家供大家参考，具体如下：
var
mysql
=
require('mysql');
//调用MySQL模块
mysql模块要安装
$
npm
install
mysql
//创建一个connection
var
connection
=
mysql.createConnection({
host
:
'127.0.0.1',
//主机
user
:
'root',
//MySQL认证用户名
password
:
'',
//MySQL认证用户密码
port:
'3306',
//端口号
database:''
//数据库名
});
//创建一个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!');
});
注：nodejs在操作数据库的时候不用设置数据库的编码格式
set
names
utf8
希望本文所述对大家nodejs程序设计有所帮助。
您可能感兴趣的文章:nodejs连接mysql数据库简单封装示例-mysql模块nodejs进阶(6)—连接MySQL数据库示例nodejs实现的连接MySQL数据库功能示例Nodejs连接mysql并实现增、删、改、查操作的方法详解nodeJs实现基于连接池连接mysql的方法示例nodejs中操作mysql数据库示例NodeJS链接MySql数据库的操作方法Nodejs使用mysql模块之获得更新和删除影响的行数的方法NodeJs使用Mysql模块实现事务处理实例nodejs连接mysql数据库及基本知识点详解

nodejs怎么后台操作mysql

连接流程代码如下：

var mysql  = require('mysql');  //调用MySQL模块//创建一个connectionvar connection = mysql.createConnection({    

host     : '127.0.0.1',       //主机
user     : 'root',            //MySQL认证用户名
password:'12345',
port:   '3306',
database: 'node'});//创建一个connectionconnection.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);

});

//关闭connectionconnection.end(function(err){

if(err){      

return;

}

console.log('[connection end] succeed!');

});12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455

关于Connection Optionos

要想创建一个数据库连接，先就要认识清楚Options

host：主机地址 （默认：localhost）

user：用户名

password：密码

port：端口号 （默认：3306）

database：数据库名

charset：连接字符集（默认：’UTF8_GENERAL_CI’，注意字符集的字母都要大写）

localAddress：此IP用于TCP连接（可选）

socketPath：连接到unix域路径，当使用 host 和 port 时会被忽略

timezone：时区（默认：’local’）

connectTimeout：连接超时（默认：不*；单位：毫秒）

stringifyObjects：是否序列化对象（默认：’false’ ；与安全相关https://github.com/felixge/node-mysql/issues/501）

typeCast：是否将列值转化为本地JavaScript类型值 （默认：true）

queryFormat：自定义query语句格式化方法 https://github.com/felixge/node-mysql#custom-format

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）

flags：用于修改连接标志，更多详情：https://github.com/felixge/node-mysql#connection-flags

ssl：使用ssl参数（与crypto.createCredenitals参数格式一至）或一个包含ssl配置文件名称的字符串，目前只*Amazon RDS的配置文件

其它：

可以使用URL形式的加接字符串，不多介绍了，不太喜欢那种格式，觉得可读性差，也易出错，想了解的可以去主页上看。

MYSQL CURD操作

增加

var mysql = require('mysql');var DATABASE = "seckill";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});

connection.connect();var addVip = 'insert into seckill(name,number) values(?,?)';var param = ['100元秒杀家教机',100];
connection.query(addVip, param, function(error, result){
if(error)
{
console.log(error.message);
}else{
console.log('insert id: '+result.insertId);
}
});

connection.end();12345678910111213141516171819202122232425

删除

var mysql = require('mysql');var DATABASE = "node";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});

connection.connect();var addVip = 'delete from seckill where seckill_id = 1005';
connection.query(addVip, function(error, result){
if(error)
{
console.log(error.message);
}else{
console.log('affectedRows: '+result.affectedRows);
}
});

connection.end();123456789101112131415161718192021222324

查找

var mysql = require("mysql");var DATABASE = "node";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
});

connection.connect();
connection.query('use '+DATABASE);
connection.query('select * from '+TABLE, function(error, results, fields){
if (error) {        throw error;
}    if (results) {        for(var i = 0; i < results.length; i++)
{
console.log('%s %s',results[i].name,results[i].end_time);
}
}
});

connection.end();12345678910111213141516171819202122232425

修改

var mysql = require('mysql');var DATABASE = "seckill";var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});
connection.connect();var userSql = "update seckill set number = number-1 where seckill_id = ?";var param = [1000, 2];
connection.query(userSql, param, function (error, result) {
if(error)
{
console.log(error.message);
}else{
console.log('affectedRows: '+result.affectedRows);
}
});
connection.end();123456789101112131415161718192021

结束连接其实有两种方法end()，destory()；

end() 
end()方法在queries都结束后执行，end()方法接收一个回调函数，queries执行出错，仍然后结束连接，错误会返回给回调函数err参数，可以在回调函数中处理！

destory() 
比较暴力，没有回调函数，即刻执行，不管queries是否完成！

使用连接池

在数据库中执行如下代码创建一个存储过程

DROP PROCEDURE IF EXISTS `P_SeckillInfo`;DELIMITER ;;CREATE DEFINER=`root`@`localhost` PROCEDURE `P_SeckillInfo`(IN ExtName VARCHAR(120),IN ExtNumber INT(11),OUT ExtReturnVal INT)

TOP: BEGIN

   DECLARE EXIT HANDLER FOR SQLEXCEPTION    BEGIN

   ROLLBACK;

   SET ExtReturnVal = 0;  -- Failed

   END;

   START TRANSACTION;

   INSERT INTO seckill(name, number) VALUES(ExtName,ExtNumber);

   SET ExtReturnVal = 1;

   SELECT ExtReturnVal;

   COMMIT;END;;

DELIMITER ;12345678910111213141516171819202122232425262728293031323334


调用示例：

var mysql = require("mysql");var pool = mysql.createPool({
   host: '127.0.0.1',    

   user: 'root',

   password:'12345',

   port:'3306',

   database:'node'});//监听connection事件pool.on('connection', function(connection) {

   connection.query('select * from seckill', function(error, results, fields){
       if (error) {            throw error;
       }        if (results) {            for(var i = 0; i < results.length; i++)
           {
               console.log('%s %s',results[i].name,results[i].end_time);
           }
       }
   });

});//连接池可以直接使用，也可以共享一个连接或管理多个连接（引用官方示例）//直接使用pool.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {

   if (err) throw err;

   console.log('The solution is: ', rows[0].solution);

});//共享连接function myQuery(sql){
   pool.getConnection(function(err, connection) {

       connection.query(sql, function(err, result) {  

           console.log(result);            //释放连接
           connection.release();

       });        //Error: Connection already released,应该每次到连接池中再次获取
       // connection.query( 'SELECT * FROM seckill;', function(err, result) {


       //  console.log(result);

       //  connection.release();

       // });

   });
}

myQuery('SELECT * FROM seckill;');
myQuery('SELECT * FROM seckill;');123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172


1.连接池的创建，使用createPool方法，options和createConntion一致； 
2.其它连接池配置选项　

waitForConnections

当连接池没有连接或超出最大*时，设置为true且会把连接放入队列，设置为false会返回error

connectionLimit 
连接数*，默认：10

queueLimit 
最大连接请求队列*，设置为0表示不*，默认：0

断开重连

示例代码：

var mysql = require('mysql');var db_config = {

   host: '127.0.0.1',    

   user: 'root',

   password:'12345',

   port:'3306',

   database:'node'};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();12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455


首先关闭mysql服务，然后执行程序，会一直打印断线重连，当再次开启mysql服务后，打印连接成功。

防止SQL注入

可以使用pool.escape()和connect.escape()，示例代码：

var mysql = require('mysql');var pool = mysql.createPool({
   host: '127.0.0.1',    

   user: 'root',

   password:'12345',

   port:'3306',

   database:'node'});function myQuery(sql){
   pool.getConnection(function(err,connection){



       connection.query(sql,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();

       // });

   });
}

myQuery('SELECT * FROM seckill WHERE seckill_id = ' + '1006 OR seckill_id = 1007');
myQuery('SELECT * FROM seckill WHERE seckill_id = ' + pool.escape('1006 OR seckill_id = 1007'));123456789101112131415161718192021222324252627282930313233343536373839404142434445464748


 
结果可以看出，第1个query拼接条件可以被执行，而通过escape方法转义后的忽略了后面的拼接的部分！

遇到的问题

编码导致的问题 
1366 (HY000): Incorrect string value: ‘xC3xEBxC9xB1’ for column ‘ExtName’ at row 1 
字符编码没有统一的问题，查看数据库的编码方式命令为: 
mysql> show variables like ‘character%’; 


从以上信息可知数据库的编码为latin1，需要修改为gbk或者是utf8；

nodejs怎么后台操作mysql

连接流程代码如下：

var mysql  = require('mysql');  //调用MySQL模块//创建一个connectionvar connection = mysql.createConnection({    

host     : '127.0.0.1',       //主机
user     : 'root',            //MySQL认证用户名
password:'12345',
port:   '3306',
database: 'node'});//创建一个connectionconnection.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);

});

//关闭connectionconnection.end(function(err){

if(err){      

return;

}

console.log('[connection end] succeed!');

});12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455

关于Connection Optionos

要想创建一个数据库连接，先就要认识清楚Options

host：主机地址 （默认：localhost）

user：用户名

password：密码

port：端口号 （默认：3306）

database：数据库名

charset：连接字符集（默认：’UTF8_GENERAL_CI’，注意字符集的字母都要大写）

localAddress：此IP用于TCP连接（可选）

socketPath：连接到unix域路径，当使用 host 和 port 时会被忽略

timezone：时区（默认：’local’）

connectTimeout：连接超时（默认：不*；单位：毫秒）

stringifyObjects：是否序列化对象（默认：’false’ ；与安全相关https://github.com/felixge/node-mysql/issues/501）

typeCast：是否将列值转化为本地JavaScript类型值 （默认：true）

queryFormat：自定义query语句格式化方法 https://github.com/felixge/node-mysql#custom-format

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）

flags：用于修改连接标志，更多详情：https://github.com/felixge/node-mysql#connection-flags

ssl：使用ssl参数（与crypto.createCredenitals参数格式一至）或一个包含ssl配置文件名称的字符串，目前只*Amazon RDS的配置文件

其它：

可以使用URL形式的加接字符串，不多介绍了，不太喜欢那种格式，觉得可读性差，也易出错，想了解的可以去主页上看。

MYSQL CURD操作

增加

var mysql = require('mysql');var DATABASE = "seckill";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});

connection.connect();var addVip = 'insert into seckill(name,number) values(?,?)';var param = ['100元秒杀家教机',100];
connection.query(addVip, param, function(error, result){
if(error)
{
console.log(error.message);
}else{
console.log('insert id: '+result.insertId);
}
});

connection.end();12345678910111213141516171819202122232425

删除

var mysql = require('mysql');var DATABASE = "node";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});

connection.connect();var addVip = 'delete from seckill where seckill_id = 1005';
connection.query(addVip, function(error, result){
if(error)
{
console.log(error.message);
}else{
console.log('affectedRows: '+result.affectedRows);
}
});

connection.end();123456789101112131415161718192021222324

查找

var mysql = require("mysql");var DATABASE = "node";var TABLE="seckill"var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
});

connection.connect();
connection.query('use '+DATABASE);
connection.query('select * from '+TABLE, function(error, results, fields){
if (error) {        throw error;
}    if (results) {        for(var i = 0; i < results.length; i++)
{
console.log('%s %s',results[i].name,results[i].end_time);
}
}
});

connection.end();12345678910111213141516171819202122232425

修改

var mysql = require('mysql');var DATABASE = "seckill";var connection = mysql.createConnection({
host:'127.0.0.1',
user:'root',
password:'12345',
port:'3306',
database: DATABASE
});
connection.connect();var userSql = "update seckill set number = number-1 where seckill_id = ?";var param = [1000, 2];
connection.query(userSql, param, function (error, result) {
if(error)
{
console.log(error.message);
}else{
console.log('affectedRows: '+result.affectedRows);
}
});
connection.end();123456789101112131415161718192021

结束连接其实有两种方法end()，destory()；

end() 
end()方法在queries都结束后执行，end()方法接收一个回调函数，queries执行出错，仍然后结束连接，错误会返回给回调函数err参数，可以在回调函数中处理！

destory() 
比较暴力，没有回调函数，即刻执行，不管queries是否完成！

使用连接池

在数据库中执行如下代码创建一个存储过程

DROP PROCEDURE IF EXISTS `P_SeckillInfo`;DELIMITER ;;CREATE DEFINER=`root`@`localhost` PROCEDURE `P_SeckillInfo`(IN ExtName VARCHAR(120),IN ExtNumber INT(11),OUT ExtReturnVal INT)

TOP: BEGIN

   DECLARE EXIT HANDLER FOR SQLEXCEPTION    BEGIN

   ROLLBACK;

   SET ExtReturnVal = 0;  -- Failed

   END;

   START TRANSACTION;

   INSERT INTO seckill(name, number) VALUES(ExtName,ExtNumber);

   SET ExtReturnVal = 1;

   SELECT ExtReturnVal;

   COMMIT;END;;

DELIMITER ;12345678910111213141516171819202122232425262728293031323334


调用示例：

var mysql = require("mysql");var pool = mysql.createPool({
   host: '127.0.0.1',    

   user: 'root',

   password:'12345',

   port:'3306',

   database:'node'});//监听connection事件pool.on('connection', function(connection) {

   connection.query('select * from seckill', function(error, results, fields){
       if (error) {            throw error;
       }        if (results) {            for(var i = 0; i < results.length; i++)
           {
               console.log('%s %s',results[i].name,results[i].end_time);
           }
       }
   });

});//连接池可以直接使用，也可以共享一个连接或管理多个连接（引用官方示例）//直接使用pool.query('SELECT 1 + 1 AS solution', function(err, rows, fields) {

   if (err) throw err;

   console.log('The solution is: ', rows[0].solution);

});//共享连接function myQuery(sql){
   pool.getConnection(function(err, connection) {

       connection.query(sql, function(err, result) {  

           console.log(result);            //释放连接
           connection.release();

       });        //Error: Connection already released,应该每次到连接池中再次获取
       // connection.query( 'SELECT * FROM seckill;', function(err, result) {


       //  console.log(result);

       //  connection.release();

       // });

   });
}

myQuery('SELECT * FROM seckill;');
myQuery('SELECT * FROM seckill;');123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172


1.连接池的创建，使用createPool方法，options和createConntion一致； 
2.其它连接池配置选项　

waitForConnections

当连接池没有连接或超出最大*时，设置为true且会把连接放入队列，设置为false会返回error

connectionLimit 
连接数*，默认：10

queueLimit 
最大连接请求队列*，设置为0表示不*，默认：0

断开重连

示例代码：

var mysql = require('mysql');var db_config = {

   host: '127.0.0.1',    

   user: 'root',

   password:'12345',

   port:'3306',

   database:'node'};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();12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455


首先关闭mysql服务，然后执行程序，会一直打印断线重连，当再次开启mysql服务后，打印连接成功。

防止SQL注入

可以使用pool.escape()和connect.escape()，示例代码：

var mysql = require('mysql');var pool = mysql.createPool({
   host: '127.0.0.1',    

   user: 'root',

   password:'12345',

   port:'3306',

   database:'node'});function myQuery(sql){
   pool.getConnection(function(err,connection){



       connection.query(sql,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();

       // });

   });
}

myQuery('SELECT * FROM seckill WHERE seckill_id = ' + '1006 OR seckill_id = 1007');
myQuery('SELECT * FROM seckill WHERE seckill_id = ' + pool.escape('1006 OR seckill_id = 1007'));123456789101112131415161718192021222324252627282930313233343536373839404142434445464748


 
结果可以看出，第1个query拼接条件可以被执行，而通过escape方法转义后的忽略了后面的拼接的部分！

遇到的问题

编码导致的问题 
1366 (HY000): Incorrect string value: ‘xC3xEBxC9xB1’ for column ‘ExtName’ at row 1 
字符编码没有统一的问题，查看数据库的编码方式命令为: 
mysql> show variables like ‘character%’; 


从以上信息可知数据库的编码为latin1，需要修改为gbk或者是utf8；

nodejs:sequelize数据库查询的Op方法

let Sequelize = require('sequelize');

const op = Sequelize.Op;

op方法：

idea创建nodejs连接mysql

在 IDEA 中创建 Node.js 项目连接 MySQL 数据库，可以按照以下步骤进行操作：

打开 IDEA，选择“Create New Project”创建一个新的 Node.js 项目。

在新建项目的目录下打开终端，使用 npm 命令安装 mysql 模块，命令如下：

css

Copy code

npm install mysql --save

在项目的根目录下创建一个名为 index.js 的文件，编写以下代码：

javascript

Copy code

const mysql = require('mysql');

// 创建连接对象

const connection = mysql.createConnection({

host: 'localhost', // 数据库服务器地址

user: 'root', // 数据库用户名

password: 'password', // 数据库密码

database: 'test', // 数据库名称

port: 3306 // 数据库端口号，默认为 3306

});

// 连接数据库

connection.connect();

// 执行 SQL 查询语句

connection.query('SELECT * FROM user', function (error, results, fields) {

if (error) throw error;

console.log('The solution is: ', results);

});

// 关闭连接

connection.end();

其中，需要将 host、user、password、database 等参数设置为实际的数据库连接信息。

在终端中运行 index.js 文件，命令如下：

Copy code

node index.js

这样，就可以连接到 MySQL 数据库，并查询指定的表中的数据。

以上是使用 Node.js 连接 MySQL 数据库的简单示例，如果需要进行更复杂的操作，可以参考 mysql 模块的文档，了解更多的 API 和用法。