Mathielen\ImportEngineBundle\Endpoint\DoctrineEndpoint

Complexity

Total Complexity

8

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	2
Dependencies	0

Test Coverage

Coverage

0%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	5	1
A	add()	0	10	2
A	chunkCompleted()	0	4	2
A	prepare()	0	4	1
A	finish()	0	4	1
A	rollback()	0	3	1

<?php

namespace Mathielen\ImportEngineBundle\Endpoint;

use Doctrine\Common\Persistence\ObjectManager;
use Mathielen\DataImport\Event\ImportProcessEvent;

class DoctrineEndpoint
{
    /**
     * @var ObjectManager
     */
    private $objectManager;

    private $chunkSize = null;
    private $currentChunkCount = 0;

    public function __construct(ObjectManager $objectManager, $chunkSize = null)
    {
        $this->objectManager = $objectManager;
        $this->chunkSize = $chunkSize;
    }

    public function add($entity)
    {
        $this->objectManager->persist($entity);
        ++$this->currentChunkCount;

        if ($this->chunkCompleted()) {
            $this->objectManager->flush();
            $this->currentChunkCount = 0;
        }
    }

    protected function chunkCompleted()
    {
        return $this->chunkSize && $this->currentChunkCount >= $this->chunkSize;
    }

    public function prepare(ImportProcessEvent $event)

The parameter $event is not used and could be removed.

    {
        $this->added = 0;

The property added does not exist. Did you maybe forget to declare it?

    }

    public function finish(ImportProcessEvent $event)

The parameter $event is not used and could be removed.

    {
        $this->objectManager->flush();
    }

    public function rollback()
    {
    }
}