メインコンテンツへスキップ
メインコンテンツへスキップ

ClickHouse への MySQL の統合

このページでは、MySQL テーブルからデータを読み取るために MySQL テーブルエンジンを使用する方法について説明します。

注記

ClickHouse Cloud では、MySQL ClickPipe（現在パブリックベータ）を使用して、MySQL テーブルから ClickHouse にデータを簡単に移行することもできます。

MySQL テーブルエンジンを使用して ClickHouse を MySQL に接続する​

MySQL テーブルエンジンを使用すると、ClickHouse を MySQL に接続できます。SELECT および INSERT 文は、ClickHouse 側からでも MySQL テーブル側からでも実行できます。本記事では、MySQL テーブルエンジンの基本的な使用方法を説明します。

1. MySQL を設定する​

  1. MySQL でデータベースを作成します：
CREATE DATABASE db1;
  1. テーブルを作成する：
CREATE TABLE db1.table1 (
  id INT,
  column1 VARCHAR(255)
);
  1. サンプル行を挿入します：
INSERT INTO db1.table1
  (id, column1)
VALUES
  (1, 'abc'),
  (2, 'def'),
  (3, 'ghi');
  1. ClickHouse への接続に使用するユーザーを作成します：
CREATE USER 'mysql_clickhouse'@'%' IDENTIFIED BY 'Password123!';
  1. 必要に応じて権限を付与します。（デモンストレーション目的で、mysql_clickhouse ユーザーには管理者権限を付与しています。）
GRANT ALL PRIVILEGES ON *.* TO 'mysql_clickhouse'@'%';
注記

ClickHouse Cloud でこの機能を使用している場合、ClickHouse Cloud の IP アドレスが MySQL インスタンスにアクセスできるように許可する必要になる場合があります。 外向き（egress）トラフィックの詳細については、ClickHouse の Cloud Endpoints API を確認してください。

2. ClickHouse でテーブルを定義する​

  1. 次に、MySQL テーブルエンジンを使用する ClickHouse テーブルを作成しましょう。
CREATE TABLE mysql_table1 (
  id UInt64,
  column1 String
)
ENGINE = MySQL('mysql-host.domain.com','db1','table1','mysql_clickhouse','Password123!')

最小限必要なパラメータは次のとおりです。

parameter説明example
hostホスト名または IPmysql-host.domain.com
databaseMySQL データベース名db1
tableMySQL テーブル名table1
userMySQL に接続するためのユーザー名mysql_clickhouse
passwordMySQL に接続するためのパスワードPassword123!
注記

利用可能なパラメータの完全な一覧は、MySQL table engine のドキュメントページを参照してください。

3. 統合をテストする​

  1. MySQL でサンプル行を挿入します。
INSERT INTO db1.table1
  (id, column1)
VALUES
  (4, 'jkl');
  1. MySQL テーブルに存在していた既存の行が、先ほど追加した新しい行とあわせて ClickHouse テーブルにも格納されていることを確認します。
SELECT
    id,
    column1
FROM mysql_table1

4行が表示されるはずです：

Query id: 6d590083-841e-4e95-8715-ef37d3e95197

┌─id─┬─column1─┐
│  1 │ abc     │
│  2 │ def     │
│  3 │ ghi     │
│  4 │ jkl     │
└────┴─────────┘

4 rows in set. Elapsed: 0.044 sec.
  1. ClickHouse テーブルに行を追加します:
INSERT INTO mysql_table1
  (id, column1)
VALUES
  (5,'mno')
  1. MySQL に新しい行が追加されていることを確認します:
mysql> select id,column1 from db1.table1;

新しい行が表示されているのが確認できるはずです。

+------+---------+
| id   | column1 |
+------+---------+
|    1 | abc     |
|    2 | def     |
|    3 | ghi     |
|    4 | jkl     |
|    5 | mno     |
+------+---------+
5 rows in set (0.01 sec)

概要​

MySQL テーブルエンジンを使用すると、ClickHouse を MySQL と接続し、両者間でデータを双方向にやり取りできます。詳しくは、MySQL テーブルエンジン のドキュメントページを参照してください。