A. NodeJS，mysql2/promise，连接池执行，将数据复制到另一个数据库
产品开发了新版本，数据不兼容，新版本的数据结构比旧版本复杂一些，目前，旧版本是在线系统，需要将旧版本程序的数据适配至新版本程序。数据库是MySQL，这里选择使用NodeJS来完成。
使用的版本：
需要的依赖
案例一，单表的数据同步：
databasemysqlmysql.tools.js
databasemysql2mysql2.tools.js
syncdata0.basesyncData.js
syncdata1.manufactormain.manufactor.js
syncdata2.brandmain.brand.js
syncdata3.categorymain.category.js
案例二，关联表的数据同步：
databasemysql2mysql2.promise.tools.js
syncdata4.general_namemain.general_name.js
syncdata5.goodsmain.goods.js
B. 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数据库及基本知识点详解
C. 关于nodejs下redis/mysql需不需要连接池的问题
mysql会为每个连接创建一个单独的线程来查询。不同于redis数据基本都在内存中，因为mysql会有大量的读取磁盘的IO操作，所以多个线程一起工作会比一个个查询要快。
但是nodejs又是单线程的，它能不能同时发送多个请求到mysql服务器上呢？
这里要理解nodejs的运作，虽然nodejs是一个主线程，但是它调用的IO指令等是通过另外的线程去做的，IO指令完成后就给主线程一个小任务片，也就是回调函数了。
这里有个很关键的点就是，nodejs主线程一个，但是IO线程会有多个。
因此如果用nodejs + mysql只用单个连接的话那么就利用不到mysql能同时服务多个查询的优势了。应该使用类似下图的运作方式，nodejs 使用多个连接来连接mysql。多连接是需要连接池的，有连接池就避免了每次连接都要去创建销毁的消耗了。
D. nodejs 使用node-mysql 中间件的普通连接与连接池连接哪个好
建议使用中间件连接，操作数据库的代码更加简单。我们的后台接口就是用的中间件连接。nodejs的设计特点，使得他本身就很快，即使是读写数据库这样耗时的操作。用连接池的目的其实就是想就加快数据库的IO速度。因此如果用nodejs，使用普通连接足矣！
E. 【node】nodejs promise-mysql 处理事务
项目用到了node来做后台服务端，自然避免不了要用redis、sql等等。在mysql中挑了promise-mysql来做，其中的pool连接池用着挺方便的。
但最近的业务需要用上事务，官方文档貌似没有特别的说明。
源码的pool有个getConnection的方法，同时return new PoolConnection
再看看这个PoolConnection，调用了Connection.call(this, null, _connection)，说明具有connection的所有功能
便可追进Connection里面看，有beginTransaction，query，commit，rollback，足够我们使用，另外PoolConnection里面还有release方法，保证了pool连接池的不用destroy掉这个connection。
不说废话，直接贴码
F. node mssql 连接池
generic-pool模块是nodejs的一个第三方模块，其作用为提供一个通用的连接池模块，可以通过generic-pool实现对tcp连接池或者MySQL数据库连接池等的管理。github的地址如下：https://github.com/coopernurse/node-pool
// Create a MySQL connection pool with
// a max of 10 connections, a min of 2, and a 30 second max idle time
var Pool = require('generic-pool').Pool;
var mysql = require('mysql'); // v2.10.x
var pool = new Pool({
name : 'mysql',
create : function(callback) {
var c = mysql.createConnection({
user: 'scott',
password: 'tiger',
database:'mydb'
})
// parameter order: err, resource
callback(null, c);
},
destroy : function(client) { client.end(); },
max : 10,
// optional. if you set this, make sure to drain() (see step 3)
min : 2,
// specifies how long a resource can stay idle in pool before being removed
idleTimeoutMillis : 30000,
// if true, logs via console.log - can also be a function
log : true
});