typo3/sysext/extbase/Classes/Persistence/Manager.php

   1 <?php
   2 /***************************************************************
   3 *  Copyright notice
   4 *
   5 *  (c) 2009 Jochen Rau <jochen.rau@typoplanet.de>
   6 *  All rights reserved
   7 *
   8 *  This class is a backport of the corresponding class of FLOW3.
   9 *  All credits go to the v5 team.
  10 *
  11 *  This script is part of the TYPO3 project. The TYPO3 project is
  12 *  free software; you can redistribute it and/or modify
  13 *  it under the terms of the GNU General Public License as published by
  14 *  the Free Software Foundation; either version 2 of the License, or
  15 *  (at your option) any later version.
  16 *
  17 *  The GNU General Public License can be found at
  18 *  http://www.gnu.org/copyleft/gpl.html.
  19 *
  20 *  This script is distributed in the hope that it will be useful,
  21 *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  22 *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  23 *  GNU General Public License for more details.
  24 *
  25 *  This copyright notice MUST APPEAR in all copies of the script!
  26 ***************************************************************/
  27
  28 /**
  29  * The Extbase Persistence Manager
  30  *
  31  * @package Extbase
  32  * @subpackage Persistence
  33  * @version $Id: Manager.php 2293 2009-05-20 18:14:45Z robert $
  34  * @api
  35  */
  36 class Tx_Extbase_Persistence_Manager implements Tx_Extbase_Persistence_ManagerInterface, t3lib_Singleton {
  37
  38         /**
  39          * @var Tx_Extbase_Persistence_BackendInterface
  40          */
  41         protected $backend;
  42
  43         /**
  44          * @var Tx_Extbase_Persistence_Session
  45          */
  46         protected $session;
  47
  48         /**
  49          * @var Tx_Extbase_Object_ManagerInterface
  50          */
  51         protected $objectManager;
  52
  53         /**
  54          * This is an array of registered repository class names.
  55          *
  56          * @var array
  57          */
  58         protected $repositoryClassNames = array();
  59
  60         /**
  61          * Injects the Persistence Backend
  62          *
  63          * @param Tx_Extbase_Persistence_BackendInterface $backend The persistence backend
  64          * @return void
  65          */
  66         public function injectBackend(Tx_Extbase_Persistence_BackendInterface $backend) {
  67                 $this->backend = $backend;
  68         }
  69
  70         /**
  71          *
  72          * Injects the Persistence Session
  73          *
  74          * @param Tx_Extbase_Persistence_Session $session The persistence session
  75          * @return void
  76          */
  77         public function injectSession(Tx_Extbase_Persistence_Session $session) {
  78                 $this->session = $session;
  79         }
  80
  81         /**
  82          * Injects the object manager
  83          *
  84          * @param Tx_Extbase_Object_ManagerInterface $objectManager
  85          * @return void
  86          */
  87         public function injectObjectManager(Tx_Extbase_Object_ManagerInterface $objectManager) {
  88                 $this->objectManager = $objectManager;
  89         }
  90
  91         /**
  92          * Returns the current persistence session
  93          *
  94          * @return Tx_Extbase_Persistence_Session
  95          */
  96         public function getSession() {
  97                 return $this->session;
  98         }
  99
 100         /**
 101          * Returns the persistence backend
 102          *
 103          * @return Tx_Extbase_Persistence_BackendInterface
 104          */
 105         public function getBackend() {
 106                 return $this->backend;
 107         }
 108
 109         /**
 110          * Registers a repository
 111          *
 112          * @param string $className The class name of the repository to be reigistered
 113          * @return void
 114          */
 115         public function registerRepositoryClassName($className) {
 116                 $this->repositoryClassNames[] = $className;
 117         }
 118
 119         /**
 120          * Returns all repository class names
 121          *
 122          * @return array An array holding the registered repository class names
 123          */
 124         public function getRepositoryClassNames() {
 125                 return $this->repositoryClassNames;
 126         }
 127
 128         /**
 129          * Commits new objects and changes to objects in the current persistence
 130          * session into the backend
 131          *
 132          * @return void
 133          * @api
 134          */
 135         public function persistAll() {
 136                 $aggregateRootObjects = new Tx_Extbase_Persistence_ObjectStorage();
 137                 $removedObjects = new Tx_Extbase_Persistence_ObjectStorage();
 138
 139                         // fetch and inspect objects from all known repositories
 140                 $repositoryClassNames = $this->getRepositoryClassNames();
 141                 foreach ($repositoryClassNames as $repositoryClassName) {
 142                         $repository = $this->objectManager->getObject($repositoryClassName);
 143                         $aggregateRootObjects->addAll($repository->getAddedObjects());
 144                         $removedObjects->addAll($repository->getRemovedObjects());
 145                 }
 146
 147                 foreach ($this->session->getReconstitutedObjects() as $reconstitutedObject) {
 148                         if (class_exists(str_replace('_Model_', '_Repository_', get_class($reconstitutedObject)) . 'Repository')) {
 149                                 $aggregateRootObjects->attach($reconstitutedObject);
 150                         }
 151                 }
 152
 153                         // hand in only aggregate roots, leaving handling of subobjects to
 154                         // the underlying storage layer
 155                 $this->backend->setAggregateRootObjects($aggregateRootObjects);
 156                 $this->backend->setDeletedObjects($removedObjects);
 157                 $this->backend->commit();
 158
 159                         // this needs to unregister more than just those, as at least some of
 160                         // the subobjects are supposed to go away as well...
 161                         // OTOH those do no harm, changes to the unused ones should not happen,
 162                         // so all they do is eat some memory.
 163                 foreach($removedObjects as $removedObject) {
 164                         $this->session->unregisterReconstitutedObject($removedObject);
 165                 }
 166         }
 167
 168 }
 169 ?>