nodejs mysql 创建连接池

用Nodejs连接MySQL

从零开始nodejs系列文章，将介绍如何利Javascript做为服务端脚本，通过Nodejs框架web开发。Nodejs框架是基于V8的引擎，是目前速度最快的Javascript引擎。chrome浏览器就基于V8，同时打开20-30个网页都很流畅。Nodejs标准的web开发框架Express，可以帮助我们迅速建立web站点，比起PHP的开发效率更高，而且学习曲线更低。非常适合小型网站，个性化网站，我们自己的Geek网站！！

关于作者

  • 张丹(Conan), 程序员Java,R,PHP,Javascript
  • weibo：@Conan_Z
  • blog: http://blog.fens.me
  • email: [email protected]

转载请注明出处：
http://blog.fens.me/nodejs-mysql-intro/

前言

MySQL是一款常用的开源数据库产品，通常也是免费数据库的首选。查了一下NPM列表，发现Nodejs有13库可以访问MySQL，felixge/node-mysql似乎是最受关注项目，我也决定尝试用一下。

要注意名字，”felixge/node-mysql”非”node-mysql”，安装部分会介绍这个小插曲！

目录

  1. node-mysql介绍
  2. 建立MySQL测试库
  3. node-mysql安装
  4. node-mysql使用

1. node-mysql介绍

felixge/node-mysql是一个纯nodejs的用javascript实现的一个MySQL客户端程序。felixge/node-mysql封装了Nodejs对MySQL的基本操作，100% MIT公共许可证。

项目地址：https://github.com/felixge/node-mysql

2. 建立MySQL测试库

本地创建MySQL测试库：nodejs

 ~ mysql -uroot -p mysql> CREATE DATABASE nodejs; mysql> SHOW DATABASES; +--------------------+ | Database           | +--------------------+ | information_schema | | mysql              | | nodejs             | | performance_schema | +--------------------+ 4 rows in set (0.00 sec)  mysql> GRANT ALL ON nodejs.* to [email protected]‘%‘ IDENTIFIED BY ‘nodejs‘; mysql> GRANT ALL ON nodejs.* to [email protected] IDENTIFIED BY ‘nodejs‘;

重新登陆MySQL

 C:\Users\Administrator>mysql -unodejs -p Enter password: ******  mysql> SHOW DATABASES; +--------------------+ | Database           | +--------------------+ | information_schema | | nodejs             | | test               | +--------------------+ 3 rows in set (0.00 sec)  mysql> USE nodejs Database changed

新建一个user表

 CREATE TABLE t_user( id INT PRIMARY KEY AUTO_INCREMENT, name VARCHAR(16) NOT NULL , create_date TIMESTAMP NULL DEFAULT now() )ENGINE=InnoDB DEFAULT CHARSET=utf8; CREATE UNIQUE INDEX t_quiz_IDX_0 on t_user(name);  mysql> SHOW TABLES; +------------------+ | Tables_in_nodejs | +------------------+ | t_user           | +------------------+ 1 row in set (0.04 sec)

3. node-mysql安装

我的系统环境

  • win7 64bit
  • Nodejs:v0.10.5
  • Npm:1.2.19
  • MySQL:Server version: 5.6.11 MySQL Community Server (GPL)

创建工程:nodejs-node-mysql

~ D:\workspace\javascript>mkdir nodejs-node-mysql ~ D:\workspace\javascript>cd nodejs-node-mysql ~ D:\workspace\javascript\nodejs-node-mysql>npm install node-mysql [email protected] node_modules\node-mysql ├── [email protected] ├── [email protected] ├── [email protected] └── [email protected] ([email protected], [email protected])

这里有一个小插曲

安装“node-mysql”后，打开package.json文件发现，这个项目地址是

https://github.com/redblaze/node-mysql.git

从依赖关系可以看到，它依赖于mysql库，是对felixge/node-mysql的封装。

由于这个项目star是0，fork也是0. 所以，我也不准备花时间测试了，重新安装felixge/node-mysql的包。

