PersistenceManager.php

Go to the documentation of this file.

<?php
namespace TYPO3\CMS\Extbase\Persistence\Generic;

use TYPO3\CMS\Extbase\Persistence\ObjectStorage;
use TYPO3\CMS\Extbase\Persistence\QueryInterface;

class PersistenceManager implements \TYPO3\CMS\Extbase\Persistence\PersistenceManagerInterface, \TYPO3\CMS\Core\SingletonInterface {

    protected $newObjects = array();

    protected $changedObjects;

    protected $addedObjects;

    protected $removedObjects;

    protected $queryFactory;

    protected $backend;

    protected $persistenceSession;

    public function __construct() {
        $this->addedObjects = new ObjectStorage();
        $this->removedObjects = new ObjectStorage();
        $this->changedObjects = new ObjectStorage();
    }

    public function registerRepositoryClassName($className) {
    }

    public function getObjectCountByQuery(QueryInterface $query) {
        return $this->backend->getObjectCountByQuery($query);
    }

    public function getObjectDataByQuery(QueryInterface $query) {
        return $this->backend->getObjectDataByQuery($query);
    }

    public function getIdentifierByObject($object) {
        return $this->backend->getIdentifierByObject($object);
    }

    public function getObjectByIdentifier($identifier, $objectType = NULL, $useLazyLoading = FALSE) {
        if (isset($this->newObjects[$identifier])) {
            return $this->newObjects[$identifier];
        }
        if ($this->persistenceSession->hasIdentifier($identifier, $objectType)) {
            return $this->persistenceSession->getObjectByIdentifier($identifier, $objectType);
        } else {
            return $this->backend->getObjectByIdentifier($identifier, $objectType);
        }
    }

    public function persistAll() {
        // hand in only aggregate roots, leaving handling of subobjects to
        // the underlying storage layer
        // reconstituted entities must be fetched from the session and checked
        // for changes by the underlying backend as well!
        $this->backend->setAggregateRootObjects($this->addedObjects);
        $this->backend->setChangedEntities($this->changedObjects);
        $this->backend->setDeletedEntities($this->removedObjects);
        $this->backend->commit();

        $this->addedObjects = new ObjectStorage();
        $this->removedObjects = new ObjectStorage();
        $this->changedObjects = new ObjectStorage();
    }

    public function createQueryForType($type) {
        return $this->queryFactory->create($type);
    }

    public function add($object) {
        $this->addedObjects->attach($object);
        $this->removedObjects->detach($object);
    }

    public function remove($object) {
        if ($this->addedObjects->contains($object)) {
            $this->addedObjects->detach($object);
        } else {
            $this->removedObjects->attach($object);
        }
    }

    public function update($object) {
        if ($this->isNewObject($object)) {
            throw new \TYPO3\CMS\Extbase\Persistence\Exception\UnknownObjectException('The object of type "' . get_class($object) . '" given to update must be persisted already, but is new.', 1249479819);
        }
        $this->changedObjects->attach($object);
    }

    public function injectSettings(array $settings) {
        throw new \TYPO3\CMS\Extbase\Persistence\Generic\Exception\NotImplementedException(__METHOD__);
    }

    public function initializeObject() {
        $this->backend->setPersistenceManager($this);
    }

    public function clearState() {
        $this->newObjects = array();
        $this->addedObjects = new ObjectStorage();
        $this->removedObjects = new ObjectStorage();
        $this->changedObjects = new ObjectStorage();
        $this->persistenceSession->destroy();
    }

    public function isNewObject($object) {
        return ($this->persistenceSession->hasObject($object) === FALSE);
    }

    public function registerNewObject($object) {
        $identifier = $this->getIdentifierByObject($object);
        $this->newObjects[$identifier] = $object;
    }

    public function convertObjectToIdentityArray($object) {
        throw new \TYPO3\CMS\Extbase\Persistence\Generic\Exception\NotImplementedException(__METHOD__);
    }

    public function convertObjectsToIdentityArrays(array $array) {
        throw new \TYPO3\CMS\Extbase\Persistence\Generic\Exception\NotImplementedException(__METHOD__);
    }

    public function tearDown() {
        if (method_exists($this->backend, 'tearDown')) {
            $this->backend->tearDown();
        }
    }

}