AnalyticDB:インスタンス間クエリ

サポートされるバージョン

ステップ 1: 両方のインスタンスに接続する

psql を使用してインスタンス A とインスタンス B に接続します。詳細については、「クライアント接続」をご参照ください。

ステップ 2: データベースを作成する

各インスタンスにデータベースを作成し、それに切り替えます。

インスタンス A で:

CREATE DATABASE db01;
\c db01

インスタンス B で:

CREATE DATABASE db02;
\c db02

ステップ 3: 必要な拡張機能をインストールする

インスタンス A の db01 データベースとインスタンス B の db02 データベースの両方のインスタンスに、greenplum_fdw および gp_parallel_retrieve_cursor 拡張機能をインストールします。インスタンス間クエリが機能するには、両方のインスタンスに同じ拡張機能がインストールされている必要があります。詳細については、「拡張機能のインストール、更新、アンインストール」をご参照ください。

ステップ 4: インスタンス A の IP アドレスをインスタンス B のホワイトリストに追加する

インスタンス A で次のステートメントを実行して、その内部 IP アドレスを取得します。

SELECT dbid, address FROM gp_segment_configuration;

返された IP アドレスをインスタンス B のホワイトリストに追加します。詳細については、「IP アドレスホワイトリストの構成」をご参照ください。

ステップ 5: インスタンス B でテストデータを準備する

インスタンス B の db02 データベースで次のステートメントを実行します。

CREATE SCHEMA s01;

CREATE TABLE s01.t1(a int, b int, c text);
CREATE TABLE s01.t2(a int, b int, c text);
CREATE TABLE s01.t3(a int, b int, c text);

INSERT INTO s01.t1 VALUES(generate_series(1,10),generate_series(11,20),'t1');
INSERT INTO s01.t2 VALUES(generate_series(11,20),generate_series(11,20),'t2');
INSERT INTO s01.t3 VALUES(generate_series(21,30),generate_series(11,20),'t3');

ステップ 6: インスタンス A でサーバーとユーザーマッピングを作成する

インスタンス A の db01 データベースで次のステートメントを実行します。

サーバーを作成する — インスタンス B への接続を定義します。

CREATE SERVER remote_adbpg FOREIGN DATA WRAPPER greenplum_fdw
    OPTIONS (host 'gp-xxxxxxxx-master.gpdb.zhangbei.rds.aliyuncs.com',
             port '5432',
             dbname 'db02');

ユーザーマッピングを作成する — インスタンス B へのアクセスに使用される認証情報を設定します。完全な構文については、「CREATE USER MAPPING」をご参照ください。

CREATE USER MAPPING FOR PUBLIC SERVER remote_adbpg
    OPTIONS (user 'report', password '******');

ステップ 7: 外部テーブルをインポートする

インスタンス B のテーブルをインスタンス A で公開するには、次のいずれかのメソッドを選択します。

オプション 1: CREATE FOREIGN TABLE — カスタム列選択で個々のテーブルをインポートする

CREATE SCHEMA s01;
CREATE FOREIGN TABLE s01.t1(a int, b int)
    server remote_adbpg options(schema_name 's01', table_name 't1');

これにより、列のサブセットのみを公開できます。上記の例では、インスタンス B の t1 には 3 つの列 (a、b、c) がありますが、a と b のみがインポートされます。各テーブルには個別の DDL ステートメントが必要です。

オプション 2: IMPORT FOREIGN SCHEMA — スキーマからすべてのテーブルを一度にインポートする

CREATE SCHEMA s01;
IMPORT FOREIGN SCHEMA s01 LIMIT TO (t1, t2, t3)
    FROM SERVER remote_adbpg INTO s01;

これにより、各テーブルの DDL を記述することなく、複数のテーブルを 1 つのステートメントでインポートできます。外部テーブルの列はソーステーブルと完全に一致する必要があります。完全な構文については、「IMPORT FOREIGN SCHEMA」をご参照ください。

ステップ 8: リモートデータをクエリする

インスタンス A でクエリを実行して、インスタンス B からデータを読み取ります。

SELECT * FROM s01.t1;

期待される出力:

 a  | b  | c
----+----+----
  2 | 12 | t1
  3 | 13 | t1
  4 | 14 | t1
  7 | 17 | t1
  8 | 18 | t1
  1 | 11 | t1
  5 | 15 | t1
  6 | 16 | t1
  9 | 19 | t1
 10 | 20 | t1
(10 rows)