Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder::__invoke()

Complexity

Conditions	13
Paths	1

Size

Total Lines

133

Duplication

Lines	30
Ratio	22.56 %

Importance

Changes

0

<?php
    public function __invoke()
    {
        /*
         * Run an insert ignore statement against the database.
         *
         * @param  array $values
         * @return bool
         */
        Builder::macro('insertIgnore', function (array $values) {
            return $this->insertOnDuplicateKey($values, null, 'ignore');

The method insertOnDuplicateKey() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

        });

        /*
         * Run an insert on duplicate key update statement against the database.
         *
         * @param  array $values
         * @param  array $columnsToUpdate
         * @param  string $type
         * @return bool
         */
        Builder::macro('insertOnDuplicateKey', function (
            array $values,
            array $columnsToUpdate = null,
            $type = 'on duplicate key'
        ) {
            // Since every insert gets treated like a batch insert, we will make sure the
            // bindings are structured in a way that is convenient for building these
            // inserts statements by verifying the elements are actually an array.
            if (empty($values)) {
                return true;
            }

            if (!\is_array(reset($values))) {

This code seems to be duplicated across your project.

                $values = [$values];
            }

            // Here, we will sort the insert keys for every record so that each insert is
            // in the same order for the record. We need to make sure this is the case
            // so there are not any errors or problems when inserting these records.
            else {
                foreach ($values as $key => $value) {
                    ksort($value);
                    $values[$key] = $value;
                }
            }
            // Finally, we will run this query against the database connection and return
            // the results. We will need to also flatten these bindings before running
            // the query so they are all in one huge, flattened array for execution.
            $bindings = $this->cleanBindings(Arr::flatten($values, 1));

The method cleanBindings() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

$values is of type array, but the function expects a object<Illuminate\Support\iterable>.

            // Essentially we will force every insert to be treated as a batch insert which
            // simply makes creating the SQL easier for us since we can utilize the same
            // basic routine regardless of an amount of records given to us to insert.
            $table = $this->grammar->wrapTable($this->from);

The property grammar does not exist. Did you maybe forget to declare it?

The property from does not exist. Did you maybe forget to declare it?

            $columns = array_keys(reset($values));

            $columnsString = $this->grammar->columnize($columns);

            // We need to build a list of parameter place-holders of values that are bound
            // to the query. Each insert should have the exact same amount of parameter
            // bindings so we will loop through the record and parameterize them all.
            $parameters = collect($values)->map(function ($record) {
                return '('.$this->grammar->parameterize($record).')';
            })->implode(', ');

            $sql = 'insert '.($type === 'ignore' ? 'ignore ' : '')."into $table ($columnsString) values $parameters";

            if ($type === 'ignore') {
                return $this->connection->insert($sql, $bindings);

The property connection does not exist. Did you maybe forget to declare it?

            }

            $sql .= ' on duplicate key update ';

            // We will update all the columns specified in $values by default.
            if ($columnsToUpdate === null) {
                $columnsToUpdate = $columns;
            }

            foreach ($columnsToUpdate as $key => $value) {
                $column = is_int($key) ? $value : $key;
                $column = $this->grammar->wrap($column);
                $sql .= "$column = ";
                if (is_int($key)) {
                    $sql .= "VALUES($column)";
                } else {
                    if ($this->grammar->isExpression($value)) {
                        $sql .= $value->getValue();
                    } else {
                        $sql .= '?';
                        $bindings[] = $value;
                    }
                }
                $sql .= ',';
            }

            return $this->connection->insert(rtrim($sql, ','), $bindings);
        });

        /*
         * Attach models to the parent ignoring existing associations.
         *
         * @param  mixed $id
         * @param  array $attributes
         * @return void
         */
        BelongsToMany::macro('attachIgnore', function ($id, array $attributes = [], $touch = true) {

This code seems to be duplicated across your project.

            $this->newPivotStatement()->insertIgnore($this->formatAttachRecords(

The method newPivotStatement() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

The method formatAttachRecords() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

                $this->parseIds($id),

The method parseIds() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

                $attributes
            ));
            if ($touch) {
                $this->touchIfTouching();

The method touchIfTouching() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

            }
        });

        /*
         * Attach models to the parent updating existing associations.
         *
         * @param  mixed $id
         * @param  array $attributes
         * @return void
         */
        BelongsToMany::macro('attachOnDuplicateKey', function ($id, array $attributes = [], $touch = true) {

This code seems to be duplicated across your project.

            $this->newPivotStatement()->insertOnDuplicateKey($this->formatAttachRecords(

The method newPivotStatement() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

The method formatAttachRecords() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

                $this->parseIds($id),

The method parseIds() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

                $attributes
            ));

            if ($touch) {
                $this->touchIfTouching();

The method touchIfTouching() does not seem to exist on object<Napp\Core\Dbal\Builder\InsertOnDuplicateKeyBuilder>.

            }
        });
    }
}