Scheduler\Infrastructure\DBAL\DbalUserMapper

Complexity

Total Complexity

10

Size/Duplication

Total Lines	84
Duplicated Lines	9.52 %

Coupling/Cohesion

Components	1
Dependencies	6

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	findStatement()	0	7	1
A	findByRoleStatement()	0	7	1
A	insertStatement()	0	4	1
A	find()	0	14	3
A	findByRole()	8	8	1
A	doLoad()	0	9	1
A	insert()	0	4	1
A	doInsert()	0	11	1

<?php

namespace Scheduler\Infrastructure\DBAL;

use DateTime;
use Doctrine\DBAL\Statement;
use Doctrine\DBAL\Types\Type;
use Scheduler\Domain\Model\User\NullUser;
use Scheduler\Domain\Model\User\User;
use Scheduler\Domain\Model\User\UserMapper;

class DbalUserMapper extends DbalMapper implements UserMapper
{
    const COLUMNS = "id, name, role, email, phone, created_at, updated_at";

    protected static function findStatement()
    {
        return sprintf(
            "SELECT %s FROM users WHERE id = ?",
            self::COLUMNS
        );
    }

    protected static function findByRoleStatement()
    {
        return sprintf(
            "SELECT %s FROM users WHERE role = ?",
            self::COLUMNS
        );
    }

    protected static function insertStatement()
    {
        return "INSERT INTO users VALUES (?, ?, ?, ?, ?, ?, ?)";
    }

    public function find($id)
    {
        if (! is_int($id)) {
            throw new \InvalidArgumentException("The id must be an integer");
        }

        $user = $this->abstractFind($id);

        if ($user == null) {
            $user = new NullUser();
        }

        return $user;
    }

    public function findByRole($role)
    {
        $statement = $this->db->prepare(self::findByRoleStatement());
        $statement->bindValue(1, $role, \PDO::PARAM_STR);
        $statement->execute();

        return $this->loadAll($statement);

$statement of type object<Doctrine\DBAL\Driver\Statement> is not a sub-type of object<Doctrine\DBAL\Statement>. It seems like you assume a concrete implementation of the interface Doctrine\DBAL\Driver\Statement to be always present.

    }

    protected function doLoad($id, array $resultSet)
    {
        extract($resultSet);
        $id = (int) $id;
        $created = new DateTime($created_at);
        $updated = new DateTime($updated_at);

        return new User($id, $name, $role, $email, $phone, $created, $updated);
    }

    public function insert(User $user)
    {
        return $this->abstractInsert($user);
    }

    /**
     * Bind query parameters and execute insert statement
     *
     * @param  User      $subject
     * @param  Statement $insertStatement
     *
     * @return int                        The id of the inserted row
     */
    protected function doInsert($subject, Statement $insertStatement)
    {
        $insertStatement->bindValue(1, null);
        $insertStatement->bindValue(2, $subject->getName(), \PDO::PARAM_STR);
        $insertStatement->bindValue(3, $subject->getRole(), \PDO::PARAM_STR);
        $insertStatement->bindValue(4, $subject->getEmail(), \PDO::PARAM_STR);
        $insertStatement->bindValue(5, $subject->getPhone(), \PDO::PARAM_STR);
        $insertStatement->bindValue(6, $subject->getCreated(), Type::DATETIME);
        $insertStatement->bindValue(7, $subject->getUpdated(), Type::DATETIME);
        $insertStatement->execute();
    }
}