MySQL データベースエンジン

Not supported in ClickHouse Cloud

リモートの MySQL サーバー上のデータベースに接続し、ClickHouse と MySQL 間でデータをやり取りするために INSERT および SELECT クエリを実行できます。

MySQL データベースエンジンはクエリを MySQL サーバー向けに変換するため、SHOW TABLES や SHOW CREATE TABLE などの操作を実行できます。

次のクエリは実行できません。

• RENAME
• CREATE TABLE
• ALTER

データベースの作成

CREATE DATABASE [IF NOT EXISTS] db_name [ON CLUSTER cluster]
ENGINE = MySQL('host:port', ['database' | database], 'user', 'password')

エンジンのパラメータ

• host:port — MySQL サーバーのアドレス。
• database — リモートデータベース名。
• user — MySQL ユーザー。
• password — ユーザーのパスワード。

データ型サポート

MySQL	ClickHouse
UNSIGNED TINYINT	UInt8
TINYINT	Int8
UNSIGNED SMALLINT	UInt16
SMALLINT	Int16
UNSIGNED INT, UNSIGNED MEDIUMINT	UInt32
INT, MEDIUMINT	Int32
UNSIGNED BIGINT	UInt64
BIGINT	Int64
FLOAT	Float32
DOUBLE	Float64
DATE	Date
DATETIME, TIMESTAMP	DateTime
BINARY	FixedString

上記以外の MySQL のデータ型はすべて String に変換されます。

Nullable をサポートします。

グローバル変数のサポート

互換性を高めるために、グローバル変数を MySQL 互換の @@identifier 形式で参照できます。

次の変数がサポートされています:

• version
• max_allowed_packet

注記

現時点では、これらの変数はスタブであり、実際には何も参照していません。

例:

SELECT @@version;

使用例

MySQL のテーブル:

mysql> USE test;
Database changed

mysql> CREATE TABLE `mysql_table` (
    ->   `int_id` INT NOT NULL AUTO_INCREMENT,
    ->   `float` FLOAT NOT NULL,
    ->   PRIMARY KEY (`int_id`));
Query OK, 0 rows affected (0,09 sec)

mysql> insert into mysql_table (`int_id`, `float`) VALUES (1,2);
Query OK, 1 row affected (0,00 sec)

mysql> select * from mysql_table;
+------+-----+
| int_id | value |
+------+-----+
|      1 |     2 |
+------+-----+
1 row in set (0,00 sec)

MySQL サーバーとデータをやり取りする ClickHouse のデータベース：

CREATE DATABASE mysql_db ENGINE = MySQL('localhost:3306', 'test', 'my_user', 'user_password') SETTINGS read_write_timeout=10000, connect_timeout=100;

SHOW DATABASES

┌─name─────┐
│ default  │
│ mysql_db │
│ system   │
└──────────┘

SHOW TABLES FROM mysql_db

┌─name─────────┐
│  mysql_table │
└──────────────┘

SELECT * FROM mysql_db.mysql_table

┌─int_id─┬─value─┐
│      1 │     2 │
└────────┴───────┘

INSERT INTO mysql_db.mysql_table VALUES (3,4)

SELECT * FROM mysql_db.mysql_table

┌─int_id─┬─value─┐
│      1 │     2 │
│      3 │     4 │
└────────┴───────┘