调用dblink_ora函数

示例

使用dblink_ora_connect()函数

执行如下语句，使用dblink_ora_connect()函数建立连接。

SELECT dblink_ora_connect('acctg', 'localhost', 'xe', 'hr', 'pwd', 1521);

其中，该示例使用用户名hr和密码pwd连接到名为xe的服务，该服务在端口1521（位于localhost）上运行。在调用其他dblink_ora函数时，您可以使用连接名称acctg引用此连接。

使用dblink_ora_copy()函数

执行如下语句，对名为polardb_conn的连接使用dblink_ora_copy()函数。

SELECT dblink_ora_copy('polardb_conn','select empid, deptno FROM ora_acctg', 'public', 'as_acctg', true, 3);

其中，该示例将empid和deptno列从名为ora_acctg的表（位于Oracle服务器上）复制到名为as_acctg的表（位于PolarDB PostgreSQL版（兼容Oracle）实例的public schema中）。将强制执行TRUNCATE选项，并指定反馈计数3。

返回结果如下：

INFO:  Row: 0
INFO:  Row: 3
INFO:  Row: 6
INFO:  Row: 9
INFO:  Row: 12

 dblink_ora_copy
-----------------
 12

(1 row)

使用dblink_ora_record()函数

执行如下语句，执行SELECT语句使用dblink_ora_record()函数和acctg连接从Oracle服务器检索信息。

SELECT * FROM dblink_ora_record( 'acctg', 'SELECT first_name from employees') AS t1(id VARCHAR);

其中，该命令检索一个列表，其中包含employees表的first_name列中的所有条目。