9.5/_record_collection_repository_8php_source.html

<?php

namespace ‪TYPO3\CMS\Core\Collection;


/*

 * 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\Core\Database\ConnectionPool;

use ‪TYPO3\CMS\Core\Database\Query\Restriction\DeletedRestriction;

use ‪TYPO3\CMS\Core\Database\Query\Restriction\FrontendRestrictionContainer;

use ‪TYPO3\CMS\Core\Utility\GeneralUtility;


class ‪RecordCollectionRepository

{

    const ‪TYPE_Static = 'static';


    protected ‪$table = 'sys_collection';


    protected ‪$typeField = 'type';


    protected ‪$tableField = 'table_name';


    public function ‪findByUid($uid)

    {

        $result = null;

        $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable($this->table);


        if ($this->‪getEnvironmentMode() === 'FE') {

            $queryBuilder->setRestrictions(GeneralUtility::makeInstance(FrontendRestrictionContainer::class));

        } else {

            $queryBuilder->getRestrictions()

                ->removeAll()

                ->add(GeneralUtility::makeInstance(DeletedRestriction::class));

        }


        $data = $queryBuilder->select('*')

            ->from($this->table)

            ->where($queryBuilder->expr()->eq('uid', $queryBuilder->createNamedParameter($uid, \PDO::PARAM_INT)))

            ->execute()

            ->fetch();

        if (is_array($data)) {

            $result = $this->‪createDomainObject($data);

        }

        return $result;

    }


    public function ‪findAll()

    {

        return $this->‪queryMultipleRecords();

    }


    public function ‪findByTableName($tableName)

    {

        $expressionBuilder = GeneralUtility::makeInstance(ConnectionPool::class)

            ->getQueryBuilderForTable($tableName)

            ->expr();


        return $this->‪queryMultipleRecords([

            $expressionBuilder->eq($this->tableField, $expressionBuilder->literal($tableName))

        ]);

    }


    public function ‪findByType($type)

    {

        $expressionBuilder = GeneralUtility::makeInstance(ConnectionPool::class)

            ->getQueryBuilderForTable($this->table)

            ->expr();


        return $this->‪queryMultipleRecords([

            $expressionBuilder->eq($this->typeField, $expressionBuilder->literal($type))

        ]);

    }


    public function ‪findByTypeAndTableName($type, $tableName)

    {

        $expressionBuilder = GeneralUtility::makeInstance(ConnectionPool::class)

            ->getQueryBuilderForTable($this->table)

            ->expr();


        return $this->‪queryMultipleRecords([

            $expressionBuilder->eq($this->typeField, $expressionBuilder->literal($type)),

            $expressionBuilder->eq($this->tableField, $expressionBuilder->literal($tableName))

        ]);

    }


    public function ‪deleteByUid($uid)

    {

        GeneralUtility::makeInstance(ConnectionPool::class)

            ->getConnectionForTable($this->table)

            ->update(

                $this->table,

                ['deleted' => 1, 'tstamp' => (int)‪$GLOBALS['EXEC_TIME']],

                ['uid' => (int)$uid]

            );

    }


    protected function ‪queryMultipleRecords(array $conditions = [])

    {

        $result = null;


        $queryBuilder = GeneralUtility::makeInstance(ConnectionPool::class)->getQueryBuilderForTable($this->table);

        $queryBuilder->getRestrictions()

            ->removeAll()

            ->add(GeneralUtility::makeInstance(DeletedRestriction::class));


        $queryBuilder->select('*')

            ->from($this->table);


        if (!empty($conditions)) {

            $queryBuilder->where(...$conditions);

        }


        $data = $queryBuilder->execute()->fetchAll();

        if (!empty($data)) {

            $result = $this->‪createMultipleDomainObjects($data);

        }


        return $result;

    }


    protected function ‪createDomainObject(array $record)

    {

        switch ($record['type']) {

            case ‪self::TYPE_Static:

                $collection = ‪StaticRecordCollection::create($record);

                break;

            default:

                throw new \RuntimeException('Unknown record collection type "' . $record['type'], 1328646798);

        }

        return $collection;

    }


    protected function ‪createMultipleDomainObjects(array $data)

    {

        $collections = [];

        foreach ($data as $collection) {

            $collections[] = $this->‪createDomainObject($collection);

        }

        return $collections;

    }


    protected function ‪getEnvironmentMode()

    {

        return TYPO3_MODE;

    }

}