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

Complexity

Total Complexity

2

Size/Duplication

Total Lines	42
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	save()	0	20	1
A	deleteByUuidAndRelationId()	0	12	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\RelationType;
use ValueObjects\Identity\UUID;
use ValueObjects\String\String as StringLiteral;

class DBALWriteRepository extends AbstractDBALRepository implements WriteRepositoryInterface
{
    /**
     * @inheritdoc
     */
    public function save(
        UUID $uuid,
        RelationType $relationType,
        StringLiteral $relationId
    ) {
        $queryBuilder = $this->createQueryBuilder()
            ->insert($this->getTableName())
            ->values([
                SchemaConfigurator::UUID_COLUMN => '?',
                SchemaConfigurator::RELATION_TYPE_COLUMN => '?',
                SchemaConfigurator::RELATION_ID_COLUMN => '?'
            ])
            ->setParameters([
                $uuid->toNative(),
                $relationType->toNative(),
                $relationId->toNative()
            ]);

        $queryBuilder->execute();
    }

    /**
     * @inheritdoc
     */
    public function deleteByUuidAndRelationId(
        UUID $uuid,
        StringLiteral $relationId
    ) {
        $queryBuilder = $this->createQueryBuilder()
            ->delete($this->getTableName())
            ->where(SchemaConfigurator::UUID_COLUMN . ' = ?')
            ->andWhere(SchemaConfigurator::RELATION_ID_COLUMN . ' = ?')
            ->setParameters([$uuid->toNative(), $relationId->toNative()]);

        $queryBuilder->execute();
    }
}