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

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()vsCollection遍历的本质区别

特性	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

⚠️MySQL 的“非缓冲查询”本质是客户端逐行读取，非真正的服务端游标，但效果相同。

---

结语

Laravel 的cursor()方法是迭代器模式在数据库遍历中的高效实践。它通过：

数据库游标 + Generator（生成器）

实现了：

• 内存恒定的逐条遍历；
• 大数据集的安全处理；
• 与foreach无缝集成。

正如你所理解的：好的性能优化不是炫技，而是在正确场景选择正确工具。
cursor()不是替代Collection，而是为其补全大数据场景的能力——这正是迭代器模式的现代价值：让遍历不再受内存限制。