DoctrinePersister::persist() - Code Metrics - jean-pasqualini/import - Measure and Improve Code Quality continuously with Scrutinizer

DoctrinePersister::persist() A
last analyzed 2018-09-29 11:52 UTC

↳ Parent: DoctrinePersister

Complexity

Conditions	2
Paths	2

Size

Total Lines	10
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	7
CRAP Score	2

Importance

Changes

Metric	Value
cc	2
eloc	6
nc	2
nop	4
dl	0
loc	10
ccs	7
cts	7
cp	1
crap	2
rs	10
c	0
b	0
f	0

<?php

declare(strict_types=1);

namespace Darkilliant\ImportBundle\Persister;

use Doctrine\ORM\EntityManagerInterface;

/**
 * @internal
 */
class DoctrinePersister implements PersisterInterface
{
    private $em;
    private $batch = 0;

    private $whiteList = [];
    private $blackList = [];

    public function __construct(EntityManagerInterface $em)
    {
        $this->em = $em;
    }

    public function persist($entity, $batchCount = 20, $whiteList = [], $blackList = [])
    {
        ++$this->batch;
        $this->whiteList = $whiteList;
        $this->blackList = $blackList;

        $this->em->persist($entity);

        if ($this->batch >= $batchCount) {
            $this->writeBatch();
        }
    }

    public function finalize()
    {
        $this->writeBatch();
    }

    private function writeBatch()
    {
        $this->em->flush();
        $this->clear();

        $this->batch = 0;
    }

    private function clear()
    {
        if (empty($this->whiteList) && empty($this->blackList)) {
            $this->em->clear();
        } elseif (!empty($this->whiteList)) {
            foreach ($this->whiteList as $class) {
                $this->em->clear($class);
            }
        } elseif (!empty($this->blackList)) {
            throw new \Exception('unsupported blacklist');
        }

        gc_collect_cycles();
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Darkilliant\ImportBundle\Persister;
6
7		use Doctrine\ORM\EntityManagerInterface;
8
9		/**
10		* @internal
11		*/
12		class DoctrinePersister implements PersisterInterface
13		{
14		private $em;
15		private $batch = 0;
16
17		private $whiteList = [];
18		private $blackList = [];
19
20	5	public function __construct(EntityManagerInterface $em)
21		{
22	5	$this->em = $em;
23	5	}
24
25	5	public function persist($entity, $batchCount = 20, $whiteList = [], $blackList = [])
26		{
27	5	++$this->batch;
28	5	$this->whiteList = $whiteList;
29	5	$this->blackList = $blackList;
30
31	5	$this->em->persist($entity);
32
33	5	if ($this->batch >= $batchCount) {
34	1	$this->writeBatch();
35		}
36	5	}
37
38	3	public function finalize()
39		{
40	3	$this->writeBatch();
41	2	}
42
43	4	private function writeBatch()
44		{
45	4	$this->em->flush();
46	4	$this->clear();
47
48	3	$this->batch = 0;
49	3	}
50
51	4	private function clear()
52		{
53	4	if (empty($this->whiteList) && empty($this->blackList)) {
54	2	$this->em->clear();
55	2	} elseif (!empty($this->whiteList)) {
56	1	foreach ($this->whiteList as $class) {
57	1	$this->em->clear($class);
58		}
59	1	} elseif (!empty($this->blackList)) {
60	1	throw new \Exception('unsupported blacklist');
61		}
62
63	3	gc_collect_cycles();
64	3	}
65		}
66

jean-pasqualini / import

DoctrinePersister::persist() A last analyzed 2018-09-29 11:52 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

DoctrinePersister::persist() A
last analyzed 2018-09-29 11:52 UTC