9.5/_query_result_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\Object\ObjectManagerInterface;

use ‪TYPO3\CMS\Extbase\Persistence\Generic\Mapper\DataMapper;

use ‪TYPO3\CMS\Extbase\Persistence\QueryResultInterface;


class ‪QueryResult implements ‪QueryResultInterface

{

    protected ‪$dataMapper;


    protected ‪$persistenceManager;


    protected ‪$numberOfResults;


    protected ‪$query;


    protected ‪$queryResult;


    protected ‪$objectManager;


    public function ‪injectObjectManager(‪ObjectManagerInterface ‪$objectManager)

    {

        $this->objectManager = ‪$objectManager;

    }


    public function ‪injectPersistenceManager(\‪TYPO3\CMS\‪Extbase\Persistence\‪PersistenceManagerInterface ‪$persistenceManager)

    {

        $this->persistenceManager = ‪$persistenceManager;

    }


    public function ‪__construct(\‪TYPO3\CMS\‪Extbase\Persistence\‪QueryInterface ‪$query)

    {

        $this->query = ‪$query;

    }


    public function ‪initializeObject()

    {

        $this->dataMapper = $this->objectManager->get(DataMapper::class, $this->query);

    }


    protected function ‪initialize()

    {

        if (!is_array($this->queryResult)) {

            $this->queryResult = $this->dataMapper->map($this->query->getType(), $this->persistenceManager->getObjectDataByQuery($this->query));

        }

    }


    public function ‪getQuery()

    {

        return clone ‪$this->query;

    }


    public function ‪getFirst()

    {

        if (is_array($this->queryResult)) {

            ‪$queryResult = ‪$this->queryResult;

            reset(‪$queryResult);

        } else {

            ‪$query = $this->‪getQuery();

            ‪$query->‪setLimit(1);

            ‪$queryResult = $this->dataMapper->map(‪$query->‪getType(), $this->persistenceManager->getObjectDataByQuery(‪$query));

        }

        $firstResult = ‪current(‪$queryResult);

        if ($firstResult === false) {

            $firstResult = null;

        }

        return $firstResult;

    }


    public function ‪count()

    {

        if ($this->numberOfResults === null) {

            if (is_array($this->queryResult)) {

                $this->numberOfResults = ‪count($this->queryResult);

            } else {

                $this->numberOfResults = $this->persistenceManager->getObjectCountByQuery($this->query);

            }

        }

        return ‪$this->numberOfResults;

    }


    public function ‪toArray()

    {

        $this->‪initialize();

        return iterator_to_array($this);

    }


    public function ‪offsetExists($offset)

    {

        $this->‪initialize();

        return isset($this->queryResult[$offset]);

    }


    public function ‪offsetGet($offset)

    {

        $this->‪initialize();

        return $this->queryResult[$offset] ?? null;

    }


    public function ‪offsetSet($offset, $value)

    {

        $this->‪initialize();

        $this->numberOfResults = null;

        $this->queryResult[$offset] = $value;

    }


    public function ‪offsetUnset($offset)

    {

        $this->‪initialize();

        $this->numberOfResults = null;

        unset($this->queryResult[$offset]);

    }


    public function ‪current()

    {

        $this->‪initialize();

        return ‪current($this->queryResult);

    }


    public function ‪key()

    {

        $this->‪initialize();

        return ‪key($this->queryResult);

    }


    public function ‪next()

    {

        $this->‪initialize();

        ‪next($this->queryResult);

    }


    public function ‪rewind()

    {

        $this->‪initialize();

        reset($this->queryResult);

    }


    public function ‪valid()

    {

        $this->‪initialize();

        return ‪current($this->queryResult) !== false;

    }


    public function ‪__wakeup()

    {

        ‪$objectManager = \TYPO3\CMS\Core\Utility\GeneralUtility::makeInstance(\‪TYPO3\CMS\‪Extbase\Object\ObjectManager::class);

        $this->persistenceManager = ‪$objectManager->‪get(\‪TYPO3\CMS\‪Extbase\Persistence\PersistenceManagerInterface::class);

        $this->dataMapper = ‪$objectManager->‪get(DataMapper::class);

    }


    public function ‪__sleep()

    {

        return ['query'];

    }

}