メインコンテンツまでスキップ
メインコンテンツまでスキップ

MySQLとClickHouseの統合

このページでは、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インスタンスにアクセスできるようにする必要があります。 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説明例
hostホスト名またはIPmysql-host.domain.com
databasemysqlデータベース名db1
tablemysqlテーブル名table1
usermysqlに接続するユーザー名mysql_clickhouse
passwordmysqlに接続するパスワードPassword123!
注記

完全なパラメータのリストについては、MySQLテーブルエンジンのドキュメントページをご覧ください。

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テーブルエンジンのドキュメントページを必ずご確認ください。