7

我在使用 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() (尽管上述查询中没有参数),但都无济于事。任何帮助,将不胜感激。

4

3 回答 3

9

如果我理解这一点,缓冲查询涉及告诉 PHP 您想在开始处理之前等待整个结果集。在 PDO 之前,这是默认设置,mysql_unbuffered_query如果您想立即处理结果,则必须调用。

为什么这在 PDO MySQL 驱动程序页面上没有解释,我不知道。

于 2009-02-23T18:39:10.327 回答
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
          )
        );
?>

......无论如何,你明白了。

于 2009-02-23T18:35:09.960 回答
-1

或者,也许您可​​以尝试使用 mysql 函数:

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

这肯定会更快,因为该 foreach 语句给人的印象是使用fetchAll()每一fetch()

于 2012-04-23T19:47:19.287 回答