开发者社区> 问答> 正文

MySQL错误2014的原因其他未缓冲的查询处于活动状态时无法执行查询

我的服务器运行CentOS 6.4,并使用yum和CentOS的存储库安装MySQL 5.1.69,以及使用yum和ius的存储库安装的PHP 5.4.16。Edit3升级到MySQL服务器版本:5.5.31由IUS社区项目分发,并且错误仍然存​​在。然后将库更改为mysqlnd,似乎消除了该错误。仍然要反复进行此操作,以了解为什么有时仅出现此错误。

使用PDO并使用创建PDO对象时PDO::ATTR_EMULATE_PREPARES=>false,有时会出现以下错误:

Table Name - zipcodes Error in query: SELECT id FROM cities WHERE name=? AND states_id=? SQLSTATE[HY000]: General error: 2014 Cannot execute queries while other unbuffered queries are active. Consider using PDOStatement::fetchAll(). Alternatively, if your code is only ever going to run against mysql, you may enable query buffering by setting the PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute. File Name: /var/www/initial_install/build_database.php Line: 547 Time of Error: Tuesday July 2, 2013, 5:52:48 PDT 547行是以下内容的最后一行:

$stmt_check_county->execute(array($data[5],$data[4])); if(!$county_id=$stmt_check_county->fetchColumn()) { $stmt_counties->execute(array($data[5])); $county_id=db::db()->lastInsertId(); } //$stmt_check_county->closeCursor(); //This will fix the error $stmt_check_city->execute(array($data[3],$data[4])); 几年前,我遇到了类似的问题,但是从PHP 5.1升级到PHP 5.3(并且MySQL可能也进行了更新),该问题神奇地消失了,现在我使用PHP 5.5。

为什么它只在时出现PDO::ATTR_EMULATE_PREPARES=>false,并且只有PHP的交替版本?

我还发现这closeCursor()也可以修复错误。是否应该始终SELECT在fetchAll()不使用每个查询之后执行此操作?请注意,即使查询SELECT COUNT(col2)仅返回一个值,该错误仍然会发生。

编辑 顺便说一下,这就是我创建连接的方式。我只是最近才添加的MYSQL_ATTR_USE_BUFFERED_QUERY=>true,但是它不能解决错误。 另外,以下脚本可以按原样使用以创建错误。

