解决PHP PDO循环查询中的致命错误：fetchAll() on null

在PHP开发中，当我们需要批量执行并处理多个数据库查询时，通常会将这些查询语句或其结果存储在数组中，然后通过循环进行迭代。然而，不当的循环逻辑或对PDOStatement对象的错误处理，可能导致程序中断并抛出致命错误。本文将详细解析这类问题，并提供一个标准化的解决方案。

错误现象与根源分析

在给定的代码示例中，开发者尝试通过一个while循环来遍历一个包含多个PDOStatement对象的数组$query。代码结构如下：

$q = 1;
$z = 1;
while ($ass = $query[$q]->fetchAll()){
    // ... 处理结果 ...
    $q++;
    $z++;
};

当$q的值逐渐增大，并最终超出了$query数组中定义的键（例如，$query数组最大键为25，但$q递增到26时），会发生以下两个错误：

1. Warning: Undefined array key 26 in C:\xampp\htdocs\connect.php on line 64 这个警告表明程序试图访问$query数组中一个不存在的键26。由于$query[26]不存在，PHP会返回null。

2. Fatal error: Uncaught Error: Call to a member function fetchAll() on null in C:\xampp\htdocs\connect.php:64 Stack trace: #0 {main} thrown in C:\xampp\htdocs\connect.php on line 64 这个致命错误紧随警告之后发生。因为它尝试在null值上调用fetchAll()方法。fetchAll()是PDOStatement类的一个成员方法，只能在有效的PDOStatement对象上调用。当$query[$q]返回null时，尝试对其调用方法自然会导致此错误，从而终止脚本执行。

因此，问题的核心在于while循环的条件判断方式。while ($ass = $query[$q]->fetchAll())这种写法，依赖于$query[$q]->fetchAll()的返回值来决定循环是否继续。当$query[$q]变成null时，整个表达式都会失败。

立即学习“PHP免费学习笔记（深入）”；

解决方案：使用foreach迭代PDOStatement对象

解决这类问题的最有效方法是使用foreach循环直接迭代存储PDOStatement对象的数组。foreach循环能够确保每次迭代都访问到数组中实际存在的元素，避免了手动管理索引可能导致的越界问题。

以下是优化后的代码示例，展示了如何正确地遍历并处理查询结果：

 false,
            PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC // 建议设置默认获取模式为关联数组
        ]
    );
    echo "数据库连接成功！
";

} catch (PDOException $error) {
    exit('数据库连接错误: ' . $error->getMessage());
}

// 预定义的查询数组
// 注意：在实际应用中，如果查询包含用户输入，应使用预处理语句（prepare/execute）而非直接query
$queryStatements = array(
    1  => $db->query('SELECT * FROM filmy;'),
    2  => $db->query('SELECT * FROM aktorzy;'),
    3  => $db->query('SELECT kraj FROM `kraje`;'),
    4  => $db->query('SELECT COUNT(`IdWydarzenie`) AS total_events FROM  wydarzenie;'),
    5  => $db->query('SELECT AVG(`Ocena`) AS avg_rating FROM recenzje;'),
    6  => $db->query('SELECT tytul FROM  filmy  WHERE CzasTrwania_min>=120;'),
    7  => $db->query('SELECT ImieNazwisko FROM aktorzy WHERE year(DataUrodzenia)>1960;'),
    8  => $db->query('SELECT COUNT(ImieNazwisko) AS actors_born_april FROM aktorzy WHERE month(DataUrodzenia)=04;'),
    9  => $db->query('SELECT COUNT(tytul) AS movies_2002 FROM filmy WHERE RokProdukcji=2002; '),
    10  => $db->query('SELECT COUNT(ImieNazwisko) AS actors_70s FROM aktorzy WHERE year(DataUrodzenia) BETWEEN 1970 AND 1979;'),
    11  => $db->query('SELECT tytul FROM `filmy` ORDER BY RokProdukcji DESC LIMIT 3; '),
    12  => $db->query('SELECT ImieNazwisko FROM aktorzy ORDER BY DataUrodzenia DESC LIMIT 2; '),
    13  => $db->query("SELECT * FROM filmy Where tytul LIKE 'S%';"),
    14  => $db->query('SELECT * FROM filmy WHERE RokProdukcji>2000 AND CzasTrwania_min<=120;'),
    15  => $db->query('SELECT RokProdukcji, COUNT(*) AS count_by_year FROM filmy GROUP BY RokProdukcji; '),
    16  => $db->query('SELECT tytul FROM filmy INNER JOIN film_aktor ON filmy.IdFilmy=film_aktor.IdFilmu INNER JOIN aktorzy ON film_aktor.IdAktora=aktorzy.IdAktorzy WHERE ImieNazwisko="Tom Hanks";'),
    17  => $db->query('SELECT ImieNazwisko, COUNT(IdFilmu) AS film_count FROM film_aktor INNER JOIN aktorzy ON film_aktor.IdAktora=aktorzy.IdAktorzy GROUP BY ImieNazwisko;'),
    18  => $db->query('SELECT ImieNazwisko, COUNT(IdFilmu) AS liczba FROM aktorzy INNER JOIN film_aktor ON aktorzy.IdAktorzy=film_aktor.IdAktora GROUP BY ImieNazwisko HAVING liczba>=2; '),
    19  => $db->query('SELECT Tytul, AVG(Ocena) AS avg_rating FROM filmy INNER JOIN film_premiera ON filmy.IdFilmy=film_premiera.IdFilm_Premiera INNER JOIN recenzje ON film_premiera.IdFilm_Premiera=recenzje.IdRecenzje GROUP BY Tytul;'),
    20  => $db->query('SELECT COUNT(tytul) AS Liczba FROM filmy INNER JOIN film_gatunek ON filmy.IdFilmy=film_gatunek.IdFilmu INNER JOIN gatunek ON film_gatunek.IdGatunku=gatunek.IdGatunek WHERE Nazwa="Familijny"; '),
    21  => $db->query('SELECT Nazwa AS GatunkiFilmówWJakichGrałMorganFreeman FROM aktorzy INNER JOIN film_aktor ON aktorzy.IdAktorzy=film_aktor.IdAktora INNER JOIN filmy ON film_aktor.IdFilmu=filmy.IdFilmy INNER JOIN film_gatunek ON filmy.IdFilmy=film_gatunek.IdFilmu INNER JOIN gatunek ON film_gatunek.IdGatunku=gatunek.IdGatunek WHERE ImieNazwisko="Morgan Freeman";'),
    22  => $db->query('SELECT Kraj, COUNT(IdFilmy) AS LiczbaFilmów FROM filmy INNER JOIN film_produkcja ON filmy.IdFilmy=film_produkcja.IdFilmu INNER JOIN kraje ON film_produkcja.IdProdukcji=kraje.IdKraje GROUP BY IdKraje;'),
    23  => $db->query('SELECT Nazwa, COUNT(IdUczestnika) AS LiczbaOsób FROM wydarzenie RIGHT JOIN wydarzenie_uczestnicy ON wydarzenie.IdOrganizatora=wydarzenie_uczestnicy.IdUczestnika GROUP BY IdWydarzenia;'),
    24  => $db->query('SELECT idOsoby, Imię, Nazwisko FROM osoby LEFT JOIN wydarzenie_uczestnicy ON osoby.IdOsoby=wydarzenie_uczestnicy.IdUczestnika WHERE idWydarzenia IS NULL;'),
    25  => $db->query("SELECT g.Nazwa FROM Kraje k INNER JOIN Film_Produkcja fp ON k.IdKraje = fp.IdProdukcji INNER JOIN Filmy f ON f.IdFilmy = fp.IdFilmu INNER JOIN Film_Gatunek fg ON fg.IdFilmu = f.IdFilmy INNER JOIN Gatunek g ON g.IdGatunek = fg.IdGatunku WHERE k.Kraj = 'Polska' GROUP BY g.Nazwa ORDER BY COUNT(*) DESC;"),
);