重新安装node-mysql

~ D:\workspace\javascript\nodejs-node-mysql>rm -rf node_modules ~ D:\workspace\javascript\nodejs-node-mysql>npm install [email protected] npm http GET https://registry.npmjs.org/mysql/2.0.0-alpha9 npm http 200 https://registry.npmjs.org/mysql/2.0.0-alpha9 npm http GET https://registry.npmjs.org/mysql/-/mysql-2.0.0-alpha9.tgz npm http 200 https://registry.npmjs.org/mysql/-/mysql-2.0.0-alpha9.tgz npm http GET https://registry.npmjs.org/require-all/0.0.3 npm http GET https://registry.npmjs.org/bignumber.js/1.0.1 npm http 304 https://registry.npmjs.org/require-all/0.0.3 npm http 304 https://registry.npmjs.org/bignumber.js/1.0.1 [email protected] node_modules\mysql ├── [email protected] └── [email protected]

这回就对了，继续下面的开发！

创建node程序启动文件：app.js

第一个测试

~ vi app.js  var mysql = require(‘mysql‘); var conn = mysql.createConnection({     host: ‘localhost‘,     user: ‘nodejs‘,     password: ‘nodejs‘,     database:‘nodejs‘,     port: 3306 }); conn.connect(); conn.query(‘SELECT 1 + 1 AS solution‘, function(err, rows, fields) {     if (err) throw err;     console.log(‘The solution is: ‘, rows[0].solution); }); conn.end();

运行node

~ D:\workspace\javascript\nodejs-node-mysql>node app.js The solution is:  2

这样我们就让Nodejs连接上了MySQL。

4. node-mysql使用

下面我们要对node-mysql的API进行常用的测试。

  • 表新删改查
  • 连接池配置
  • MySQL断线重连
  • 连接池超时测试

1). 表新删改查
修改app.js

 ~ vi app.js  var mysql = require(‘mysql‘); var conn = mysql.createConnection({     host: ‘localhost‘,     user: ‘nodejs‘,     password: ‘nodejs‘,     database: ‘nodejs‘,     port: 3306 }); conn.connect();  var insertSQL = ‘insert into t_user(name) values("conan"),("fens.me")‘; var selectSQL = ‘select * from t_user limit 10‘; var deleteSQL = ‘delete from t_user‘; var updateSQL = ‘update t_user set name="conan update"  where name="conan"‘;  //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]);                     }                 });             });         });     }); });  //conn.end();

控制台输出：

D:\workspace\javascript\nodejs-node-mysql>node app.js DELETE Return ==> { fieldCount: 0,   affectedRows: 2,   insertId: 0,   serverStatus: 34,   warningCount: 0,   message: ‘‘,   protocol41: true,   changedRows: 0 } INSERT Return ==> { fieldCount: 0,   affectedRows: 2,   insertId: 33,   serverStatus: 2,   warningCount: 0,   message: ‘&Records: 2  Duplicates: 0  Warnings: 0‘,   protocol41: true,   changedRows: 0 } SELECT ==> { id: 33,   name: ‘conan‘,   create_date: Wed Sep 11 2013 12:09:15 GMT+0800 (中国标准时间) } { id: 34,   name: ‘fens.me‘,   create_date: Wed Sep 11 2013 12:09:15 GMT+0800 (中国标准时间) } UPDATE Return ==> { fieldCount: 0,   affectedRows: 1,   insertId: 0,   serverStatus: 2,   warningCount: 0,   message: ‘(Rows matched: 1  Changed: 1  Warnings: 0‘,   protocol41: true,   changedRows: 1 } SELECT ==> { id: 33,   name: ‘conan update‘,   create_date: Wed Sep 11 2013 12:09:15 GMT+0800 (中国标准时间) } { id: 34,   name: ‘fens.me‘,   create_date: Wed Sep 11 2013 12:09:15 GMT+0800 (中国标准时间) }

由于node的异步的，上面是一个连续的操作，代码会被写的支离破碎。我们可以通过async库对上面代码进行封装，请参考文章：Nodejs异步流程控制Async

2). 连接池配置

