CommandPDOPgsql::internalExecute() - Code Metrics - Inspection of "7c715d94ae906f1b7cc64a9f159040e6319131a6" - yiisoft/db-pgsql - Measure and Improve Code Quality continuously with Scrutinizer

Passed

Branch — dev (7c715d)

by Wilmer

created 2022-05-04 18:02 UTC

CommandPDOPgsql::internalExecute() B

↳ Parent: CommandPDOPgsql

Complexity

Conditions	9
Paths	9

Size

Total Lines	25
Code Lines	18

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	13
CRAP Score	9.5338

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	9
eloc	18
c	1
b	0
f	0
nc	9
nop	1
dl	0
loc	25
ccs	13
cts	16
cp	0.8125
crap	9.5338
rs	8.0555

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

yiisoft / db-pgsql

Branch — dev (7c715d)

CommandPDOPgsql::internalExecute() B

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like