$query_number = 1; // 用于显示查询编号

foreach ($queryStatements as $index => $statement) {
    if ($statement instanceof PDOStatement) { // 确保当前元素是PDOStatement对象
        echo('
');
        echo("Zapytanie nr. " . $query_number . ":
");

        $results = $statement->fetchAll(); // 获取所有结果

        if (!empty($results)) {
            foreach ($results as $row) {
                // 假设我们希望以关联数组形式显示数据
                // 如果PDO::ATTR_DEFAULT_FETCH_MODE未设置，可以在fetchAll()中指定 PDO::FETCH_ASSOC
                foreach ($row as $key => $value) {
                    echo htmlspecialchars($key) . ": " . htmlspecialchars($value) . " ";
                }
                echo("
");
            }
        } else {
            echo "无结果或查询返回空。
";
        }
        echo"
";
    } else {
        echo('
');
        echo("Zapytanie nr. " . $query_number . ":
");
        echo "错误：数组中键 " . $index . " 对应的不是一个有效的PDOStatement对象。
";
        echo"
";
    }
    $query_number++;
}

?>

关键改进点说明

1. 使用foreach循环：foreach ($queryStatements as $index => $statement)直接遍历$queryStatements数组中的每个元素。$index将是数组的键（1到25），$statement将是对应的PDOStatement对象。这消除了手动递增索引$q的需要，自然避免了访问越界。

2. PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC： 在PDO连接初始化时设置此属性，可以使fetchAll()默认返回关联数组（以列名为键）。这使得结果的访问和显示更加直观和方便，例如$row['column_name']。原始代码中通过count(array_keys($asscount))和count/2-1来处理PDO::FETCH_BOTH（默认模式，同时返回数字和关联键）的复杂逻辑不再需要。如果未设置此默认模式，可以在$statement->fetchAll(PDO::FETCH_ASSOC)中单独指定。

3. 类型检查：if ($statement instanceof PDOStatement) 这是一个额外的安全检查，确保$statement确实是一个PDOStatement对象，防止数组中可能混入非预期的值。

4. 简化结果显示： 内部的foreach ($results as $row)和foreach ($row as $key => $value)循环以更清晰的方式迭代并显示每行和每列的数据。htmlspecialchars()用于防止XSS攻击，是输出用户或数据库内容时的良好实践。

5. 错误处理增强： 数据库连接的try-catch块提供了更详细的错误信息，便于调试。

注意事项与最佳实践

• 预处理语句（Prepared Statements）： 在上述示例中，所有查询都是通过$db->query()直接执行的。虽然对于静态查询这通常没有问题，但如果查询字符串中包含任何来自用户输入的数据，强烈建议使用预处理语句（$db->prepare()和$statement->execute()）。这能有效防止SQL注入攻击，并提高查询效率（特别是当相同查询模板被多次执行时）。

• 资源管理： PDOStatement对象在完成结果获取后通常会自动释放数据库资源。但在处理大量数据或长时间运行的脚本时，了解资源使用情况仍然很重要。

• 代码可读性： 清晰的变量命名、合理的代码缩进和注释都能极大地提高代码的可读性和可维护性。避免过于复杂的嵌套循环，尽量保持逻辑简洁。

• 错误日志： 在生产环境中，不应直接将错误信息显示给用户。应将错误记录到日志文件，并向用户显示一个友好的错误页面。

通过遵循这些原则和采用本文提供的解决方案，您可以有效地避免PHP PDO循环查询中常见的致命错误，并编写出更健壮、更专业的数据库交互代码。