<?phpabstract class AbstractDB { private $m_pdo; public $m_stmt; private static $empty_array = array(); public function open(){ try { $this->m_pdo = new PDO('mysql:host=127.0.0.1;dbname=MYDB', 'root', '123456', array(PDO::MYSQL_ATTR_INIT_COMMAND => "SET NAMES 'utf8';")); return true; } catch (PDOException $e){ return false; } } public function close(){ $this->m_stmt = null; $this->m_pdo = null; } public function prepare_statement($prepare_statement_text){ if (empty($this->m_pdo)) return; if(!empty($this->m_stmt)){ $this->m_stmt->closeCursor(); } $this->m_stmt = $this->m_pdo->prepare($prepare_statement_text); } public function set_param($param_name, $param_value){ if (empty($this->m_stmt)) return; $this->m_stmt->bindParam($param_name, $param_value); } public function execute_single_row(){ if (empty($this->m_stmt)) return self::$empty_array; if (!$this->m_stmt->execute()){ return self::$empty_array; } return $this->m_stmt->fetch(PDO::FETCH_ASSOC); } public function execute_rows(){ if (empty($this->m_stmt)) return self::$empty_array; if (!$this->m_stmt->execute()) { $error = $this->m_stmt->errorInfo(); return self::$empty_array; } $this->m_stmt->setFetchMode(PDO::FETCH_ASSOC); return $this->m_stmt->fetchALL(); }}class TCategoryAttrDB extends AbstractDB{ public function get_category_attr_list($arr_params){ $sql = 'select category_id,category_name,attrib_name,attrib_content from cat_attrib where category_id = :category_id and is_delete = 0'; $this->prepare_statement($sql); $this->set_param(':category_id', $arr_params['category_id']); return $this->execute_rows(); } public function getCategoryIdFromTCategory($arr_params) { $sql = 'SELECT category_id FROM `t_category` where category_name = :category_name and is_delete = 0 and parent_id = (SELECT category_id from t_category WHERE category_name = :parent_category_name and is_delete = 0);'; $this->prepare_statement($sql); $this->set_param(':parent_category_name', $arr_params['parent_category_name']); $this->set_param(':category_name', $arr_params['category_name']); return $this->execute_single_row(); }}$t_db = new TCategoryAttrDB();$arr_params = array('parent_category_name' => 'XXXX', 'category_name' => 'YYY');if($t_db->open()){ $category = $t_db->getCategoryIdFromTCategory($arr_params); $result = $t_db->get_category_attr_list($category);}?> 上面的代码是我提取出来的关键代码,在我的开发机上,当执行第二条SQL的prepare()方法会返回false而不是PDOStatement对象,errorInfo输出的信息是: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."
但是这个代码在生产环境是没有问题的,我试过用下面的方法解决我开发机的问题都成功了,如下:
//(1)在PDO初始化时候设置MYSQL_ATTR_USE_BUFFERED_QUERY属性,PDO::MYSQL_ATTR_USE_BUFFERED_QUERY=>1//(2)在prepare_statement函数中添加下面代码,就是在prepare前执行closeCursor()if(!empty($this->m_stmt)){ $this->m_stmt->closeCursor();} 现在有几点疑惑想请教：
1.我的PHP版本是5.2.10,生产环境的PHP版本是5.3.11,但是到底是什么差异导致这个结果的不一致？只是PHP版本吗？
2.PDO::MYSQL_ATTR_USE_BUFFERED_QUERY (available in MySQL): Use buffered queries。这是文档对属性的解释,但是还不是很明白。什么叫用缓存查询,缓存的对象是什么,用多大的内存,占用的大小跟什么有关系。
3.添加PDOStatement::closeCursor 对性能的影响有多大(当并发高的时候)？
回复讨论(解决方案)
是php的差异！毕竟是越来越完善的
PDO 被设计成单用户方式，每次查询后都应读完数据再复用对象
是php的差异！毕竟是越来越完善的
PDO 被设计成单用户方式，每次查询后都应读完数据再复用对象
你的意思是5.3版本以后不需要closeCursor就能复用statement？
是的！
你的生产环境已然是5.3.11，那你的开发环境为什么还是5.2.10呢？
这样不就不能发挥出php5.3的优势了吗？（至少php5.3要比php5.2快5倍，php5.4比php5.3快10倍）
是的！
你的生产环境已然是5.3.11，那你的开发环境为什么还是5.2.10呢？
这样不就不能发挥出php5.3的优势了吗？（至少php5.3要比php5.2快5倍，php5.4比php5.3快10倍）
项目是新交接的,原来的项目一直是5.2.10,又不愿意换开发机~~
问题2,3能解答一下吗？