AttachEntities::maybeUpdatePivotRow() - Code Metrics - siriusphp/orm - Measure and Improve Code Quality continuously with Scrutinizer

AttachEntities::maybeUpdatePivotRow() B
last analyzed 2020-12-13 08:50 UTC

↳ Parent: AttachEntities

Complexity

Conditions	9
Paths	73

Size

Total Lines	52
Code Lines	35

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
eloc	35
c	0
b	0
f	0
dl	0
loc	52
rs	8.0555
cc	9
nc	73
nop	0

How to fix Long Method

<?php
declare(strict_types=1);

namespace Sirius\Orm\Action;

use Sirius\Orm\Entity\EntityInterface;
use Sirius\Orm\Mapper;
use Sirius\Orm\Relation\ManyToMany;
use Sirius\Orm\Relation\Relation;
use Sirius\Orm\Relation\RelationConfig;

class AttachEntities implements ActionInterface
{
    /**
     * @var EntityInterface
     */
    protected $nativeEntity;
    /**
     * @var EntityInterface
     */
    protected $foreignEntity;
    /**
     * @var Relation
     */
    protected $relation;
    /**
     * @var string
     */
    protected $actionType;
    /**
     * @var Mapper
     */
    protected $nativeMapper;
    /**
     * @var Mapper
     */
    protected $foreignMapper;

    public function __construct(
        Mapper $nativeMapper,
        EntityInterface $nativeEntity,
        Mapper $foreignMapper,
        EntityInterface $foreignEntity,
        Relation $relation,
        string $actionType
    ) {
        $this->nativeMapper  = $nativeMapper;
        $this->nativeEntity  = $nativeEntity;
        $this->foreignMapper = $foreignMapper;
        $this->foreignEntity = $foreignEntity;
        $this->relation      = $relation;
        $this->actionType    = $actionType;
    }

    public function revert()
    {
        /**
         * @todo restore previous values
         */
    }

    public function run()
    {
        /**
         * @todo store current attribute values
         */
        $this->relation->attachEntities($this->nativeEntity, $this->foreignEntity);
        $this->maybeUpdatePivotRow();
    }

    public function onSuccess()
    {
    }

    protected function maybeUpdatePivotRow()
    {
        if (!$this->relation instanceof ManyToMany) {
            return;
        }

        $conn = $this->relation->getNativeMapper()->getWriteConnection();
        $throughTable = (string)$this->relation->getOption(RelationConfig::THROUGH_TABLE);

        $throughNativeColumns = (array) $this->relation->getOption(RelationConfig::THROUGH_NATIVE_COLUMN);
        $throughForeignColumns = (array) $this->relation->getOption(RelationConfig::THROUGH_FOREIGN_COLUMN);
        $nativeKey = (array) $this->nativeMapper->getEntityPk($this->nativeEntity);
        $foreignKey = (array) $this->foreignMapper->getEntityPk($this->foreignEntity);

        $delete = new \Sirius\Sql\Delete($conn);
        $delete->from($throughTable);
        foreach ($throughNativeColumns as $k => $col) {
            $delete->where($col, $nativeKey[$k]);
            $delete->where($throughForeignColumns[$k], $foreignKey[$k]);
        }
        foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_GUARDS) as $col => $value) {
            if (!is_int($col)) {
                $delete->where($col, $value);
            } else {
                $delete->where($value);
            }
        }
        $delete->perform();

        $insertColumns = [];
        foreach ($throughNativeColumns as $k => $col) {
            $insertColumns[$col] = $nativeKey[$k];
            $insertColumns[$throughForeignColumns[$k]] = $foreignKey[$k];
        }

        $throughColumnPrefix = $this->relation->getOption(RelationConfig::THROUGH_COLUMNS_PREFIX);
        foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_COLUMNS) as $col) {
            $insertColumns[$col] = $this->relation
                ->getForeignMapper()
                ->getEntityAttribute($this->foreignEntity, "{$throughColumnPrefix}{$col}");
        }

        foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_GUARDS) as $col => $value) {
            if (!is_int($col)) {
                $insertColumns[$col] = $value;
            }
        }

        $insert = new \Sirius\Sql\Insert($conn);
        $insert->into($throughTable)
               ->columns($insertColumns)
               ->perform();
    }
}


