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

Complexity

Total Complexity

6

Size/Duplication

Total Lines	87
Duplicated Lines	31.03 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes	1
Bugs	0	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	save()	0	23	2
A	deleteByRelationId()	0	9	1
A	deleteByLabelNameAndRelationId()	12	12	1
A	deleteImportedByRelationId()	15	15	1
A	executeTransactional()	0	6	1

<?php

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

use CultuurNet\UDB3\Label\ReadModels\Doctrine\AbstractDBALRepository;
use CultuurNet\UDB3\Label\ReadModels\Relations\Repository\WriteRepositoryInterface;
use CultuurNet\UDB3\Label\ValueObjects\LabelName;
use CultuurNet\UDB3\Label\ValueObjects\RelationType;
use Doctrine\DBAL\Query\QueryBuilder;
use ValueObjects\StringLiteral\StringLiteral;

class DBALWriteRepository extends AbstractDBALRepository implements WriteRepositoryInterface
{
    /**
     * @inheritdoc
     */
    public function save(
        LabelName $labelName,
        RelationType $relationType,
        StringLiteral $relationId,
        $imported
    ) {
        $queryBuilder = $this->createQueryBuilder()
            ->insert($this->getTableName())
            ->values([
                SchemaConfigurator::LABEL_NAME => '?',
                SchemaConfigurator::RELATION_TYPE => '?',
                SchemaConfigurator::RELATION_ID => '?',
                SchemaConfigurator::IMPORTED => '?',
            ])
            ->setParameters([
                $labelName->toNative(),
                $relationType->toNative(),
                $relationId->toNative(),
                $imported ? 1 : 0,
            ]);

        $this->executeTransactional($queryBuilder);
    }

    /**
     * @inheritdoc
     */
    public function deleteByLabelNameAndRelationId(

This method seems to be duplicated in your project.

        LabelName $labelName,
        StringLiteral $relationId
    ) {
        $queryBuilder = $this->createQueryBuilder()
            ->delete($this->getTableName())
            ->where(SchemaConfigurator::LABEL_NAME . ' = ?')
            ->andWhere(SchemaConfigurator::RELATION_ID . ' = ?')
            ->setParameters([$labelName->toNative(), $relationId->toNative()]);

        $this->executeTransactional($queryBuilder);
    }

    /**
     * @inheritdoc
     */
    public function deleteByRelationId(StringLiteral $relationId)
    {
        $queryBuilder = $this->createQueryBuilder()
            ->delete($this->getTableName())
            ->where(SchemaConfigurator::RELATION_ID . ' = ?')
            ->setParameters([$relationId->toNative()]);

        $this->executeTransactional($queryBuilder);
    }

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

This method seems to be duplicated in your project.

    {
        $queryBuilder = $this->createQueryBuilder()
            ->delete($this->getTableName())
            ->where(SchemaConfigurator::RELATION_ID . ' = :relationId')
            ->andWhere(SchemaConfigurator::IMPORTED . ' = :imported')
            ->setParameters(
                [
                    ':relationId' => $relationId->toNative(),
                    ':imported' => true,
                ]
            );

        $this->executeTransactional($queryBuilder);
    }

    /**
     * @param QueryBuilder $queryBuilder
     */
    private function executeTransactional(QueryBuilder $queryBuilder)
    {
        $this->getConnection()->transactional(function () use ($queryBuilder) {
            $queryBuilder->execute();
        });
    }
}