华山资源网

mysql从一张表查询批量数据并插入到另一表中的完整实例
数据库 2024/12/23 佚名
3 1

说在前面

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([列值],[列值])),([列值],[列值])),([列值],[列值]));

总结

华山资源网 Design By www.eoogi.com
广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
华山资源网 Design By www.eoogi.com
www.eoogi.com 华山资源网
120,135影音资源
344,641技术资源
22,817软件资源
435,032站长资源

更新日志

友情链接

杰晶网络 DDR爱好者之家 桃源资源网 杰网资源 富贵资源网 南强小屋 铁雪资源网 幽灵资源网 万梅资源网 狼山资源网 白云岛资源网 昆仑资源网 相思资源网 明霞山资源网 内蒙古资源网 黑松山资源网 茶园资源网 饿虎岗资源网 大旗谷资源网 常春岛资源网 岱庙资源网 兴国资源网 快活林资源网 蝙蝠岛资源网 帝王谷资源网 白云城资源网 伏龙阁资源网 清风细雨楼 天枫庄资源网 圆月山庄资源网 无争山庄资源网 神水资源网 移花宫资源网 神剑山庄资源网 无为清净楼资源网 金钱帮资源网 丐帮资源网 华山资源网 极乐门资源网 小李飞刀资源网 凤求凰客栈 风云阁资源网 金狮镖局 鸳鸯亭资源网 千金楼资源网 更多链接
华山资源网 Design By www.eoogi.com