如何使用 Laravel 5 对自定义查询的结果进行分块
How to chunk results from a custom query with Laravel 5
跟进这个问题:How to chunk results from a custom query in Laravel
我试试
DB::connection('mgnt')->select($query)->chunk(200, function($orders) {
foreach ($orders as $order) {
//a bunch of code...
}
});
但我收到以下错误:
FatalErrorException in MigrationController.php line 98:
Call to a member function chunk() on array
如果没有合适的 Eloquent ORM 模型,是否可以进行分块?
我尝试分块,因为如果查询 returns 的结果太多,我会得到一个空白页(在任何日志中都找不到任何错误)。
我想现在一次最多可以查询 50.000 个结果。这可能是由于 Laravel 中的某些限制或限制?
既然查询只是 return 一个对象数组,您可以简单地使用 PHP 的 array_chunk()
:
$result = DB::connection('mgnt')->select($query);
foreach(array_chunk($result, 200) as $orders){
foreach($orders as $order){
// a bunch of code...
}
}
chunk()
在 eloquent 模型上的作用如下:
$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.
call_user_func($callback, $results);
$page++;
$results = $this->forPage($page, $count)->get();
}
您可以尝试做类似的事情(尽管我认为应该可以 运行 您的查询一次全部完成,但我无法帮助您...)
- 为您的 SQL 查询添加限制
LIMIT 200
- 每次查询时增加偏移量运行。第一个0,第二个1 * 200,第三个2 * 200
- 这样做直到结果return为空(例如,使用上面的 while 循环)
跟进这个问题:How to chunk results from a custom query in Laravel
我试试
DB::connection('mgnt')->select($query)->chunk(200, function($orders) {
foreach ($orders as $order) {
//a bunch of code...
}
});
但我收到以下错误:
FatalErrorException in MigrationController.php line 98:
Call to a member function chunk() on array
如果没有合适的 Eloquent ORM 模型,是否可以进行分块? 我尝试分块,因为如果查询 returns 的结果太多,我会得到一个空白页(在任何日志中都找不到任何错误)。
我想现在一次最多可以查询 50.000 个结果。这可能是由于 Laravel 中的某些限制或限制?
既然查询只是 return 一个对象数组,您可以简单地使用 PHP 的 array_chunk()
:
$result = DB::connection('mgnt')->select($query);
foreach(array_chunk($result, 200) as $orders){
foreach($orders as $order){
// a bunch of code...
}
}
chunk()
在 eloquent 模型上的作用如下:
$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.
call_user_func($callback, $results);
$page++;
$results = $this->forPage($page, $count)->get();
}
您可以尝试做类似的事情(尽管我认为应该可以 运行 您的查询一次全部完成,但我无法帮助您...)
- 为您的 SQL 查询添加限制
LIMIT 200
- 每次查询时增加偏移量运行。第一个0,第二个1 * 200,第三个2 * 200
- 这样做直到结果return为空(例如,使用上面的 while 循环)