DoctrinePersister::persist() - Code Metrics - Inspection of "Je veux pouvoir faire du profilling sur mon traite..." - jean-pasqualini/import - Measure and Improve Code Quality continuously with Scrutinizer

Failed Conditions

Pull Request — 0.3 (#20)

by jean

created 2018-06-24 13:13 UTC

DoctrinePersister::persist() A

↳ Parent: DoctrinePersister

Complexity

Conditions	2
Paths	2

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	9
CRAP Score	2

Importance

Changes

Metric	Value
cc	2
nc	2
nop	4
dl	0
loc	14
ccs	9
cts	9
cp	1
crap	2
rs	9.7998
c	0
b	0
f	0

<?php
/**
 * Created by PhpStorm.
 * User: darkilliant
 * Date: 5/8/18
 * Time: 7:56 AM.
 */

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();
            return true;
        }

        return false;
    }

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

jean-pasqualini / import

Pull Request — 0.3 (#20)

DoctrinePersister::persist() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like