跳到主要内容
跳到主要内容

ExternalDistributed

ExternalDistributed 引擎允许在存储于远程服务器 MySQL 或 PostgreSQL 的数据上执行 SELECT 查询。接收 MySQL 或 PostgreSQL 引擎作为参数，因此可以实现分片。

创建表​

CREATE TABLE [IF NOT EXISTS] [db.]table_name [ON CLUSTER cluster]
(
    name1 [type1] [DEFAULT|MATERIALIZED|ALIAS expr1] [TTL expr1],
    name2 [type2] [DEFAULT|MATERIALIZED|ALIAS expr2] [TTL expr2],
    ...
) ENGINE = ExternalDistributed('engine', 'host:port', 'database', 'table', 'user', 'password');

查看 CREATE TABLE 查询的详细描述。

表结构可以与原始表结构不同：

  • 列名应与原始表中的相同，但可以只使用其中一些列，并且顺序可以不同。
  • 列类型可以与原始表中的不同。 ClickHouse 会尝试 cast 值为 ClickHouse 数据类型。

引擎参数

  • engine — 表引擎 MySQL 或 PostgreSQL。
  • host:port — MySQL 或 PostgreSQL 服务器地址。
  • database — 远程数据库名称。
  • table — 远程表名称。
  • user — 用户名。
  • password — 用户密码。

实现细节​

支持多个副本，副本之间必须用 | 分隔，而分片之间则必须用 , 分隔。例如：

CREATE TABLE test_shards (id UInt32, name String, age UInt32, money UInt32) ENGINE = ExternalDistributed('MySQL', `mysql{1|2}:3306,mysql{3|4}:3306`, 'clickhouse', 'test_replicas', 'root', 'clickhouse');

在指定副本时，在读取每个分片时会选择一个可用的副本。如果连接失败，将选择下一个副本，如此类推。如果所有副本的连接尝试都失败，则会重复尝试多次，同样的方式。

您可以为每个分片指定任意数量的副本和任意数量的分片。

另请参见