eZ\Publish\Core\Persistence\Legacy\URL\Gateway\DoctrineDatabase

Complexity

Total Complexity

19

Size/Duplication

Total Lines	254
Duplicated Lines	2.36 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

10 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
B	find()	6	37	10
A	findUsages()	0	46	1
A	updateUrl()	0	29	1
A	loadUrlData()	0	15	1
A	loadUrlDataByUrl()	0	15	1
A	doCount()	0	15	1
A	createSelectQuery()	0	7	1
A	createSelectDistinctQuery()	0	7	1
A	getSelectColumns()	0	12	1

<?php

/**
 * @copyright Copyright (C) eZ Systems AS. All rights reserved.
 * @license For full copyright and license information view LICENSE file distributed with this source code.
 */
namespace eZ\Publish\Core\Persistence\Legacy\URL\Gateway;

use eZ\Publish\Core\Persistence\Database\SelectQuery;
use eZ\Publish\API\Repository\Values\URL\Query\Criterion;
use eZ\Publish\API\Repository\Values\URL\Query\SortClause;
use eZ\Publish\Core\Persistence\Legacy\URL\Gateway;
use eZ\Publish\Core\Persistence\Legacy\URL\Query\CriteriaConverter;
use eZ\Publish\Core\Persistence\Database\DatabaseHandler;
use eZ\Publish\SPI\Persistence\URL\URL;
use PDO;

/**
 * URL gateway implementation using the Doctrine.
 */
class DoctrineDatabase extends Gateway
{
    const URL_TABLE = 'ezurl';
    const URL_LINK_TABLE = 'ezurl_object_link';

    const COLUMN_ID = 'id';
    const COLUMN_URL = 'url';
    const COLUMN_ORIGINAL_URL_MD5 = 'original_url_md5';
    const COLUMN_IS_VALID = 'is_valid';
    const COLUMN_LAST_CHECKED = 'last_checked';
    const COLUMN_MODIFIED = 'modified';
    const COLUMN_CREATED = 'created';

    /**
     * Database handler.
     *
     * @param \eZ\Publish\Core\Persistence\Database\DatabaseHandler $dbHandler
     */
    protected $handler;

    /**
     * Criteria converter.
     *
     * @var \eZ\Publish\Core\Persistence\Legacy\URL\Query\CriteriaConverter
     */
    protected $criteriaConverter;

    /**
     * Creates a new Doctrine database Section Gateway.
     *
     * @param \eZ\Publish\Core\Persistence\Database\DatabaseHandler $dbHandler
     * @param \eZ\Publish\Core\Persistence\Legacy\URL\Query\CriteriaConverter $criteriaConverter
     */
    public function __construct(DatabaseHandler $dbHandler, CriteriaConverter $criteriaConverter)
    {
        $this->handler = $dbHandler;
        $this->criteriaConverter = $criteriaConverter;
    }

    /**
     * {@inheritdoc}
     */
    public function find(Criterion $criterion, $offset, $limit, array $sortClauses = [], $doCount = true)
    {
        $count = $doCount ? $this->doCount($criterion) : null;
        if (!$doCount && $limit === 0) {
            throw new \RuntimeException('Invalid query. Cannot disable count and request 0 items at the same time');
        }

        if ($limit === 0 || ($count !== null && $count <= $offset)) {

This code seems to be duplicated across your project.

            return [
                'count' => $count,
                'rows' => [],
            ];
        }

        $query = $this->createSelectDistinctQuery();
        $query->where($this->criteriaConverter->convertCriteria($query, $criterion));
        $query->limit($limit > 0 ? $limit : PHP_INT_MAX, $offset);

        foreach ($sortClauses as $sortClause) {
            $column = $this->handler->quoteColumn($sortClause->target, self::URL_TABLE);

            $direction = SelectQuery::ASC;
            if ($sortClause->direction === SortClause::SORT_DESC) {
                $direction = SelectQuery::DESC;
            }

            $query->orderBy($column, $direction);
        }

        $statement = $query->prepare();
        $statement->execute();

        return [
            'count' => $count,
            'rows' => $statement->fetchAll(PDO::FETCH_ASSOC),
        ];
    }

