mysql テーブル関数
リモート MySQL サーバーに保存されているデータに対して SELECT および INSERT クエリを実行できます。
構文
引数
| 引数 | 説明 |
|---|---|
host:port | MySQL サーバーアドレス。 |
database | リモートデータベース名。 |
table | リモートテーブル名。 |
user | MySQL ユーザー。 |
password | ユーザーパスワード。 |
replace_query | INSERT INTO クエリを REPLACE INTO に変換するフラグ。可能な値:- 0 - クエリは INSERT INTO として実行されます。- 1 - クエリは REPLACE INTO として実行されます。 |
on_duplicate_clause | INSERT クエリに追加される ON DUPLICATE KEY on_duplicate_clause 式。replace_query = 0 の場合にのみ指定できます（replace_query = 1 と on_duplicate_clause を同時に渡すと、ClickHouse は例外を生成します）。例: INSERT INTO t (c1,c2) VALUES ('a', 2) ON DUPLICATE KEY UPDATE c2 = c2 + 1;この on_duplicate_clause は UPDATE c2 = c2 + 1 です。ON DUPLICATE KEY 句で使用できる on_duplicate_clause については MySQL ドキュメントを参照してください。 |
引数は named collections を使用しても渡すことができます。この場合、host と port は別々に指定する必要があります。このアプローチは本番環境で推奨されます。
=, !=, >, >=, <, <= のような単純な WHERE 句は現在 MySQL サーバーで実行されます。
残りの条件や LIMIT サンプリング制約は、MySQL へのクエリが終了した後に ClickHouse でのみ実行されます。
複数のレプリカを | で列挙することがサポートされています。例えば：
または
戻り値
元の MySQL テーブルと同じカラムを持つテーブルオブジェクト。
注記
MySQL の特定のデータ型は異なる ClickHouse 型にマッピングできる場合があります - これはクエリレベルの設定 mysql_datatypes_support_level によって対処されます。
注記
INSERT クエリでは、テーブル関数 mysql(...) とカラム名リストを区別するために、キーワード FUNCTION または TABLE FUNCTION を使用する必要があります。以下に例を示します。
例
MySQL のテーブル：
ClickHouse からデータを選択：
または named collections を使用：
置き換えと挿入：
MySQL テーブルから ClickHouse テーブルにデータをコピー：
または、現在の最大 ID に基づいて MySQL から増分バッチのみをコピーする場合：
