FDW for MongoDB

1. 准备 Mongo 环境

MongoDB 环境：

Host: 127.0.0.1
Port: 5888
User: mongo_user
Database: mongo_pass

2. 在 YMatrix 中创建 FDW

下面登录 YMatrix，使用 mongo_fdw 连接 MongoDB：

首先要在集群所有主机上安装 mongo 客户端库。

首先，创建 mongo_fdw 扩展：

mxadmin=# CREATE EXTENSION mongo_fdw;
CREATE EXTENSION

创建 Mongo 服务器定义：

mxadmin=# CREATE SERVER mongo_server FOREIGN DATA WRAPPER mongo_fdw OPTIONS (address '127.0.0.1', port '5888');
CREATE SERVER

创建用户映射：

mxadmin=# CREATE USER MAPPING FOR postgres
    SERVER mongo_server
    OPTIONS (username 'mongo_user', password 'mongo_pass');
CREATE USER MAPPING

创建外部表：

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

3. 使用 mongo_fdw 读写数据表

外部表创建成功后，下面就可以通过直接读写外部表来实现对 MongoDB 中的 test 表的操作。

3.1 查询数据

在 MongoDB 中查询：

db.warehouse.find
(
    {
        "warehouse_id" : 1
    }
).pretty()
{
    "_id" : ObjectId("53720b1904864dc1f5a571a0"),
    "warehouse_id" : 1,
    "warehouse_name" : "UPS",
    "warehouse_created" : ISODate("2014-12-12T07:12:10Z")
}

使用 mongo_fdw 在 YMatrix 中查询：

mxadmin=# SELECT * FROM warehouse WHERE warehouse_id = 1;
           _id            | warehouse_id | warehouse_name |     warehouse_created
--------------------------+--------------+----------------+---------------------------
 53720b1904864dc1f5a571a0 |            1 | UPS            | 2014-12-12 12:42:10+05:30
(1 row)

3.2 写入数据

向外部表插入数据：

mxadmin=# INSERT INTO warehouse VALUES (0, 2, 'Laptop', '2015-11-11T08:13:10Z');
INSERT 0 1