AnalyticDB:mysql_fdw拡張子を使用してMySQLデータにアクセスする

使用上の注意

MySQL外部テーブルに対してUPDATE、DELETE、INSERTなどのDML操作を実行する場合、ソーステーブルは最初の列を一意の主キー列または複合主キーの一部として使用する必要があります。 主キー制約制限はSELECT操作には適用されません。

前提条件

• mysql_fdw拡張子がインストールされています。 詳細については、「拡張機能のインストール、更新、およびアンインストール」をご参照ください。

• AnalyticDB for PostgreSQLインスタンス用にデータベースアカウントが作成されます。 詳細については、「データベースアカウントの作成」をご参照ください。

入門ガイド

mysql_fdw拡張機能を使用してリモートMySQLデータベース上のデータにアクセスするには、次の手順を実行します。

1. AnalyticDB for PostgreSQLコンソールにログインします。 管理するAnalyticDB for PostgreSQLインスタンスを見つけ、インスタンスIDをクリックして、インスタンスの [基本情報] ページに移動します。

2. ページの右上隅にある [データベースにログイン] をクリックします。 [データベースインスタンスへのログイン] ダイアログボックスで、[データベースアカウント] と [データベースパスワード] パラメーターを設定し、[ログイン] をクリックします。

3. データベースを入力し、CREATE SERVERステートメントを実行して、アクセスするMySQLデータベースとして外部サーバーを作成します。 サンプル文:

   -- Create a foreign server named mysql_svr.
   CREATE SERVER mysql_svr FOREIGN DATA WRAPPER mysql_fdw
     OPTIONS (host '127.0.0.1', port '3306');
   
   -- Create a user mapping for the mysql_svr server by specifying the username and the password that are used to access the MySQL database.
   CREATE USER MAPPING FOR public SERVER mysql_svr
     OPTIONS (username '$MYSQL_USER_NAME', password '$MYSQL_PASS');
   
   -- Use the mysql_svr server to create a foreign table.
   CREATE FOREIGN TABLE test_foreign_table(
     c1 INT,
     c2 INT,
     c3 TEXT,
     c4 TEXT)
     SERVER mysql_svr OPTIONS(dbname 'mysql_fdw_database', table_name 'test_foreign_table');

   パラメーター：

   • CREATE SERVER: 外部サーバーを作成します。 外部サーバーは、アクセスするMySQLデータベースを指定します。

   • CREATE USER MAPPING: ユーザーマッピングを作成します。 MySQLデータベースへのアクセスに使用するユーザー名とパスワードを指定する必要があります。

   • CREATE FOREIGN TABLE: 外部テーブルを作成します。 外部テーブルの列名は、アクセスするリモートテーブルの列名と一致する必要があります。 また、IMPORT FOREIGN SCHEMAステートメントを実行して、mysql_fdw拡張子が、アクセスするMySQLテーブルのAnalyticDB for PostgreSQLインスタンスに外部テーブルを自動的に作成できるようにすることもできます。

4. MySQLデータベースのデータに対して、クエリ、挿入、追加、および削除の操作を実行します。 上記の操作のみがサポートされています。

構文

CREATE SERVER [IF NOT EXISTS] server_name [TYPE 'server_type'] [VERSION 'server_version']
    FOREIGN DATA WRAPPER fdw_name
    [OPTIONS([mpp_execute 'any | master | all segments' ], option 'value' [, ... ])]

CREATE USER MAPPING [ IF NOT EXISTS ] FOR { user_name | USER | CURRENT_USER | PUBLIC }
    SERVER server_name
    [ OPTIONS ( option 'value' [ , ... ] ) ]

CREATE FOREIGN TABLE [ IF NOT EXISTS ] table_name ( [
  { column_name data_type [ OPTIONS ( option 'value' [, ... ] ) ] [ COLLATE collation ] [ column_constraint [ ... ] ]
    | table_constraint }
    [, ... ]
] )
[ INHERITS ( parent_table [, ... ] ) ]
  SERVER server_name
[ OPTIONS ( [ mpp_execute 'any | master | all segments' ], option 'value' [, ... ] ) ]

IMPORT FOREIGN SCHEMA remote_schema
    [ { LIMIT TO | EXCEPT } ( table_name [, ...] ) ]
    FROM SERVER server_name
    INTO local_schema
    [ OPTIONS ( option 'value' [, ... ] ) ]

互換性

AnalyticDB for PostgreSQLのmysql_fdw拡張機能は、次のMySQLインスタンスおよびデータベースと互換性があります。

ApsaraDB RDS for MySQL

自己管理MySQLデータベース

V5.7より前のMySQLバージョンは維持されなくなりました。 ほとんどの場合、MySQL V5.7以降が使用されます。

PolarDB for MySQL

機能とデータ型

機能

接続プール

同じセッション内のすべてのクエリは、新しいMySQL接続の代わりに同じMySQLデータベース接続を使用します。

プッシュダウンの場所

外部テーブルのWHERE句がMySQLにプッシュされます。 このようにして、外部テーブルに関連するWHERE条件がMySQLで実行され、AnalyticDB for PostgreSQLインスタンスに送信されるデータの行が少なくなります。

投影プッシュダウン

MySQLテーブルのすべてのデータが照会され、AnalyticDB for PostgreSQLインスタンスに送信されるわけではありません。 mysql_fdw拡張子は、SELECTステートメントを実行して照会するテーブル内の列のみを返します。 これにより、AnalyticDB for PostgreSQLインスタンスに送信されるデータが少なくなり、パフォーマンスが向上します。

準備されたステートメント

SELECTクエリは、単純なSELECTステートメントの代わりに準備済みステートメントを使用して実行されます。

プッシュダウンに参加

同じMySQLデータベース内の2つの外部テーブル間の結合操作は、実行のためにリモートMySQLデータベースにプッシュダウンされます。 これにより、2つのテーブルのすべての行を取得し、AnalyticDB for PostgreSQLインスタンスで結合操作を実行する方法と比較して、パフォーマンスが向上します。

集約プッシュダウン

集計関数は、実行のためにリモートMySQLデータベースにプッシュダウンされます。 これにより、すべての行を取得し、AnalyticDB for PostgreSQLインスタンスで集計操作を実行する方法と比較して、パフォーマンスが向上します。

pushdownによる注文

ORDER BY句は、MySQLから順序付けられた結果セットを取得するために実行するためにリモートMySQLデータベースにプッシュダウンされます。 MySQLデータベースは、AnalyticDB for PostgreSQLとは逆の方法でNULL関連の操作を実行します。 AnalyticDB for PostgreSQLの結果と同じ結果を取得するには、各ORDER BY句の先頭に式is NULL述語を追加します。 このように、MySQLは、昇順でソートされた結果セットの後にNULL値を配置します。

LIMITおよびOFFSETプッシュダウン

LIMIT句とOFFSET句は、実行のためにリモートMySQLデータベースにプッシュダウンされます。 これにより、すべてのデータをAnalyticDB for PostgreSQLインスタンスに送信する方法と比較して、AnalyticDB for PostgreSQLインスタンスとMySQLデータベース間で送信されるデータ量が削減されます。

データ型