Bdf\Prime\Query\Custom\BulkInsert\BulkInsertSqlCompiler

Complexity

Total Complexity

22

Size/Duplication

Total Lines	155
Duplicated Lines	0 %

Test Coverage

Coverage

86.67%

Importance

Changes	1
Bugs	0	Features	0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	doCompileSelect()	0	3	1
A	doCompileDelete()	0	3	1
A	doCompileUpdate()	0	3	1
A	doCompileInsert()	0	11	2
A	quoteIdentifier()	0	7	2
A	compileValues()	0	9	2
A	getBindings()	0	22	5
A	compileMode()	0	16	4
A	compileColumns()	0	25	4

<?php

namespace Bdf\Prime\Query\Custom\BulkInsert;

use Bdf\Prime\Query\CompilableClause;
use Bdf\Prime\Query\Compiler\AbstractCompiler;
use Bdf\Prime\Types\TypeInterface;

/**
 * Compiler for @see BulkInsertQuery
 *
 * The query will be compiled into a prepared statement

Doc comment long description must end with a full stop

 */
class BulkInsertSqlCompiler extends AbstractCompiler
{
    /**

Parameter $query should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */
    protected function doCompileInsert(CompilableClause $query)

Expected 1 blank line before function; 0 found

    {
        $sql = $this->compileMode($query).' INTO '.$this->quoteIdentifier($query, $query->statements['table']);

        if (!isset($query->state()->compiledParts['columns'])) {
            $this->compileColumns($query);
        }

        $sql .= $query->state()->compiledParts['columns']['sql'].$this->compileValues($query);

        return $this->connection->prepare($sql);

The method prepare() does not exist on Bdf\Prime\Connection\ConnectionInterface. Since it exists in all sub-types, consider adding an abstract or default implementation to Bdf\Prime\Connection\ConnectionInterface.

    }

    /**

Parameter $query should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */

Missing @throws tag in function comment

    protected function doCompileUpdate(CompilableClause $query)

The method parameter $query is never used

    {
        throw new \BadMethodCallException();
    }

    /**

Parameter $query should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */

Missing @throws tag in function comment

    protected function doCompileDelete(CompilableClause $query)

The method parameter $query is never used

    {
        throw new \BadMethodCallException();
    }

    /**

Parameter $query should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */

Missing @throws tag in function comment

    protected function doCompileSelect(CompilableClause $query)

The method parameter $query is never used

    {
        throw new \BadMethodCallException();
    }

    /**

Parameter $query should have a doc-comment as per coding-style.

Parameter $column should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */
    public function quoteIdentifier(CompilableClause $query, $column)
    {
        if (!$query->isQuoteIdentifier()) {
            return $column;
        }

        return $this->platform()->grammar()->quoteIdentifier($column);
    }

    /**

Parameter $query should have a doc-comment as per coding-style.

     * {@inheritdoc}
     */
    public function getBindings(CompilableClause $query)
    {
        if ($query->statements['bulk']) {
            $bindings = [];

            foreach ($query->statements['values'] as $values) {
                foreach ($query->state()->compiledParts['columns']['types'] as $field => $type) {
                    $bindings[] = $this->platform()->types()->toDatabase($values[$field] ?? null, $type);

Operation must be bracketed

                }
            }

            return $bindings;
        }

        $values = $query->statements['values'][0];
        $bindings = [];

        foreach ($query->state()->compiledParts['columns']['types'] as $field => $type) {
            $bindings[] = $this->platform()->types()->toDatabase($values[$field] ?? null, $type);

Operation must be bracketed

        }

        return $bindings;
    }

    /**
     * Compile the INSERT mode
     *
     * @param CompilableClause $query
     *
     * @return string
     */
    private function compileMode(CompilableClause $query)

Private method name "BulkInsertSqlCompiler::compileMode" must be prefixed with an underscore

    {
        switch ($query->statements['mode']) {
            case BulkInsertQuery::MODE_REPLACE:
                return 'REPLACE';

Case breaking statement indented incorrectly; expected 14 spaces, found 16

            case BulkInsertQuery::MODE_IGNORE:
                if ($this->platform()->grammar()->getName() === 'sqlite') {
                    return 'INSERT OR IGNORE';
                } else {
                    return 'INSERT IGNORE';
                }
                break;

Case breaking statement indented incorrectly; expected 14 spaces, found 16

        }

        return 'INSERT';
    }

    /**
     * Compile columns, and resolve types
     *
     * @param CompilableClause $query
     */
    private function compileColumns(CompilableClause $query)

Private method name "BulkInsertSqlCompiler::compileColumns" must be prefixed with an underscore

    {
        $columns = [];
        $types = [];

        foreach ($query->statements['columns'] as $column) {
            if (!empty($column['type'])) {
                $types[$column['name']] = $column['type'];
                $type = null;
            } else {
                $types[$column['name']] = null;
                $type = true;
            }

            $columns[] = $this->quoteIdentifier($query, $query->preprocessor()->field($column['name'], $type));

            if ($type instanceof TypeInterface) {
                $types[$column['name']] = $type;
            }
        }

        $query->state()->compiledParts['columns'] = [
            'sql'    => '('.implode(', ', $columns).') ',
            'types'  => $types,
            'values' => '('.str_repeat('?, ', count($types) - 1).'?)',

Operation must be bracketed

        ];
    }

    /**
     * Compile values for bulk INSERT query
     *
     * @param CompilableClause $query
     *
     * @return string
     */
    private function compileValues(CompilableClause $query)

Private method name "BulkInsertSqlCompiler::compileValues" must be prefixed with an underscore

    {
        if (!$query->statements['bulk']) {
            return 'VALUES '.$query->state()->compiledParts['columns']['values'];
        }

        $values = $query->state()->compiledParts['columns']['values'];

        return 'VALUES '.str_repeat($values.', ', count($query->statements['values']) - 1).$values;

Operation must be bracketed

    }
}