跳过正文
利用procedure批量插入数据
  1. Posts/

利用procedure批量插入数据

·506 字·2 分钟· · ·
Mysql
小碗汤
作者
小碗汤
云原生搬砖师
Table of Contents

图片描述: 100

正文
#

  要求在页面查询到5000条数据,为了方便插入,准备用shell脚本写curl命令调用自己写的代码接口,但是速度慢,而且写的时候遇到点儿小问题,故用sql语句写了这个功能
  由于operationlog表中的ts字段为13位的时间戳,所以采用了截取的方式。

DROP TABLE IF EXISTS `operationlog`;
CREATE TABLE `operationlog` (
  `sn` int(11) NOT NULL AUTO_INCREMENT,
  `opl` varchar(8) NOT NULL,
  `src` varchar(32) NOT NULL,
  `pid` varchar(32) DEFAULT NULL,
  `ts` varchar(13) NOT NULL,
  PRIMARY KEY (`sn`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

drop procedure if exists batchAdd;

/*count1 循环次数 opl和src为operationlog的列*/
create procedure batchAdd(in count1 int,in opl varchar(32),in src varchar(32))
begin
	declare a int;
	set a=0;
	while a<count1 do
		begin
			/*延时1s*/
			select sleep(1);
			/*获取时间戳1523285555.207000,后面3位是0,现在的需求是ts为13位,即带ms的*/
			select @time1:=unix_timestamp(now(3));
			/*将1523285555.207000的.去掉*/
			select @time1:=replace(@time1, '.', '');
			/*取1523285555207000左边13位*/
			select @time1:=left(@time1, 13);
			/*生成sql,进行insert*/
			insert into operationlog(opl, src, pid, ts) values(opl, src, '1111', @time1);
			/*a加1*/
			set a = a + 1;
		end;

	end while;
end;

--查看procedure
show procedure status;

--调用该procedure
call batchAdd(10, 'INFO', 'AJG');

--删除procedure
drop procedure batchAdd;

create procedure batchAdd如图所示:
#

batchAdd_procedure

创建好procedure后,可以通过call batchAdd(10, ‘INFO’, ‘AJG’);来调用,如下图所示:
#

call_batchAdd

-------莫愁前路无知己 天下谁人不识君-------

相关文章

采坑指南——k8s域名解析coredns问题排查过程
·1652 字·4 分钟·
Kubernetes
史上最全docker基础知识汇总
·4193 字·9 分钟·
Docker
docker镜像制作必备技能
·819 字·2 分钟·
Docker
kubernetes垃圾回收器GarbageCollector控制器源码分析(一)
·6943 字·14 分钟·
Kubernetes
k8s中负载均衡器【ingress-nginx】部署
·1853 字·4 分钟·
Kubernetes Ingress-Nginx
云服务器使用docker搭建服务
·541 字·2 分钟·
Docker

公众号二维码