下面由laravel教程欄目給大家介紹使用chunkbyid方法時請不要進行排序!,希望對需要的朋友有所幫助!
使用 chunkById 方法的時候請不要進行排序
最近在做開發任務的時候碰到了個詭異的問題,于是分享給大家
問題說明
由于需要批量處理數據,并且這個數據的量很大,一次全部取出然后執行是不現實的,幸運的是 Laravel 為我們提供了 chunkById 方法來讓我們方便的處理。偽代碼如下
Student::query() ????->where('is_delete',?false) ????->orderBy('id',?'DESC') ????->chunkById(200,?function($students)?{ ????????????//?在這里進行邏輯處理 ????});
咋一眼看上去,并沒有什么問題,但是實際執行代碼的時候會發現 chunkById 只會執行第一次,第二次以后由于某種原因會停止執行。
查找原因
Laravel 的源碼中 chunkById 代碼如下
??public?function?chunkById($count,?callable?$callback,?$column?=?null,?$alias?=?null) ????{ ????????$column?=?is_null($column)???$this->getModel()->getKeyName()?:?$column; ????????$alias?=?is_null($alias)???$column?:?$alias; ????????$lastId?=?null; ????????do?{ ????????????$clone?=?clone?$this; ????????????$results?=?$clone->forPageAfterId($count,?$lastId,?$column)->get(); ????????????$countResults?=?$results->count(); ????????????if?($countResults?==?0)?{ ????????????????break; ????????????} ????????????if?($callback($results)?===?false)?{ ????????????????return?false; ????????????} ????????????$lastId?=?$results->last()->{$alias}; ????????????unset($results); ????????}?while?($countResults?==?$count); ????????return?true; ????}
看起來沒什么問題,由于 while 循環是根據 $countResults == $count 來判斷的,那么我們 dump 一下這兩個變量就會發現, 第一次這兩個是一致的,第二次由于數據不一致導致程序停止。
在上面的代碼中, $count 是由 $results = $clone->forPageAfterId($count, $lastId, $column)->get(); 來獲得的,
繼續查看 forPageAfterId 方法
public?function?forPageAfterId($perPage?=?15,?$lastId?=?0,?$column?=?'id') { ????$this->orders?=?$this->removeExistingOrdersFor($column); ????if?(!?is_null($lastId))?{ ????????$this->where($column,?'>',?$lastId); ????} ????return?$this->orderBy($column,?'asc') ????????????????->take($perPage); }
我們可以看到,在這里返回的結果是 orderBy 進行升序排列的, 而我們的原始代碼是進行降序排列,就會導致 count 不一致,從而使 chunkById 結束執行。
解決方案
把之前的 orderBy(‘id’, ‘desc’) 移除即可。
Student::query() ????->where('is_delete',?false) ????->chunkById(200,?function($students)?{ ????????????//?在這里進行邏輯處理 ????});
總結
-
以后使用 chunkById 或者 chunk 方法的時候不要添加自定義的排序
-
騷到老,學到老。。。