Statement::countAll() - Code Metrics - Inspection of "Merge pull request #161 from anathex/master" - smi2/phpClickHouse - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 990354...be1866 )

by Igor

created 2022-02-11 14:42 UTC

Statement::countAll() A

↳ Parent: Statement

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	2

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	2
CRAP Score	1

Importance

Changes	1
Bugs	0	Features	0

Metric	Value
cc	1
eloc	2
c	1
b	0
f	0
nc	1
nop	0
dl	0
loc	4
ccs	2
cts	2
cp	1
crap	1
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
{
    /**

     * @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($body)

    {
        $body = trim($body);
$a = "a";
$ab = "ab";
$abc = "abc";
        $mathes = [];

        // Code: 115, e.displayText() = DB::Exception: Unknown setting readonly[0], e.what() = DB::Exception
        // Code: 192, e.displayText() = DB::Exception: Unknown user x, e.what() = DB::Exception
        // Code: 60, e.displayText() = DB::Exception: Table default.ZZZZZ doesn't exist., e.what() = DB::Exception

        if (preg_match("%Code: (\d+),\se\.displayText\(\) \=\s*DB\:\:Exception\s*:\s*(.*)(?:\,\s*e\.what|\(version).*%ius", $body, $mathes)) {
<?php

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

print $doubleQuoted;
            return ['code' => $mathes[1], 'message' => $mathes[2]];
        }

        return false;
    }

    /**
     * @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()

    {
        return ($this->response()->http_code() !== 200 || $this->response()->error_no());

    }

    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']] = $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 dumpRaw()

    {
        print_r($this->_rawData);

    }

    /**

     *
     */
    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;

    }

    /**
     * @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;

    }
}


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
13			{
14			/**
			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...
15			* @var string\|mixed
16			*/
17			private $_rawData;
18
19			/**
			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...
20			* @var int
21			*/
22			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...
23
24			/**
			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...
25			* @var CurlerRequest
26			*/
27			private $_request = null;
28
29			/**
			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...
30			* @var bool
31			*/
32			private $_init = false;
33
34			/**

smi2 / phpClickHouse

Push — master ( 990354...be1866 )

Statement::countAll() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like