CultuurNet\UDB3\Label\ReadModels\Relations\Repository\Doctrine\DBALReadRepository

Complexity

Total Complexity

5

Size/Duplication

Total Lines	63
Duplicated Lines	63.49 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	getLabelRelations()	17	17	2
A	getLabelRelationsForItem()	23	23	2
A	getAliases()	0	9	1

<?php

namespace CultuurNet\UDB3\Label\ReadModels\Relations\Repository\Doctrine;

use CultuurNet\UDB3\Label\ReadModels\Doctrine\AbstractDBALRepository;
use CultuurNet\UDB3\Label\ReadModels\Relations\Repository\LabelRelation;
use CultuurNet\UDB3\Label\ReadModels\Relations\Repository\ReadRepositoryInterface;
use CultuurNet\UDB3\Label\ValueObjects\LabelName;
use ValueObjects\StringLiteral\StringLiteral;

class DBALReadRepository extends AbstractDBALRepository implements ReadRepositoryInterface
{
    /**
     * @inheritdoc
     */
    public function getLabelRelations(LabelName $labelName)

This method seems to be duplicated in your project.

    {
        $aliases = $this->getAliases();
        $whereLabelName = SchemaConfigurator::LABEL_NAME . ' = ?';

        $queryBuilder = $this->createQueryBuilder()->select($aliases)
            ->from($this->getTableName()->toNative())
            ->where($whereLabelName)
            ->setParameters([$labelName->toNative()]);

        $statement = $queryBuilder->execute();

        while ($row = $statement->fetch(\PDO::FETCH_ASSOC)) {
            $labelRelation = LabelRelation::fromRelationalData($row);
            yield $labelRelation;
        }
    }

    /**
     * @inheritdoc
     */
    public function getLabelRelationsForItem(StringLiteral $relationId)

This method seems to be duplicated in your project.

    {
        $aliases = $this->getAliases();
        $whereRelationId = SchemaConfigurator::RELATION_ID . ' = ?';

        $queryBuilder = $this->createQueryBuilder()->select($aliases)
            ->from($this->getTableName()->toNative())
            ->where($whereRelationId)
            ->setParameters(
                [
                    $relationId->toNative(),
                ]
            );

        $statement = $queryBuilder->execute();

        $labelRelations = [];
        while ($row = $statement->fetch(\PDO::FETCH_ASSOC)) {
            $labelRelations[] = LabelRelation::fromRelationalData($row);
        }

        return $labelRelations;
    }

    /**
     * @return array
     */
    private function getAliases()
    {
        return [
            SchemaConfigurator::LABEL_NAME,
            SchemaConfigurator::RELATION_TYPE,
            SchemaConfigurator::RELATION_ID,
            SchemaConfigurator::IMPORTED
        ];
    }
}