欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  后端开发

PHP的PDO的问题

程序员文章站 2022-05-16 22:13:47
...
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能解答一下吗?

相关标签: PHP的PDO的问题