NAME

AnyEvent::ClickHouse - Simple but non-blocking HTTP client for ClickHouse Database

VERSION

Version 0.021

SYNOPSIS

use AnyEvent::ClickHouse;

clickhouse_select
    {   # connection options
        host        => '127.0.0.1',
        user        => 'Harry',
        password    => 'Alohomora'
    },
    'select * from test FORMAT Pretty', # query
    sub {   # callback function if status ok 200
        my $data = shift;
    },
    sub {   # callback function if status error 500
        my $data = shift;
    }
;

# ... do something else here  

DESCRIPTION

This module is an AnyEvent user, you need to make sure that you use and run a supported event loop.

This module implements a simple and non-blocking HTTP client for ClickHouse Database. It supports clickhouse_do, clickhouse_select clickhouse_select_array and clickhouse_select_hash methods.

METHODS

clickhouse_select

Fetch data from the table (readonly).

By default, data is returned in TabSeparated format. You use the FORMAT clause of the query to request any other format.

• Native

• TabSeparated # default

• TabSeparatedWithNames

• CSV # Comma separated values

• Pretty

• JSON # Outputs data in JSON format

• XML

• ...

https://clickhouse.yandex/reference_en.html#Formats

clickhouse_select
    {
        host        => '127.0.0.1',
        user        => 'Harry',
        password    => 'Alohomora'
    },
    'select * from test',
    sub {   # callback function if status ok 200
        my $data = shift;

        # ... do something
        # print $data;
    },
    sub {   # callback function if status error 500
        my $data = shift;

        # do something
        # print "err: ".$data."\n";
    }
;

You can use URI

use URI;
use URI::QueryParam;

my $uri = URI->new(sprintf ("http://%s:%d/",'127.0.0.1',8123));  # host and port
$uri->query_param('user' => 'Harry');
$uri->query_param('password' => 'Alohomora');
$uri->query_param('database' => 'default');

clickhouse_select
    { 
        uri => $uri
    },
    ...

clickhouse_select_array

Fetch data from the table (readonly). It returns a reference to an array containing a references to an arrays for each row of data fetched.

Don't use FORMAT in query!

clickhouse_select_array
    {
        host        => '127.0.0.1',
        user        => 'Harry',
        password    => 'Alohomora'
    },
    'select * from test',
    sub {   # callback function if status ok 200
        my $data = shift;

        # ... do something

        # foreach my $row (@$data) {
        #     # Do something with your row
        #     foreach my $col (@$row) {
        #         # ... Do something
        #         print $col."\t";
        #     }
        #     print "\n";
        # }

    },
    sub {   # callback function if status error 500
        my $data = shift;

        # do something
        # print "err: ".$data."\n";
    }
;

clickhouse_select_hash

Fetch data from the table (readonly). It returns a reference to an array containing a references to an hashes for each row of data fetched.

Don't use FORMAT in query!

clickhouse_select_hash
    {
        host        => '127.0.0.1',
        user        => 'Harry',
        password    => 'Alohomora'
    },
    'select * from test',
    sub {   # callback function if status ok 200
        my $data = shift;

        # ... do something

        # foreach my $row (@$data) {
        #     # Do something with your row
        #     foreach my $col (@$row) {
        #         # ... Do something
        #         print $col."\t";
        #     }
        #     print "\n";
        # }

    },
    sub {   # callback function if status error 500
        my $data = shift;

        # do something
        # print "err: ".$data."\n";
    }
;

clickhouse_do

Universal method for any queries inside the database, which modify data (insert data, create, alter, detach or drop table or partition).

clickhouse_do
    {
        host        => '127.0.0.1',
        user        => 'Harry',
        password    => 'Alohomora'
    },
    "INSERT INTO test (id, f1, f2) VALUES",
    sub {   # callback function if status ok 200
        my $data = shift;
        # do something
    },
    undef,   # You can skip callback function
    [1, "Gryffindor", "a546825467 1861834657416875469"],
    [2, "Hufflepuff", "a18202568975170758 46717657846"],
    [3, "Ravenclaw", "a678 2527258545746575410210547"],
    [4, "Slytherin", "a1068267496717456 878134788953"]
);

SEE ALSO

• ClickHouse official documentation

  https://clickhouse.yandex/reference_en.html

• AnyEvent

  AnyEvent

AUTHOR

Maxim Motylkov

MODIFICATION HISTORY

See the Changes file.

COPYRIGHT AND LICENSE

Copyright 2016 Maxim Motylkov

This module is free software; you can redistribute it and/or modify it under the same terms as Perl itself. 

THIS PACKAGE IS PROVIDED "AS IS" AND WITHOUT ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, WITHOUT LIMITATION,
THE IMPLIED WARRANTIES OF MERCHANTIBILITY AND FITNESS FOR A PARTICULAR PURPOSE.

cpanm AnyEvent::ClickHouse

perl -MCPAN -e shell
install AnyEvent::ClickHouse