前言

如果你需要處理成千上萬個 Eloquent 結果，可以使用 chunk 命令。chunk 方法會獲取一個“組塊”的 Eloquent 模型，并將其填充到給定閉包進行處理。使用 chunk 方法能夠在處理大量數(shù)據(jù)集合時能夠有效減少內存消耗：

Flight::chunk(200, function ($flights) {
 foreach ($flights as $flight) {
  //
 }
});

$all_ark=Arkvolume::chunk(50000, function ($flights) {
 foreach ($flights as $flight) {
  $GLOBALS['something'][] = $flight['id'];
 }
});
 
var_dump($GLOBALS['something'] );exit;

這段代碼是執(zhí)行一個100條的數(shù)據(jù)進行更新，當執(zhí)行完成后繼續(xù)后面的另一百條數(shù)據(jù)……

也就是說他每次操作的是一個數(shù)據(jù)塊而不是整個數(shù)據(jù)庫。

需要注意的是：當使用帶篩選的條件的chunk時，如果是自更新，那么你會漏掉一些數(shù)據(jù)，接著看代碼：

User::where('approved', 0)->chunk(100, function ($users) {
 foreach ($users as $user) {
 $user->update(['approved' => 1]);
 }
});

如果要運行上面的代碼，并不會有報錯，但是where條件是篩選approved為0的user然后將approved的值跟新為1。
在這個過程中，檔第一數(shù)據(jù)庫的數(shù)據(jù)被修改后，下一個數(shù)據(jù)塊的數(shù)據(jù)將是在被修改后的數(shù)據(jù)中選出來的，這個時候數(shù)據(jù)變了，而page也加了1。所以執(zhí)行結束后，只對數(shù)據(jù)中一半的數(shù)據(jù)進行了更新操作。

如果沒有明白的話，我們來看一下chunk的底層實現(xiàn)。還以上面的代碼為例，假如一共有400條數(shù)據(jù)，數(shù)據(jù)被按照100條進行分塊處理。

page = 1: 最開始的時候page為1，選取1-100條數(shù)據(jù)進行處理;

page = 2: 這時候前一百數(shù)據(jù)的approved值全部為1，那么在次篩選的時候數(shù)據(jù)將從第101條開始，而這個時候的page=2,那么處理的數(shù)據(jù)將是第200-300之前的數(shù)據(jù)

之后依舊。

public function chunk($count, callable $callback)
{
 $results = $this->forPage($page = 1, $count)->get();
 
 while (count($results) > 0) {
  // On each chunk result set, we will pass them to the callback and then let the
  // developer take care of everything within the callback, which allows us to
  // keep the memory low for spinning through large result sets for working.
  if (call_user_func($callback, $results) === false) {
   return false;
  }
 
  $page++;
 
  $results = $this->forPage($page, $count)->get();
 }
 
 return true;
}

Laravel chunk 使用注意的問題

使用 Laravel 的 chunk 可以用來優(yōu)化大結果集的查詢，提供分塊處理數(shù)據(jù)的方法，但是如下的例子就會有問題：

User::where('approved', 0)->chunk(100, function ($users) {
 foreach ($users as $user) {
 $user->update(['approved' => 1]);
 }
});

原因在于第一次查詢：

select * from users where approved = 0 limit 100 offset 0;

update 這一批數(shù)據(jù)的 approved 為 1 之后，

再看第二次查詢：

select * from users where approved = 0 limit 100 offset 100;

這個時候因為有 where approved = 0 條件并且偏移量從 100 開始，這樣其實就漏掉了 100 條 approved 為 0 的數(shù)據(jù)。

所以，我們要避免使用 chunk 的時候，更改和過濾條件的字段的值。

總結

以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。