Doctrine\ORM\Query\Exec\MultiTableUpdateExecutor

Complexity

Total Complexity

15

Size/Duplication

Total Lines	181
Duplicated Lines	3.31 %

Coupling/Cohesion

Components	1
Dependencies	10

Test Coverage

Coverage

98.59%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
D	__construct()	6	97	9
B	execute()	0	43	6

<?php

declare(strict_types=1);

namespace Doctrine\ORM\Query\Exec;

use Doctrine\DBAL\Connection;
use Doctrine\ORM\Mapping\ColumnMetadata;
use Doctrine\ORM\Query\AST;
use Doctrine\ORM\Query\ParameterTypeInferer;
use Doctrine\ORM\Utility\PersisterHelper;

/**
 * Executes the SQL statements for bulk DQL UPDATE statements on classes in
 * Class Table Inheritance (JOINED).
 *
 * @author Roman Borschel <roman@code-factory.org>
 * @since 2.0
 */
class MultiTableUpdateExecutor extends AbstractSqlExecutor
{
    /**
     * @var string
     */
    private $createTempTableSql;

    /**
     * @var string
     */
    private $dropTempTableSql;

    /**
     * @var string
     */
    private $insertSql;

    /**
     * @var array
     */
    private $sqlParameters = [];

    /**
     * @var int
     */
    private $numParametersInUpdateClause = 0;

    /**
     * Initializes a new <tt>MultiTableUpdateExecutor</tt>.
     *
     * Internal note: Any SQL construction and preparation takes place in the constructor for
     *                best performance. With a query cache the executor will be cached.
     *
     * @param \Doctrine\ORM\Query\AST\Node  $AST The root AST node of the DQL query.
     * @param \Doctrine\ORM\Query\SqlWalker $sqlWalker The walker used for SQL generation from the AST.
     */
    public function __construct(AST\Node $AST, $sqlWalker)
    {
        $em             = $sqlWalker->getEntityManager();
        $conn           = $em->getConnection();
        $platform       = $conn->getDatabasePlatform();

        $updateClause   = $AST->updateClause;

The property updateClause does not seem to exist in Doctrine\ORM\Query\AST\Node.

        $primaryClass   = $sqlWalker->getEntityManager()->getClassMetadata($updateClause->abstractSchemaName);
        $rootClass      = $em->getClassMetadata($primaryClass->getRootClassName());

The method getRootClassName() does not seem to exist on object<Doctrine\Common\Persistence\Mapping\ClassMetadata>.

        $updateItems    = $updateClause->updateItems;

        $tempTable         = $platform->getTemporaryTableName($rootClass->getTemporaryIdTableName());

The method getTemporaryIdTableName() does not seem to exist on object<Doctrine\Common\Persistence\Mapping\ClassMetadata>.

        $idColumns         = $rootClass->getIdentifierColumns($em);

The method getIdentifierColumns() does not exist on Doctrine\Common\Persistence\Mapping\ClassMetadata. Did you maybe mean getIdentifier()?

        $idColumnNameList  = implode(', ', array_keys($idColumns));

        // 1. Create an INSERT INTO temptable ... SELECT identifiers WHERE $AST->getWhereClause()
        $sqlWalker->setSQLTableAlias($primaryClass->getTableName(), 'i0', $updateClause->aliasIdentificationVariable);

The method getTableName() does not seem to exist on object<Doctrine\Common\Persistence\Mapping\ClassMetadata>.

        $this->insertSql = 'INSERT INTO ' . $tempTable . ' (' . $idColumnNameList . ')'
                . ' SELECT i0.' . implode(', i0.', array_keys($idColumns));

        $rangeDecl = new AST\RangeVariableDeclaration($primaryClass->getClassName(), $updateClause->aliasIdentificationVariable);

The method getClassName() does not seem to exist on object<Doctrine\Common\Persistence\Mapping\ClassMetadata>.

        $fromClause = new AST\FromClause([new AST\IdentificationVariableDeclaration($rangeDecl, null, [])]);

        $this->insertSql .= $sqlWalker->walkFromClause($fromClause);

        // 2. Create statement used in UPDATE ... WHERE ... IN (subselect)
        $updateSQLTemplate = sprintf(
            'UPDATE %%s SET %%s WHERE (%s) IN (SELECT %s FROM %s)',
            $idColumnNameList,
            $idColumnNameList,
            $tempTable
        );

        // 3. Create and store UPDATE statements
        $hierarchyClasses = array_merge(
            array_map(
                function ($className) use ($em) { return $em->getClassMetadata($className); },
                array_reverse($primaryClass->getSubClasses())

The method getSubClasses() does not seem to exist on object<Doctrine\Common\Persistence\Mapping\ClassMetadata>.

            ),
            [$primaryClass],
            $primaryClass->getAncestorsIterator()->getArrayCopy()

The method getAncestorsIterator() does not seem to exist on object<Doctrine\Common\Persistence\Mapping\ClassMetadata>.

        );

        $i = 0;

        foreach ($hierarchyClasses as $class) {
            $updateSQLParts = [];

            foreach ($updateItems as $updateItem) {
                $field    = $updateItem->pathExpression->field;
                $property = $class->getProperty($field);

                if ($property && ! $class->isInheritedProperty($field)) {
                    $updateSQLParts[] = $sqlWalker->walkUpdateItem($updateItem);
                    $newValue         = $updateItem->newValue;

                    if ($newValue instanceof AST\InputParameter) {
                        $this->sqlParameters[$i][] = $newValue->name;

                        ++$this->numParametersInUpdateClause;
                    }
                }
            }

            if ($updateSQLParts) {

The expression $updateSQLParts of type array is implicitly converted to a boolean; are you sure this is intended? If so, consider using ! empty($expr) instead to make it clear that you intend to check for an array without elements.

                $this->sqlStatements[$i] = sprintf(
                    $updateSQLTemplate,
                    $class->table->getQuotedQualifiedName($platform),
                    implode(', ', $updateSQLParts)
                );

                $i++;
            }
        }

        // Append WHERE clause to insertSql, if there is one.
        if ($AST->whereClause) {
            $this->insertSql .= $sqlWalker->walkWhereClause($AST->whereClause);

The property whereClause does not seem to exist in Doctrine\ORM\Query\AST\Node.

        }

        // 4. Store DDL for temporary identifier table.
        $columnDefinitions = [];

        foreach ($idColumns as $columnName => $column) {

This code seems to be duplicated across your project.

            $columnDefinitions[$columnName] = [
                'notnull' => true,
                'type'    => $column->getType(),
            ];
        }

        $this->createTempTableSql = $platform->getCreateTemporaryTableSnippetSQL() . ' ' . $tempTable . ' ('
                . $platform->getColumnDeclarationListSQL($columnDefinitions) . ')';

        $this->dropTempTableSql = $platform->getDropTemporaryTableSQL($tempTable);
    }

