CompilesDataManipulations::compileInsertOrIgnoreUsing() - Code Metrics - Inspection of "Merge pull request #183 from LaravelFreelancerNL/1..." - LaravelFreelancerNL/laravel-arangodb - Measure and Improve Code Quality continuously with Scrutinizer

Passed
Push — next ( e392f1...a0f087 )

by Bas
created 2024-12-28 23:30 UTC
compileInsertOrIgnoreUsing() A

↳ Parent: CompilesDataManipulations
Complexity

Conditions	5
Paths	4
Size

Total Lines	25
Code Lines	15
Duplication

Lines	0
Ratio	0 %
Code Coverage

Tests	15
CRAP Score	5.0061
Importance

Changes
Metric	Value
cc	5
eloc	15
nc	4
nop	3
dl	0
loc	25
ccs	15
cts	16
cp	0.9375
crap	5.0061
rs	9.4555
c	0
b	0
f	0
<?php

namespace LaravelFreelancerNL\Aranguent\Query\Concerns;

use Illuminate\Database\Query\Builder as IlluminateQueryBuilder;
use Illuminate\Support\Arr;
use LaravelFreelancerNL\Aranguent\Query\Builder;

trait CompilesDataManipulations
{
    /**
     * Compile an insert statement into AQL.
     *
     * @param Builder|IlluminateQueryBuilder $query
     * @param array<mixed> $values
     * @param string|null $bindVar
     * @return string
     */
    public function compileInsert(Builder|IlluminateQueryBuilder $query, array $values, ?string $bindVar = null)
    {
        $table = $this->prefixTable($query->from);
        $table = $this->prefixTable($query->from);

        if (empty($values)) {
            $aql = /** @lang AQL */ 'INSERT {} INTO ' . $table . ' RETURN NEW._key';

            return $aql;
        }

        return /** @lang AQL */ 'LET values = ' . $bindVar
            . ' FOR value IN values'
            . ' INSERT value INTO ' . $table
            . ' RETURN NEW._key';
    }

    /**
     * Compile an insert and get ID statement into SQL.
     *
     * @param IlluminateQueryBuilder $query
     * @param array<mixed> $values
     * @param null|string $sequence
     * @param string|null $bindVar
     * @return string
     */
    public function compileInsertGetId(IlluminateQueryBuilder $query, $values, $sequence = '_key', ?string $bindVar = null)
    {
        $table = $this->prefixTable($query->from);

        $sequence = $this->convertIdToKey($sequence);
        $sequence = $this->convertIdToKey($sequence);

        if (empty($values)) {
            $aql = /** @lang AQL */ 'INSERT {} INTO ' . $table . ' RETURN NEW.' . $sequence;

            return $aql;
        }

        $aql = /** @lang AQL */ 'LET values = ' . $bindVar
            . ' FOR value IN values'
            . ' INSERT value INTO ' . $table
            . ' RETURN NEW.' . $sequence;

        return $aql;
    }

    /**
     * Compile an insert statement into AQL.
     *
     * @param IlluminateQueryBuilder $query
     * @param array<mixed> $values
     * @return string
     */
    public function compileInsertOrIgnore(IlluminateQueryBuilder $query, array $values, ?string $bindVar = null)
    {
        $table = $this->prefixTable($query->from);

        if (empty($values)) {
            $aql = /** @lang AQL */ "INSERT {} INTO $table RETURN NEW._key";

            return $aql;
        }

        $aql = /** @lang AQL */ "LET values = $bindVar "
            . "FOR value IN values "
            . "INSERT value INTO $table "
            . "OPTIONS { ignoreErrors: true } "
            . "RETURN NEW._key";

        return $aql;
    }

    /**
     * Compile an insert statement using a subquery into SQL.
     *
     * @param  IlluminateQueryBuilder  $query
     * @param  array<mixed>  $columns
     * @param  string  $sql
     * @return string
     */
    public function compileInsertUsing(IlluminateQueryBuilder $query, array $columns, string $sql)
    {
        $table = $this->wrapTable($query->from);
        $table = $this->wrapTable($query->from);

        $insertDoc = '';
        if (empty($columns) || $columns === ['*']) {
            $insertDoc = 'docDoc';
        }


        if ($insertDoc === '') {
            $insertValues = [];
            foreach ($columns as $column) {
                $insertValues[$column] = $this->normalizeColumnReferences($query, $column, 'docs');
                $insertValues[$column] = $this->normalizeColumnReferences($query, $column, 'docs');
            }
            $insertDoc = $this->generateAqlObject($insertValues);
            $insertDoc = $this->generateAqlObject($insertValues);
        }

        $aql = /** @lang AQL */ 'LET docs = ' . $sql
            . ' FOR docDoc IN docs'
            . ' INSERT ' . $insertDoc . ' INTO ' . $table
            . ' RETURN NEW._key';


        return $aql;
    }

    /**
     * Compile an insert statement using a subquery into SQL.
     *
     * @param  IlluminateQueryBuilder  $query
     * @param  array<mixed>  $columns
     * @param  string  $sql
     * @return string
     */
    public function compileInsertOrIgnoreUsing(IlluminateQueryBuilder $query, array $columns, string $sql)
    {
        $table = $this->wrapTable($query->from);

        $insertDoc = '';
        if (empty($columns) || $columns === ['*']) {
            $insertDoc = 'docDoc';
        }


        if ($insertDoc === '') {
            $insertValues = [];
            foreach ($columns as $column) {
                $insertValues[$column] = $this->normalizeColumnReferences($query, $column, 'docs');
            }
            $insertDoc = $this->generateAqlObject($insertValues);
        }

        $aql = /** @lang AQL */ 'LET docs = ' . $sql
            . ' FOR docDoc IN docs'
            . ' INSERT ' . $insertDoc . ' INTO ' . $table
            . ' OPTIONS { ignoreErrors: true }'
            . ' RETURN NEW._key';

        return $aql;
    }

    /**
     * @param array<mixed> $values
     * @return string
     */
    protected function createUpdateObject($values)
    {
        $valueStrings = [];
        foreach ($values as $key => $value) {
            if (is_array($value)) {
                $valueStrings[] = $key . ': ' . $this->createUpdateObject($value);

                continue;
            }

            $valueStrings[] = $key . ': ' . $value;
        }

        return '{ ' . implode(', ', $valueStrings) . ' }';
    }

    /**
     * Compile an update statement into AQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  array<mixed>  $values
     * @return string
     */
    public function compileUpdate(IlluminateQueryBuilder $query, array|string $values)
    {
        assert($query instanceof Builder);

        $table = $this->getValue($query->from);
        $table = $this->getValue($query->from);
        $alias = $query->getTableAlias($query->from);

        if (!is_array($values)) {

            $values = Arr::wrap($values);
        }

        $updateValues = $this->generateAqlObject($values);

        $aqlElements = [];
        $aqlElements[] = $this->compileFrom($query, $query->from);
        $aqlElements[] = $this->compileFrom($query, $query->from);

        if (!empty($query->joins)) {
            $aqlElements[] = $this->compileJoins($query, $query->joins);
            $aqlElements[] = $this->compileJoins($query, $query->joins);
        }

        $aqlElements[] = $this->compileWheres($query);
        $aqlElements[] = $this->compileWheres($query);

        $aqlElements[] = 'UPDATE ' . $alias . ' WITH ' . $updateValues . ' IN ' . $table;

        return implode(' ', $aqlElements);
    }

    /**
     * Compile an "upsert" statement into AQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  array<mixed>  $values
     * @param  array<mixed>  $uniqueBy
     * @param  array<mixed>  $update
     * @return string
     */
    public function compileUpsert(IlluminateQueryBuilder $query, array $values, array $uniqueBy, array $update)
    {
        $searchFields = [];
        foreach ($uniqueBy as $field) {
            $searchFields[$field] = 'doc.' . $field;
        }
        $searchObject = $this->generateAqlObject($searchFields);

        $updateFields = [];
        foreach ($update as $field) {
            $updateFields[$field] = 'doc.' . $field;
        }
        $updateObject = $this->generateAqlObject($updateFields);

        $valueObjects = [];
        foreach ($values as $data) {
            $valueObjects[] = $this->generateAqlObject($data);
        }

        return 'LET docs = [' . implode(', ', $valueObjects) . ']'
            . ' FOR doc IN docs'
            . ' UPSERT ' . $searchObject
            . ' INSERT doc'
            . ' UPDATE ' . $updateObject
            . ' IN ' . $this->getValue($query->from);
    }

    /**
     * Compile a delete statement into SQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @return string
     */
    public function compileDelete(IlluminateQueryBuilder $query)
    {
        $table = (string) $this->getValue($query->from);

        $where = $this->compileWheres($query);

        return trim(
            !empty($query->joins)
                ? $this->compileDeleteWithJoins($query, $table, $where)
                ? $this->/** @scrutinizer ignore-call */ compileDeleteWithJoins($query, $table, $where)
                : $this->compileDeleteWithoutJoins($query, $table, $where),
        );
    }

    /**
     * Compile a delete statement without joins into SQL.
     *
     * @param  \Illuminate\Database\Query\Builder  $query
     * @param  string  $table
     * @param  string  $where
     * @return string
     */
    protected function compileDeleteWithoutJoins(IlluminateQueryBuilder $query, $table, $where)
    {
        assert($query instanceof Builder);

        $alias = $this->normalizeColumn($query, $query->registerTableAlias($table));
        $alias = $this->normalizeColumn($query, $query->registerTableAlias($table));

        $table = $this->wrapTable($this->prefixTable($table));

        return "FOR {$alias} IN {$table} {$where} REMOVE {$alias} IN {$table}";
    }

    /**
     * Compile a truncate table statement into SQL.
     *
     * @param  IlluminateQueryBuilder  $query
     * @return array<mixed>
     */
    public function compileTruncate(IlluminateQueryBuilder $query)
    {
        return [$this->compileDelete($query) => []];
    }

}

LaravelFreelancerNL / laravel-arangodb

Push — next ( e392f1...a0f087 )

compileInsertOrIgnoreUsing() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like
