pg_rewrite
在线重写整表,不阻塞读写
概览
| 扩展包名 | 版本 | 分类 | 许可证 | 语言 |
|---|---|---|---|---|
pg_rewrite | 2.1.0 | ADMIN | BSD 3-Clause | C |
| ID | 扩展名 | Bin | Lib | Load | Create | Trust | Reloc | 模式 |
|---|---|---|---|---|---|---|---|---|
| 5020 | pg_rewrite | 否 | 是 | 是 | 是 | 否 | 是 | - |
| 相关扩展 | pg_repack pg_squeeze pgfincore pg_prewarm pgstattuple amcheck pageinspect pg_visibility |
|---|
版本
| 类型 | 仓库 | 版本 | PG 大版本 | 包名 | 依赖 |
|---|---|---|---|---|---|
| EXT | PGDG | 2.1.0 | 1817161514 | pg_rewrite | - |
| RPM | PGDG | 2.1.0 | 1817161514 | pg_rewrite_$v | - |
| DEB | PGDG | 2.1.0 | 1817161514 | postgresql-$v-pg-rewrite | - |
安装
您可以直接安装 pg_rewrite 扩展包的预置二进制包,首先确保 PGDG 仓库已经添加并启用:
pig repo add pgdg -u # 添加 PGDG 仓库并更新缓存
使用 pig 或者是 apt/yum/dnf 安装扩展:
pig install pg_rewrite; # 当前活跃 PG 版本安装
pig ext install -y pg_rewrite -v 18 # PG 18
pig ext install -y pg_rewrite -v 17 # PG 17
pig ext install -y pg_rewrite -v 16 # PG 16
pig ext install -y pg_rewrite -v 15 # PG 15
pig ext install -y pg_rewrite -v 14 # PG 14
dnf install -y pg_rewrite_18 # PG 18
dnf install -y pg_rewrite_17 # PG 17
dnf install -y pg_rewrite_16 # PG 16
dnf install -y pg_rewrite_15 # PG 15
dnf install -y pg_rewrite_14 # PG 14
apt install -y postgresql-18-pg-rewrite # PG 18
apt install -y postgresql-17-pg-rewrite # PG 17
apt install -y postgresql-16-pg-rewrite # PG 16
apt install -y postgresql-15-pg-rewrite # PG 15
apt install -y postgresql-14-pg-rewrite # PG 14
预加载配置:
shared_preload_libraries = 'pg_rewrite';
创建扩展:
CREATE EXTENSION pg_rewrite;
用法
pg_rewrite 需要设置 wal_level = logical,并且必须添加到 shared_preload_libraries 中。常见用例包括更改列数据类型、分区表、重新排列列以及将表移动到不同的表空间——同时允许并发读写。
重写表
创建具有目标架构的目标表,然后调用 rewrite_table():
-- 源表
CREATE TABLE measurement (id int, city_id int NOT NULL, logdate date NOT NULL, peaktemp int, PRIMARY KEY(id, logdate));
-- 具有新模式的目标表(例如 bigint id + 分区)
CREATE TABLE measurement_aux (id bigint, city_id int NOT NULL, logdate date NOT NULL, peaktemp int, PRIMARY KEY(id, logdate))
PARTITION BY RANGE (logdate);
CREATE TABLE measurement_y2006m02 PARTITION OF measurement_aux FOR VALUES FROM ('2006-02-01') TO ('2006-03-01');
-- 执行重写(复制数据、应用并发变更,然后重命名)
SELECT rewrite_table('measurement', 'measurement_aux', 'measurement_old');
源表和目标表都必须有一个标识索引(通常是主键)。该函数会复制所有行,通过逻辑解码重放并发变更,然后原子性地重命名表。
进度监控
SELECT * FROM pg_rewrite_progress;
显示 ins_initial(初始复制的行数)、ins、upd、del(应用的并发变更)。
配置
rewrite.max_xlock_time– 最终重命名阶段持有排他锁的最大时间(毫秒)。默认0(不限制)。设置为例如100可将锁定时间限制在 0.1 秒;超出时函数会重试。
SET rewrite.max_xlock_time TO 100;
约束处理
- PRIMARY KEY、UNIQUE、EXCLUDE:在调用
rewrite_table()之前添加到目标表 - CHECK、NOT NULL(PG18+)、FOREIGN KEY:自动创建为 NOT VALID;使用
ALTER TABLE ... VALIDATE CONSTRAINT ...验证