增加文件：app-pooling.js

~ vi app-pooling.js  var mysql = require(‘mysql‘); var pool = mysql.createPool({     host: ‘localhost‘,     user: ‘nodejs‘,     password: ‘nodejs‘,     database: ‘nodejs‘,     port: 3306 });  var selectSQL = ‘select * from t_user limit 10‘;  pool.getConnection(function (err, conn) {     if (err) console.log("POOL ==> " + err);      conn.query(selectSQL,function(err,rows){         if (err) console.log(err);         console.log("SELECT ==> ");         for (var i in rows) {             console.log(rows[i]);         }         conn.release();     }); });

控制台输出：

D:\workspace\javascript\nodejs-node-mysql>node app-pooling.js SELECT ==> { id: 39,   name: ‘conan update‘,   create_date: Wed Sep 11 2013 13:41:18 GMT+0800 (中国标准时间) } { id: 40,   name: ‘fens.me‘,   create_date: Wed Sep 11 2013 13:41:18 GMT+0800 (中国标准时间) }

3). MySQL断线重连

分别模拟3种错误

  • 登陆密码错误
  • 数据库宕机
  • 数据库连接超时

新增文件：app-reconnect.js

~ vi app-reconnect.js  var mysql = require(‘mysql‘); var conn; function handleError () {     conn = mysql.createConnection({         host: ‘localhost‘,         user: ‘nodejs‘,         password: ‘nodejs‘,         database: ‘nodejs‘,         port: 3306     });      //连接错误，2秒重试     conn.connect(function (err) {         if (err) {             console.log(‘error when connecting to db:‘, err);             setTimeout(handleError , 2000);         }     });      conn.on(‘error‘, function (err) {         console.log(‘db error‘, err);         // 如果是连接断开，自动重新连接         if (err.code === ‘PROTOCOL_CONNECTION_LOST‘) {             handleError();         } else {             throw err;         }     }); } handleError();

a. 模拟密码错误

修改password: ‘nodejs11′

控制台输出。

D:\workspace\javascript\nodejs-node-mysql>node app-reconnect.js error when connecting to db: { [Error: ER_ACCESS_DENIED_ERROR: Access denied for user ‘nodejs‘@‘localhost‘ (using pass rd: YES)]   code: ‘ER_ACCESS_DENIED_ERROR‘,   errno: 1045,   sqlState: ‘28000‘,   fatal: true } error when connecting to db: { [Error: ER_ACCESS_DENIED_ERROR: Access denied for user ‘nodejs‘@‘localhost‘ (using pass rd: YES)]   code: ‘ER_ACCESS_DENIED_ERROR‘,   errno: 1045,   sqlState: ‘28000‘,   fatal: true }

b. 模拟数据库宕机
正常启动node，然后杀掉mysqld的进程。

控制台输出。

 D:\workspace\javascript\nodejs-node-mysql>node app-reconnect.js db error { [Error: read ECONNRESET]   code: ‘ECONNRESET‘,   errno: ‘ECONNRESET‘,   syscall: ‘read‘,   fatal: true }  Error: read ECONNRESET     at errnoException (net.js:884:11)     at TCP.onread (net.js:539:19)

这个异常，直接导致node程序被杀死！

c. 模拟连接超时，PROTOCOL_CONNECTION_LOST
切换到root账户, 修改MySQL的wait_timeout参数，设置为10毫秒超时。

~ mysql -uroot -p mysql> show variables like ‘wait_timeout‘; +---------------+-------+ | Variable_name | Value | +---------------+-------+ | wait_timeout  | 28800 | +---------------+-------+ 1 row in set (0.00 sec)  mysql> set global wait_timeout=10; Query OK, 0 rows affected (0.00 sec)  mysql> show variables like ‘wait_timeout‘; +---------------+-------+ | Variable_name | Value | +---------------+-------+ | wait_timeout  | 10    | +---------------+-------+ 1 row in set (0.00 sec)

修改文件：app-reconnection.js，在最后增加代码

~ vi app-reconnection.js  function query(){     console.log(new Date());     var sql = "show variables like ‘wait_timeout‘";     conn.query(sql, function (err, res) {         console.log(res);     }); }  query(); setInterval(query, 15*1000);

程序会每融15秒，做一次查询。

控制台输出

D:\workspace\javascript\nodejs-node-mysql>node app-reconnect.js Wed Sep 11 2013 15:21:14 GMT+0800 (中国标准时间) [ { Variable_name: ‘wait_timeout‘, Value: ‘10‘ } ] db error { [Error: Connection lost: The server closed the connection.] fatal: true, code: ‘PROTOCOL_CONNECTION_LOST‘ } Wed Sep 11 2013 15:21:28 GMT+0800 (中国标准时间) [ { Variable_name: ‘wait_timeout‘, Value: ‘10‘ } ] db error { [Error: Connection lost: The server closed the connection.] fatal: true, code: ‘PROTOCOL_CONNECTION_LOST‘ } Wed Sep 11 2013 15:21:43 GMT+0800 (中国标准时间) [ { Variable_name: ‘wait_timeout‘, Value: ‘10‘ } ]

我们自己的程序捕获了“PROTOCOL_CONNECTION_LOST”异常，并自动的实现了数据库重连。

4). MySQL连接池的超时测试

