VastbaseG100

基于openGauss内核开发的企业级关系型数据库。

Menu

Oracle_FDW

功能描述

支持创建外部数据封装器oracle_fdw,连接Oracle数据库,并能在外部表上进行查询、插入、更新和删除操作。

注意事项

  • 两个Oracle外表间的SELECT JOIN不支持下推到Oracle server执行,会被分成两条SQL语句传递到Oracle执行,然后在Vastbase处汇总处理结果。
  • 不支持IMPORT FOREIGN SCHEMA语法。
  • 不支持对外表进行CREATE TRIGGER操作。

编译Oracle_FDW

编译oracle_fdw需要安装Oracle的开发库和头文件。

1、选择合适的运行环境和版本,下载Basic Package和SDK Package并安装。另外SQLPlus Package是Oracle的客户端工具,也可以根据需要安装,用于连接Oracle Server进行测试。

2、安装好开发包后,就可以开始编译oracle_fdw了。编译时需要在执行configure时,加入--enable-oracle-fdw选项。后续按照正常的Vstbase安装方式安装即可。

3、编译完成后,编译产物为oracle_fdw.so,位于安装目录的 lib/postgresql/下。oracle_fdw相关的sql文件和control文件,位于安装目录的 share/postgresql/extension/下。

4、如果编译安装时,没有加入 --enable-oracle-fdw 选项,可以在Vastbase安装完成后,再次编译oracle_fdw,然后手动将编译产物 oracle_fdw.so放到对应的安装目录 lib/postgresql/ ,将 oracle_fdw--1.0--1.1.sqloracle_fdw--1.1.sqloracle_fdw.control放到对应的安装目录 share/postgresql/extension/即可。

使用Oracle_FDW

  • 使用oracle_fdw需要连接Oracle,Oracle server请自行安装。

  • 加载oracle_fdw扩展:

    CREATE EXTENSION oracle_fdw
    
  • 创建服务器对象:

    CREATE SERVER
    
  • 创建用户映射:

    CREATE USER MAPPING
    
  • 创建外表: 外表的表结构需要与Oracle数据库中的表结构保持一致。注意Oracle server侧的表的第一个字段必须具有唯一性约束(如PRIMARY KEY、UNIQUE等)。

    CREATE FOREIGN TABLE
    
  • 对外表做正常的操作,如INSERT、UPDATE、DELETE、SELECT、EXPLAIN、ANALYZE、COPY等。

  • 删除外表:

    DROP FOREIGN TABLE
    
  • 删除用户映射:

    DROP USER MAPPING
    
  • 删除服务器对象:

    DROP SERVER
    
  • 删除扩展:

    DROP EXTENSION oracle_fdw
    

示例

1、在Vastbase中创建扩展。

create extension oracle_fdw;

2、在Vastbase中创建用于远程连接的用户并授权。

create user use_ora password 'Bigdata@123';
grant usage on foreign data wrapper oracle_fdw to use_ora ;

3、使用use_ora用户,创建FDW Server用于识别外部数据源。

\c - use_ora
create server ora_fdw_server foreign data wrapper oracle_fdw
options(dbserver '172.16.103.104:1521/orcl');

4、使用use_ora用户,创建USER MAPPING用于映射Oracle数据库用户。

create user mapping for use_ora server ora_fdw_server options(user 'system',password 'root');

5、在Oracle中创建测试表并插入数据。

create table system.emp_fdw(empno int,ename varchar(30));
insert into emp_fdw values(1,'foo');
insert into emp_fdw values(2,'bar');

6、使用use_ora用户在Vastbase中创建外部表。

create foreign table emp_fdw_ora(empno int,ename varchar(30))
server ora_fdw_server options(schema 'SYSTEM',table 'EMP_FDW');

7、使用use_ora用户对外部表插入数据。

insert into emp_fdw_ora values(3,'bar3');

8、使用use_ora用户查询外部表数据。

select * from emp_fdw_ora;

查询成功,返回结果如下:

 empno | ename
-------+-------
     1 | foo
     2 | bar
     3 | bar3
(3 rows)