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 からの増分バッチのみをコピーする場合: