CultuurNet\UDB3\MyOrganizers\ReadModel\Doctrine\DBALRepository

Complexity

Total Complexity

6

Size/Duplication

Total Lines	81
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	add()	0	33	2
A	delete()	0	9	1
A	setUpdateDate()	0	10	1
A	matchesId()	0	6	1

<?php

namespace CultuurNet\UDB3\MyOrganizers\ReadModel\Doctrine;

use DateTimeInterface;
use CultuurNet\UDB3\MyOrganizers\ReadModel\RepositoryInterface;
use Doctrine\DBAL\Connection;
use ValueObjects\StringLiteral\StringLiteral;

class DBALRepository implements RepositoryInterface
{
    use DBALHelperTrait;

    /** @var StringLiteral */
    private $tableName;

    /**
     * @param Connection $connection
     * @param StringLiteral $tableName
     */
    public function __construct(
        Connection $connection,
        StringLiteral $tableName
    ) {
        $this->connection = $connection;
        $this->tableName = $tableName;
    }

    public function add(
        string $id,
        string $userId,
        DateTimeInterface $created
    ) {
        $this->connection->beginTransaction();

        try {
            /** @var \Doctrine\DBAL\Query\QueryBuilder $q */
            $q = $this->connection->createQueryBuilder();
            $q->insert($this->tableName->toNative())
                ->values(
                    [
                        Columns::ID => $this->parameter(Columns::ID),
                        Columns::UID => $this->parameter(Columns::UID),
                        Columns::CREATED => $this->parameter(Columns::CREATED),
                        // We intentionally set updated the same as created.
                        Columns::UPDATED => $this->parameter(Columns::CREATED),
                    ]
                );

            $q->setParameter(Columns::ID, $id);
            $q->setParameter(Columns::UID, $userId);
            $q->setParameter(Columns::CREATED, $created->getTimestamp());

            $q->execute();
        } catch (\Exception $e) {
            $this->connection->rollBack();
            throw $e;
        }

        $this->connection->commit();
    }

    public function delete(string $id)
    {
        $q = $this->connection->createQueryBuilder();

        $q->delete($this->tableName->toNative())
            ->where($this->matchesId())
            ->setParameter(Columns::ID, $id)
            ->execute();
    }

    public function setUpdateDate(string $id, DateTimeInterface $updated)
    {
        $q = $this->connection->createQueryBuilder();

        $q->update($this->tableName->toNative())
            ->where($this->matchesId())
            ->set(Columns::UPDATED, $updated->getTimestamp())
            ->setParameter(Columns::ID, $id)
            ->execute();
    }

    private function matchesId(): string
    {
        $expr = $this->connection->getExpressionBuilder();

        return $expr->eq(Columns::ID, $this->parameter(Columns::ID));
    }
}