mindplay\sql\model\query\UpdateQuery

Complexity

Total Complexity

12

Size/Duplication

Total Lines	137
Duplicated Lines	13.14 %

Coupling/Cohesion

Components	1
Dependencies	5

Test Coverage

Coverage

90.48%

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	7	1
A	setValue()	9	20	2
A	setExpr()	9	18	2
A	assign()	0	14	3
A	getSQL()	0	12	2
A	getPlaceholder()	0	12	2

<?php

namespace mindplay\sql\model\query;

use mindplay\sql\model\components\Conditions;
use mindplay\sql\model\Driver;
use mindplay\sql\model\schema\Column;
use mindplay\sql\model\schema\Table;
use mindplay\sql\model\TypeProvider;

/**
 * This class represents an UPDATE query.
 */
class UpdateQuery extends Query
{
    use Conditions;

    /**
     * @var Table
     */
    protected $table;

    /**
     * @var Driver
     */
    protected $driver;

    /**
     * @var mixed[] map where Column name => literal SQL expression to assign
     */
    private $assignments = [];

    /**
     * @param Table        $table
     * @param TypeProvider $types
     */
    public function __construct(Table $table, Driver $driver, TypeProvider $types)
    {
        parent::__construct($types);

        $this->table = $table;
        $this->driver = $driver;
    }

    /**
     * @param Column|string $column Column to update (or Column name)
     * @param mixed         $value  value to apply
     *
     * @return $this
     */
    public function setValue($column, $value)
    {
        // TODO qualify table-references to support UPDATE queries with JOINs

        if ($column instanceof Column) {

This code seems to be duplicated across your project.

            $name = $this->getPlaceholder($column);

            $quoted_name = $this->driver->quoteName($column->getName());
        } else {
            $name = $column;

            $quoted_name = $this->driver->quoteName($name);
        }

        $this->assignments[$name] = "{$quoted_name} = :{$name}";

        $this->bind($name, $value, $column->getType());

It seems like $column is not always an object, but can also be of type string. Maybe add an additional type check?

        return $this;
    }

    /**
     * @param Column|string $column Column to update (or Column name)
     * @param string        $expr   literal SQL expression
     *
     * @return $this
     */
    public function setExpr($column, $expr)
    {
        // TODO qualify table-references to support UPDATE queries with JOINs

        if ($column instanceof Column) {

This code seems to be duplicated across your project.

            $name = $this->getPlaceholder($column);

            $quoted_name = $this->driver->quoteName($column->getName());
        } else {
            $name = $column;

            $quoted_name = $this->driver->quoteName($name);
        }

        $this->assignments[$name] = "{$quoted_name} = {$expr}";

        return $this;
    }

    /**
     * @param array $values map where Column name => scalar values to assign
     *
     * @return $this
     */
    public function assign(array $values)
    {
        $columns = $this->table->listColumns();

        foreach ($columns as $column) {
            $name = $column->getName();

            if (array_key_exists($name, $values)) {
                $this->setValue($column, $values[$name]);
            }
        }

        return $this;
    }

    /**
     * @inheritdoc
     */
    public function getSQL()
    {
        $update = "UPDATE " . $this->table->getNode();

        $set = "\nSET " . implode(",\n    ", $this->assignments);

        $where = count($this->conditions)
            ? "\nWHERE " . $this->buildConditions()
            : ''; // no conditions present

        return "{$update}{$set}{$where}";
    }

    /**
     * @param Column $column
     *
     * @return string
     */
    private function getPlaceholder(Column $column)
    {
        $table = $column->getTable();

        $table_name = $table->getAlias() ?: $table->getName();

        $column_name = $column->getName();

        $name = "{$table_name}_{$column_name}";

        return $name;
    }
}