CommandPDOPgsql::insertEx() - Code Metrics - Inspection of "Use injection dependencies, remove dependencie tra..." - yiisoft/db-pgsql - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Pull Request — dev (#124)

by Wilmer

created 2022-05-04 16:49 UTC

CommandPDOPgsql::insertEx() A

↳ Parent: CommandPDOPgsql

Complexity

Conditions	2
Paths	2

Size

Total Lines	12
Code Lines	6

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	6
CRAP Score	2

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	2
eloc	6
c	1
b	0
f	0
nc	2
nop	2
dl	0
loc	12
ccs	6
cts	6
cp	1
crap	2
rs	10

<?php

declare(strict_types=1);

namespace Yiisoft\Db\Pgsql\PDO;

use Exception;
use Yiisoft\Db\Driver\PDO\CommandPDO;
use Yiisoft\Db\Exception\ConvertException;
use Yiisoft\Db\Query\QueryBuilderInterface;
use Yiisoft\Db\Schema\SchemaInterface;

final class CommandPDOPgsql extends CommandPDO
{
    /**
     * @inheritDoc
     */
    public function insertEx(string $table, array $columns): bool|array
    {
        $params = [];
        $sql = $this->queryBuilder()->insertEx($table, $columns, $params);

        $this->setSql($sql)->bindValues($params);
        $this->prepare(false);

        /** @var mixed */
        $queryOne = $this->queryOne();

        return is_array($queryOne) ? $queryOne : false;
    }

    public function queryBuilder(): QueryBuilderInterface
    {
        return $this->db->getQueryBuilder();
    }

    public function schema(): SchemaInterface
    {
        return $this->db->getSchema();
    }

    protected function internalExecute(?string $rawSql): void
    {
        $attempt = 0;

        while (true) {
            try {
                if (
                    ++$attempt === 1
                    && $this->isolationLevel !== null
                    && $this->db->getTransaction() === null
                ) {
                    $this->db->transaction(
                        fn (?string $rawSql) => $this->internalExecute($rawSql),
                        $this->isolationLevel
                    );
                } else {
                    $this->pdoStatement?->execute();
                }
                break;
            } catch (Exception $e) {
                $rawSql = $rawSql ?: $this->getRawSql();
                $e = (new ConvertException($e, $rawSql))->run();

                if ($this->retryHandler === null || !($this->retryHandler)($e, $attempt)) {
                    throw $e;
                }
            }
        }
    }
}


1		<?php
2
3		declare(strict_types=1);
4
5		namespace Yiisoft\Db\Pgsql\PDO;
6
7		use Exception;
8		use Yiisoft\Db\Driver\PDO\CommandPDO;
9		use Yiisoft\Db\Exception\ConvertException;
10		use Yiisoft\Db\Query\QueryBuilderInterface;
11		use Yiisoft\Db\Schema\SchemaInterface;
12
13		final class CommandPDOPgsql extends CommandPDO
14		{
15		/**
16	1	* @inheritDoc
17		*/
18	1	public function insertEx(string $table, array $columns): bool\|array
19	1	{
20		$params = [];
21	1	$sql = $this->queryBuilder()->insertEx($table, $columns, $params);
22	1
23		$this->setSql($sql)->bindValues($params);
24		$this->prepare(false);
25	1
26		/** @var mixed */
27	1	$queryOne = $this->queryOne();
28
29		return is_array($queryOne) ? $queryOne : false;
30	204	}
31
32	204	public function queryBuilder(): QueryBuilderInterface
33		{
34		return $this->db->getQueryBuilder();
35	193	}
36
37	193	public function schema(): SchemaInterface
38		{
39	193	return $this->db->getSchema();
40		}
41
42	193	protected function internalExecute(?string $rawSql): void
43	193	{
44	193	$attempt = 0;
45
46		while (true) {
47		try {
48		if (
49		++$attempt === 1
50		&& $this->isolationLevel !== null
51	193	&& $this->db->getTransaction() === null
52		) {
53	193	$this->db->transaction(
54	7	fn (?string $rawSql) => $this->internalExecute($rawSql),
55	7	$this->isolationLevel
56	7	);
57		} else {
58	7	$this->pdoStatement?->execute();
59	7	}
60		break;
61		} catch (Exception $e) {
62		$rawSql = $rawSql ?: $this->getRawSql();
63		$e = (new ConvertException($e, $rawSql))->run();
64
65		if ($this->retryHandler === null \|\| !($this->retryHandler)($e, $attempt)) {
66		throw $e;
67		}
68		}
69		}
70		}
71		}
72

yiisoft / db-pgsql

Pull Request — dev (#124)

CommandPDOPgsql::insertEx() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like