PHP PDO缓冲查询问题

Question

我在使用 PHP 数据对象函数时遇到一些严重问题。 我试图使用缓冲查询循环遍历一个相当大的结果集（~60k 行，~1gig）以避免获取整个结果集。

无论我做什么，脚本都会挂在 PDO::query() 上 - 查询似乎正在无缓冲地运行（否则为什么结果集大小的更改会“修复”问题？）。 这是我重现问题的代码：

<?php
$Database = new PDO(
    'mysql:host=localhost;port=3306;dbname=mydatabase',
    'root',
    '',
    array(
        PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
        PDO::MYSQL_ATTR_USE_BUFFERED_QUERY => true
    )
);

$rQuery = $Database->query('SELECT id FROM mytable');

// This is never reached because the result set is too large
echo 'Made it through.';

foreach($rQuery as $aRow) {
    print_r($aRow);
}
?>

如果我用一些合理的数字限制查询，它工作正常：

$rQuery = $Database->query('SELECT id FROM mytable LIMIT 10');

我尝试使用 PDO::MYSQL_ATTR_MAX_BUFFER_SIZE 并使用 PDO::prepare() 和 PDO::execute() （尽管上面的查询中没有参数），两者都无济于事。 任何帮助，将不胜感激。

Answer 1

如果我理解正确的话，缓冲查询涉及告诉 PHP 您要在开始处理之前等待整个结果集。 在 PDO 之前，这是默认设置，您必须调用 mysql_unbuffered_query 如果你想立即处理结果。

我不知道为什么 PDO MySQL 驱动程序页面上没有对此进行解释。

Answer 2

您可以尝试将其分成不会大到引起问题的块：

<?php    
$id = 0;
$rQuery = $Database->query('SELECT id FROM mytable ORDER BY id ASC LIMIT 100');

do {
    stuff($rQuery);
    $id += 100;
} while ( $rQuery = $Database->query(
            'SELECT id FROM mytable ORDER BY id ASC LIMIT 100 OFFSET '.$id
          )
        );
?>

……无论如何，您明白了。

Answer 3

或者也许你可以尝试使用 mysql 函数：

while ($row = mysql_fetch_row($query)) {
...
}

这肯定会更快，因为 foreach 语句给人的印象是使用 fetchAll() 而不是 fetch() 每行