    /**
     * {@inheritdoc}
     */
    public function findUsages($id)
    {
        $query = $this->handler->createSelectQuery();
        $query->selectDistinct(
            $this->handler->quoteColumn('id', 'ezcontentobject')
        )->from(
            $this->handler->quoteTable('ezcontentobject')
        )->innerJoin(
            $this->handler->quoteTable('ezcontentobject_attribute'),
            $query->expr->lAnd(
                $query->expr->eq(
                    $this->handler->quoteColumn('id', 'ezcontentobject'),
                    $this->handler->quoteColumn(
                        'contentobject_id',
                        'ezcontentobject_attribute'
                    )
                ),
                $query->expr->eq(
                    $this->handler->quoteColumn('current_version', 'ezcontentobject'),
                    $this->handler->quoteColumn('version', 'ezcontentobject_attribute')
                )
            )
        )->innerJoin(
            $this->handler->quoteTable(self::URL_LINK_TABLE),
            $query->expr->lAnd(
                $query->expr->eq(
                    $this->handler->quoteColumn('id', 'ezcontentobject_attribute'),
                    $this->handler->quoteColumn('contentobject_attribute_id', self::URL_LINK_TABLE)
                ),
                $query->expr->eq(
                    $this->handler->quoteColumn('version', 'ezcontentobject_attribute'),
                    $this->handler->quoteColumn('contentobject_attribute_version', self::URL_LINK_TABLE)
                )
            )
        )->where(
            $query->expr->eq(
                $this->handler->quoteColumn('url_id', self::URL_LINK_TABLE),
                $query->bindValue($id, null, PDO::PARAM_INT)
            )
        );

        $statement = $query->prepare();
        $statement->execute();

        return array_column($statement->fetchAll(PDO::FETCH_ASSOC), 'id');
    }

    /**
     * {@inheritdoc}
     */
    public function updateUrl(URL $url)
    {
        $query = $this->handler->createUpdateQuery();
        $query->update(
            $this->handler->quoteTable(self::URL_TABLE)
        )->set(
            $this->handler->quoteColumn(self::COLUMN_URL),
            $query->bindValue($url->url)
        )->set(
            $this->handler->quoteColumn(self::COLUMN_ORIGINAL_URL_MD5),
            $query->bindValue($url->originalUrlMd5)
        )->set(
            $this->handler->quoteColumn(self::COLUMN_MODIFIED),
            $query->bindValue($url->modified, null, PDO::PARAM_INT)
        )->set(
            $this->handler->quoteColumn(self::COLUMN_IS_VALID),
            $query->bindValue((int)$url->isValid, null, PDO::PARAM_INT)
        )->set(
            $this->handler->quoteColumn(self::COLUMN_LAST_CHECKED),
            $query->bindValue($url->lastChecked, null, PDO::PARAM_INT)
        )->where(
            $query->expr->eq(
                $this->handler->quoteColumn(self::COLUMN_ID),
                $query->bindValue($url->id, null, PDO::PARAM_INT)
            )
        );

        $query->prepare()->execute();
    }

    /**
     * {@inheritdoc}
     */
    public function loadUrlData($id)
    {
        $query = $this->createSelectQuery();
        $query->where(
            $query->expr->eq(
                $this->handler->quoteColumn(self::COLUMN_ID),
                $query->bindValue($id, null, PDO::PARAM_INT)
            )
        );

        $statement = $query->prepare();
        $statement->execute();

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

    /**
     * {@inheritdoc}
     */
    public function loadUrlDataByUrl($url)
    {
        $query = $this->createSelectQuery();
        $query->where(
            $query->expr->eq(
                $this->handler->quoteColumn(self::COLUMN_URL),
                $query->bindValue($url, null, PDO::PARAM_STR)
            )
        );

        $statement = $query->prepare();
        $statement->execute();

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

    /**
     * {@inheritdoc}
     */
    protected function doCount(Criterion $criterion)
    {
        $columnName = $this->handler->quoteColumn(self::COLUMN_ID, self::URL_TABLE);

        $query = $this->handler->createSelectQuery();
        $query
            ->select("COUNT(DISTINCT $columnName)")
            ->from($this->handler->quoteTable(self::URL_TABLE))
            ->where($this->criteriaConverter->convertCriteria($query, $criterion));

        $statement = $query->prepare();
        $statement->execute();

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

    /**
     * Creates a Url find query.
     *
     * @return \eZ\Publish\Core\Persistence\Database\SelectQuery
     */
    protected function createSelectQuery(): SelectQuery
    {
        return $this->handler
            ->createSelectQuery()
            ->select(...$this->getSelectColumns())
            ->from($this->handler->quoteTable(self::URL_TABLE));
    }

    private function createSelectDistinctQuery(): SelectQuery
    {
        return $this->handler
            ->createSelectQuery()
            ->selectDistinct(...$this->getSelectColumns())
            ->from($this->handler->quoteTable(self::URL_TABLE));
    }

    private function getSelectColumns(): array
    {
        return [
            $this->handler->quoteColumn(self::COLUMN_ID, self::URL_TABLE),
            $this->handler->quoteColumn(self::COLUMN_URL, self::URL_TABLE),
            $this->handler->quoteColumn(self::COLUMN_ORIGINAL_URL_MD5, self::URL_TABLE),
            $this->handler->quoteColumn(self::COLUMN_IS_VALID, self::URL_TABLE),
            $this->handler->quoteColumn(self::COLUMN_LAST_CHECKED, self::URL_TABLE),
            $this->handler->quoteColumn(self::COLUMN_CREATED, self::URL_TABLE),
            $this->handler->quoteColumn(self::COLUMN_MODIFIED, self::URL_TABLE),
        ];
    }
}