运用Node.js从一个数据库的某个表中导数据到另一个数据库的某个表

时间:2021-11-15 19:10:07

身为一个正处于创业阶段的导师的唯一亲传弟子,楼主真是苦逼。从研一开始,一边上课,一边课余时间就参与导师的项目的开发。从写后台开始,到做前端,现在自己写接口自己写页面。。然后,又要我做运营报表了,做报表需要用到Node.js的内容,公司的CTO给了一点提示就自己去弄了。毕竟没学过Node.js呀,自己就慢慢鼓捣,后来就成了,下面是做运营报表的部分代码,主要功能是把数据从一个数据库的某个表导入到另一个数据库的某个表中,实现起来很简单

//从59数据库里读数据
var mysqlr = require('mysql');
var readConnection = mysqlr.createConnection({
host: '***', //数据库地址
user: '***', //用户名
password: '****', //密码
database: '****' //数据库名称
});
readConnection.connect();

//写到本地的test数据库上
var mysqlw = require('mysql');
var writeConnection = mysqlw.createConnection({
host: 'localhost',
user: 'root', //用户名
password: '123456', //密码
database: 'test' //数据库名称
});
writeConnection.connect();

//将在今天之前注册的用户信息写到本地的数据库中
var oldUserLoginInfo = "SELECT id,phone,regist_time,login_lasttime FROM `user` WHERE DATE_FORMAT(regist_time,'%Y-%m-%d') < CURDATE()";

var writeOldUserInfo = "INSERT INTO userlogininfo (id,phone,regist_time,login_lasttime) VALUES (?,?,?,?)";

readConnection.query(oldUserLoginInfo,function(err,rows,fields){
if (err)
throw err;
for(var item of rows){
var addItem = [item.id,item.phone,item.regist_time,item.login_lasttime];
console.log(addItem);
writeConnection.query(writeOldUserInfo,addItem,function(err,result){
if(err)
console.log(err);
});
}
writeConnection.end();
readConnection.end();
});