使用chunkById方法時為什么不要進(jìn)行排序

這篇文章給大家分享的是有關(guān)使用chunkById方法時為什么不要進(jìn)行排序的內(nèi)容。小編覺得挺實(shí)用的，因此分享給大家做個參考，一起跟隨小編過來看看吧。

使用 chunkById 方法的時候請不要進(jìn)行排序

最近在做開發(fā)任務(wù)的時候碰到了個詭異的問題，于是分享給大家

問題說明

由于需要批量處理數(shù)據(jù)，并且這個數(shù)據(jù)的量很大，一次全部取出然后執(zhí)行是不現(xiàn)實(shí)的，幸運(yùn)的是 Laravel 為我們提供了 chunkById 方法來讓我們方便的處理。偽代碼如下

Student::query()
    ->where('is_delete', false)
    ->orderBy('id', 'DESC')
    ->chunkById(200, function($students) {
            // 在這里進(jìn)行邏輯處理
    });

咋一眼看上去，并沒有什么問題，但是實(shí)際執(zhí)行代碼的時候會發(fā)現(xiàn) chunkById 只會執(zhí)行第一次，第二次以后由于某種原因會停止執(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;
    }

看起來沒什么問題，由于 while 循環(huán)是根據(jù) $countResults == $count 來判斷的，那么我們 dump 一下這兩個變量就會發(fā)現(xiàn)， 第一次這兩個是一致的，第二次由于數(shù)據(jù)不一致導(dǎo)致程序停止。

在上面的代碼中， $count 是由 $results = $clone->forPageAfterId($count, $lastId, $column)->get(); 來獲得的，

繼續(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)行降序排列，就會導(dǎo)致 count 不一致，從而使 chunkById 結(jié)束執(zhí)行。

解決方案

把之前的 orderBy('id', 'desc') 移除即可。

Student::query()
    ->where('is_delete', false)
    ->chunkById(200, function($students) {
            // 在這里進(jìn)行邏輯處理
    });

感謝各位的閱讀！關(guān)于“使用chunkById方法時為什么不要進(jìn)行排序”這篇文章就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識，如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！