【发布时间】：2017-02-20 08:52:48
【问题描述】：
我正在尝试了解 PDO 的详细信息。所以我编码了这个：
<?php
namespace news\system\worker;
use news\data\news\NewsEditor;
use wcf\data\object\type\ObjectTypeCache;
use wcf\system\database\util\PreparedStatementConditionBuilder;
use wcf\system\search\SearchIndexManager;
use wcf\system\user\activity\point\UserActivityPointHandler;
use wcf\system\worker\AbstractRebuildDataWorker;
use wcf\system\WCF;
/**
* Worker actions for news entries.
*
* @author Pascal Bade
* @copyright 2013 voolia.de
* @license Creative Commons CC-BY-ND <http://creativecommons.org/licenses/by-nd/3.0/deed.de>
* @package de.voolia.news
*/
class NewsDataWorker extends AbstractRebuildDataWorker {
/**
* @see \wcf\system\worker\AbstractRebuildDataWorker::$objectListClassName
*/
protected $objectListClassName = 'news\data\news\NewsList';
/**
* @see \wcf\system\worker\AbstractWorker::$limit
*/
protected $limit = 250;
/**
* @see \wcf\system\worker\AbstractRebuildDataWorker::initObjectList
*/
protected function initObjectList() {
parent::initObjectList();
$this->objectList->sqlOrderBy = 'news.newsID';
}
/**
* @see \wcf\system\worker\IWorker::execute()
*/
public function execute() {
parent::execute();
if (!count($this->objectList)) {
return;
}
if (!$this->loopCount) {
// remove the activity points
UserActivityPointHandler::getInstance()->reset('de.voolia.news.activityPointEvent.news');
// remove the entry from search index
SearchIndexManager::getInstance()->reset('de.voolia.news.entry');
}
// get news attachments
$attachmentObjectType = ObjectTypeCache::getInstance()->getObjectTypeByName('com.woltlab.wcf.attachment.objectType', 'de.voolia.news.entry');
$sql = "SELECT COUNT(*) AS attachments
FROM wcf".WCF_N."_attachment
WHERE objectTypeID = ?
AND objectID = ?";
$attachments = WCF::getDB()->prepareStatement($sql);
// calculate the cumulative likes
$conditions = new PreparedStatementConditionBuilder();
$conditions->add("objectID IN (?)", array($this->objectList->getObjectIDs()));
$conditions->add("objectTypeID = ?", array(ObjectTypeCache::getInstance()->getObjectTypeIDByName('com.woltlab.wcf.like.likeableObject', 'de.voolia.news.likeableNews')));
$sql = "SELECT objectID,
cumulativeLikes
FROM wcf".WCF_N."_like_object
".$conditions;
$statement = WCF::getDB()->prepareStatement($sql);
$statement->execute($conditions->getParameters());
$likes = array();
while ($row = $statement->fetchArray()) {
$likes[$row['objectID']] = $row['cumulativeLikes'];
}
// update the news entries
$userItems = array();
foreach ($this->objectList as $news) {
// new EntryEditor
$editor = new NewsEditor($news);
// update search index
SearchIndexManager::getInstance()->add('de.voolia.news.entry', $news->newsID, $news->message, $news->subject, $news->time, $news->userID, $news->username, $news->languageID);
// news data
$newsData = array();
// likes
$newsData['cumulativeLikes'] = (isset($likes[$news->newsID])) ? $likes[$news->newsID] : 0;
// attachments
$attachments->execute(array($attachmentObjectType->objectTypeID, $news->newsID));
$row = $attachments->fetchArray();
$newsData['attachments'] = $row['attachments'];
if ($news->userID) {
if (!isset($userItems[$news->userID])) {
$userItems[$news->userID] = 0;
}
$userItems[$news->userID]++;
}
$editor->update($newsData);
}
// update activity points
UserActivityPointHandler::getInstance()->fireEvents('de.voolia.news.activityPointEvent.news', $userItems, false);
}
}
但我收到了这个
SQLSTATE[HY000]：一般错误：2014 在其他无缓冲查询处于活动状态时无法执行查询。考虑使用 PDOStatement::fetchAll()。或者，如果您的代码只针对 mysql 运行，您可以通过设置 PDO::MYSQL_ATTR_USE_BUFFERED_QUERY 属性来启用查询缓冲。
谁能解释一下？
【问题讨论】：
-
恐怕你得把这段代码的10个部分中的9个取出来，隔离出唯一的问题点。您的代码既现代又花哨，但您真的希望有人会阅读它并在他们的脑海中评估它以为您找到错误吗？
-
是的，您甚至没有标记出现此错误的代码行。这样就找不到原因了。