本文介绍如何调用dblink_ora函数。

以下命令使用 dblink_ora_connect() 函数建立连接:

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

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

以下命令对名为 polardb_conn 的连接使用 dblink_ora_copy() 函数,以将 empid 和 deptno 列从名为 ora_acctg 的表(位于 Oracle 服务器上)复制到名为 as_acctg 的表(位于 PolarDB-O 实例的 public schema 中)。将强制执行 TRUNCATE 选项,并指定反馈计数 3:

polardb=# SELECT dblink_ora_copy('polardb_conn','select empid, deptno FROM ora_acctg', 'public', 'as_acctg', true, 3);
INFO:  Row: 0
INFO:  Row: 3
INFO:  Row: 6
INFO:  Row: 9
INFO:  Row: 12

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

(1 row)

以下 SELECT 语句使用 dblink_ora_record() 函数和 acctg 连接从 Oracle 服务器检索信息:

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

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