Basis\Clickhouse

Complexity

Total Complexity

7

Size/Duplication

Total Lines	46
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

95.24%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
B	select()	0	23	4
A	insert()	0	15	3

<?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) {
                $binds[$k] = (array) $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)

The parameter $table is not used and could be removed.

    {
        $client = $this->get(Client::class);
        if (count($data) < $this->bucketSize) {
            $buckets = [$data];
        } else {
            $buckets = array_chunk($data, $this->bucketSize);
        }

        foreach ($buckets as $bucket) {
            $client->insert('tester', $bucket, $headers);
        }

        return count($buckets);
    }
}