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

操作分区和分区片段

分区 的以下操作可用:

DETACH PARTITION|PART

将指定分区的所有数据移动到 detached 目录。服务器会将已移除的数据分区忘记,就好像它不存在一样。服务器在你进行 ATTACH 查询之前,不会知道这些数据。

示例:

有关设置分区表达式的详细信息,请参阅 如何设置分区表达式 部分。

执行查询后,你可以对 detached 目录中的数据随心所欲 - 从文件系统中删除它,或只是留下它。

此查询是复制的 - 它将数据移动到所有副本的 detached 目录。请注意,您只能在主副本上执行此查询。要确定某个副本是否为主副本,请对 system.replicas 表执行 SELECT 查询。或者,在所有副本上进行 DETACH 查询更简单 - 所有副本都会抛出异常,除了主副本(因为允许多个主副本)。

DROP PARTITION|PART

从表中删除指定分区。此查询将分区标记为不活动,并完全删除数据,约需 10 分钟。

有关设置分区表达式的详细信息,请参阅 如何设置分区表达式 部分。

此查询是复制的 - 它在所有副本上删除数据。

示例:

DROP DETACHED PARTITION|PART

detached 中移除指定的分区片段或所有指定分区的分区片段。有关设置分区表达式的更多信息,请参阅 如何设置分区表达式 部分。

FORGET PARTITION

从 ZooKeeper 中移除有关空分区的所有元数据。如果分区不为空或未知,查询将失败。确保仅对将来不会再使用的分区执行。

有关设置分区表达式的详细信息,请参阅 如何设置分区表达式 部分。

示例:

ATTACH PARTITION|PART

detached 目录向表中添加数据。可以为整个分区或单独的分区片段添加数据。示例:

有关设置分区表达式的详细信息,请参阅 如何设置分区表达式 部分。

此查询是复制的。副本发起者检查 detached 目录中是否存在数据。如果存在数据,则查询将检查其完整性。如果一切正常,查询将数据添加到表中。

如果非发起副本在其自己的 detached 文件夹中找到具有正确校验和的分区片段,则会在不从其他副本获取数据的情况下附加数据。如果没有具有正确校验和的分区片段,则从具有该分区片段的任何副本下载数据。

你可以在一个副本的 detached 目录中放置数据,并使用 ALTER ... ATTACH 查询将其添加到所有副本的表中。

ATTACH PARTITION FROM

此查询将数据分区从 table1 复制到 table2

请注意:

  • 数据既不会从 table1 中删除,也不会从 table2 中删除。
  • table1 可以是临时表。

要使查询成功执行,必须满足以下条件:

  • 两个表必须具有相同的结构。
  • 两个表必须具有相同的分区键,相同的排序键和相同的主键。
  • 两个表必须具有相同的存储策略。
  • 目标表必须包含源表的所有索引和投影。如果在目标表中启用了 enforce_index_structure_match_on_partition_manipulation 设置,则索引和投影必须完全相同。否则,目标表可以拥有源表索引和投影的超集。

REPLACE PARTITION

此查询将数据分区从 table1 复制到 table2 并替换 table2 中的现有分区。该操作是原子的。

请注意:

  • 数据不会从 table1 中删除。
  • table1 可以是临时表。

要使查询成功执行,必须满足以下条件:

  • 两个表必须具有相同的结构。
  • 两个表必须具有相同的分区键,相同的排序键和相同的主键。
  • 两个表必须具有相同的存储策略。
  • 目标表必须包含源表的所有索引和投影。如果在目标表中启用了 enforce_index_structure_match_on_partition_manipulation 设置,则索引和投影必须完全相同。否则,目标表可以拥有源表索引和投影的超集。

MOVE PARTITION TO TABLE

此查询将在删除数据的情况下将数据分区从 table_source 移动到 table_dest

要使查询成功执行,必须满足以下条件:

  • 两个表必须具有相同的结构。
  • 两个表必须具有相同的分区键,相同的排序键和相同的主键。
  • 两个表必须具有相同的存储策略。
  • 两个表必须属于相同引擎系列(复制或非复制)。
  • 目标表必须包含源表的所有索引和投影。如果在目标表中启用了 enforce_index_structure_match_on_partition_manipulation 设置,则索引和投影必须完全相同。否则,目标表可以拥有源表索引和投影的超集。

CLEAR COLUMN IN PARTITION

重置分区中指定列的所有值。如果在创建表时确定了 DEFAULT 子句,则此查询将列值设置为指定的默认值。

示例:

FREEZE PARTITION

此查询创建指定分区的本地备份。如果省略 PARTITION 子句,则查询一次性创建所有分区的备份。

备注

整个备份过程在不停止服务器的情况下进行。

请注意,对于旧式表,您可以指定分区名称的前缀(例如,2019) - 然后将查询为所有对应分区创建备份。有关设置分区表达式的详细信息,请参阅 如何设置分区表达式 部分。

在执行时,对于数据快照,查询创建指向表数据的硬链接。硬链接放在目录 /var/lib/clickhouse/shadow/N/... 下,其中:

  • /var/lib/clickhouse/ 是在配置中指定的工作 ClickHouse 目录。
  • N 是备份的递增编号。
  • 如果指定了 WITH NAME 参数,则使用 'backup_name' 参数的值替代递增编号。
备注

如果您使用 用于数据存储的磁盘集,则在每个磁盘上都会出现 shadow/N 目录,存储与 PARTITION 表达式匹配的数据片段。

备份内部会生成与 /var/lib/clickhouse/ 内部相同的目录结构。查询执行 chmod 以禁止对所有文件的写入。

创建备份后,您可以从 /var/lib/clickhouse/shadow/ 将数据复制到远程服务器,然后从本地服务器中删除它。请注意,ALTER t FREEZE PARTITION 查询不是复制的。它仅在本地服务器上创建本地备份。

该查询几乎瞬间创建备份(但首先会等待当前查询完成)。

ALTER TABLE t FREEZE PARTITION 仅复制数据,而不复制表元数据。要备份表元数据,请复制文件 /var/lib/clickhouse/metadata/database/table.sql

要从备份中恢复数据,请执行以下操作:

  1. 如果表不存在,则创建该表。要查看查询,请使用 .sql 文件(将 ATTACH 替换为 CREATE)。
  2. 从备份内部的 data/database/table/ 目录复制数据到 /var/lib/clickhouse/data/database/table/detached/ 目录。
  3. 运行 ALTER TABLE t ATTACH PARTITION 查询以将数据添加到表中。

从备份中恢复不需要停止服务器。

有关备份和恢复数据的更多信息,请参阅 数据备份 部分。

UNFREEZE PARTITION

从磁盘中移除具有指定名称的 freezed 分区。如果省略 PARTITION 子句,则查询一次性删除所有分区的备份。

CLEAR INDEX IN PARTITION

该查询的作用类似于 CLEAR COLUMN,但它重置的是索引,而不是列数据。

FETCH PARTITION|PART

从另一台服务器下载分区。此查询仅适用于复制表。

该查询执行以下操作:

  1. 从指定分片下载分区|分区片段。在 'path-in-zookeeper' 中,你必须指定 ZooKeeper 中分片的路径。
  2. 然后,该查询将下载的数据放置在 table_name 表的 detached 目录中。使用 ATTACH PARTITION|PART 查询将数据添加到表中。

例如:

  1. FETCH PARTITION
  1. FETCH PART

请注意:

  • ALTER ... FETCH PARTITION|PART 查询不会被复制。它仅将分区或分区片段放置在本地服务器的 detached 目录中。
  • ALTER TABLE ... ATTACH 查询是复制的。它将数据添加到所有副本。数据将从 detached 目录中的一个副本添加到其他副本 - 从相邻副本中添加。

在下载之前,系统将检查分区是否存在以及表结构是否匹配。最合适的副本会从健康的副本中自动选择。

尽管该查询被称为 ALTER TABLE,但它不会改变表结构,也不会立即改变表中可用的数据。

MOVE PARTITION|PART

将分区或数据片段移动到 MergeTree 引擎表的另一卷或磁盘。请参见 使用多个块设备进行数据存储

ALTER TABLE t MOVE 查询:

  • 不进行复制,因为不同副本可以具有不同的存储策略。
  • 如果指定的磁盘或卷未配置,则返回错误。如果不能应用存储策略中指定的数据移动条件,查询也会返回错误。
  • 在数据被后台进程、并发 ALTER TABLE t MOVE 查询或后台数据合并移动的情况下,可能会返回错误。在这种情况下,用户不应执行任何额外操作。

示例:

UPDATE IN PARTITION

按照指定的过滤表达式操作指定分区中的数据。实现为 突变

语法:

示例

参见

DELETE IN PARTITION

在指定的分区中删除符合指定过滤表达式的数据。实现为 突变

语法:

示例

参见

如何设置分区表达式

您可以通过不同方式在 ALTER ... PARTITION 查询中指定分区表达式:

  • 使用 system.parts 表中的 partition 列的值。例如,ALTER TABLE visits DETACH PARTITION 201901
  • 使用关键字 ALL。它仅可与 DROP/DETACH/ATTACH/ATTACH FROM 一起使用。例如,ALTER TABLE visits ATTACH PARTITION ALL
  • 作为与表分区键元组匹配的表达式或常量的元组。在单个元素分区键的情况下,表达式应使用 tuple (...) 函数包装。例如,`ALTER TABLE visits DETACH PARTITION tuple(toYYYYMM(toDate('2019-01-25')))。
  • 使用分区 ID。分区 ID 是分区的字符串标识符(如果可能是可读的)。必须在 PARTITION ID 子句中指定分区 ID,且必须用单引号包围。例如,ALTER TABLE visits DETACH PARTITION ID '201901'
  • ALTER ATTACH PARTDROP DETACHED PART 查询中,要指定分区片段的名称,请使用来自 system.detached_parts 表的 name 列的字符串字面值。例如,ALTER TABLE visits ATTACH PART '201901_1_1_0'

指定分区时使用引号的方式取决于分区表达式的类型。例如,对于 String 类型,您必须在引号中指定其名称(')。对于 DateInt* 类型,则无需引号。

上述所有规则同样适用于 OPTIMIZE 查询。如果您需要在优化非分区表时仅指定分区,则设置表达式为 PARTITION tuple()。例如:

IN PARTITION 指定将在 ALTER TABLE 查询的结果中应用到的 UPDATEDELETE 表达式的分区。新分区仅从指定分区中创建。通过这种方式,IN PARTITION 有助于减少在表被分为多个分区时的负载,而你只需逐个更新数据点。

ALTER ... PARTITION 查询的示例在测试中演示 00502_custom_partitioning_local00502_custom_partitioning_replicated_zookeeper