1. 程式人生 > >thinkphp對180萬資料批量更新支援事務回滾

thinkphp對180萬資料批量更新支援事務回滾

目前測試180萬多的資料,大概是正常的,不知道再多了會怎麼樣了
我們要給表改成 innodb型別

乾貨來了:

  1.        set_time_limit(0);
  2.         ini_set("memory_limit","800M");//180萬資料  資料越多越消耗記憶體
  3.         $t1 = microtime(true);
  4.         $Model = M('orderlisttest');//先用 M 函式例項化一個空物件
  5.         $rr['goods_tuihuo']=1;
  6.         $subQuery = $Model->field('orderlist_id')->table('vc_orderlisttest')->where($rr)->buildSql();//建立臨時表
  7.         $Model->startTrans();//開啟事務
  8.         $result=$Model->table($subQuery.'a')->field('orderlist_id')->select();
  9.         $total=count($result);
  10.         $num=100000;//每次執行的數量
  11.         $fornumber =ceil($total/$num) ;//分多少次處理
  12.         echo "事務已開啟.........<br>";
  13.         sleep(1);
  14.         ob_flush();
  15.         echo 'Begin ...<br />';
  16.         echo '正在批量更新,請耐心等待...<br />';
  17.         echo "共有".$total."條資料<br />";
  18.         echo "事務正在處理.........<br />";
  19.         echo "正在執行第<span id='c'></span>組/共有".$fornumber."組</br>";
  20.         foreach ($result as $value)
  21.         {
  22.             $order[]=$value['orderlist_id'];
  23.         }
  24.         $index=0;
  25.         for ($i=1;$i<=$fornumber;$i++)
  26.         {
  27.             echo '<script>document.getElementById("c").innerHTML = "'.$i.'";</script>';
  28.             ob_flush();
  29.             flush();
  30.             $arr = array();
  31.             for($j = $index; $j < $index+$num;$j++)
  32.             {
  33.                 $arr[] = $order[$j];
  34.             }
  35.             $this->updatestatus($arr,$i);
  36.             $index += $num;
  37.         }
  38.         echo "執行完畢<br />";
  39.         $t2 = microtime(true);
  40.         echo '共耗時'.round($t2-$t1,3).'秒<br>';
  41.         echo '共消耗記憶體: ' . memory_get_usage() . '<br />';
  42.     }
  43.     public function updatestatus($arr,$i)
  44.     {
  45.         $value='';
  46.         foreach ($arr as $k=>$v)
  47.         {
  48.             if($k==0)
  49.             {
  50.                 $value.=$v;
  51.             }
  52.             else
  53.             {
  54.                 $value.=','.$v;
  55.             }
  56.         }
  57.         $condition['orderlist_id'] =array('in',$value);
  58.         $update['goods_tuihuo'] =0;
  59.         $res = M('Orderlisttest')-> where($condition)->setField($update);
  60.         if($res)
  61.         {
  62.             $map = true;
  63.         }
  64.         else
  65.         {
  66.             $map = false;
  67.         }
  68.         if($map==true)
  69.         {
  70.             M('Orderlist')->where($condition)->commit();
  71.             echo '第'.$i.'組成功<br/>';
  72.         }else
  73.         {
  74.             M('Orderlist')->where($condition)->rollback();//執行失敗回滾
  75.             echo '第'.$i.'組失敗<br/>';
  76.         }
  77.     }

  效果圖: