League\Database\BulkSql\BulkInsert

Complexity

Total Complexity

12

Size/Duplication

Total Lines	84
Duplicated Lines	53.57 %

Coupling/Cohesion

Components	1
Dependencies	3

Importance

Changes

0

5 Methods

Rating	Name	Duplication	Size	Complexity
B	buildQuery()	30	30	3
A	bindValues()	15	15	3
A	addOnDuplicateUpdateStatement()	0	10	3
A	resetOnDuplicateUpdateStatement()	0	6	1
A	getOnDuplicateUpdateRow()	0	10	2

<?php

namespace League\Database\BulkSql;

use PDOStatement;
use League\Database\Traits\BulkSqlTrait;
use League\Database\Exceptions\LogicException;

class BulkInsert extends Base
{
    use BulkSqlTrait;

    private $onDuplicateUpdate = [];

    const QUERY_TEMPLATE = 'INSERT %s INTO %s (%s) VALUES %s %s';

    protected function buildQuery() : string

This method seems to be duplicated in your project.

    {
        $this->resetFields();
        $this->resetPreparedItems();

        $queryParams = $this->iterateOverItems($this->getPreparedItems(), function ($iteration) {
            $prepared = array_map(function ($field, $key) use ($iteration) {
                if (in_array($field, $this->getIgnoredColumn(), true)) {
                    return $this->getPreparedItems()[$iteration][$field] ?? $this->getPreparedItems()[$iteration][$key];
                }

                return ':'.$field.'_'.$iteration;
            }, $this->getFields(), array_keys($this->getFields()));

            return '('.implode(',', $prepared).')';
        });

        $fields = array_map(function ($field) {
            return "`{$field}`";
        }, $this->getFields());

        return sprintf(
            self::QUERY_TEMPLATE,
            ($this->isIgnoreUsed() ? 'IGNORE' : ''),
            $this->getTable(),
            implode(',', $fields),
            implode(',', $queryParams),
            $this->getOnDuplicateUpdateRow()
        );
    }

    protected function bindValues(PDOStatement $statement)

This method seems to be duplicated in your project.

    {
        $this->resetFields();
        $this->resetPreparedItems();

        $this->iterateOverItems($this->getPreparedItems(), function ($iteration) use ($statement) {
            foreach ($this->getFields() as $key => $field) {
                if (in_array($field, $this->getIgnoredColumn(), true)) {
                    return;
                }
                $value = $this->getPreparedItems()[$iteration][$field] ?? $this->getPreparedItems()[$iteration][$key];
                $statement->bindValue(':'.$field.'_'.$iteration, $value);
            }
        });
    }

    public function addOnDuplicateUpdateStatement(array $array)
    {
        if (!array_is_assoc($array)) {
            throw new LogicException('ON DUPLICATE UPDATE setter should take associative array');
        } elseif (array_depth($array) !== 1) {
            throw new LogicException('ON DUPLICATE UPDATE setter should take one depth array');
        }

        $this->onDuplicateUpdate += $array;
    }

    public function resetOnDuplicateUpdateStatement() : self
    {
        $this->onDuplicateUpdate = [];

        return $this;
    }

    private function getOnDuplicateUpdateRow() : string
    {
        if (!$this->onDuplicateUpdate) {

The expression $this->onDuplicateUpdate 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.

            return '';
        }

        return ' ON DUPLICATE KEY UPDATE ' . implode(', ', array_map(function ($key, $value) {
            return "$key = $value";
        }, array_keys($this->onDuplicateUpdate), $this->onDuplicateUpdate));
    }
}