1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
|
#pragma once
#include "query.h"
#include "exceptions.h"
#include "columns/array.h"
#include "columns/date.h"
#include "columns/nullable.h"
#include "columns/numeric.h"
#include "columns/string.h"
#include "columns/tuple.h"
#include <library/cpp/openssl/io/stream.h>
#include <util/generic/string.h>
namespace NClickHouse {
/// Метод сжатия
enum class ECompressionMethod {
None = -1,
LZ4 = 1,
};
struct TClientOptions {
#define DECLARE_FIELD(name, type, default) \
type name{default}; \
inline TClientOptions& Set##name(const type& value) { \
name = value; \
return *this; \
}
/// Hostname of the server.
DECLARE_FIELD(Host, TString, TString());
/// Service port.
DECLARE_FIELD(Port, int, 9000);
/// Default database.
DECLARE_FIELD(DefaultDatabase, TString, "default");
/// User name.
DECLARE_FIELD(User, TString, "default");
/// Access password.
DECLARE_FIELD(Password, TString, TString());
/// By default all exceptions received during query execution will be
/// passed to OnException handler. Set rethrow_exceptions to true to
/// enable throwing exceptions with standard c++ exception mechanism.
DECLARE_FIELD(RethrowExceptions, bool, true);
/// Ping server every time before execute any query.
DECLARE_FIELD(PingBeforeQuery, bool, false);
/// Count of retry to send request to server.
DECLARE_FIELD(SendRetries, int, 1);
/// Amount of time to wait before next retry.
DECLARE_FIELD(RetryTimeout, TDuration, TDuration::Seconds(5));
/// Define timeout for establishing a connection to server.
DECLARE_FIELD(ConnectTimeout, TDuration, TDuration::Seconds(5));
/// Define timeout for any operations.
DECLARE_FIELD(RequestTimeout, TDuration, TDuration::Zero());
/// Compression method.
DECLARE_FIELD(CompressionMethod, ECompressionMethod, ECompressionMethod::None);
/// Use SSL encryption
DECLARE_FIELD(UseSsl, bool, false);
/// SSL Options
DECLARE_FIELD(SslOptions, TOpenSslClientIO::TOptions, TOpenSslClientIO::TOptions());
#undef DECLARE_FIELD
};
/**
*
*/
class TClient {
public:
TClient(const TClientOptions& opts);
~TClient();
/// Intends for execute arbitrary queries.
void Execute(const TQuery& query);
/// Intends for execute select queries. Data will be returned with
/// one or more call of \p cb.
void Select(const TString& query, TSelectCallback cb, const TString& query_id = "");
/// Alias for Execute.
void Select(const TQuery& query);
/// Intends for insert block of data into a table \p table_name.
void Insert(const TString& table_name, const TBlock& block, const TString& query_id = "", const TString& deduplication_token = "");
/// Ping server for aliveness.
void Ping();
/// Reset connection with initial params.
void ResetConnection();
private:
TClientOptions Options_;
class TImpl;
THolder<TImpl> Impl_;
};
}
|