1			<?php
2			declare(strict_types=1);
3
4			namespace Sirius\Orm\Action;
5
6			use Sirius\Orm\Entity\EntityInterface;
7			use Sirius\Orm\Mapper;
8			use Sirius\Orm\Relation\ManyToMany;
9			use Sirius\Orm\Relation\Relation;
10			use Sirius\Orm\Relation\RelationConfig;
11
12			class AttachEntities implements ActionInterface
13			{
14			/**
15			* @var EntityInterface
16			*/
17			protected $nativeEntity;
18			/**
19			* @var EntityInterface
20			*/
21			protected $foreignEntity;
22			/**
23			* @var Relation
24			*/
25			protected $relation;
26			/**
27			* @var string
28			*/
29			protected $actionType;
30			/**
31			* @var Mapper
32			*/
33			protected $nativeMapper;
34			/**
35			* @var Mapper
36			*/
37			protected $foreignMapper;
38
39			public function __construct(
40			Mapper $nativeMapper,
41			EntityInterface $nativeEntity,
42			Mapper $foreignMapper,
43			EntityInterface $foreignEntity,
44			Relation $relation,
45			string $actionType
46			) {
47			$this->nativeMapper = $nativeMapper;
48			$this->nativeEntity = $nativeEntity;
49			$this->foreignMapper = $foreignMapper;
50			$this->foreignEntity = $foreignEntity;
51			$this->relation = $relation;
52			$this->actionType = $actionType;
53			}
54
55			public function revert()
56			{
57			/**
58			* @todo restore previous values
59			*/
60			}
61
62			public function run()
63			{
64			/**
65			* @todo store current attribute values
66			*/
67			$this->relation->attachEntities($this->nativeEntity, $this->foreignEntity);
68			$this->maybeUpdatePivotRow();
69			}
70
71			public function onSuccess()
72			{
73			}
74
75			protected function maybeUpdatePivotRow()
76			{
77			if (!$this->relation instanceof ManyToMany) {
78			return;
79			}
80
81			$conn = $this->relation->getNativeMapper()->getWriteConnection();
82			$throughTable = (string)$this->relation->getOption(RelationConfig::THROUGH_TABLE);
83
84			$throughNativeColumns = (array) $this->relation->getOption(RelationConfig::THROUGH_NATIVE_COLUMN);
85			$throughForeignColumns = (array) $this->relation->getOption(RelationConfig::THROUGH_FOREIGN_COLUMN);
86			$nativeKey = (array) $this->nativeMapper->getEntityPk($this->nativeEntity);
87			$foreignKey = (array) $this->foreignMapper->getEntityPk($this->foreignEntity);
88
89			$delete = new \Sirius\Sql\Delete($conn);
90			$delete->from($throughTable);
91			foreach ($throughNativeColumns as $k => $col) {
92			$delete->where($col, $nativeKey[$k]);
93			$delete->where($throughForeignColumns[$k], $foreignKey[$k]);
94			}
95			foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_GUARDS) as $col => $value) {
96			if (!is_int($col)) {
97			$delete->where($col, $value);
98			} else {
99			$delete->where($value);
100			}
101			}
102			$delete->perform();
103
104			$insertColumns = [];
105			foreach ($throughNativeColumns as $k => $col) {
106			$insertColumns[$col] = $nativeKey[$k];
107			$insertColumns[$throughForeignColumns[$k]] = $foreignKey[$k];
108			}
109
110			$throughColumnPrefix = $this->relation->getOption(RelationConfig::THROUGH_COLUMNS_PREFIX);
111			foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_COLUMNS) as $col) {
112			$insertColumns[$col] = $this->relation
113			->getForeignMapper()
114			->getEntityAttribute($this->foreignEntity, "{$throughColumnPrefix}{$col}");
115			}
116
117			foreach ((array)$this->relation->getOption(RelationConfig::THROUGH_GUARDS) as $col => $value) {
118			if (!is_int($col)) {
119			$insertColumns[$col] = $value;
120			}
121			}
122
123			$insert = new \Sirius\Sql\Insert($conn);
124			$insert->into($throughTable)
125			->columns($insertColumns)
126			->perform();
127			}
128			}
129

siriusphp / orm

AttachEntities::maybeUpdatePivotRow() B last analyzed 2020-12-13 08:50 UTC

Complexity

Size

Duplication

Importance

How to fix Long Method

Long Method

Duplication Side-by-Side

Filter issues like

AttachEntities::maybeUpdatePivotRow() B
last analyzed 2020-12-13 08:50 UTC