当前位置：首页 > news >正文

迭代器模式（Iterator）：Eloquent 的 `cursor()` 方法如何实现内存高效的逐条遍历？它与 `Collection` 的遍历有何不同？

news 2026/6/16 12:06:30

Laravel 的cursor()方法正是迭代器模式（Iterator Pattern）在数据库遍历场景中的高效应用，它通过数据库游标（Cursor）逐条拉取记录，避免将整个结果集加载到内存中，从而实现内存恒定（O(1) 内存）的高效遍历。这与Collection的全量加载（O(n) 内存）形成鲜明对比。

一、迭代器模式的核心思想（GoF 定义）

提供一种方法顺序访问一个聚合对象中的各个元素，而又不暴露该对象的内部表示。

Iterator（迭代器）：定义访问接口（如current(),next(),valid()）；
Aggregate（聚合）：可遍历的对象（如数据库结果集）；
关键：按需获取元素，而非一次性加载全部。

在cursor()中：

Aggregate= 数据库查询结果集；
Iterator=Generator或PDO Statement游标；
按需拉取= 每次foreach迭代只从数据库取一行。

二、`cursor()`如何实现内存高效的遍历？

1.底层机制：数据库游标（Cursor）

默认的get()会执行SELECT * FROM ...并将所有结果加载到内存；
cursor()使用游标查询（Cursor-based Query）：
- 对于 MySQL：使用PDO::MYSQL_ATTR_USE_BUFFERED_QUERY = false，禁用结果集缓冲；
- 对于 PostgreSQL：使用服务端游标（Server-side Cursor）；
- 对于 SQLite：逐行读取。

2.返回 Generator（生成器）

// Illuminate/Database/Concerns/BuildsQueries.phppublicfunctioncursor(){return$this->connection->cursor($this->toSql(),$this->getBindings(),!$this->useWritePdo);}// Connection::cursor()publicfunctioncursor($query,$bindings=[],$useReadPdo=true){$statement=$this->getPdoForSelect($useReadPdo)->prepare($query);$statement->execute($bindings);// 返回 Generator：逐行 yieldwhile($record=$statement->fetch()){yield$this->hydrate($record,$this->model);}}

✅cursor()返回一个Generator，每次迭代只从数据库取一行，并转换为模型。

3.内存使用对比

方法	内存占用	适用场景
`get()`→`Collection`	O(n)（加载所有记录）	小数据集（< 1万行）
`cursor()`	O(1)（恒定内存）	大数据集（10万+ 行）

三、`cursor()`vs`Collection`遍历的本质区别

特性	`Collection`（`get()`）	`cursor()`
数据加载时机	立即加载全部	按需逐条加载
内存占用	随记录数线性增长	恒定（仅当前记录）
数据库连接	查询后立即释放	遍历期间保持连接
可链式操作	支持所有`Collection`方法（`map`,`filter`等）	仅支持`foreach`遍历
异常安全	遍历中断不影响数据库	必须遍历完或显式关闭，否则连接可能保持打开
适用操作	复杂集合操作	简单逐条处理（如导入、导出、批量更新）

⚠️关键限制：cursor()返回的是Generator，不支持Collection的链式方法（如->filter()->map()），因为数据未全量加载。

四、正确使用`cursor()`的最佳实践

1.适用场景

大数据导出（如生成 CSV）；
批量处理（如发送邮件、更新状态）；
ETL 任务（Extract-Transform-Load）。

2.代码示例

// 高效遍历 100 万用户foreach(User::cursor()as$user){// 处理单个用户Mail::to($user->email)->queue(newMonthlyReport());// 注意：避免在循环内执行 N+1 查询// 如需关联数据，使用 `with()` 预加载}// 或使用 chunkById（更安全）User::chunkById(200,function($users){foreach($usersas$user){// 处理 200 个用户}});

3.注意事项

避免 N+1 查询：在cursor()前使用with()预加载关联；
保持事务简短：不要在foreach中开启长事务；
连接超时：确保数据库wait_timeout足够长；
异常处理：捕获异常并确保资源释放（Generator会自动关闭游标，但需测试）。

五、`chunk()`与`cursor()`的对比

Laravel 还提供chunk()方法，它与cursor()有何不同？

方法	机制	内存	适用场景
`chunk($count, $callback)`	分页查询（`LIMIT/OFFSET`）	O($count)	需要分批处理，且支持复杂操作
`cursor()`	数据库游标（逐行流式）	O(1)	纯遍历，极致内存优化

✅chunk()更安全（每次查询独立），cursor()更高效（单次查询）。

六、与你工程理念的深度对齐

你的原则	在`cursor()`中的体现
性能意识	避免内存溢出，处理大数据集
资源管理	按需使用数据库连接，及时释放
适用场景驱动	不盲目使用，仅在大数据场景启用
避免过度工程	简单遍历用`cursor()`，复杂操作用`chunk()`或`Collection`
可维护性	代码清晰表达“逐条处理”意图

七、底层数据库游标支持情况

数据库	游标支持	Laravel 实现
MySQL	客户端游标（非缓冲查询）	`PDO::MYSQL_ATTR_USE_BUFFERED_QUERY = false`
PostgreSQL	服务端游标	`DECLARE ... CURSOR`（Laravel 未默认启用，需自定义）
SQLite	逐行读取	原生支持
SQL Server	客户端游标	类似 MySQL