针对wait_timeout问题，我们再对连接做一下测试。

修改app-pooling.js文件

 var mysql = require(‘mysql‘); var pool = mysql.createPool({     host: ‘localhost‘,     user: ‘nodejs‘,     password: ‘nodejs‘,     database: ‘nodejs‘,     port: 3306 });  var selectSQL ="show variables like ‘wait_timeout‘";  pool.getConnection(function (err, conn) {     if (err) console.log("POOL ==> " + err);      function query(){         conn.query(selectSQL, function (err, res) {             console.log(new Date());             console.log(res);             conn.release();         });     }     query();     setInterval(query, 5000); });

控制台输出：

D:\workspace\javascript\nodejs-node-mysql>node app-pooling.js Wed Sep 11 2013 15:32:25 GMT+0800 (中国标准时间) [ { Variable_name: ‘wait_timeout‘, Value: ‘10‘ } ] Wed Sep 11 2013 15:32:30 GMT+0800 (中国标准时间) [ { Variable_name: ‘wait_timeout‘, Value: ‘10‘ } ] Wed Sep 11 2013 15:32:35 GMT+0800 (中国标准时间) [ { Variable_name: ‘wait_timeout‘, Value: ‘10‘ } ]

连接池，已经解决了自动重连的问题了，后面我们的开发，可以尽量使用pooling的方式。

转载请注明出处：
http://blog.fens.me/nodejs-mysql-intro/

This entry was posted in Javascript语言实践, 数据库

Copyright © 2015 All rights reserved.

Designed by 

时间： 2024-08-02 23:12:24

nodejs mysql 创建连接池的相关文章

Node.js使用MySQL的连接池

使用Nodejs+MySQL肯定比PHP和MySQL的组合更适合做服务器端的开发. 使用Nodejs你会从他的异步行为中获益良多.比如,提升性能,你无须在从已有的MySQL数据库迁移到其他的NoSQL数据库获得性能的提升.   Nodejs如何使用MySQL Nodejs要连接MySQL,可以使用Nodejs的MysQL驱动来实现.比如,我们这里使用“node-mysql”连接数据库.我们使用下面的方式来连接数据库: 首先,我们需要使用nodejs的包管理工具(npm)安装mysql的驱动.命令

Node.js如何使用MySQL的连接池实例

