php一次性大量資料入庫如何解決-php教程-PHP中文網

php一次性大量資料入庫如何解決

小云云

發布： 2023-03-21 13:06:02

原創

1790 人瀏覽過

資料庫的insert 是可以批次更新的,當有大量資料循環insert時,可以將資料先保留不執行插入指令,到最後一條時一次插入,例如tp的addAll()方法;

資料庫的update 如果使用case when 的話,也是可以批量更新的,本人在百度上找到了一個基於tp的saveAll()方法,用於更新數據

本文主要講關於批量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 10555 THEN`1'1059 THEN '68' WHEN 1058 THEN '47 ' WHEN 1055 THEN '49' END,`food_name` = CASE `id` WHEN 1041 THEN '紅棗' WHEN 1, `id` WHEN 1041 THEN '2 ' WHEN 1058 THEN '3' WHEN 1055 THEN '2' END,`level` = CASE `id` WHEN 1041 ,`update_time` = CASE `id ` WHEN 1041 THEN '2017-12-09 21:40:06' WHEN 1058 THEN '2017-12-09 21:40:06' WHEN 1055217 WHERE id IN ( 1041,1058,1055 )

附帶基於tp的saveAll()

//批量更新
public function saveAll($datas,$model){
    ( $model || $model=$this->tableName);
    $model=empty($model)?$this->name:$model;
    $sql   = ''; //Sql
    $lists = []; //记录集$lists
    $pk    = $this->getPk();//获取主键
    foreach ($datas as $data) {
        foreach ($data as $key=>$value) {
            if($pk===$key){
                $ids[]=$value;
            }else{
                $lists[$key].= sprintf("WHEN %u THEN '%s' ",$data[$pk],$value);
            }
        }
    }
    foreach ($lists as $key => $value) {
        $sql.= sprintf("`%s` = CASE `%s` %s END,",$key,$pk,$value);
    }
    $sql = sprintf('UPDATE __%s__ SET %s WHERE %s IN ( %s )',strtoupper($model),rtrim($sql,','),$pk,implode(',',$ids));
    return M()->execute($sql);
}

登入後複製