9.5/_persistence_manager_8php_source.html

<?php

namespace ‪TYPO3\CMS\Extbase\Persistence\Generic;


/*

 * This file is part of the TYPO3 CMS project.

 *

 * It is free software; you can redistribute it and/or modify it under

 * the terms of the GNU General Public License, either version 2

 * of the License, or any later version.

 *

 * For the full copyright and license information, please read the

 * LICENSE.txt file that was distributed with this source code.

 *

 * The TYPO3 project - inspiring people to share!

 */


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 = [];


    protected ‪$changedObjects;


    protected ‪$addedObjects;


    protected ‪$removedObjects;


    protected ‪$queryFactory;


    protected ‪$backend;


    protected ‪$persistenceSession;


    public function ‪injectQueryFactory(\‪TYPO3\CMS\‪Extbase\Persistence\Generic\‪QueryFactoryInterface ‪$queryFactory)

    {

        $this->queryFactory = ‪$queryFactory;

    }


    public function ‪injectBackend(\‪TYPO3\CMS\‪Extbase\Persistence\Generic\‪BackendInterface ‪$backend)

    {

        $this->backend = ‪$backend;

    }


    public function ‪injectPersistenceSession(\‪TYPO3\CMS\‪Extbase\Persistence\Generic\‪Session ‪$persistenceSession)

    {

        $this->persistenceSession = ‪$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);

        }

        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__, 1476108078);

    }


    public function ‪initializeObject()

    {

        $this->backend->setPersistenceManager($this);

    }


    public function ‪clearState()

    {

        $this->newObjects = [];

        $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__, 1476108103);

    }


    public function ‪convertObjectsToIdentityArrays(array $array)

    {

        throw new \TYPO3\CMS\Extbase\Persistence\Generic\Exception\NotImplementedException(__METHOD__, 1476108111);

    }


    public function ‪tearDown()

    {

        if (method_exists($this->backend, 'tearDown')) {

            $this->backend->tearDown();

        }

    }

}