MySQL

リモートのMySQLサーバーに保存されているデータに対してSELECTおよびINSERTクエリを実行することができます。

構文

mysql('host:port', 'database', 'table', 'user', 'password'[, replace_query, 'on_duplicate_clause'])

引数

• 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式。replace_query = 0と同時に指定することができます（replace_query = 1とon_duplicate_clauseを同時に渡すと、MyScaleは例外を生成します）。

  例: 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のドキュメントを参照してください。

• 現在は、=、!=、>、>=、<、<=などの単純なWHERE句はMySQLサーバーで実行されます。

• 残りの条件とLIMITサンプリング制約は、MySQLへのクエリが完了した後にのみMyScaleで実行されます。

複数のレプリカをサポートし、|でリストアップする必要があります。例:

SELECT name FROM mysql(`mysql_host{1|2|3}:3306`, '[mysql_database]', '[mysql_table]', '[mysql_user]', '[mysql_password]');

または

SELECT name FROM mysql(`mysql_host1:3306|mysql_host2:3306|mysql_host3:3306`, '[mysql_database]', '[mysql_table]', '[mysql_user]', '[mysql_password]');

返される値

元のMySQLテーブルと同じ列を持つテーブルオブジェクト。

例

MySQLのテーブル

# CREATE DATABASE
mysql> CREATE DATABASE test;
Query OK, 1 row affected (0.00 sec)
# CREATE TABLE
mysql> CREATE TABLE `test`.`test` (
    ->  `int_id` INT NOT NULL AUTO_INCREMENT,
    ->  `float` FLOAT NOT NULL,
    ->  PRIMARY KEY (`int_id`));
Query OK, 0 rows affected (0.01 sec)
# INSERT
mysql> INSERT INTO test.test (`int_id`, `float`) VALUES (1,2);
Query OK, 1 row affected (0.00 sec)
# SELECT
mysql> SELECT * FROM test.test;
+--------+-------+
| int_id | float |
+--------+-------+
|      1 |     2 |
+--------+-------+
1 row in set (0.00 sec)

MySQLからデータを選択する

SELECT * FROM mysql('[ホスト:ポート]', 'test', 'test', '[mysql_user]', '[mysql_password]');

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

置換と挿入

# INSERT
INSERT INTO FUNCTION mysql('[host:port]', 'test', 'test', '[mysql_user]', '[mysql_password]') (int_id, float) VALUES (2, 3);  
# REPLACE
INSERT INTO TABLE FUNCTION mysql('[host:port]', 'test', 'test', '[mysql_user]', '[mysql_password]', 0, 'UPDATE int_id = int_id + 1') (int_id, float) VALUES (2, 4);
# SELECT
SELECT * FROM mysql('[host:port]', 'test', 'test', '[mysql_user]', '[mysql_password]');

┌─int_id─┬─float─┐
│      1 │     3 │
│      3 │     3 │
└────────┴───────┘

MySQLのテーブルからデータをMyScaleのテーブルにコピーする

# CREATE TABLE
CREATE TABLE mysql_copy
(
  `id` UInt64 NOT NULL,
  `score` FLOAT NOT NULL,
)
ENGINE = MergeTree
ORDER BY (id);
# INSERT
INSERT INTO mysql_copy
SELECT * FROM mysql('[host:port]', 'test', 'test', '[mysql_user]', '[mysql_password]');
# SELECT
SELECT * from mysql_copy;

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

現在の最大IDに基づいてMySQLのテーブルから増分バッチのみをコピーする

# INSERT
INSERT INTO mysql_copy
SELECT * FROM mysql('[host:port]', 'test', 'test', '[mysql_user]', '[mysql_password]');
WHERE int_id > (SELECT max(id) from mysql_copy);
# SELECT
SELECT * FROM mysql_copy;

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

関連コンテンツ

• MySQLテーブルエンジン (opens new window)
• 辞書ソースとしてのMySQLの使用 (opens new window)