http://www.111cn.net/database/mysql/90774.htm Nodejs如何使用MySQL Nodejs要连接MySQL,可以使用Nodejs的MysQL驱动来实现.比如,我们这里使用"node-mysql"连接数据库.我们使用下面的方式来连接数据库: 首先,我们需要使用nodejs的包管理工具(npm)安装mysql的驱动.命令行如下: npm install musql 现在,要在js文件中使用mysql,添加下面的代码到你的文件中: var mys

使用代理创建连接池 proxyPool

配置文件properties 1 url=jdbc:mysql://127.0.0.1:3306/mine?characterEncoding=UTF-8 2 user=root 3 password=1234 4 driverClass=com.mysql.jdbc.Driver 主要代码 1 package JDBCUtils; 2 3 import java.io.IOException; 4 import java.io.InputStream; 5 import java.lang.r

Python 使用 PyMysql、DBUtils 创建连接池提升性能

Python 使用 PyMysql.DBUtils 创建连接池提升性能 Python 编程中可以使用 PyMysql 进行数据库的连接及诸如查询/插入/更新等操作,但是每次连接 MySQL 数据库请求时,都是独立的去请求访问,相当浪费资源,而且访问数量达到一定数量时,对 mysql 的性能会产生较大的影响.因此,实际使用中,通常会使用数据库的连接池技术,来访问数据库达到资源复用的目的. 解决方案:DBUtils DBUtils 是一套 Python 数据库连接池包,并允许对非线程安全的数据库接口

spring创建连接池的几种方式

spring使用连接池有很多种方式,jdbc(不使用连接池),c3p0,dbcp,jndi,下面将分别贴代码介绍这几种:  1.jdbc方式 使用的是DriverManagerDataSource,DriverManagerDataSource建立连接是只要有连接就新建一个connection,  根本没有连接池的作用 <bean id="dataSource" class="org.springframework.jdbc.datasource.DriverManag

nodejs之memcache连接池应用方法

花了二天时间才测试成功 NODEJS技术太新了点 中英文的资料都少 所以记录下正确的nodejs之memcache连接池应用方法方便后来人 按理说memcached应该自带有连接池 但是不知道为什么总是不正确 外面再套一个暂时正常了 或许以后会有更方便的方法 先用着 欢迎指正 module.exports = MemCache78; var EventEmitter = require('events').EventEmitter; var Util = require('util'); Uti

MySql &amp; JDBC &amp; 连接池 &amp; 总结

连接池:解决资源浪费,提高代码性能. 本小节目标: 使用DBCP,C3P0连接池完成基本数据库的操作. 使用DBUtils完成CRUD的操作. 数据库连接池的解决方案是: 当应用程序启动时,系统主动建立足够的数据库连接,并将这些连接组成一个连接池.每次应用程序请求数据库连接时,无须重新打开连接,而是从连接池中取出已有的连接使用,使用完后不再关闭数据库连接,而是直接将连接归还给连接池.通过使用连接池,将大大提高程序的运行效率. 数据库连接池是Connection 对象的工程.数据库连接池的常用参数

Java创建连接池连接不同数据库

在一个应用里面,可能涉及到连接多个不同数据库进行操作,而每次连接写不同的实现会很麻烦.前面已经会了用JDBC连接数据库,那么利用反射和工厂模式,可以实现连接不同的数据库,这样处理起来将会很方便.同时建造数据库连接池,处理多个业务数据处理. 那么具体怎么实现呢,下面一起来看一下: 整体结构如下: 第一步,先处理连接不同数据库 1.首先,将数据库配置信息创建一个公用类:JdbcUrl.java 主数据库可以用默认的构造方法,如果是连接其他库,则通过传递参数的方式来处理. 数据库参数有如下几个: 1

Python下Mysql数据连接池——单例

# coding:utf-8 import threading import pymysql from DBUtils.PooledDB import PooledDB from app.common.file_config import get_config class DbPool(object): _instance_lock = threading.Lock() def __init__(self): if not hasattr(DbPool, "pool"): DbPool