Netgen\Bundle\InformationCollectionBundle\Core\Persistence\Gateway\DoctrineDatabase

Complexity

Total Complexity

5

Size/Duplication

Total Lines	124
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	getContentsWithCollectionsCount()	0	30	1
B	getObjectsWithCollections()	0	58	3

<?php

declare(strict_types=1);

namespace Netgen\InformationCollection\Core\Persistence\Gateway;

use Doctrine\DBAL\Connection;
use PDO;

class DoctrineDatabase
{
    /**
     * @var \Doctrine\DBAL\Connection
     */
    protected $connection;

    /**
     * DoctrineDatabase constructor.
     *
     * @param \Doctrine\DBAL\Connection $connection
     */
    public function __construct(Connection $connection)
    {
        $this->connection = $connection;
    }

    /**
     * Returns number of content objects that have any collection.
     *
     * @throws \Doctrine\DBAL\DBALException
     *
     * @return int
     */
    public function getContentsWithCollectionsCount()
    {
        $query = $this->connection->createQueryBuilder();
        $query->select(
                'COUNT(DISTINCT eic.contentobject_id) AS count'
            )
            ->from($this->connection->quoteIdentifier('ezinfocollection'), 'eic')
            ->innerJoin(
                'eic',
                $this->connection->quoteIdentifier('ezcontentobject'),
                'eco',
                $query->expr()->eq(
                    $this->connection->quoteIdentifier('eic.contentobject_id'),
                    $this->connection->quoteIdentifier('eco.id')
                )
            )
            ->leftJoin(
                'eic',
                $this->connection->quoteIdentifier('ezcontentobject_tree'),
                'ecot',
                $query->expr()->eq(
                    $this->connection->quoteIdentifier('eic.contentobject_id'),
                    $this->connection->quoteIdentifier('ecot.contentobject_id')
                )
            );

        $statement = $query->execute();

        return (int) $statement->fetchColumn();
    }

    /**
     * Returns content objects with their collections.
     *
     * @param int $limit
     * @param int $offset
     *
     * @throws \Doctrine\DBAL\DBALException
     *
     * @return array
     */
    public function getObjectsWithCollections($limit, $offset)
    {
        $contentIdsQuery = $this->connection->createQueryBuilder();
        $contentIdsQuery
            ->select('DISTINCT contentobject_id AS id')
            ->from($this->connection->quoteIdentifier('ezinfocollection'));

        $statement = $contentIdsQuery->execute();

        $contents = [];
        foreach ($statement->fetchAll() as $content) {
            $contents[] = (int) $content['id'];
        }

        if (empty($contents)) {
            return [];
        }

        $query = $this->connection->createQueryBuilder();
        $query
            ->select(
                'eco.id AS content_id',
                'eco.name',
                'ecot.main_node_id',
                'ecc.serialized_name_list',
                'ecc.identifier AS class_identifier'
            )
            ->from($this->connection->quoteIdentifier('ezcontentobject'), 'eco')
            ->leftJoin(
                'eco',
                $this->connection->quoteIdentifier('ezcontentobject_tree'),
                'ecot',
                $query->expr()->eq(
                    $this->connection->quoteIdentifier('eco.id'),
                    $this->connection->quoteIdentifier('ecot.contentobject_id')
                )
            )
            ->innerJoin(
                'eco',
                $this->connection->quoteIdentifier('ezcontentclass'),
                'ecc',
                $query->expr()->eq(
                    $this->connection->quoteIdentifier('eco.contentclass_id'),
                    $this->connection->quoteIdentifier('ecc.id')
                )
            )
            ->where(
                $query->expr()->eq('ecc.version', 0)
            )
            ->andWhere($query->expr()->in('eco.id', $contents))
            ->groupBy($this->connection->quoteIdentifier('ecot.main_node_id'))
            ->setFirstResult($offset)
            ->setMaxResults($limit);

        $statement = $query->execute();

        return $statement->fetchAll(PDO::FETCH_ASSOC);
    }
}