Name

QBit::Application::Model::DB::clickhouse::Table - Class for ClickHouse tables.

Description

Implements methods for ClickHouse tables.

Package methods

add

Arguments:

• $data - reference to hash or object(QBit::Application::Model::DB::Query)

• %opts - additional options

  • fields - array ref (order for fields)

Return values:

• $count - number of new records

Example:

my $count = $app->db->stat->add({date => '2017-09-03', hits => 10}); # $count = 1, insert all fields

$count = $app->db->stat->add({date => '2017-09-03', hits => 10, not_exists => 'something'}, fields => [qw(date hits)]);
# $count = 1, insert only date and hits in this order

$app->db->stat->add(
    $app->db->query->select(
        table  => $app->db->today_stat,
        fields => [qw(date hits)],
        filter => {date => '2017-09-17 19:19:23'}
    ),
    fields => [qw(date hits)]
);

# clickhouse
INSERT INTO `stat` (`date`, `hits`) SELECT
  `today_stat`.`date` AS `date`,
  `today_stat`.`hits` AS `hits`
FROM `today_stat`
WHERE (
  `today_stat`.`date` = '2017-09-17 19:19:23'
);

add_multi

ADD_CHUNK (records number in one statement; default: 1000)

$QBit::Application::Model::DB::clickhouse::ADD_CHUNK = 500;

Arguments:

• $data - reference to array

• %opts - additional options

  • fields - array ref (order for fields)

  • identical_rows - boolean (true: get field names from first row, false: Unites all fields from all rows; default: false)

  • ignore_extra_fields - boolean (true: ignore field names that not exists in table, false: throw exception; default: false)

Return values:

• $count - records number

Example:

my $count = $app->db->stat->add_multi([{date => '2017-09-02', hits => 5}, {date => '2017-09-03', hits => 10}]); # $count = 2

$count = $app->db->stat->add_multi([
    {date => '2017-09-02', hits => 5, not_exists => 'something'},
    {date => '2017-09-03', hits => 10, not_exists => 'something'}
  ],
  fields => [qw(date hits)]
);
# $count = 2, insert only date and hits in this order

create_sql

returns sql for create table.

No arguments.

Return values:

• $sql - string

Example:

my $sql = $app->db->stat->create_sql();