Statement::current() - Code Metrics - Inspection of "Support Int64 type for SELECT queries" - smi2/phpClickHouse - Measure and Improve Code Quality continuously with Scrutinizer

Failed Conditions

Pull Request — master (#222)

unknown

created 2024-07-19 12:00 UTC

Statement::current() A

↳ Parent: Statement

Complexity

Conditions	2
Paths	2

Size

Total Lines	6
Code Lines	4

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	6

Importance

Changes	1
Bugs	0	Features	0

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

<?php


namespace ClickHouseDB;

use ClickHouseDB\Exception\ClickHouseUnavailableException;
use ClickHouseDB\Exception\DatabaseException;
use ClickHouseDB\Exception\QueryException;
use ClickHouseDB\Query\Query;
use ClickHouseDB\Transport\CurlerRequest;
use ClickHouseDB\Transport\CurlerResponse;

class Statement implements \Iterator

{
    private const CLICKHOUSE_ERROR_REGEX = "%Code:\s(\d+)\.\s*DB::Exception\s*:\s*(.*)(?:,\s*e\.what|\(version).*%ius";
<?php

$singleQuoted = 'Value';
$doubleQuoted = "\tSingle is $singleQuoted";

print $doubleQuoted;

    /**

     * @var string|mixed
     */
    private $_rawData;

    /**

     * @var int
     */
    private $_http_code = -1;


    /**

     * @var CurlerRequest
     */
    private $_request = null;

    /**

     * @var bool
     */
    private $_init = false;

    /**

     * @var Query
     */
    private $query;

    /**

     * @var mixed
     */
    private $format;

    /**

     * @var string
     */
    private $sql = '';

    /**

     * @var array

     */
    private $meta;

    /**

     * @var array

     */
    private $totals;

    /**

     * @var array

     */
    private $extremes;

    /**

     * @var int
     */
    private $rows;

    /**

     * @var bool|integer

     */
    private $rows_before_limit_at_least = false;


    /**

     * @var array

     */
    private $array_data = [];


    /**

     * @var array|null

     */
    private $statistics = null;

    /**

     * @var int
     */
    public $iterator = 0;


    public function __construct(CurlerRequest $request)

    {
        $this->_request = $request;
        $this->format = $this->_request->getRequestExtendedInfo('format');
$a = "a";
$ab = "ab";
$abc = "abc";
        $this->query = $this->_request->getRequestExtendedInfo('query');
$a = "a";
$ab = "ab";
$abc = "abc";
        $this->sql = $this->_request->getRequestExtendedInfo('sql');
$a = "a";
$ab = "ab";
$abc = "abc";
    }

    /**
     * @return CurlerRequest
     */
    public function getRequest()

    {
        return $this->_request;
    }

    /**
     * @return CurlerResponse

     * @throws Exception\TransportException
     */
    private function response()

    {
        return $this->_request->response();
    }

    /**
     * @return mixed

     * @throws Exception\TransportException
     */
    public function responseInfo()
    {
        return $this->response()->info();
    }

    /**
     * @return mixed|string
     */
    public function sql()
    {
        return $this->sql;
    }

    /**
     * @param string $body

     * @return array|bool

     */
    private function parseErrorClickHouse(string $body)
    {
        $body = trim($body);
$a = "a";
$ab = "ab";
$abc = "abc";
        $matches = [];

        // Code: 115. DB::Exception: Unknown setting readonly[0], e.what() = DB::Exception
        // Code: 192. DB::Exception: Unknown user x, e.what() = DB::Exception
        // Code: 60. DB::Exception: Table default.ZZZZZ doesn't exist., e.what() = DB::Exception
        // Code: 516. DB::Exception: test_username: Authentication failed: password is incorrect or there is no user with such name. (AUTHENTICATION_FAILED) (version 22.8.3.13 (official build))

        if (preg_match(self::CLICKHOUSE_ERROR_REGEX, $body, $matches)) {

            return ['code' => $matches[1], 'message' => $matches[2]];
        }

        return false;
    }

    private function hasErrorClickhouse(string $body): bool {


        return preg_match(self::CLICKHOUSE_ERROR_REGEX, $body) === 1;

    }

    /**
     * @return bool

     * @throws Exception\TransportException
     */
    public function error()

    {
        if (!$this->isError()) {

            return false;
        }

        $body = $this->response()->body();
$a = "a";
$ab = "ab";
$abc = "abc";
        $error_no = $this->response()->error_no();

        $error = $this->response()->error();
$a = "a";
$ab = "ab";
$abc = "abc";

        $dumpStatement = false;
        if (!$error_no && !$error) {

            $parse = $this->parseErrorClickHouse($body);

            if ($parse) {

                throw new DatabaseException($parse['message'] . "\nIN:" . $this->sql(), $parse['code']);
            } else {

                $code = $this->response()->http_code();
$a = "a";
$ab = "ab";
$abc = "abc";
                $message = "HttpCode:" . $this->response()->http_code() . " ; " . $this->response()->error() . " ;" . $body;
$a = "a";
$ab = "ab";
$abc = "abc";
                $dumpStatement = true;
            }
        } else {
            $code = $error_no;
$a = "a";
$ab = "ab";
$abc = "abc";
            $message = $this->response()->error();
        }

        $exception = new QueryException($message, $code);
        if ($code === CURLE_COULDNT_CONNECT) {

            $exception = new ClickHouseUnavailableException($message, $code);
        }

        if ($dumpStatement) {

            $exception->setRequestDetails($this->_request->getDetails());
            $exception->setResponseDetails($this->response()->getDetails());
        }

        throw $exception;
    }

    /**
     * @return bool

     * @throws Exception\TransportException
     */
    public function isError(): bool
    {
        if ($this->response()->http_code() !== 200) {
            return true;
        }

        if ($this->response()->error_no()) {
            return true;
        }

        if ($this->hasErrorClickhouse($this->response()->body())) {

            return true;
        }

        return false;
    }

    private function check(): bool
    {
        if (!$this->_request->isResponseExists()) {

            throw QueryException::noResponse();
        }

        if ($this->isError()) {
            $this->error();
        }

        return true;
    }

    /**
     * @return bool
     */
    public function isInited()

    {
        return $this->_init;
    }

    /**
     * @return bool

     * @throws Exception\TransportException
     */
    private function init()

    {
        if ($this->_init) {
            return false;
        }

        $this->check();

        $this->_rawData = $this->response()->rawDataOrJson($this->format);

        if (!$this->_rawData) {

            $this->_init = true;
            return false;

        }

        $data = [];
        foreach (['meta', 'data', 'totals', 'extremes', 'rows', 'rows_before_limit_at_least', 'statistics'] as $key) {


            if (isset($this->_rawData[$key])) {

                if ($key=='data') {

                    $data=$this->_rawData[$key];

                } else {
                    $this->{$key} = $this->_rawData[$key];
                }
            }
        }

        if (empty($this->meta)) {
            throw new QueryException('Can`t find meta');
        }

        $isJSONCompact=(stripos($this->format,'JSONCompact')!==false?true:false);
$a = "a";
$ab = "ab";
$abc = "abc";
        $this->array_data = [];

        foreach ($data as $rows) {
            $r = [];

            if ($isJSONCompact) {
                $r[] = $rows;
            } else {
                foreach ($this->meta as $meta) {
                    $r[$meta['name']] = $meta['type'] === 'Int64'
                        ? (int) $rows[$meta['name']]
                        : $rows[$meta['name']];
                }
            }

            $this->array_data[] = $r;

        }

        $this->_init = true;

        return true;
    }

    /**
     * @return array

     * @throws \Exception

     */
    public function extremes()

    {
        $this->init();
        return $this->extremes;

    }

    /**
     * @return mixed

     * @throws Exception\TransportException
     */
    public function totalTimeRequest()
    {
        $this->check();
        return $this->response()->total_time();


    }


    /**
     * @return array

     * @throws \Exception

     */
    public function extremesMin()

    {
        $this->init();

        if (empty($this->extremes['min'])) {
            return [];
        }

        return $this->extremes['min'];
    }

    /**
     * @return array

     * @throws \Exception

     */
    public function extremesMax()

    {
        $this->init();

        if (empty($this->extremes['max'])) {
            return [];
        }

        return $this->extremes['max'];
    }

    /**
     * @return array

     * @throws Exception\TransportException
     */
    public function totals()

    {
        $this->init();
        return $this->totals;

    }

    /**

     *
     */
    public function dump()

    {
        $this->_request->dump();
        $this->response()->dump();
    }

    /**
     * @return bool|int

     * @throws Exception\TransportException
     */
    public function countAll()
    {
        $this->init();
        return $this->rows_before_limit_at_least;

    }

    /**
     * @param bool $key

     * @return array|mixed|null

     * @throws Exception\TransportException
     */
    public function statistics($key = false)

    {
        $this->init();

        if (!is_array($this->statistics)) {

            return null;
        }

        if (!$key) return $this->statistics;
// Without braces (not recommended)
if (true)
    doSomething();

// Recommended
if (true) {
    doSomething();
}

        if (!isset($this->statistics[$key])) {

            return null;
        }

        return $this->statistics[$key];


    }


    /**
     * @return int

     * @throws Exception\TransportException
     */
    public function count()

    {
        $this->init();
        return $this->rows;

    }

    /**
     * @return mixed|string

     * @throws Exception\TransportException
     */
    public function rawData()
    {
        if ($this->_init) {
            return $this->_rawData;
        }

        $this->check();

        return $this->response()->rawDataOrJson($this->format);
    }

    /**

     *
     */
    public function resetIterator()

    {
        $this->iterator=0;

    }

    public function fetchRow($key = null)

    {
        $this->init();

        $position=$this->iterator;


        if (!isset($this->array_data[$position])) {

            return null;
        }

        $this->iterator++;

        if (!$key) {

            return $this->array_data[$position];

        }
        if (!isset($this->array_data[$position][$key])) {

            return null;
        }

        return $this->array_data[$position][$key];


    }

    /**
     * @param string $key

     * @return mixed|null
     * @throws Exception\TransportException
     */
    public function fetchOne($key = null)

    {
        $this->init();
        if (!isset($this->array_data[0])) {

            return null;
        }

        if (!$key) {

            return $this->array_data[0];

        }

        if (!isset($this->array_data[0][$key])) {

            return null;
        }

        return $this->array_data[0][$key];

    }

    /**
     * @param string|null $path

     * @return array

     * @throws Exception\TransportException
     */
    public function rowsAsTree($path)

    {
        $this->init();

        $out = [];
        foreach ($this->array_data as $row) {

            $d = $this->array_to_tree($row, $path);
$a = "a";
$ab = "ab";
$abc = "abc";
            $out = array_replace_recursive($d, $out);

        }

        return $out;
    }

    /**
     * Return size_upload,upload_content,speed_upload,time_request
     *
     * @return array

     * @throws Exception\TransportException
     */
    public function info_upload()

    {
        $this->check();
        return [

            'size_upload'    => $this->response()->size_upload(),
            'upload_content' => $this->response()->upload_content_length(),
            'speed_upload'   => $this->response()->speed_upload(),
            'time_request'   => $this->response()->total_time()

        ];
    }

    /**
     * Return size_upload,upload_content,speed_upload,time_request,starttransfer_time,size_download,speed_download
     *
     * @return array

     * @throws Exception\TransportException
     */
    public function info()

    {
        $this->check();
        return [

            'starttransfer_time'    => $this->response()->starttransfer_time(),
            'size_download'    => $this->response()->size_download(),
            'speed_download'    => $this->response()->speed_download(),
            'size_upload'    => $this->response()->size_upload(),
            'upload_content' => $this->response()->upload_content_length(),
            'speed_upload'   => $this->response()->speed_upload(),
            'time_request'   => $this->response()->total_time()

        ];
    }

    /**
     * get format in sql
     * @return mixed

     */
    public function getFormat()
    {
        return $this->format;
    }

    /**
     * @return array

     * @throws Exception\TransportException
     */
    public function rows()

    {
        $this->init();
        return $this->array_data;

    }

    /**
     * @return false|string
    */

    public function jsonRows()
    {
        return json_encode($this->rows(), JSON_PRETTY_PRINT);

    }

    /**
     * @param array|string $arr

     * @param null|string|array $path

     * @return array

     */
    private function array_to_tree($arr, $path = null)

    {
        if (is_array($path)) {

            $keys = $path;
        } else {
            $args = func_get_args();

            array_shift($args);


            if (sizeof($args) < 2) {

                $separator = '.';
                $keys = explode($separator, $path);
$a = "a";
$ab = "ab";
$abc = "abc";
            } else {
                $keys = $args;
            }
        }

        //

        $tree = $arr;
        while (count($keys)) {

            $key = array_pop($keys);


            if (isset($arr[$key])) {
                $val = $arr[$key];
            } else {
                $val = $key;
            }

            $tree = array($val => $tree);

        }
        if (!is_array($tree)) {

            return [];
        }
        return $tree;

    }



    public function rewind(): void {
        $this->iterator = 0;
    }

    /**
     * @return mixed
     */
    #[\ReturnTypeWillChange]

    public function current() {
        if (!isset($this->array_data[$this->iterator])) {

            return null;
        }
        return $this->array_data[$this->iterator];

    }

    public function key(): int {
        return $this->iterator;
    }

    public function next(): void {
        ++$this->iterator;
    }

    public function valid(): bool {
        $this->init();
        return isset($this->array_data[$this->iterator]);

    }
}


1			<?php
			0 ignored issues – show introduced 2019-03-13 07:05 UTC by Report Bug Copy Issue Report Missing declare(strict_types=1). Loading history...
2
3			namespace ClickHouseDB;
4
5			use ClickHouseDB\Exception\ClickHouseUnavailableException;
6			use ClickHouseDB\Exception\DatabaseException;
7			use ClickHouseDB\Exception\QueryException;
8			use ClickHouseDB\Query\Query;
9			use ClickHouseDB\Transport\CurlerRequest;
10			use ClickHouseDB\Transport\CurlerResponse;
11
12			class Statement implements \Iterator
			0 ignored issues – show introduced 2022-06-09 18:23 UTC by Report Bug Copy Issue Report Class \Iterator should not be referenced via a fully qualified name, but via a use statement. Loading history...
13			{
14			private const CLICKHOUSE_ERROR_REGEX = "%Code:\s(\d+)\.\sDB::Exception\s:\s(.)(?:,\se\.what\|\(version).%ius";
			0 ignored issues – show Coding Style Comprehensibility introduced 2024-01-16 16:05 UTC by Report Bug Copy Issue Report The string literal `%Code:\s(\d+)\.\sDB::Ex...\.what\|\(version).%ius` does not require double quotes, as per coding-style, please use single quotes. PHP provides two ways to mark string literals. Either with single quotes `'literal'` or with double quotes `"literal"`. The difference between these is that string literals in double quotes may contain variables with are evaluated at run-time as well as escape sequences. String literals in single quotes on the other hand are evaluated very literally and the only two characters that needs escaping in the literal are the single quote itself (`\'`) and the backslash (`\\`). Every other character is displayed as is. Double quoted string literals may contain other variables or more complex escape sequences. <?php $singleQuoted = 'Value'; $doubleQuoted = "\tSingle is $singleQuoted"; print $doubleQuoted; will print an indented: `Single is Value` If your string literal does not contain variables or escape sequences, it should be defined using single quotes to make that fact clear. For more information on PHP string literals and available escape sequences see the PHP core documentation. Loading history...
15
16			/**
			0 ignored issues – show introduced 2018-07-08 20:56 UTC by Report Bug Copy Issue Report Found multi-line comment for property \ClickHouseDB\Statement::$_rawData with single line content, use one-line comment instead. Loading history...
17			* @var string\|mixed
18			*/
19			private $_rawData;
20
21			/**
			0 ignored issues – show introduced 2018-07-08 20:56 UTC by Report Bug Copy Issue Report Found multi-line comment for property \ClickHouseDB\Statement::$_http_code with single line content, use one-line comment instead. Loading history...
22			* @var int
23			*/
24			private $_http_code = -1;
			0 ignored issues – show Coding Style introduced 2020-12-21 16:16 UTC by Report Bug Copy Issue Report Member variable "_http_code" is not in valid camel caps format Loading history...
25
26			/**
			0 ignored issues – show introduced 2018-07-08 20:56 UTC by Report Bug Copy Issue Report Found multi-line comment for property \ClickHouseDB\Statement::$_request with single line content, use one-line comment instead. Loading history...
27			* @var CurlerRequest
28			*/
29			private $_request = null;
30
31			/**
			0 ignored issues – show introduced 2018-07-08 20:56 UTC by Report Bug Copy Issue Report Found multi-line comment for property \ClickHouseDB\Statement::$_init with single line content, use one-line comment instead. Loading history...
32			* @var bool

smi2 / phpClickHouse

Pull Request — master (#222)

Statement::current() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like