function sql_error($e,$sql=NULL){return('

Error in query:

'.$sql.'

'.$e->getMessage().'

File Name: '.$e->getFile().' Line: '.$e->getLine().'

');}

class db { private static $instance = NULL; private function __construct() {} //Make private private function __clone(){} //Make private public static function db() //Get instance of DB { if (!self::$instance) { //try{self::$instance = new PDO("mysql:host=localhost;dbname=myDB;charset=utf8",'myUsername','myPassword',array(PDO::ATTR_EMULATE_PREPARES=>false,PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION,PDO::ATTR_DEFAULT_FETCH_MODE=>PDO::FETCH_ASSOC));} try{self::$instance = new PDO("mysql:host=localhost;dbname=myDB;charset=utf8",'myUsername','myPassword',array(PDO::ATTR_EMULATE_PREPARES=>false,PDO::MYSQL_ATTR_USE_BUFFERED_QUERY=>true,PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION,PDO::ATTR_DEFAULT_FETCH_MODE=>PDO::FETCH_ASSOC));} //try{self::$instance = new PDO("mysql:host=localhost;dbname=myDB;charset=utf8",'myUsername','myPassword',array(PDO::ATTR_ERRMODE=>PDO::ERRMODE_EXCEPTION,PDO::ATTR_DEFAULT_FETCH_MODE=>PDO::FETCH_ASSOC));} catch(PDOException $e){echo(sql_error($e));} } return self::$instance; } }

$row=array( 'zipcodes_id'=>'55555', 'cities_id'=>123 ); $data=array($row,$row,$row,$row);

$sql = 'CREATE TEMPORARY TABLE temp1(temp_id INT UNSIGNED NOT NULL AUTO_INCREMENT, PRIMARY KEY (temp_id) )'; db::db()->exec($sql);

$sql='SELECT COUNT(*) AS valid FROM cities_has_zipcodes WHERE cities_id=? AND zipcodes_id=?'; $stmt1 = db::db()->prepare($sql);

$sql ='SELECT temp_id FROM temp1';

展开
收起
保持可爱mmm 2020-05-13 13:47:08 768 0
1 条回答
写回答
取消 提交回答
  • MySQL客户端协议不允许进行多个查询。也就是说,您已经执行了查询,并且已经获取了一些结果,但不是全部—然后尝试执行第二个查询。如果第一个查询仍有要返回的行,则第二个查询将收到错误。

    客户端库通过在首次获取时隐式获取第一个查询的所有行来解决此问题,然后后续获取仅对内部缓存的结果进行迭代。这给他们提供了关闭游标的机会(就MySQL服务器而言)。这就是“缓冲查询”。这与使用fetchAll()相同,这两种情况都必须在PHP客户端中分配足够的内存以容纳完整的结果集。

    不同之处在于,缓冲的查询将结果保存在MySQL客户端库中,因此,只有在依次提取(fetch())每行之后,PHP才能访问这些行。而fetchAll()立即为所有结果填充一个PHP数组,从而允许您访问任何随机行。

    不使用fetchAll()的主要原因是结果可能太大而无法容纳在您的PHP memory_limit中。但是看来您的查询结果仍然只有一行,所以这应该不是问题。

    您可以先关闭closeCursor()以“放弃”结果,然后再获取最后一行。MySQL服务器收到通知,可以在服务器端放弃该结果,然后可以执行另一个查询。在完成获取给定结果集之前,您不应该关闭closeCursor()。

    另外:我注意到您在循环内一遍又一遍地执行$ stmt2,但是每次都会返回相同的结果。根据将循环不变代码移出循环的原理,您应该在开始循环之前执行一次,并将结果保存在PHP变量中。因此,无论使用缓冲查询还是fetchAll(),都无需嵌套查询。

    因此,我建议您以这种方式编写代码:

    $sql ='SELECT temp_id FROM temp1'; $stmt2 = db::db()->prepare($sql); $stmt2->execute(); $rs2 = $stmt2->fetchAll(PDO::FETCH_ASSOC); $stmt2->closeCursor();

    $sql='SELECT COUNT(*) AS valid FROM cities_has_zipcodes WHERE cities_id=:cities_id AND zipcodes_id=:zipcodes_id'; $stmt1 = db::db()->prepare($sql);

    foreach($data AS $row) { try { $stmt1->execute($row); $rs1 = $stmt1->fetchAll(PDO::FETCH_ASSOC); $stmt1->closeCursor(); syslog(LOG_INFO,'$rs1: '.print_r($rs1[0],1).' '.rand()); syslog(LOG_INFO,'$rs2: '.print_r($rs2[0],1).' '.rand()); } catch(PDOException $e){echo(sql_error($e));}
    } 注意我还使用了命名参数而不是位置参数,这使得将$ row作为参数值数组进行传递更加简单。如果数组的键与参数名称匹配,则只需传递数组即可。在旧版本的PHP中,您必须:在数组键中包含前缀,但是您不再需要该前缀。

    无论如何,您应该使用mysqlnd。它具有更多功能,具有更高的内存效率,并且其许可证与PHP兼容。来源:stack overflow

    2020-05-13 13:47:25
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
One Box: 解读事务与分析一体化数据库 HybridDB for MySQL 立即下载
One Box:解读事务与分析一体化数据库HybridDB for MySQL 立即下载
如何支撑HTAP场景-HybridDB for MySQL系统架构和技术演进 立即下载

相关镜像