mysql从一张表查询批量数据并插入到另一表中的完整实例

 更新时间:2021年01月06日 10:55:34   作者:gaoshanyangzhi_1999  
这篇文章主要给大家介绍了关于mysql从一张表查询批量数据并插入到另一表中的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

说在前面

nodejs 读取数据库是一个异步操作,所以在数据库还未读取到数据之前,就会继续往下执行代码。
最近写东西时,需要对数据库进行批量数据的查询后,insert到另一表中。
说到批量操作,让人最容易想到的是for循环。

错误的 for 循环版本

先放出代码,提前说明一下,在这里封装了sql操作:sql.sever(数据库连接池,sql语句拼接函数,回调函数)

for(let i=0;i<views.xuehao.length;i++){
	sql.sever(pool,sql.select(["name"],"registryinformation",["xuehao="+sql.escape(views.xuehao[i])]),function(data){
  sql.sever(pool,sql.insert("personnelqueue",["xuehao","name","selfgroup","time"],[sql.escape(views.xuehao[i]),data[0].name,selfgroup,'NOW()'],true),function(){
  let allGroup = ['Android', 'ios', 'Web', '后台','产品'];	//这里是邮件相关代码
  let group = allGroup[selfgroup - 1];
  let mailmsg = "您好," + group + "组通过人员表已提交,请您尽快审核!";
  mail.mailepass(mailmsg);
  res.write(JSON.stringify({
   style:1,
   msg:"已将名单提交,待管理员审核!"
  }));
  res.end();
  })
 })
}

上面代码中,是先进行数据查询再进行数据的插入,(在这里假定有2条数据)按照常理,我们想的执行顺序是:查询 插入 查询 插入。然而,并非我们所想那么简单,虽然插入操作也确实在数据库查询的回调中写的,但是实际的顺序是:查询 查询,一旦直接进行了两次查询,想当然后面的代码直接报错了。没来得及回调时,已经执行了第二次循环。

改进的 for 循环版本

mysql 用一条语句可以完成查询并插入,格式为:INSERT IGNORE INTO 插入表表名 (item1,item2) SELECT item1,item2 FROM 查询表表名 WHERE,于是乎,便想到了下面的解决方案。

for (let i = 0; i < views.xuehao.length; i++) {
 sql.sever(pool, 'INSERT IGNORE INTO personnelqueue (xuehao,name,selfgroup,time) SELECT xuehao,name,selfgroup,NOW() FROM registryinformation WHERE xuehao=' + sql.escape(views.xuehao[i]) + ' and pass=' + state, function () {
  if (i == views.xuehao.length - 1) {
   let allGroup = ['Android', 'ios', 'Web', '后台', '产品'];
   let group = allGroup[selfgroup - 1];
   let mailmsg = "您好," + group + "组通过人员表已提交,请您尽快审核!";
   mail.mailepass(mailmsg);
   res.write(JSON.stringify({
    style: 1,
    msg: "已将名单提交,待管理员审核!"
   }));
   res.end();
  }
 })
} 

这样,数据库操作正确,目的达到了。但是仔细想来,这样做还是有缺陷的。如果数据量小还好说,但若数据量大时,这样导致程序和数据库建立多次连接,会增加服务器负荷。

改进版

结合上一次的缺陷,顾名思义,这次我们要减少程序与数据库连接次数。于是,我们不再将插入和查询写到一起,而是将其分开,进行批量的插询,从而利用所查数据批量插入。代码如下:

let sqlString = 'SELECT xuehao,name,selfgroup FROM registryinformation WHERE pass=' + state + ' AND (xuehao=' + sql.escape(views.xuehao[0]);
for (let i = 1; i < views.xuehao.length; i++) {
 sqlString += ' OR xuehao=' + sql.escape(views.xuehao[i]);
}
sqlString = sqlString + ')';
sql.sever(pool, sqlString, function (data) {
 //拼接插入sql语句
 let istSqlStr = 'INSERT IGNORE INTO personnelqueue (xuehao,name,selfgroup,time) VALUES (' + data[0].xuehao + ',' + sql.escape(data[0].name) + ',' + data[0].selfgroup + ',NOW())';
 for (let j = 1; j < data.length; j++) {
 istSqlStr += ',(' + data[j].xuehao + ',' + sql.escape(data[j].name) + ',' + data[j].selfgroup + ',' + 'NOW())';
 }
 sql.sever(pool, istSqlStr, function () {
 let allGroup = ['Android', 'ios', 'Web', '后台', '产品'];
 let group = allGroup[selfgroup - 1];
 let mailmsg = "您好," + group + "组通过人员表已提交,请您尽快审核!";
 mail.mailepass(mailmsg);
 res.write(JSON.stringify({
  style: 1,
  msg: "已将名单提交,待管理员审核!"
 }));
 res.end();
 })
})

