Laravel 5.8如何流式处理数据库查询结果以降低内存消耗？

完全可行，Laravel 5.8提供了两种方案来避免一次性加载大量数据到内存，其中**游标（Cursor）**正好符合你要的"获取到第一条结果就开始处理"的流式需求，另一种分块（Chunk）则是批量处理，也能降低内存占用。

方案一：使用游标（Cursor）逐行处理 #

Laravel的DB::cursor()方法返回一个迭代器，底层利用PDO的fetch()方法逐行从数据库获取记录，处理完一条就释放内存，不会一次性加载所有结果。

修改后的代码示例 #

首先修正你原SQL中的错误：non_bahamas_vac.user_id = NULL 应该改为 non_bahamas_vac.user_id IS NULL（SQL中判断NULL必须用IS NULL，=无法匹配NULL值），然后替换查询方式为游标：

use Illuminate\Console\Command;
use Illuminate\Support\Facades\DB;

use App\Jobs\SendVaccationEmail;

class ProcessDbResult extends Command
{
    protected $signature = "process:entries";
    protected $description = "Bulk Process of results";

    public function handle() 
    {
        $sql = "
            SELECT DISTINCT 
                 user_id 
            from 
             (Select user_id from travels where destination = 'Bahamas') as bahamas_vac
             LEFT JOIN (Select user_id from travels where destination <> 'Bahamas') as non_bahamas_vac ON bahamas_vac.user_id = non_bahamas_vac.user_id
            WHERE
              non_bahamas_vac.user_id IS NULL
        ";

        // 使用cursor获取迭代器，逐行处理
        foreach (DB::cursor($sql) as $result) {
            SendVaccationEmail::dispatch($result);
        }
    }
}

方案二：分块处理（Chunk） #

如果你希望批量处理（比如每次处理1000条），可以使用DB::table()->chunk()方法，它会自动分页查询并分批返回结果：

// 改用查询构造器实现同样的SQL逻辑，方便使用chunk方法
DB::table('travels')
    ->select('user_id')
    ->where('destination', 'Bahamas')
    ->whereNotIn('user_id', function($query) {
        $query->select('user_id')->from('travels')->where('destination', '<>', 'Bahamas');
    })
    ->distinct()
    ->chunk(1000, function($users) {
        foreach ($users as $user) {
            SendVaccationEmail::dispatch($user);
        }
    });

这种方式内存占用也远低于一次性加载所有数据，适合不需要严格逐行处理的场景。

关键说明 #

• 游标方案内存占用最低，完全符合流式处理的需求，处理10万条记录时内存消耗会非常稳定。
• 务必修正SQL中的IS NULL错误，否则原查询会返回空结果，无法处理任何数据。

内容的提问来源于stack exchange，提问作者Dimitrios Desyllas