clickhouse-cpp は ClickHouse 向けの公式 C++クライアントライブラリで、ネイティブバイナリプロトコルを使用して ClickHouse への高速かつ型安全な
インターフェイスを提供します。
ビルド手順、使用例、および追加ドキュメントは、プロジェクトの GitHub リポジトリで参照できます: https://github.com/ClickHouse/clickhouse-cpp.
ライブラリをプロジェクトに組み込む
ライブラリをプロジェクトに組み込む最も簡単な方法は、CMake の FetchContent
モジュールを使用することです。この方法では、ライブラリの特定のバージョンを固定し、通常の
CMake ワークフローの一部としてビルドできます。
include(FetchContent)
set(WITH_OPENSSL YES CACHE BOOL "Enable OpenSSL in clickhouse-cpp" FORCE)
FetchContent_Declare(
clickhouse-cpp
GIT_REPOSITORY https://github.com/ClickHouse/clickhouse-cpp.git
GIT_TAG v2.6.0 # can also be `master` or other banch
)
FetchContent_MakeAvailable(clickhouse-cpp)WITH_OPENSSL オプションを有効にすると、ライブラリで TLS をサポートできるようになり、
ClickHouse Cloud やその他の SSL 対応 ClickHouse デプロイメントに接続する際に必要です。TLS を使用しない
接続では省略できますが、通常は有効にしておくことを推奨します。
SSL サポートを有効にしてビルドするには、OpenSSL の開発用パッケージがインストールされている必要があります。Debian、
Ubuntu またはその派生ディストリビューションでは libssl-dev、Fedora や Red Hat では openssl-devel、macOS では
Homebrew を使用して openssl をインストールしてください。
依存関係を利用可能にしたら、エクスポートされたライブラリターゲットに対して自分のターゲットをリンクしてください。
target_link_libraries(your-target PRIVATE clickhouse-cpp-lib)例
Client オブジェクトの設定
ClickHouse への接続を確立するには、Client インスタンスを作成します。次の例では、
パスワード不要かつ SSL が有効になっていないローカルの ClickHouse インスタンスに接続する方法を
示します。
#include <clickhouse/client.h>
clickhouse::Client client{clickhouse::ClientOptions().SetHost("localhost")};より高度な構成では、追加の設定が必要です。次の例では、 いくつかの追加パラメータを使用して ClickHouse Cloud インスタンスに接続する方法を示します。
#include <clickhouse/client.h>
clickhouse::Client client{
clickhouse::ClientOptions{}
.SetHost("your.instance.clickhouse.cloud")
.SetUser("default")
.SetPassword("your-password")
.SetSSLOptions({}) // Enable SSL
.SetPort(9440) // for connections over SSL ClickHouse Cloud uses port 9440
};データを返さずにテーブルを作成し、クエリを実行する
テーブルの作成のように、データを返さないクエリを実行するには、Execute メソッドを使用します。
同じ方法は、ALTER TABLE や DROP などの他のステートメントにも適用できます。
client.Execute(R"(
CREATE TABLE IF NOT EXISTS greetings (
id UInt64,
message String,
language String)
ENGINE = MergeTree ORDER BY id)");データの挿入
テーブルにデータを挿入するには、Block を作成し、テーブルスキーマに対応するカラムオブジェクトを格納します。
データはカラムごとに追加され、その後、効率的なバッチ書き込み向けに最適化された Insert メソッドを使用して、
1 回の操作で挿入されます。
auto id = std::make_shared<clickhouse::ColumnUInt64>();
auto message = std::make_shared<clickhouse::ColumnString>();
auto language = std::make_shared<clickhouse::ColumnString>();
id->Append(1);
message->Append("Hello, World!");
language->Append("English");
id->Append(2);
message->Append("¡Hola, Mundo!");
language->Append("Spanish");
id->Append(3);
message->Append("Hallo wereld!");
language->Append("Dutch");
clickhouse::Block block{};
block.AppendColumn("id", id);
block.AppendColumn("message", message);
block.AppendColumn("language", language);
client.Insert("greetings", block);データの取得
データを返すクエリを実行するには、Select メソッドを使用し、結果を処理するコールバックを指定します。クエリ結果は Block オブジェクトとして返され、ClickHouse ネイティブのカラム指向データ表現を反映しています。
client.Select(
"SELECT id, message, language FROM greetings",
[](const clickhouse::Block & block){
for (size_t i = 0; i < block.GetRowCount(); ++i) {
auto id = block[0]->AsStrict<clickhouse::ColumnUInt64>()->At(i);
auto message = block[1]->AsStrict<clickhouse::ColumnString>()->At(i);
auto language = block[2]->AsStrict<clickhouse::ColumnString>()->At(i);
std::cout << id << "\t" << message << "\t" << language << "\n";
}
});サポートされているデータ型
UInt8,UInt16,UInt32,UInt64,Int8,Int16,Int32,Int64UInt128,Int128Decimal32,Decimal64,Decimal128Float32,Float64DateDateTime,DateTime64DateTime([timezone]),DateTime64(N, [timezone])UUIDEnum8,Enum16StringFixedString(N)LowCardinality(String)およびLowCardinality(FixedString(N))Nullable(T)Array(T)TupleMapIPv4,IPv6Point,Ring,Polygon,MultiPolygon