* @version 0.0.0 * @copyright Copyright(c) 2007, 2008 Roland Haeder, this is free software * @license GNU GPL 3.0 or any newer version * @link http://www.ship-simu.org * * This program is free software: you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation, either version 3 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License * along with this program. If not, see . */ class UserDatabaseWrapper extends BaseDatabaseWrapper { /** * Cache instance */ private $cacheInstance = null; // Constants for exceptions const EXCEPTION_CLIENT_USERNAME_NOT_FOUND = 0x800; // Constants for database columns const DB_COLUMN_USERNAME = "username"; const DB_COLUMN_EMAIL = "email"; // Constants for database table names const DB_TABLE_USER = "user"; /** * Protected constructor * * @return void */ protected function __construct() { // Call parent constructor parent::__construct(__CLASS__); // Set part description $this->setObjectDescription("Database wrapper for user objects"); // Create unique ID number $this->generateUniqueId(); } /** * Creates an instance of this database wrapper by a provided user class * * @return $wrapperInstance An instance of the created wrapper class * @throws WrapperUserNameNotFoundException If the supplied username * does not exist */ public final static function createUserDatabaseWrapper () { // Get a new instance $wrapperInstance = new UserDatabaseWrapper(); // Initialize the cache instance $wrapperInstance->initCacheInstance(); // Return the instance return $wrapperInstance; } /** * Initializes the cache instance with a new object * * @return void */ protected function initCacheInstance () { // Set the new instance $this->cacheInstance = CacheFactory::getFactory()->createConfiguredCache(); } /** * Do a "select" query on the user table with the given search criteria and * store it in cache for later usage * * @param $criteriaInstance An instance of a Criteria class * @return $resultInstance An instance of a database result class */ public function doSelectByCriteria (Criteria $criteriaInstance) { // First get a key suitable for our cache and extend it with this class name $cacheKey = sprintf("%s@%s", $this->__toString(), $criteriaInstance->getCacheKey() ); // Does this key exists in cache? if ($this->cacheInstance->offsetExists($cacheKey)) { // Then use this result $result = $cacheInstance->offsetGet($cacheKey); } else { // Now it's time to ask the database layer for this select statement $result = $this->getDatabaseInstance()->doSelectByTableCriteria(self::DB_TABLE_USER, $criteriaInstance); // Cache the result if not null if (!is_null($result)) { // A valid result has returned from the database layer $this->cacheInstance->offsetSet($cacheKey, $result); } else { // This invalid result must be wrapped $result = array( 'status' => "invalid", 'exception' => $this->getDatabaseInstance()->getLastException() ); } } // Create an instance of a DatabaseResult class with the given result $resultInstance = DatabaseResult::createDatabaseResult($result); // And return the instance return $resultInstance; } /** * Handles inserting the registration data from a registration instance into the database * * @param $registrationInstance An instance of a registration class * @return void */ public function insertRegistrationObject (UserRegister $registrationInstance) { // Generate a data set for the request $dataSetInstance = ObjectFactory::createObjectByConfiguredName('dataset_criteria_class'); $dataSetInstance->setTableName(self::DB_TABLE_USER); // Add registration elements to the dataset $registrationInstance->addElementsToDataSet($dataSetInstance); // "Insert" this request instance completely into the database $this->getDatabaseInstance()->queryInsertDataSet($dataSetInstance); } /** * Updates an user database entry with given result * * @param $resultInstance An instance of a Updateable database result * @return void */ public function doUpdateByResult (UpdateableResult $resultInstance) { // Generate a data set object $dataSetInstance = ObjectFactory::createObjectByConfiguredName('dataset_criteria_class'); $dataSetInstance->setTableName(self::DB_TABLE_USER); // Add all update criteria to the database set $resultInstance->addElementsToDataSet($dataSetInstance); // Add seach criteria $dataSetInstance->setSearchInstance($resultInstance->getSearchInstance()); // Add the primary key $dataSetInstance->setUniqueKey('username'); // "Update" this request with the database $this->getDatabaseInstance()->queryUpdateDataSet($dataSetInstance); } } // [EOF] ?>