Basis\Clickhouse

Complexity

Total Complexity

8

Size/Duplication

Total Lines	52
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Test Coverage

Coverage

88%

Importance

Changes

0

2 Methods

Rating	Name	Duplication	Size	Complexity
A	insert()	0	15	3
A	select()	0	29	5

<?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);
    }
}