PostgreSQL逻辑复制默认不支持列级同步，但可通过影子表+触发器、逻辑解码插件或中间ETL工具实现。推荐方案：在源库创建仅含所需列的影子表并启用发布，通过触发器同步原始表变更，目标库订阅该表；高级方案可使用支持列过滤的wal2json插件或Debezium等中间件过滤列，实现灵活、低影响的列级复制，需注意主键要求、性能开销与结构同步维护。
PostgreSQL 的逻辑复制默认是以表为单位进行的，不直接支持列级（只同步某些列）复制。但通过一些变通方式，可以在逻辑复制中实现仅同步特定列的效果。以下是几种可行的 PostgreSQL 列级复制方案。
使用视图 + 逻辑复制发布（推荐方案）
PostgreSQL 允许将视图作为逻辑复制的发布对象，虽然不能直接发布视图，但可以通过“只复制所需列”的表或物化视图来间接实现。实际操作思路：
- 在源数据库创建一个只包含需要同步列的视图或影子表。
- 对这个影子表启用逻辑复制发布。
- 在目标端订阅该影子表。
示例：
-- 源库：原始表
CREATE TABLE public.user_info (
id serial PRIMARY KEY,
name text,
email text,
phone text,
salary numeric, -- 敏感字段，不想同步
created_at timestamptz
);
-- 创建只包含需同步列的影子表
CREATE TABLE public.user_info_pub AS
SELECT id, name, email, created_at FROM public.user_info WHERE false;
-- 或者用视图（但不能直接发布视图，需配合物化）
CREATE MATERIALIZED VIEW public.user_info_filtered AS
SELECT id, name, email, created_at FROM public.user_info;
-- 启动逻辑复制前，需确保影子表结构一致
CREATE TABLE public.user_info_replica (
id int PRIMARY KEY,
name text,
email text,
created_at timestamptz
);
创建发布：
CREATE PUBLICATION user_pub FOR TABLE user_info_replica;
使用触发器或逻辑解码插件将原始表的变更同步到影子表：
CREATE OR REPLACE FUNCTION fn_sync_user_replica()
RETURNS TRIGGER AS $$
BEGIN
IF (TG_OP = 'INSERT') THEN
INSERT INTO user_info_replica (id, name, email, created_at)
VALUES (NEW.id, NEW.name, NEW.email, NEW.created_at);
ELSIF (TG_OP = 'UPDATE') THEN
UPDATE user_info_replica
SET name = NEW.name, email = NEW.email, created_at = NEW.created_at
WHERE id = NEW.id;
ELSIF (TG_OP = 'DELETE') THEN
DELETE FROM user_info_replica WHERE id = OLD.id;
END IF;
RETURN NULL;
END;
$$ LANGUAGE plpgsql;
CREATE TRIGGER tr_user_to_replica
AFTER INSERT OR UPDATE OR DELETE ON user_info
FOR EACH ROW EXECUTE FUNCTION fn_sync_user_replica();
目标库创建对应表并订阅：
CREATE SUBSCRIPTION sub_user_replica CONNECTION 'host=source_host dbname=mydb user=repuser' PUBLICATION user_pub;
利用逻辑解码插件自定义输出（高级用法）
如果你使用的是 pg_logical_slot_get_changes 或自定义逻辑解码插件（如 test_decoding、wal2json），可以编写插件过滤输出的列。wal2json 支持列过滤（需编译版本支持）：
SELECT * FROM pg_logical_slot_get_changes( 'slot_name', NULL, NULL, 'format-version', '1', 'filter-tables', 'public.user_info', 'filter-by-columns', 'id,name,email,created_at' -- 假设插件支持 );
注意：原生 wal2json 不直接支持列过滤，但可自行扩展或使用 fork 版本（如 wal2json_rfc 或定制版）。
中间层ETL工具过滤列（灵活方案）
使用外部工具如 Debezium、pg_chameleon、Slony 或自研程序消费逻辑复制槽的变更数据，在应用层过滤列后再写入目标库。优点：
- 完全控制同步哪些列。
- 支持跨数据库、数据清洗、脱敏等处理。
- 不影响源库主业务表。
流程示意：
- 源库开启逻辑复制槽。
- Debezium 监听 WAL 变更。
- 转换阶段移除不需要的列（如 salary）。
- 写入目标 PostgreSQL 或其他数据库。
限制与注意事项
- 逻辑复制要求主键或 REPLICA IDENTITY，影子表也需满足。
- 触发器方式会增加源库负载，注意性能影响。
- 列类型和约束需在影子表中保持兼容。
- DDL 变更需手动同步影子表结构。
- 不支持直接发布视图，必须使用普通表或物化视图（手动刷新）。
基本上就这些方法。PostgreSQL 原生不支持列级复制，但通过影子表+触发器、逻辑解码定制或中间件，完全可以实现只同步特定列的需求。选择哪种方案取决于你对实时性、维护成本和系统复杂度的权衡。
