最近公司生产环境的系统有个需求,需要往mysql数据库的一张表里批量添加数据,业务部门给的数据大致如下:
中心 | 3.5L箱子(条码) | 8L箱子(条码) | 15L箱子(条码) | 20L箱子(条码) |
---|---|---|---|---|
浙江物流一区 | 6个(X04571301-X04571306) | 8个(X03571301-X03571308) | 4个(X02571301-X02571304) | 12个(X01571301-X01571312) |
浙江物流二区 | 24个(X04571401-X04571424) | 42个(X03571401-X03571442) | 78个(X02571401-X02571478) | 36个(X01571401-X01571436) |
这样的数据,首先想到的是在我的macOS上连上服务器数据库,然后把数据一条一条insert进去。但是我insert了几十条后,我发现业务部门给的数据累计有700多条。我当然不愿意就这样老老实实的一条一条insert了,因为实在是太耗费时间了。
根据以往的经验,最先想到的是,把表导入到navicat里,然后生成批量sql插入脚本,再传到服务器上去执行。但是,业务部门给的Excel并不是标准的一条一条的数据展示的,而是像上面那样给定箱子条码范围和数量。这样,我还得先给它生成一个标准的Excel,也比较麻烦。
然后我想到用写程序的方式,写循环,连接数据库插入数据。但是本地环境去连接生产环境的数据库是需要走流程申请权限的,可能流程要走个一两天,业务部门又急着要这个数据,这种方法又要摒弃掉了,只能使用下面一种方案了。
mysql自定义function实现批量添加数据
mysql定义function语法如下:
CREATE FUNCTION func_name ( [func_parameter] ) //括号是必须的,参数是可选的
RETURNS type
[ characteristic ...] routine_body
- CREATE FUNCTION 用来创建函数的关键字
- func_name 表示函数的名称
- func_parameters为函数的参数列表,参数列表的形式为:[IN|OUT|INOUT] param_name type
- IN:表示输入参数
- OUT:表示输出参数
- INOUT:表示既可以输入也可以输出
- param_name:表示参数的名称
- type:表示参数的类型,该类型可以是MySQL数据库中的任意类型
- RETURNS type:语句表示函数返回数据的类型
- characteristic: 指定函数的特性,取值与存储过程的定义相同,可以有以下几种取值方式
- LANGUAGE SQL: 说明routine_body部分由SQL语句组成,当前系统支持的语言为SQL, SQL是LANGUAGE特性的唯一值
- [NOT] DETERMINISTIC: 指明存储过程执行的结果是否正确。DETERMINISTIC表示结果是确定的。每次执行存储过程时,相同的输入会得到相同的输出;
而NOT DETERMINISTIC表示结果是不确定的,相同的输入可能得到不同的输出。如果没有指定任意一个值,默认为NOT DETERMINISTIC - {CONTAINS SQL | NO SQL | READS SQL DATA | MODIFIES SQL DATA}: 指明子程序使用SQL语句限制
- CONTAINS SQL表明子程序包含SQL语句,但是不包含读写数据的语句
- NO SQL表明子程序不包含SQL语句
- READS SQL DATA说明子程序包含读写数据的语句
- MODIFIES SQL DATA表明子程序包含写数据的语句
- 默认情况下,系统会指定为CONTAINS SQL
- SQL SECURITY { DEFINER|INVOKER}: 指明谁有权限来执行。DEFINER表示只有定义存储过程者才能执行;INVOKER表示拥有权限的调用者可以执行。
默认情况下,系统指定为DEFINER - COMMENT 'string': 注释信息,可以用来描述存储过程或者函数
- routine_body是SQL代码内容,可以用BEGIN...END来表示SQL代码的开始与结束
实现批量添加数据的function过程如下:
首先,我把服务器数据库这张表的表结构拷到了本地,便于本地调试所写function是否正确。该表结构与所需要插入的数据相关的字段有三个:
ybxtm, dept_id, box_size //dept_id对应上面数据的中心
然后,实现function实现及调用:
DELIMITER $$ /*定义分隔符,用于在Linux环境下防止function定义的内部分号造成的中途输出*/
CREATE FUNCTION addData(deptId INT, boxSize DOUBLE, ybxtm VARCHAR(20), amount INT)
RETURNS INT DETERMINISTIC /*该参数需要指定,不指定Linux环境下执行时会提示你需要指定function的characteristic*/
BEGIN
DECLARE i INT DEFAULT 1;
DECLARE result INT DEFAULT 1;
DECLARE sampleBoxNum VARCHAR(20) DEFAULT '';
myloop: LOOP
SET sampleBoxNum = ybxtm;
IF i > amount
THEN LEAVE myloop;
END IF;
IF i < 10
THEN SET sampleBoxNum = concat(sampleBoxNum, concat('0', i));
ELSE
SET sampleBoxNum = concat(sampleBoxNum, i);
END IF;
INSERT INTO lx_ybx (ybxtm, dept_id, box_size) VALUES (sampleBoxNum, deptId, boxSize);
SET result = result + 1;
SET i = i + 1;
END LOOP myloop;
RETURN result - 1;
END $$ /*结束时需要挂上分隔符,告诉Linux终端,function定义结束*/
/*调用function*/
SELECT addData(29, 20, 'X025714', 78);