MysqL批量insert数据的方法:1、循环插入,语法格式“for($i=1;$i<=条件;$i++){//insert语句}”;2、减少连接资源,拼接一条sql;3、使用存储过程;4、使用“MysqL LOCAL_INFILE”。
本教程操作环境:windows7系统、MysqL8.0.22版、thinkpad t480电脑。
方法一:循环插入
这个也是最普通的方式,如果数据量不是很大,可以使用,但是每次都要消耗连接数据库的资源。
大致思维如下
(我这里写伪代码,具体编写可以结合自己的业务逻辑或者框架语法编写)
for($i=1;$i<=100;$i++){ $sql = 'insert...............'; //querysql } foreach($arr as $key => $value){ $sql = 'insert...............'; //querysql } while($i <= 100){ $sql = 'insert...............'; //querysql $i++ }
因为太过普通同时也没什么难度同时也不是我今天主要写的所以这里我不多说
伪代码如下
//这里假设arr的key和数据库字段同步,其实大多数框架中在PHP操作数据库的时候都是这么设计的 $arr_keys = array_keys($arr); $sql = 'INSERT INTO tablename (' . implode(',' ,$arr_keys) . ') values'; $arr_values = array_values($arr); $sql .= (' . implode(',' ,$arr_values) . '),; $sql = substr($sql ,0 ,-1); //拼接之后大概就是 INSERT INTO tablename ('username','password') values ('xxx','xxx'),('xxx','xxx'),('xxx','xxx'),('xxx','xxx'),('xxx','xxx'),('xxx','xxx') ....... //querysql
这样写正常插入一万条基本问题不大,除非数据很长,应付普通的批量插入够用了,比如:批量生成卡号,批量生成随机码等等。
方法三:使用存储过程
这个我手里正好再用这个就把sql付出来,具体业务逻辑大家自己组合一下就可以。
delimiter $$$ create procedure zqtest() begin declare i int default 0; set i=0; start transaction; while i<80000 do //your insert sql set i=i+1; end while; commit; end $$$ delimiter; call zqtest();
这个也只是个测试代码,具体参数大家自行定义
我这里是一次插入8万条,虽然不多但是,每一条数据量都很大,有很多varchar4000 和text字段
耗时 6.524s
这个我目前正在使用,所以顺便把pdo的代码也复上来,以便大家参考
//设置pdo开启MysqL_ATTR_LOCAL_INFILE /*hs96.cn@gmail.com public function pdo_local_info () { global $system_dbserver; $dbname = 'hs96.cn@gmail.com'; $ip = 'hs96.cn@gmail.com'; $user = 'hs96.cn@gmail.com'; $pwd = 'hs96.cn@gmail.com'; $dsn = 'MysqL:dbname=' . $dbname . ';host=' . $ip . ';port=3306'; $options = [PDO::MysqL_ATTR_LOCAL_INFILE => true]; $db = new PDO($dsn ,$user ,$pwd ,$options); return $db; } //伪代码如下 public function test(){ $arr_keys = array_keys($arr); $root_dir = $_SERVER[DOCUMENT_ROOT] . '/'; $my_file = $root_dir . hs96.cn@gmail.com/sql_cache/ . $order['OrderNo'] . '.sql'; $fhandler = fopen($my_file,'a+'); if ($fhandler) { $sql = implode(\t ,$arr); $i = 1; while ($i <= 80000) { $i++; fwrite($fhandler ,$sql . \r\n); } $sql = LOAD DATA local INFILE ' . $myFile . ' INTO TABLE ; $sql .= tablename ( . implode(',' ,$arr_keys) . ); $pdo = $this->pdo_local_info (); $res = $pdo->exec($sql); if (!$res) { //Todo 插入失败 } @unlink($my_file); } }
更多相关免费学习推荐:mysql教程(视频)
原文地址:https://www.jb51.cc/mysql/1208785.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。