    /**
     * {@inheritDoc}
     */
    public function execute(Connection $conn, array $params, array $types)
    {
        // Create temporary id table
        $conn->executeUpdate($this->createTempTableSql);

        try {
            // Insert identifiers. Parameters from the update clause are cut off.
            $numUpdated = $conn->executeUpdate(
                $this->insertSql,
                array_slice($params, $this->numParametersInUpdateClause),
                array_slice($types, $this->numParametersInUpdateClause)
            );

            // Execute UPDATE statements
            foreach ($this->sqlStatements as $key => $statement) {
                $paramValues = [];
                $paramTypes  = [];

                if (isset($this->sqlParameters[$key])) {
                    foreach ($this->sqlParameters[$key] as $parameterKey => $parameterName) {
                        $paramValues[] = $params[$parameterKey];
                        $paramTypes[]  = isset($types[$parameterKey])
                            ? $types[$parameterKey]
                            : ParameterTypeInferer::inferType($params[$parameterKey])
                        ;
                    }
                }

                $conn->executeUpdate($statement, $paramValues, $paramTypes);
            }
        } catch (\Exception $exception) {
            // FAILURE! Drop temporary table to avoid possible collisions
            $conn->executeUpdate($this->dropTempTableSql);

            // Re-throw exception
            throw $exception;
        }

        // Drop temporary table
        $conn->executeUpdate($this->dropTempTableSql);

        return $numUpdated;

The return type of return $numUpdated; (integer) is incompatible with the return type declared by the abstract method Doctrine\ORM\Query\Exec\AbstractSqlExecutor::execute of type Doctrine\DBAL\Driver\Statement.

    }
}