Clickhouse::select() - Code Metrics - basis-company/framework.php - Measure and Improve Code Quality continuously with Scrutinizer

Clickhouse::select() A
last analyzed 2020-03-03 11:24 UTC

↳ Parent: Clickhouse

Complexity

Conditions	5
Paths	4

Size

Total Lines

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	14
CRAP Score	5.1374

Importance

Changes

Metric	Value
dl	0
loc	29
ccs	14
cts	17
cp	0.8235
rs	9.1448
c	0
b	0
f	0
cc	5
nc	4
nop	3
crap	5.1374

<?php

namespace Basis;

use ClickHouseDB\Client;

class Clickhouse
{
    use Toolkit;

    public $bucketSize = 1000;

    public function select($fields, string $table, array $params = [])
    {
        if (is_array($fields)) {
            $fields = implode(', ', $fields);
        }

        $query = "SELECT $fields FROM $table";
        $binds = [];

        if (count($params)) {
            $where = [];
            foreach ($params as $k => $v) {
                $v = (array) $v;
                if (count($v) == 1) {
                    $binds[$k] = $v[0];
                    $where[] = $k.' = :'.$k;
                } else {
                    $binds[$k] = $v;
                    $where[] = $k.' in (:'.$k.')';
                }
            }

            $where = implode(' and ', $where);

            $query .= " where $where";
        }

        return $this->get(Client::class)->select($query, $binds);
    }

    public function insert(string $table, array $data, array $headers)
    {
        if (count($data) < $this->bucketSize) {
            $buckets = [$data];
        } else {
            $buckets = array_chunk($data, $this->bucketSize);
        }

        $client = $this->get(Client::class);
        foreach ($buckets as $bucket) {
            $client->insert($table, $bucket, $headers);
        }

        return count($buckets);
    }
}


1		<?php
2
3		namespace Basis;
4
5		use ClickHouseDB\Client;
6
7		class Clickhouse
8		{
9		use Toolkit;
10
11		public $bucketSize = 1000;
12
13	2	public function select($fields, string $table, array $params = [])
14		{
15	2	if (is_array($fields)) {
16		$fields = implode(', ', $fields);
17		}
18
19	2	$query = "SELECT $fields FROM $table";
20	2	$binds = [];
21
22	2	if (count($params)) {
23	1	$where = [];
24	1	foreach ($params as $k => $v) {
25	1	$v = (array) $v;
26	1	if (count($v) == 1) {
27	1	$binds[$k] = $v[0];
28	1	$where[] = $k.' = :'.$k;
29		} else {
30		$binds[$k] = $v;
31		$where[] = $k.' in (:'.$k.')';
32		}
33		}
34
35	1	$where = implode(' and ', $where);
36
37	1	$query .= " where $where";
38		}
39
40	2	return $this->get(Client::class)->select($query, $binds);
41		}
42
43	2	public function insert(string $table, array $data, array $headers)
44		{
45	2	if (count($data) < $this->bucketSize) {
46	2	$buckets = [$data];
47		} else {
48	1	$buckets = array_chunk($data, $this->bucketSize);
49		}
50
51	2	$client = $this->get(Client::class);
52	2	foreach ($buckets as $bucket) {
53	2	$client->insert($table, $bucket, $headers);
54		}
55
56	2	return count($buckets);
57		}
58		}
59

basis-company / framework.php

Clickhouse::select() A last analyzed 2020-03-03 11:24 UTC

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like

Clickhouse::select() A
last analyzed 2020-03-03 11:24 UTC