创建FOREIGN DATA WRAPPER

teledb=# CREATE FOREIGN DATA WRAPPER datalake_fdw
  		HANDLER datalake_fdw_handler
  		VALIDATOR datalake_fdw_validator;

• CREATE FOREIGN DATA WRAPPER
• FOREIGN DATA WRAPPER名字可以自行设置。

创建成功的FOREIGN DATA WRAPPER可以通过查看系统表pg_foreign_data_wrapper是否存在。

teledb=# select * from pg_foreign_data_wrapper;
fdwname    | fdwowner | fdwhandler | fdwvalidator | fdwacl | fdwoptions 
--------------+----------+------------+--------------+--------+------------
datalake_fdw |       10 |      16578 |        16579 |        | 
(1 row)

创建FOREIGN SERVER

teledb=#  CREATE SERVER minio_foreign_server
teledb-#         FOREIGN DATA WRAPPER datalake_fdw
teledb-#         OPTIONS (host 'XXX', protocol 'minio', isvirtual 'false',
teledb(#         ishttps 'false');
CREATE SERVER

• host：对象存储的endpoint，或者控制台的ip地址加端口，例如192.168.20.15:3421。
• protocol：对象存储的协议名称，可以为minio等。
• isvritual：按照virutal-host-style 还是 path-host-style 的方式来解析对象存储的主机，true为virutal-host-style。
• Ishttps：是否使用https协议。

创建成功的FOREIGN SERVER可以通过查看系统表pg_foreign_server是否存在。

teledb=# select * from pg_foreign_server;
srvname        | srvowner | srvfdw | srvtype | srvversion | srvacl |                             srvoptions                          
-----------------------+----------+--------+---------+------------+--------+-------------------------------------------------------------------------
 minio_foreign_server |       10 |  16582 |         |            |        | {host=XXX,protocol=minio,isvirtual=false,ishttps=false}
(1 row)

创建USER MAPPING

teledb=# CREATE USER MAPPING FOR XXX
        SERVER minio_foreign_server
        OPTIONS (user 'XXX', accesskey 'XXXXXXXXXXXXX', secretkey 'XXXXXXXXXX');
CREATE USER MAPPING

• User：对象存储服务用户名（如有）。
• Accesskey：对象存储服务accesskey。
• Secretkey：对象存储服务secretkey。

创建成功的USERMAPPING可以通过查看系统表pg_user_mapping是否存在。

teledb=# select * from pg_user_mapping;
 umuser | umserver |                        umoptions                    
--------+----------+---------------------------------------------------------
     10 |    16583 | {user=XXX,accesskey=XXXXXXXXXXXXX,secretkey=XXXXXXXXXX}
(1 row)