use wcf\data\user\group\UserGroup;
use wcf\data\user\UserList;
use wcf\system\cache\CacheHandler;
-use wcf\system\storage\StorageHandler;
+use wcf\system\user\storage\UserStorageHandler;
use wcf\system\WCF;
use wcf\util\StringUtil;
}
else {
// load storage data
- StorageHandler::getInstance()->loadStorage(array($this->userID), 1);
+ UserStorageHandler::getInstance()->loadStorage(array($this->userID), 1);
// get group ids
- $data = StorageHandler::getInstance()->getStorage(array($this->userID), 'groupIDs', 1);
+ $data = UserStorageHandler::getInstance()->getStorage(array($this->userID), 'groupIDs', 1);
// cache does not exist or is outdated
if ($data[$this->userID] === null) {
}
// update storage data
- StorageHandler::getInstance()->update($this->userID, 'groupIDs', serialize($this->groupIDs), 1);
+ UserStorageHandler::getInstance()->update($this->userID, 'groupIDs', serialize($this->groupIDs), 1);
}
else {
$this->groupIDs = unserialize($data[$this->userID]);
// load storage data
StorageHandler::getInstance()->loadStorage(array($this->userID), 1);
- // get group ids
- $data = StorageHandler::getInstance()->getStorage(array($this->userID), 'languageIDs', 1);
+ // get language ids
+ $data = UserStorageHandler::getInstance()->getStorage(array($this->userID), 'languageIDs', 1);
// cache does not exist or is outdated
if ($data[$this->userID] === null) {
}
// update storage data
- StorageHandler::getInstance()->update($this->userID, 'languageIDs', serialize($this->languageIDs), 1);
+ UserStorageHandler::getInstance()->update($this->userID, 'languageIDs', serialize($this->languageIDs), 1);
}
else {
$this->languageIDs = unserialize($data[$this->userID]);
use wcf\system\package\PackageInstallationDispatcher;
use wcf\system\session\SessionFactory;
use wcf\system\session\SessionHandler;
-use wcf\system\storage\StorageHandler;
use wcf\system\template\TemplateEngine;
+use wcf\system\user\storage\UserStorageHandler;
use wcf\system\exception;
use wcf\util;
CacheHandler::getInstance()->getCacheSource()->close();
}
- // execute shutdown actions
- StorageHandler::getInstance()->shutdown();
+ // execute shutdown actions of user storage handler
+ UserStorageHandler::getInstance()->shutdown();
}
/**
use wcf\system\auth\UserAuth;
use wcf\system\cache\CacheHandler;
use wcf\system\exception\PermissionDeniedException;
-use wcf\system\storage\StorageHandler;
+use wcf\system\user\storage\UserStorageHandler;
use wcf\system\SingletonFactory;
use wcf\system\WCF;
use wcf\util\StringUtil;
*/
public static function resetSessions(array $userIDs = array()) {
if (count($userIDs)) {
- StorageHandler::getInstance()->reset($userIDs, 'groupIDs', 1);
- StorageHandler::getInstance()->reset($userIDs, 'languageIDs', 1);
+ UserStorageHandler::getInstance()->reset($userIDs, 'groupIDs', 1);
+ UserStorageHandler::getInstance()->reset($userIDs, 'languageIDs', 1);
}
else {
- StorageHandler::getInstance()->resetAll('groupIDs', 1);
- StorageHandler::getInstance()->resetAll('languageIDs', 1);
+ UserStorageHandler::getInstance()->resetAll('groupIDs', 1);
+ UserStorageHandler::getInstance()->resetAll('languageIDs', 1);
}
}
}
+++ /dev/null
-<?php
-namespace wcf\system\storage;
-use wcf\system\database\util\PreparedStatementConditionBuilder;
-use wcf\system\SingletonFactory;
-use wcf\system\WCF;
-
-/**
- * Handles the persistent data storage.
- *
- * @author Alexander Ebert
- * @copyright 2001-2011 WoltLab GmbH
- * @license GNU Lesser General Public License <http://opensource.org/licenses/lgpl-license.php>
- * @package com.woltlab.wcf
- * @subpackage system.storage
- * @category Community Framework
- */
-class StorageHandler extends SingletonFactory {
- /**
- * data cache
- * @var array<array>
- */
- protected $cache = array();
-
- /**
- * list of outdated data records
- * @var array<array>
- */
- protected $resetFields = array();
-
- /**
- * list of updated or new data records
- * @var array<array>
- */
- protected $updateFields = array();
-
- /**
- * Loads storage for a given set of users.
- *
- * @param array<integer> $userIDs
- * @param integer $packageID
- */
- public function loadStorage(array $userIDs, $packageID = PACKAGE_ID) {
- $tmp = array();
- foreach ($userIDs as $userID) {
- if (!isset($this->cache[$userID])) $tmp[] = $userID;
- }
-
- // ignore users whose storage data is already loaded
- if (empty($tmp)) return;
-
- $conditions = new PreparedStatementConditionBuilder();
- $conditions->add("userID IN (?)", array($tmp));
- $conditions->add("packageID = ?", array(PACKAGE_ID));
-
- $sql = "SELECT *
- FROM wcf".WCF_N."_storage
- ".$conditions;
- $statement = WCF::getDB()->prepareStatement($sql);
- $statement->execute($conditions->getParameters());
- while ($row = $statement->fetchArray()) {
- if (!isset($this->cache[$row['userID']])) {
- $this->cache[$row['userID']] = array();
- }
-
- if (!isset($this->cache[$row['userID']][$row['packageID']])) {
- $this->cache[$row['userID']][$row['packageID']] = array();
- }
-
- $this->cache[$row['userID']][$row['packageID']][$row['field']] = $row['fieldValue'];
- }
- }
-
- /**
- * Returns stored data for given users.
- *
- * @param array<integer> $userIDs
- * @param string $field
- * @param integer $packageID
- * @return array<array>
- */
- public function getStorage(array $userIDs, $field, $packageID = PACKAGE_ID) {
- $data = array();
-
- foreach ($userIDs as $userID) {
- if (isset($this->cache[$userID][$packageID][$field])) {
- $data[$userID] = $this->cache[$userID][$packageID][$field];
- }
- else {
- $data[$userID] = null;
- }
- }
-
- return $data;
- }
-
- /**
- * Inserts new data records into database.
- *
- * @param integer $userID
- * @param string $field
- * @param string $fieldValue
- * @param integer $packageID
- */
- public function update($userID, $field, $fieldValue, $packageID = PACKAGE_ID) {
- $this->updateFields[$userID][$packageID][$field] = $fieldValue;
-
- // update data cache for given user
- if (!isset($this->cache[$userID])) {
- $this->cache[$userID] = array();
- }
-
- if (!isset($this->cache[$userID][$packageID])) {
- $this->cache[$userID][$packageID] = array();
- }
-
- $this->cache[$userID][$packageID][$field] = $fieldValue;
-
- // flag key as outdated
- self::reset(array($userID), $field, $packageID);
- }
-
- /**
- * Removes a data record from database.
- *
- * @param array<integer> $userIDs
- * @param string $field
- * @param integer $packageID
- */
- public function reset(array $userIDs, $field, $packageID = PACKAGE_ID) {
- foreach ($userIDs as $userID) {
- $this->resetFields[$userID][$packageID][] = $field;
- }
- }
-
- /**
- * Removes a specific data record for all users.
- *
- * @param string $field
- * @param integer $packageID
- */
- public function resetAll($field, $packageID = PACKAGE_ID) {
- $sql = "DELETE FROM wcf".WCF_N."_storage
- WHERE field = ?
- AND packageID = ?";
- $statement = WCF::getDB()->prepareStatement($sql);
- $statement->execute(array(
- $field,
- $packageID
- ));
- }
-
- /**
- * Removes and inserts data records on shutdown.
- */
- public function shutdown() {
- // remove outdated entries
- if (count($this->resetFields)) {
- $sql = "DELETE FROM wcf".WCF_N."_storage
- WHERE userID = ?
- AND field = ?
- AND packageID = ?";
- $statement = WCF::getDB()->prepareStatement($sql);
-
- foreach ($this->resetFields as $userID => $data) {
- foreach ($data as $packageID => $fields) {
- foreach ($fields as $field) {
- $statement->execute(array(
- $userID,
- $field,
- $packageID
- ));
- }
- }
- }
- }
-
- // insert data
- if (count($this->updateFields)) {
- $sql = "INSERT INTO wcf".WCF_N."_storage
- (userID, field, fieldValue, packageID)
- VALUES (?, ?, ?, ?)";
- $statement = WCF::getDB()->prepareStatement($sql);
-
- foreach ($this->updateFields as $userID => $data) {
- foreach ($data as $packageID => $fieldValues) {
- foreach ($fieldValues as $field => $fieldValue) {
- $statement->execute(array(
- $userID,
- $field,
- $fieldValue,
- $packageID
- ));
- }
- }
- }
- }
- }
-}
--- /dev/null
+<?php
+namespace wcf\system\user\storage;
+use wcf\system\database\util\PreparedStatementConditionBuilder;
+use wcf\system\SingletonFactory;
+use wcf\system\WCF;
+
+/**
+ * Handles the persistent user data storage.
+ *
+ * @author Alexander Ebert
+ * @copyright 2001-2011 WoltLab GmbH
+ * @license GNU Lesser General Public License <http://opensource.org/licenses/lgpl-license.php>
+ * @package com.woltlab.wcf
+ * @subpackage system.storage
+ * @category Community Framework
+ */
+class UserStorageHandler extends SingletonFactory {
+ /**
+ * data cache
+ * @var array<array>
+ */
+ protected $cache = array();
+
+ /**
+ * list of outdated data records
+ * @var array<array>
+ */
+ protected $resetFields = array();
+
+ /**
+ * list of updated or new data records
+ * @var array<array>
+ */
+ protected $updateFields = array();
+
+ /**
+ * Loads storage for a given set of users.
+ *
+ * @param array<integer> $userIDs
+ * @param integer $packageID
+ */
+ public function loadStorage(array $userIDs, $packageID = PACKAGE_ID) {
+ $tmp = array();
+ foreach ($userIDs as $userID) {
+ if (!isset($this->cache[$userID])) $tmp[] = $userID;
+ }
+
+ // ignore users whose storage data is already loaded
+ if (empty($tmp)) return;
+
+ $conditions = new PreparedStatementConditionBuilder();
+ $conditions->add("userID IN (?)", array($tmp));
+ $conditions->add("packageID = ?", array(PACKAGE_ID));
+
+ $sql = "SELECT *
+ FROM wcf".WCF_N."_storage
+ ".$conditions;
+ $statement = WCF::getDB()->prepareStatement($sql);
+ $statement->execute($conditions->getParameters());
+ while ($row = $statement->fetchArray()) {
+ if (!isset($this->cache[$row['userID']])) {
+ $this->cache[$row['userID']] = array();
+ }
+
+ if (!isset($this->cache[$row['userID']][$row['packageID']])) {
+ $this->cache[$row['userID']][$row['packageID']] = array();
+ }
+
+ $this->cache[$row['userID']][$row['packageID']][$row['field']] = $row['fieldValue'];
+ }
+ }
+
+ /**
+ * Returns stored data for given users.
+ *
+ * @param array<integer> $userIDs
+ * @param string $field
+ * @param integer $packageID
+ * @return array<array>
+ */
+ public function getStorage(array $userIDs, $field, $packageID = PACKAGE_ID) {
+ $data = array();
+
+ foreach ($userIDs as $userID) {
+ if (isset($this->cache[$userID][$packageID][$field])) {
+ $data[$userID] = $this->cache[$userID][$packageID][$field];
+ }
+ else {
+ $data[$userID] = null;
+ }
+ }
+
+ return $data;
+ }
+
+ /**
+ * Inserts new data records into database.
+ *
+ * @param integer $userID
+ * @param string $field
+ * @param string $fieldValue
+ * @param integer $packageID
+ */
+ public function update($userID, $field, $fieldValue, $packageID = PACKAGE_ID) {
+ $this->updateFields[$userID][$packageID][$field] = $fieldValue;
+
+ // update data cache for given user
+ if (!isset($this->cache[$userID])) {
+ $this->cache[$userID] = array();
+ }
+
+ if (!isset($this->cache[$userID][$packageID])) {
+ $this->cache[$userID][$packageID] = array();
+ }
+
+ $this->cache[$userID][$packageID][$field] = $fieldValue;
+
+ // flag key as outdated
+ self::reset(array($userID), $field, $packageID);
+ }
+
+ /**
+ * Removes a data record from database.
+ *
+ * @param array<integer> $userIDs
+ * @param string $field
+ * @param integer $packageID
+ */
+ public function reset(array $userIDs, $field, $packageID = PACKAGE_ID) {
+ foreach ($userIDs as $userID) {
+ $this->resetFields[$userID][$packageID][] = $field;
+ }
+ }
+
+ /**
+ * Removes a specific data record for all users.
+ *
+ * @param string $field
+ * @param integer $packageID
+ */
+ public function resetAll($field, $packageID = PACKAGE_ID) {
+ $sql = "DELETE FROM wcf".WCF_N."_storage
+ WHERE field = ?
+ AND packageID = ?";
+ $statement = WCF::getDB()->prepareStatement($sql);
+ $statement->execute(array(
+ $field,
+ $packageID
+ ));
+ }
+
+ /**
+ * Removes and inserts data records on shutdown.
+ */
+ public function shutdown() {
+ // remove outdated entries
+ if (count($this->resetFields)) {
+ $sql = "DELETE FROM wcf".WCF_N."_storage
+ WHERE userID = ?
+ AND field = ?
+ AND packageID = ?";
+ $statement = WCF::getDB()->prepareStatement($sql);
+
+ foreach ($this->resetFields as $userID => $data) {
+ foreach ($data as $packageID => $fields) {
+ foreach ($fields as $field) {
+ $statement->execute(array(
+ $userID,
+ $field,
+ $packageID
+ ));
+ }
+ }
+ }
+ }
+
+ // insert data
+ if (count($this->updateFields)) {
+ $sql = "INSERT INTO wcf".WCF_N."_storage
+ (userID, field, fieldValue, packageID)
+ VALUES (?, ?, ?, ?)";
+ $statement = WCF::getDB()->prepareStatement($sql);
+
+ foreach ($this->updateFields as $userID => $data) {
+ foreach ($data as $packageID => $fieldValues) {
+ foreach ($fieldValues as $field => $fieldValue) {
+ $statement->execute(array(
+ $userID,
+ $field,
+ $fieldValue,
+ $packageID
+ ));
+ }
+ }
+ }
+ }
+ }
+}
projects / GitHub / WoltLab / WCF.git / commitdiff