Mathielen\ImportEngine\Storage\DoctrineStorage

Complexity

Total Complexity

9

Size/Duplication

Total Lines	75
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	7

Test Coverage

Coverage

88.46%

Importance

Changes	8
Bugs	2	Features	0

5 Methods

Rating	Name	Duplication	Size	Complexity
A	reader()	0	4	1
A	getFields()	0	4	1
A	info()	0	10	1
A	__construct()	0	14	4
A	writer()	0	11	2

<?php
namespace Mathielen\ImportEngine\Storage;

use Ddeboer\DataImport\Writer\DoctrineWriter;
use Doctrine\ORM\EntityManagerInterface;
use Doctrine\ORM\Query;
use Mathielen\DataImport\Reader\DoctrineQueryReader;
use Mathielen\ImportEngine\Exception\InvalidConfigurationException;

class DoctrineStorage implements StorageInterface
{

    /**
     * @var EntityManagerInterface
     */
    private $entityManager;

    /**
     * @var Query
     */
    private $query;

    private $entityName;

    public function __construct(EntityManagerInterface $entityManager, $entityName=null, Query $query=null)
    {
        $this->entityManager = $entityManager;
        $this->entityName = $entityName;

        if (is_null($query) && is_string($entityName) && class_exists($entityName)) {
            $query = $this->entityManager->createQueryBuilder()
                ->select('o')
                ->from($this->entityName, 'o')
                ->getQuery();
        }

        $this->query = $query;
    }

    /**
     * (non-PHPdoc) @see \Mathielen\ImportEngine\Storage\StorageInterface::writer()
     */
    public function writer()
    {
        if (empty($this->entityName)) {
            throw new InvalidConfigurationException("Can only use doctrine for writing if entityName is given.");
        }

        $writer = new DoctrineWriter($this->entityManager, $this->entityName);

$this->entityManager of type object<Doctrine\ORM\EntityManagerInterface> is not a sub-type of object<Doctrine\ORM\EntityManager>. It seems like you assume a concrete implementation of the interface Doctrine\ORM\EntityManagerInterface to be always present.

        $writer->setTruncate(false);

        return $writer;
    }

    /**
     * (non-PHPdoc) @see \Mathielen\ImportEngine\Storage\StorageInterface::info()
     */
    public function info()
    {
        $count = count($this->reader());

        return new StorageInfo(array(
            'name' => $this->query->getDQL(),
            'type' => 'DQL Query',
            'count' => $count
        ));
    }

    /**
     * (non-PHPdoc) @see \Mathielen\ImportEngine\Storage\StorageInterface::reader()
     */
    public function reader()
    {
        return new DoctrineQueryReader($this->query);
    }

    /**
     * (non-PHPdoc) @see \Mathielen\ImportEngine\Storage\StorageInterface::getFields()
     */
    public function getFields()
    {
        return $this->reader()->getFields();
    }
}