Spiral\Database\Drivers\Postgres\InsertQuery

Complexity

Total Complexity

6

Size/Duplication

Total Lines	39
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	sqlStatement()	0	22	5
A	run()	0	7	1

<?php
/**
 * Spiral Framework.
 *
 * @license   MIT
 * @author    Anton Titov (Wolfy-J)
 */

namespace Spiral\Database\Drivers\Postgres;

use Spiral\Database\Builders\InsertQuery as CommonInsertQuery;
use Spiral\Database\Drivers\Postgres\QueryCompiler as PostgresCompiler;
use Spiral\Database\Entities\QueryCompiler as AbstractCompiler;
use Spiral\Database\Exceptions\BuilderException;

/**
 * Postgres driver requires little bit different way to handle last insert id.
 */
class InsertQuery extends CommonInsertQuery
{
    /**
     * {@inheritdoc}
     */
    public function sqlStatement(AbstractCompiler $compiler = null): string
    {
        if (
            !$this->driver instanceof PostgresDriver
            || (!empty($compiler) && !$compiler instanceof PostgresCompiler)
        ) {
            throw new BuilderException(
                'Postgres InsertQuery can be used only with Postgres driver and compiler'

The call to BuilderException::__construct() has too many arguments starting with 'Postgres InsertQuery can be used only with Postgres driver and compiler'.

            );
        }

        if (empty($compiler)) {
            $compiler = $this->compiler->resetQuoter();
        }

        return $compiler->compileInsert(
            $this->table,
            $this->columns,
            $this->rowsets,
            $this->driver->getPrimary($this->compiler->getPrefix(), $this->table)

The call to QueryCompiler::compileInsert() has too many arguments starting with $this->driver->getPrimary($this->compiler->getPrefix(), $this->table).

        );
    }

    /**
     * {@inheritdoc}
     */
    public function run(): int
    {
        return (int)$this->driver->statement(
            $this->sqlStatement(),
            $this->getParameters()
        )->fetchColumn();
    }
}