mongo_fdw

概览

版本

安装

您可以直接安装 mongo_fdw 扩展包的预置二进制包，首先确保 PGDG 仓库已经添加并启用：

pig repo add pgdg -u          # 添加 PGDG 仓库并更新缓存

使用 pig 或者是 apt/yum/dnf 安装扩展：

• 安装
• pig
• dnf

pig install mongo_fdw;          # 当前活跃 PG 版本安装

pig ext install -y mongo_fdw -v 18  # PG 18
pig ext install -y mongo_fdw -v 17  # PG 17
pig ext install -y mongo_fdw -v 16  # PG 16
pig ext install -y mongo_fdw -v 15  # PG 15
pig ext install -y mongo_fdw -v 14  # PG 14

dnf install -y mongo_fdw_18       # PG 18
dnf install -y mongo_fdw_17       # PG 17
dnf install -y mongo_fdw_16       # PG 16
dnf install -y mongo_fdw_15       # PG 15
dnf install -y mongo_fdw_14       # PG 14

创建扩展：

CREATE EXTENSION mongo_fdw;

用法

mongo_fdw: 访问 MongoDB 的外部数据包装器

创建服务器

CREATE EXTENSION mongo_fdw;

CREATE SERVER mongo_server FOREIGN DATA WRAPPER mongo_fdw
  OPTIONS (address '127.0.0.1', port '27017');

服务器选项： address（默认 127.0.0.1）、port（默认 27017）、authentication_database、replica_set、read_preference（primary、secondary、primaryPreferred、secondaryPreferred、nearest）、ssl（默认 false）、pem_file、pem_pwd、ca_file、ca_dir、crl_file、weak_cert_validation、use_remote_estimate（默认 false）、enable_join_pushdown（默认 true）、enable_aggregate_pushdown（默认 true）、enable_order_by_pushdown（默认 true）。

创建用户映射

CREATE USER MAPPING FOR pguser SERVER mongo_server
  OPTIONS (username 'mongouser', password 'mongopass');

创建外部表

CREATE FOREIGN TABLE warehouse (
  _id name,
  warehouse_id int,
  warehouse_name text,
  warehouse_created timestamptz
)
SERVER mongo_server
OPTIONS (database 'mydb', collection 'warehouse');

重要： 第一列必须是 name 类型的 _id（MongoDB 的对象标识符）。

表选项： database（默认 test）、collection（默认为表名）、enable_join_pushdown、enable_aggregate_pushdown、enable_order_by_pushdown。

CRUD 操作

SELECT warehouse_id, warehouse_name FROM warehouse WHERE warehouse_id > 10;
INSERT INTO warehouse VALUES ('new_id', 100, 'New Warehouse', now());
UPDATE warehouse SET warehouse_name = 'Updated' WHERE warehouse_id = 100;
DELETE FROM warehouse WHERE warehouse_id = 100;

下推特性

mongo_fdw 将 WHERE 子句、同一服务器上外部表之间的 JOIN、聚合函数和 ORDER BY 下推到 MongoDB，以实现高效查询执行。

注意事项

• BSON 仅支持 UTF-8；确保 PostgreSQL 数据库使用 UTF-8 编码
• 包含大写字母或点号（用于嵌套文档）的列名需要双引号
• PostgreSQL 默认将列名限制为 63 个字符