PDO 无缓冲查询

Question

我正在尝试了解 PDO 详细信息。 所以我编码如下：

$cn = getConnection();

// get table sequence
$comando = "call p_generate_seq('bitacora')";
$id = getValue($cn, $comando);

//$comando = 'INSERT INTO dsa_bitacora (id, estado, fch_creacion) VALUES (?, ?, ?)';
$comando = 'INSERT INTO dsa_bitacora (id, estado, fch_creacion) VALUES (:id, :estado, :fch_creacion)';
$parametros = array (
    ':id'=> (int)$id,
    ':estado'=>1,
    ':fch_creacion'=>date('Y-m-d H:i:s')
);
execWithParameters($cn, $comando, $parametros);

我的 getValue 函数工作正常，并且我得到了表的下一个序列。 但是当我进入 execWithParameters 时，我得到了这个异常：

PDOException：SQLSTATE[HY000]：一般错误：2014 当其他未缓冲查询处于活动状态时无法执行查询。 考虑使用 PDOStatement::fetchAll()。 或者，如果您的代码仅针对 mysql 运行，您可以通过设置 PDO::MYSQL_ATTR_USE_BUFFERED_QUERY 属性来启用查询缓冲。 在 D:\Servidor\xampp_1_7_1\htdocs\bitacora\func_db.php 第 77 行

我尝试修改连接属性，但它不起作用。

这些是我的核心数据库功能：

function getConnection() {
    try {
        $cn = new PDO("mysql:host=$host;dbname=$bd", $usuario, $clave, array(
                PDO::ATTR_ERRMODE => PDO::ERRMODE_EXCEPTION,
            ));

        $cn->setAttribute(PDO::MYSQL_ATTR_USE_BUFFERED_QUERY, true);
        return $cn;
    } catch (PDOException $e) {
        print "Error!: " . $e->getMessage() . "<br/>";
        die();
    }
}
function getValue($cn, $comando) {
    $resul = $cn->query($comando);
        if (!$resul) return null;
        while($res = $resul->fetch()) {
            $retorno = $res[0][0];
            break;
        }
        return $retorno;
}
function execWithParameters($cn, $comando, $parametros) {
    $q = $cn->prepare($comando);
    $q->execute($parametros);
    if ($q->errorInfo() != null) {
        $e = $q->errorInfo();
        echo $e[0].':'.$e[1].':'.$e[2];
    }
}

有人可以解释一下吗？ PD。 请不要建议执行自动数字 ID，因为我是从另一个系统移植的。

Answer 1

问题是 mysql 在给定时间只允许有一个未完成的游标。 通过使用 fetch() 方法并且不消耗所有待处理的数据，您将使游标保持打开状态。

推荐的方法是使用 fetchAll() 方法消耗所有数据。
另一种方法是使用 closeCursor() 方法。

如果你改变这个功能，我想你会更高兴：

<?php
function getValue($cn, $comando) {
    $resul = $cn->query($comando);
    if (!$resul) return null;
    foreach ($resul->fetchAll() as $res) {
            $retorno = $res[0];
            break;
    }
    return $retorno;
}
?>

Answer 2

如果您不执行返回数据的查询（即 UPDATE、INSERT 等），我认为 PDOStatement::closeCursor() 不会起作用。

更好的解决方案是在调用 PDOStatement::execute() 之后简单地 unset() PDOStatement 对象：

$stmt = $pdo->prepare('UPDATE users SET active = 1');
$stmt->execute();
unset($stmt);

Answer 3

问题似乎是——我对 PDO 不太熟悉——在 getValue 调用返回后，查询仍然绑定到连接（你只要求第一个值，但连接返回几个，或期望这样做）。

添加来修复

$resul->closeCursor();

也许 getValue 可以通过在返回之前

。 否则，如果对 getValue 的查询始终返回单个（或足够少的）值，则似乎首选使用 fetchAll。

Answer 4

我只花了 15 分钟在互联网上谷歌搜索，并查看了至少 5 个不同的 Stackoverflow 问题，其中一些人声称我的 bug 显然是由错误版本的 PHP、错误版本的 MySQL 库或任何其他神奇的黑盒东西引起的......

我将所有代码更改为使用“fetchAll”，甚至在每次查询后对查询对象调用 closeCursor() 和 unset() 。 老实说我已经绝望了！ 我还尝试了 MYSQL_ATTR_USE_BUFFERED_QUERY 标志，但它不起作用。

终于我把所有的东西都扔到了窗外，查看了 PHP 错误，并跟踪了发生错误的代码行。

SELECT AVG((original_bytes-new_bytes)/original_bytes) as saving 
    FROM (SELECT original_bytes, new_bytes FROM jobs ORDER BY id DESC LIMIT 100) AS t1

不管怎样，问题的发生是因为我的original_bytes和new_bytes都是无符号的bigints，这意味着如果我曾经有一份工作，new_bytes实际上比original_bytes大，那么我会遇到令人讨厌的 MySQL“超出范围”错误。 这只是在运行我的缩小服务一段时间后随机发生的。

为什么我得到这个奇怪的 MySQL 错误而不是仅仅给我简单的错误，这超出了我的范围！ 当我运行原始查询时，它实际上出现在 SQLBuddy（轻量级 PHPMyAdmin）中。
我打开了 PDO 异常，所以它应该给我 MySQL 错误。

没关系，底线是：

如果您遇到此错误，请务必检查您的原始 MySQL 是否确实正确并且仍在工作！！！

Answer 5

我的一个朋友在使用 xampp 1.7.1 版本时也遇到了同样的问题。 用 5.2.9-2 php.net 版本替换 xampp/php/* 并将所有必需的文件复制到 xampp/apache/bin 后，它工作正常。

Answer 6

如果您使用的是 XAMPP 1.7.1，则只需升级到 1.7.2。