Yiisoft\Db\Query\DMLQueryBuilder

Complexity

Total Complexity

24

Size/Duplication

Total Lines	104
Duplicated Lines	0 %

Importance

Changes

0

8 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	2	1
A	update()	0	11	2
A	resetSequence()	0	3	1
A	insert()	0	8	3
A	selectExists()	0	3	1
C	batchInsert()	0	48	13
A	delete()	0	6	2
A	upsert()	0	7	1

<?php

declare(strict_types=1);

namespace Yiisoft\Db\Query;

use Generator;
use Yiisoft\Db\Exception\NotSupportedException;
use Yiisoft\Db\Expression\ExpressionInterface;
use Yiisoft\Strings\NumericHelper;

abstract class DMLQueryBuilder
{
    public function __construct(private QueryBuilderInterface $queryBuilder)

The type Yiisoft\Db\Query\QueryBuilderInterface was not found. Maybe you did not declare it correctly or list all dependencies?

    {
    }

    public function batchInsert(string $table, array $columns, iterable|Generator $rows, array &$params = []): string
    {
        if (empty($rows)) {
            return '';
        }

        if (($tableSchema = $this->queryBuilder->schema()->getTableSchema($table)) !== null) {
            $columnSchemas = $tableSchema->getColumns();
        } else {
            $columnSchemas = [];
        }

        $values = [];

        foreach ($rows as $row) {
            $vs = [];
            foreach ($row as $i => $value) {
                if (isset($columns[$i], $columnSchemas[$columns[$i]])) {
                    $value = $columnSchemas[$columns[$i]]->dbTypecast($value);
                }
                if (is_string($value)) {
                    $value = $this->queryBuilder->quoter()->quoteValue($value);
                } elseif (is_float($value)) {
                    /* ensure type cast always has . as decimal separator in all locales */
                    $value = NumericHelper::normalize((string) $value);
                } elseif ($value === false) {
                    $value = 0;
                } elseif ($value === null) {
                    $value = 'NULL';
                } elseif ($value instanceof ExpressionInterface) {
                    $value = $this->queryBuilder->buildExpression($value, $params);
                }
                $vs[] = $value;
            }
            $values[] = '(' . implode(', ', $vs) . ')';
        }

        if (empty($values)) {
            return '';
        }

        foreach ($columns as $i => $name) {
            $columns[$i] = $this->queryBuilder->quoter()->quoteColumnName($name);
        }

        return 'INSERT INTO '
            . $this->queryBuilder->quoter()->quoteTableName($table)
            . ' (' . implode(', ', $columns) . ') VALUES ' . implode(', ', $values);
    }

    public function delete(string $table, array|string $condition, array &$params): string
    {
        $sql = 'DELETE FROM ' . $this->queryBuilder->quoter()->quoteTableName($table);
        $where = $this->queryBuilder->buildWhere($condition, $params);

        return $where === '' ? $sql : $sql . ' ' . $where;
    }

    public function insert(string $table, Query|array $columns, array &$params = []): string
    {
        [$names, $placeholders, $values, $params] = $this->queryBuilder->prepareInsertValues($table, $columns, $params);

        return 'INSERT INTO '
            . $this->queryBuilder->quoter()->quoteTableName($table)
            . (!empty($names) ? ' (' . implode(', ', $names) . ')' : '')
            . (!empty($placeholders) ? ' VALUES (' . implode(', ', $placeholders) . ')' : $values);
    }

    public function resetSequence(string $tableName, array|int|string|null $value = null): string

The parameter $value is not used and could be removed.

The parameter $tableName is not used and could be removed.

    {
        throw new NotSupportedException(static::class . ' does not support resetting sequence.');
    }

    public function selectExists(string $rawSql): string
    {
        return 'SELECT EXISTS(' . $rawSql . ')';
    }

    public function update(string $table, array $columns, array|string $condition, array &$params = []): string
    {
        /**
         * @var array $lines
         * @var array $params
         */
        [$lines, $params] = $this->queryBuilder->prepareUpdateSets($table, $columns, $params);
        $sql = 'UPDATE ' . $this->queryBuilder->quoter()->quoteTableName($table) . ' SET ' . implode(', ', $lines);
        $where = $this->queryBuilder->buildWhere($condition, $params);

        return $where === '' ? $sql : $sql . ' ' . $where;
    }

    public function upsert(
        string $table,

The parameter $table is not used and could be removed.

        Query|array $insertColumns,

The parameter $insertColumns is not used and could be removed.

        bool|array $updateColumns,

The parameter $updateColumns is not used and could be removed.

        array &$params

The parameter $params is not used and could be removed.

    ): string {
        throw new NotSupportedException(static::class . ' does not support upsert.');
    }
}