PDO::MYSQL_ATTR_USE_BUFFERED_QUERY设为false无效,因必须在new PDO时传入而非setAttribute;且需同时禁用PDO::ATTR_EMULATE_PREPARES。

为什么 PDO::MYSQL_ATTR_USE_BUFFERED_QUERY 关闭后还卡住?
默认情况下,PDO MySQL 会启用缓冲查询(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY = true),这意味着整个结果集在 execute() 后就一次性拉到 PHP 内存里,fetch() 只是读本地数组。想“实时输出”,第一步必须关掉它——但很多人设了 false 却没生效,原因通常是:属性必须在 PDO 实例化时传入,不能用 setAttribute() 动态修改。
- 正确写法:
$pdo = new PDO($dsn, $user, $pass, [ PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => false, PDO::ATTR_EMULATE_PREPARES => false, // 必须关,否则流式失效 ]); -
PDO::ATTR_EMULATE_PREPARES => false是硬性要求:开启模拟预处理会强制缓冲,流式直接退化 - 如果用的是 PDO 的
query()方法而非prepare()->execute(),同样受该属性控制,无需额外操作
如何边查边 echo 而不等全部查完?
关闭缓冲后,fetch() 每次调用都会从 MySQL 连接中读取下一行(网络 I/O 块级等待),这才是“流式”的本质。关键在于别把所有数据攒起来再输出。
- 避免:
$rows = $stmt->fetchAll(); foreach ($rows as $r) echo ...—— 这又回到全量内存加载 - 推荐模式:
$stmt = $pdo->query("SELECT id, name FROM huge_table"); while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) { echo json_encode($row) . "\n"; ob_flush(); // 强制刷新输出缓冲 flush(); // 强制刷新 Web 服务器缓冲(需 SAPI 支持) } - 注意
ob_start()如果已开启,必须配对ob_flush();Apache + mod_php 下flush()才有效,Nginx + PHP-FPM 默认会拦截,需配置fastcgi_buffering off
PDOStatement::fetch() 流式下有哪些隐藏限制?
流式查询不是万能的。一旦触发某些操作,PDO 会悄悄回退到缓冲模式,导致“以为在流,其实早载完了”。
-
rowCount()在未遍历完前永远返回 -1;调用它不会触发回退,但也没用 -
fetchColumn(0)或fetchObject()没问题,它们只是 fetch 的语法糖 -
绝对禁止:在流式过程中调用
nextRowset()(多结果集)、或执行另一条query()—— 这会让 PDO 内部强制清空当前未读流,行为不可控 - MySQL 的
max_allowed_packet仍起作用:单行超大字段(如长文本、BLOB)可能被截断,且无法分块读,这是协议层限制
用 yield 封装流式查询更安全吗?
直接在循环里 echo 容易和业务逻辑耦合,用生成器隔离 IO 和处理逻辑更可控,也方便测试。
立即学习“PHP免费学习笔记(深入)”;
- 示例:
function streamQuery(PDO $pdo, string $sql): \Generator { $stmt = $pdo->query($sql); while ($row = $stmt->fetch(PDO::FETCH_ASSOC)) { yield $row; } } // 使用 foreach (streamQuery($pdo, "SELECT * FROM log WHERE ts > NOW() - INTERVAL 1 HOUR") as $log) { echo $log['message'] . "\n"; ob_flush(); flush(); } - 生成器本身不改变流式行为,但它让错误处理更清晰:比如某次
fetch()失败(连接中断),可捕获PDOException并 clean up - 注意不要在生成器内做耗时操作(如 curl 请求),否则会阻塞流式节奏,失去“实时”意义
流式输出真正的难点不在 PDO 设置,而在于整条链路的缓冲控制:PHP 输出缓冲、Web 服务器代理缓冲、浏览器渲染策略,三者只要一环堵住,用户就看不到“实时”。调试时先用 curl -N 直连 PHP-FPM 或 CLI 模式验证,排除中间层干扰。











