MySQL表引擎
Clickhouse 上的MySQL引擎可以对存在远程MySQL服务器上的数据执行SELECT
查询。
调用格式:
MySQL('host:port', 'database', 'table', 'user', 'password', replace_query, 'on_duplicate_clause');
调用参数
-
host:port
— MySQL 服务器地址。 -
database
— 数据库的名称。 -
table
— 表名称。 -
user
— 数据库用户。 -
password
— 用户密码。 -
replace_query
— 将INSERT INTO
查询是否替换为REPLACE INTO
的标志。如果replace_query=1
,则替换查询 -
'on_duplicate_clause'
— 将ON DUPLICATE KEY UPDATE 'on_duplicate_clause'
表达式添加到INSERT
查询语句中。例如:impression = VALUES(impression) + impression
。如果需要指定'on_duplicate_clause'
,则需要设置replace_query=0
。如果同时设置replace_query = 1
和'on_duplicate_clause'
,则会抛出异常。
此时,简单的WHERE
子句(例如 =, !=, >, >=, <, <=
)是在MySQL服务器上执行。
其余条件以及LIMIT
采样约束语句仅在对MySQL的查询完成后才在ClickHouse中执行。
MySQL
引擎不支持NULL
值,因此,当从MySQL表中读取数据时,NULL
将转换为指定列类型的默认值(通常为0或空字符串)。
示例:
select * from MySQL('host:port', 'database', 'table', 'user', 'password', replace_query, 'on_duplicate_clause');
mysql 远程表映射
MySQL引擎用于将远程的MySQL服务器中的表映射到ClickHouse中,并允许您对表进行INSERT
和SELECT
查询,以方便您在ClickHouse与MySQL之间进行数据交换
MySQL
数据库引擎会将对其的查询转换为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
— MySQL数据库名称user
— MySQL用户名password
— MySQL用户密码
支持的数据类型
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.
全局变量支持
为了更好地兼容,您可以在SQL样式中设置全局变量,如@@identifier
.
支持这些变量:
version
max_allowed_packet
!!! warning "警告" 到目前为止,这些变量是存根,并且不对应任何内容。
示例: SELECT @@version;
MySQL操作示例:
mysql> USE test;
Database changedmysql> 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)