PostgreSQL FDW：能否自动为外部模式表添加来源标识列？

核心结论 #

原生PostgreSQL FDW（如postgres_fdw）本身不支持自动为外部表添加来源标识列，但可以通过以下几种成熟方案实现需求，无需手动修改所有远程表：

1. 视图封装（最直接的原生方案） #

不需要修改远程表或FDW配置，在控制节点对每个外部表创建封装视图，手动注入来源标识列：

-- 假设外部模式为us_east1_schema，远程表为users
CREATE VIEW us_east1_users AS
SELECT *, 'us_east1' AS region FROM us_east1_schema.users;

-- 同理处理eu_central1的表
CREATE VIEW eu_central1_users AS
SELECT *, 'eu_central1' AS region FROM eu_central1_schema.users;

如果要批量处理整个外部模式的表，可以用plpgsql写脚本自动生成视图：

CREATE OR REPLACE FUNCTION create_region_views(schema_name text, region text)
RETURNS void AS $$
DECLARE
    rec record;
BEGIN
    FOR rec IN SELECT table_name FROM information_schema.tables WHERE table_schema = schema_name LOOP
        EXECUTE format(
            'CREATE OR REPLACE VIEW %I AS SELECT *, %L AS region FROM %I.%I',
            region || '_' || rec.table_name,
            region,
            schema_name,
            rec.table_name
        );
    END LOOP;
END;
$$ LANGUAGE plpgsql;

-- 调用生成us_east1模式下所有表的视图
SELECT create_region_views('us_east1_schema', 'us_east1');
-- 调用生成eu_central1模式下所有表的视图
SELECT create_region_views('eu_central1_schema', 'eu_central1');

这种方案完全基于原生功能，适配任何FDW，后续创建聚合分区表时直接基于视图即可。

2. 自定义FDW扩展（进阶方案） #

如果需要更底层的自动注入，可以基于postgres_fdw二次开发自定义FDW扩展，在查询时自动追加来源列。不过这种方案需要PostgreSQL开发能力，适合有深度定制需求的场景。

3. 现成工具简化流程 #

PostgreSQL生态中有工具可以替代手动编写plpgsql脚本：

• pg_partman：虽主打分区管理，但可结合其自动刷新功能，配合视图封装实现批量处理；
• fdw_utils：部分版本提供批量生成带额外列的外部视图的功能，减少手动编码量；
• Citus：若使用分布式PostgreSQL扩展Citus（匹配你提到的多租户分布式架构），其分片放置机制可自动关联数据来源区域，直接支持按region分区的聚合查询，无需手动添加列。

多租户地理分布式场景适配 #

参考《面向多租户应用的地理分布式PostgreSQL》架构，控制节点可按以下步骤实现区域标识：

1. 为每个区域的远程服务器创建独立外部模式（如us_east1、eu_central1）；
2. 用上述批量视图脚本为每个模式下的表生成带region列的视图；
3. 创建聚合分区表时以region为分区键，直接从视图拉取数据：

-- 创建按region分区的聚合表
CREATE TABLE aggregated_users (
    id int,
    name text,
    email text,
    region text
) PARTITION BY LIST (region);

-- 创建对应分区
CREATE TABLE aggregated_users_us_east1 PARTITION OF aggregated_users FOR VALUES IN ('us_east1');
CREATE TABLE aggregated_users_eu_central1 PARTITION OF aggregated_users FOR VALUES IN ('eu_central1');

-- 插入数据（或用触发器/定时任务同步）
INSERT INTO aggregated_users SELECT * FROM us_east1_users;
INSERT INTO aggregated_users SELECT * FROM eu_central1_users;

关键优势：无需修改远程表 #

所有标识逻辑都在控制节点的视图或扩展层实现，远程表保持原有结构即可，避免跨区域的Schema同步成本。

内容的提问来源于stack exchange，提问作者Filip Allberg