补充

批量查询语法(在这里and与or进行了混用) SELECT 列名,列名 FROM 表名 WHERE 条件 AND (item1=‘xxx' OR item1=‘yyy');
一条语句进行批量插入语法 INSERT INTO [ 表名 ]([ 列名] ,[ 列名 ]) VALUES([列值],[列值])),([列值],[列值])),([列值],[列值]));

总结

到此这篇关于mysql从一张表查询批量数据并插入到另一表中的文章就介绍到这了,更多相关mysql查询批量数据插入到另一表内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • MAC下Mysql5.7.10版本修改root密码的方法

    MAC下Mysql5.7.10版本修改root密码的方法

    这篇文章主要介绍了MAC下Mysql5.7.10版本修改root密码的方法,非常不错,具有参考借鉴价值,需要的朋友可以参考下
    2017-03-03
  • 一个mysql死锁场景实例分析

    一个mysql死锁场景实例分析

    这篇文章主要给大家实例分析了一个mysql死锁场景的相关资料,文中通过示例代码介绍的非常详细,对大家学习或者使用mysql具有一定的参考学习价值,需要的朋友们下面来一起学习学习吧
    2019-05-05
  • MySQL UDF调试方式debugview的相关方法

    MySQL UDF调试方式debugview的相关方法

    MySQL UDF调试方式debugview的相关方法...
    2007-07-07
  • MySQL5.7 windows二进制安装教程

    MySQL5.7 windows二进制安装教程

    这篇文章主要为大家详细介绍了MySQL5.7 windows二进制安装教程,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2016-08-08
  • mysql 5.7.25 安装配置方法图文教程

    mysql 5.7.25 安装配置方法图文教程

    这篇文章主要为大家详细介绍了mysql 5.7.25 安装配置方法图文教程,文中安装步骤介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-10-10
  • mysql tmp_table_size优化之设置多大合适

    mysql tmp_table_size优化之设置多大合适

    这篇文章主要介绍了mysql tmp_table_size优化问题,很多朋友都会问tmp_table_size设置多大合适,其实既然你都搜索到这篇文章了,一般大于64M比较好,当然你也可以可以根据自己的机器内容配置增加,一般64位的系统能充分利用大内存
    2016-05-05
  • CentOS8下MySQL 8.0安装部署的方法

    CentOS8下MySQL 8.0安装部署的方法

    这篇文章主要介绍了CentOS 8下 MySQL 8.0 安装部署的方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-11-11
  • MYSQL存储过程即常用逻辑知识点总结

    MYSQL存储过程即常用逻辑知识点总结

    在本篇文章里小编给大家整理的是关于MYSQL存储过程即常用逻辑知识点,有需要的朋友们可以学习下。
    2019-08-08
  • mysql 5.7.13 winx64安装配置教程

    mysql 5.7.13 winx64安装配置教程

    这篇文章主要为大家分享了windows下mysql 5.7.13winx64安装配置教程,总结在安装mysql5.7时遇到的坑,感兴趣的朋友可以参考一下
    2016-12-12
  • MySQL配置文件my.cnf中文详解附mysql性能优化方法分享

    MySQL配置文件my.cnf中文详解附mysql性能优化方法分享

    Mysql参数优化对于新手来讲,是比较难懂的东西,其实这个参数优化,是个很复杂的东西,对于不同的网站,及其在线量,访问量,帖子数量,网络情况,以及机器硬件配置都有关系,优化不可能一次性完成,需要不断的观察以及调试,才有可能得到最佳效果。
    2011-09-09

最新评论