php处理大批量数据,php大量数据入库怎么处理

迈不过友情╰ 2022-11-12 13:53 195阅读 0赞

有业务需求需要一次性循环n条数据,插入或更新数据库时,如果单纯的循环,插入/更新,会消耗太多的数据库资源

![243f31b77ef94527dff6ea2cb5521ca1.png][]

以下是一种简单的解决方案

数据库的insert是可以批量更新的，当有大量数据循环insert时，可以将数据先保留不执行插入命令，到最后一条时一次性插入，例如tp的addAll()方法； (推荐学习：PHP视频教程)

数据库的update 如果使用case when 的话，也是可以批量更新的。

本文主要讲关于批量insert；

生成一个订单

正常情况的语句为:INSERT INTO order (\`goods\_id\`,\`num\`,\`price\`) VALUES (1,1,'10.00');

//封装成函数

function add\_order($goods\_id,$num,$price)\{

$db->query("INSERT INTO order (\`goods\_id\`,\`num\`,\`price\`) VALUES ($goods\_id,$num,$price)");

假设有一个用户,一次性将购物车的1000个商品结算成订单,生成1000个订单时;for ($i=0;$i<1000;$i++)\{

$db->query("INSERT INTO order (\`goods\_id\`,\`num\`,\`price\`) VALUES ($goods\_id,$num,$price)");

//这样的话会导致服务器资源占用过大,网站卡死

//所以,我们可以

$sql = "INSERT INTO order (\`goods\_id\`,\`num\`,\`price\`) VALUES ";

for ($i=0;$i<1000;$i++)\{

if($i==0)\{

$sql.="($goods\_id,$num,$price)";

\}else\{

$sql.=",($goods\_id,$num,$price)";

$db->query($sql);

大概意思就是这样了，批量更新实现比较麻烦一点,就不发了，以下是批量更新的sql执行语句UPDATE tiyan.dm\_user\_cupboard SET \`res\_id\` = CASE \`id\` WHEN 1041 THEN '1' WHEN 1058 THEN '1' WHEN 1055 THEN '1' END,\`food\_code\` = CASE \`id\` WHEN 1041 THEN '68' WHEN 1058 THEN '47' WHEN 1055 THEN '49' END,\`food\_name\` = CASE \`id\` WHEN 1041 THEN '红枣' WHEN 1058 THEN '莲藕' WHEN 1055 THEN '洋葱' END,\`num\` = CASE \`id\` WHEN 1041 THEN '2' WHEN 1058 THEN '3' WHEN 1055 THEN '2' END,\`level\` = CASE \`id\` WHEN 1041 THEN '2' WHEN 1058 THEN '2' WHEN 1055 THEN '2' END,\`update\_time\` = CASE \`id\` WHEN 1041 THEN '2017-12-09 21:40:06' WHEN 1058 THEN '2017-12-09 21:40:06' WHEN 1055 THEN '2017-12-09 21:40:06' END WHERE id IN ( 1041,1058,1055 )

[243f31b77ef94527dff6ea2cb5521ca1.png]: /images/20221022/c2f7f337c8d944cbb9d6d9b3ae16a7a4.png