main/UnifiedContainer/UnifiedContainer.class.php Source File home about examples API documentation download forum contacts

UnifiedContainer.class.php Go to the documentation of this file. <?php /*************************************************************************** * Copyright (C) 2005-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: UnifiedContainer.class.php 5209 2008-06-17 12:39:25Z voxus $ */ /* UnifiedContainer: child's and parent's field names: abstract public function getChildIdField() abstract public function getParentIdField() all we need from outer world: public function __construct( Identifiable $parent, UnifiedContainer $dao, $lazy = true ) if you want to apply Criteria's "filter": public function setCriteria(Criteria $criteria) first you should fetch whatever you want: public function fetch() then you can get it: public function getList() set you modified list: public function setList($list) finally, sync fetched data and stored one: public function save() OneToManyLinked <- UnifiedContainer: indicates whether child can be free (parent_id nullable): protected function isUnlinkable() ManyToManyLinked <- UnifiedContainer: helper's table name: abstract public function getHelperTable() id field name at parent's primary table: protected function getParentTableIdField() */ abstract class UnifiedContainer { protected $worker = null; protected $parent = null; protected $dao = null; protected $lazy = true; protected $fetched = false; protected $list = array(); protected $clones = array(); // sleep state protected $workerClass = null; protected $daoClass = null; abstract public function getParentIdField(); abstract public function getChildIdField(); public function __construct( Identifiable $parent, GenericDAO $dao, $lazy = true ) { Assert::isBoolean($lazy); $this->parent = $parent; $this->lazy = $lazy; $this->dao = $dao; Assert::isInstance($dao->getObjectName(), 'Identifiable'); } public function __sleep() { $this->daoClass = get_class($this->dao); $this->workerClass = get_class($this->worker); return array('workerClass', 'daoClass', 'parent', 'lazy'); } public function __wakeup() { $this->dao = Singleton::getInstance($this->daoClass); $this->worker = new $this->workerClass($this); } public function getParentObject() { return $this->parent; } public function getDao() { return $this->dao; } public function isLazy() { return $this->lazy; } public function isFetched() { return $this->fetched; } public function setCriteria(Criteria $criteria) { Assert::isTrue( $criteria->getDao() === null || ( $criteria->getDao() === $this->dao ), "criteria's dao doesn't match container's one" ); if (!$criteria->getDao()) $criteria->setDao($this->dao); $this->worker->setCriteria($criteria); return $this; } public function getCriteria() { return $this->worker->getCriteria(); } public function setList($list) { Assert::isArray($list); $this->list = $list; return $this; } public function mergeList(array $list) { Assert::isArray($list); return $this->importList($list); } public function getList() { if (!$this->list && !$this->isFetched()) $this->fetch(); return $this->list; } public function getCount() { if (!$this->isFetched() && $this->parent->getId()) { $row = $this->dao->getCustom($this->worker->makeCountQuery()); return $row['count']; } return count($this->list); } public function fetch() { if (!$this->parent->getId()) throw new WrongStateException( 'save parent object first' ); try { $this->fetchList(); } catch (ObjectNotFoundException $e) { // yummy } $this->fetched = true; return $this; } public function save() { Assert::isArray( $this->list, "that's not an array :-/" ); if (!$this->fetched) throw new WrongStateException( 'do not want to save non-fetched collection' ); $list = $this->list; $clones = $this->clones; $ids = $insert = $delete = $update = array(); if ($this->lazy) { foreach ($list as $id) { if (!isset($clones[$id])) $insert[] = $ids[$id] = $id; else $ids[$id] = $id; } foreach ($clones as $id) { if (!isset($ids[$id])) $delete[] = $id; } } else { foreach ($list as $object) { $id = $object->getId(); if (null === $id) { $insert[] = $object; } elseif ( isset($clones[$id]) && ( ($object !== $clones[$id]) || ($object != $clones[$id]) ) ) { $update[] = $object; } elseif (!isset($clones[$id])) { $insert[] = $object; } if (null !== $id) $ids[$id] = $object; } foreach ($clones as $id => $object) { if (!isset($ids[$id])) $delete[] = $object; } } $db = DBPool::getByDao($this->getDao()); if (!$db->inTransaction()) { $outerQueue = $db->isQueueActive(); if (!$outerQueue) $db->queueStart(); $db->begin(); try { $this->worker->sync($insert, $update, $delete); $db->commit(); if (!$outerQueue) $db->queueFlush(); } catch (DatabaseException $e) { if (!$outerQueue) $db->queueDrop()->queueStop(); $db->rollback(); throw $e; } } else { $this->worker->sync($insert, $update, $delete); } $this->clones = array(); $this->syncClones(); $this->dao->uncacheLists(); return $this; } public function clean() { $this->list = $this->clones = array(); $this->fetched = false; return $this; } public function dropList() { $this->worker->dropList(); $this->clean(); return $this; } /* void */ public static function destroy(UnifiedContainer $container) { unset($container->worker, $container); } protected function fetchList() { $query = $this->worker->makeFetchQuery(); if ($this->lazy) $list = $this->dao->getCustomRowList($query); else $list = $this->dao->getListByQuery($query); $this->list = array(); return $this->importList($list); } private function importList(array $list) { if ($this->lazy) { foreach ($list as $id) $this->list[$id] = $id; } else { $this->list = array_merge($this->list, $list); } $this->syncClones(); $this->fetched = true; return $this; } private function syncClones() { if ($this->lazy) { foreach ($this->list as $id) { $this->clones[$id] = $id; } } else { foreach ($this->list as $object) { // don't track unsaved objects if ($id = $object->getId()) $this->clones[$id] = clone $object; } } return $this; } } ?>

generated by doxygen-1.5.5 for onPHP at Tue Jun 17 16:42:55 2008