main/DAOs/Workers/TransparentDaoWorker.class.php Source File home about examples API documentation download forum contacts

TransparentDaoWorker.class.php Go to the documentation of this file. <?php /*************************************************************************** * Copyright (C) 2006-2008 by Konstantin V. Arkhipov * * * * This program is free software; you can redistribute it and/or modify * * it under the terms of the GNU Lesser General Public License as * * published by the Free Software Foundation; either version 3 of the * * License, or (at your option) any later version. * * * ***************************************************************************/ /* $Id: TransparentDaoWorker.class.php 5374 2008-08-03 14:15:27Z voxus $ */ abstract class TransparentDaoWorker extends CommonDaoWorker { abstract protected function gentlyGetByKey($key); public function getById($id) { try { return parent::getById($id, Cache::EXPIRES_FOREVER); } catch (CachedObjectNotFoundException $e) { throw $e; } catch (ObjectNotFoundException $e) { $this->cacheNullById($id); throw $e; } } public function getByLogic(LogicalObject $logic) { return parent::getByLogic($logic, Cache::EXPIRES_FOREVER); } public function getByQuery(SelectQuery $query) { try { return parent::getByQuery($query, Cache::EXPIRES_FOREVER); } catch (CachedObjectNotFoundException $e) { throw $e; } catch (ObjectNotFoundException $e) { $this->cacheByQuery($query, Cache::NOT_FOUND); throw $e; } } public function getCustom(SelectQuery $query) { try { return parent::getCustom($query, Cache::EXPIRES_FOREVER); } catch (CachedObjectNotFoundException $e) { throw $e; } catch (ObjectNotFoundException $e) { $this->cacheByQuery($query, Cache::NOT_FOUND); throw $e; } } public function getListByIds(array $ids) { $list = array(); $toFetch = array(); $prefixed = array(); $proto = $this->dao->getProtoClass(); $proto->beginPrefetch(); // dupes, if any, will be resolved later @ ArrayUtils::regularizeList $ids = array_unique($ids); foreach ($ids as $id) $prefixed[$id] = $this->className.'_'.$id; if ( $cachedList = Cache::me()->mark($this->className)->getList($prefixed) ) { foreach ($cachedList as $cached) { if ($cached && ($cached !== Cache::NOT_FOUND)) { $list[] = $this->dao->completeObject($cached); unset($prefixed[$cached->getId()]); } } } $toFetch += array_keys($prefixed); if ($toFetch) { $remainList = array(); foreach ($toFetch as $id) { try { $remainList[] = $this->getById($id); } catch (ObjectNotFoundException $e) {/*_*/} } $list = array_merge($list, $remainList); } $proto->endPrefetch($list); return $list; } public function getListByQuery(SelectQuery $query) { $list = $this->getCachedList($query); if ($list) { if ($list === Cache::NOT_FOUND) throw new ObjectNotFoundException(); else return $list; } else { if ($list = $this->fetchList($query)) return $this->cacheListByQuery($query, $list); else { $this->cacheListByQuery($query, Cache::NOT_FOUND); throw new ObjectNotFoundException(); } } Assert::isUnreachable(); } public function getListByLogic(LogicalObject $logic) { return parent::getListByLogic($logic, Cache::EXPIRES_FOREVER); } public function getPlainList() { return parent::getPlainList(Cache::EXPIRES_FOREVER); } public function getCustomList(SelectQuery $query) { try { return parent::getCustomList($query, Cache::EXPIRES_FOREVER); } catch (CachedObjectNotFoundException $e) { throw $e; } catch (ObjectNotFoundException $e) { $this->cacheByQuery($query, Cache::NOT_FOUND); throw $e; } } public function getCustomRowList(SelectQuery $query) { try { return parent::getCustomRowList($query, Cache::EXPIRES_FOREVER); } catch (CachedObjectNotFoundException $e) { throw $e; } catch (ObjectNotFoundException $e) { $this->cacheByQuery($query, Cache::NOT_FOUND); throw $e; } } public function getQueryResult(SelectQuery $query) { return parent::getQueryResult($query, Cache::EXPIRES_FOREVER); } protected function cacheById( Identifiable $object, $expires = Cache::EXPIRES_FOREVER) { Cache::me()->mark($this->className)-> add( $this->className.'_'.$object->getId(), $object, $expires ); return $object; } protected function getCachedByQuery(SelectQuery $query) { return $this->gentlyGetByKey( $this->className.self::SUFFIX_QUERY.$query->getId() ); } protected function getCachedList(SelectQuery $query) { return $this->gentlyGetByKey( $this->className.self::SUFFIX_LIST.$query->getId() ); } protected function cacheNullById($id) { return Cache::me()->mark($this->className)-> add( $this->className.'_'.$id, Cache::NOT_FOUND, Cache::EXPIRES_FOREVER ); } protected function keyToInt($key) { // 7 == strlen(dechex(x86 PHP_INT_MAX)) - 1 return hexdec(substr(md5($key), 0, 7)) + strlen($key); } } ?>

generated by doxygen-1.5.5 for onPHP at Thu Aug 7 18:24:24 2008