.jpg)
下面由laravel教程欄目給大家介紹使用chunkbyid方法時(shí)請(qǐng)不要進(jìn)行排序！，希望對(duì)需要的朋友有所幫助！
使用 chunkById 方法的時(shí)候請(qǐng)不要進(jìn)行排序
最近在做開發(fā)任務(wù)的時(shí)候碰到了個(gè)詭異的問題，于是分享給大家
問題說(shuō)明
由于需要批量處理數(shù)據(jù)，并且這個(gè)數(shù)據(jù)的量很大，一次全部取出然后執(zhí)行是不現(xiàn)實(shí)的，幸運(yùn)的是 Laravel 為我們提供了 chunkById 方法來(lái)讓我們方便的處理。偽代碼如下
Student::query() ????->where('is_delete',?false) ????->orderBy('id',?'DESC') ????->chunkById(200,?function($students)?{ ????????????//?在這里進(jìn)行邏輯處理 ????});
咋一眼看上去，并沒有什么問題，但是實(shí)際執(zhí)行代碼的時(shí)候會(huì)發(fā)現(xiàn) chunkById 只會(huì)執(zhí)行第一次，第二次以后由于某種原因會(huì)停止執(zhí)行。
查找原因
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; ????}
看起來(lái)沒什么問題，由于 while 循環(huán)是根據(jù) $countResults == $count 來(lái)判斷的，那么我們 dump 一下這兩個(gè)變量就會(huì)發(fā)現(xiàn)， 第一次這兩個(gè)是一致的，第二次由于數(shù)據(jù)不一致導(dǎo)致程序停止。
在上面的代碼中， $count 是由 $results = $clone->forPageAfterId($count, $lastId, $column)->get(); 來(lái)獲得的，
繼續(xù)查看 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); }
我們可以看到，在這里返回的結(jié)果是 orderBy 進(jìn)行升序排列的， 而我們的原始代碼是進(jìn)行降序排列，就會(huì)導(dǎo)致 count 不一致，從而使 chunkById 結(jié)束執(zhí)行。
解決方案
把之前的 orderBy(‘id’, ‘desc’) 移除即可。
Student::query() ????->where('is_delete',?false) ????->chunkById(200,?function($students)?{ ????????????//?在這里進(jìn)行邏輯處理 ????});
總結(jié)
-
以后使用 chunkById 或者 chunk 方法的時(shí)候不要添加自定義的排序
-
騷到老，學(xué)到老。。。
.png)
