DBMS_CLOUD_IMPORTを使用したデータの移行

インポート・タスクを作成するステップについて説明します。

1. ソース・データベースの資格情報を作成します。これらの資格証明は、ソース・システムに安全に認証および接続するために使用されます。次に例を示します。

   BEGIN
     DBMS_CLOUD.CREATE_CREDENTIAL(
       credential_name => 'db1_cred',
       username        => '<username>',
       password        => '<password>'
     );
   END;
   /

   詳細は、「CREATE_CREDENTIALプロシージャ」を参照してください。

2. インポート・タスクの作成:

   資格証明を作成した後、DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASKプロシージャを使用してインポート・タスクを作成および開始します。このプロシージャは、OracleおよびMySQL、PostgreSQL、Amazon RedshiftなどのサポートされているOracle以外のデータベースからデータをインポートします。

   このプロシージャを実行する場合は、必要な接続の詳細および資格証明を指定します。schema_listやtable_listなどのパラメータを使用して、インポートするデータを制御することもできます。

   Oracle Databaseは、Oracle Schedulerジョブとしてインポートを実行します。このジョブは、操作を管理し、進行状況を追跡します。ジョブでは、インポートの状態が表レベルで維持されます。インポートが中断されると、操作全体を再開するのではなく、最後の不完全な表から続行して、自動的に再開されます。

   次の例では、必要な接続の詳細および資格証明を指定して、様々なソース・データベース・タイプのインポート・タスクを作成する方法を示します。

   例: Oracleソースに接続し、指定された表(ADMIN.TABLE1やADMIN.TABLE2など)のみをターゲットAutonomous AIデータベースに移行するインポート・タスクを作成します。

   BEGIN
     DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASK(
       task_name          => '<orcl_import_job>',
       hostname           => '<example1.oraclecloud.com>',
       port               => '<port>',
       service_name       => '<service_name>',
       ssl_server_cert_dn => '<cn=remote_db_cn_name>',
       directory_name     => '<walletdb1>',
       credential_name    => 'db1_cred',
       table_list         => '[{"schema_name": "admin", "table_name": "table1"},
                              {"schema_name": "admin",  "table_name": "table2"}]'
     );
   END;
   /

   例: 指定された接続の詳細および資格証明を使用してソースOracleデータベースに接続し、ADMINスキーマ全体を移行するインポート・タスクを作成します。個々の表を指定するのではなく、1つ以上のスキーマを移行する場合は、schema_listを使用します。

   BEGIN
     DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASK(
       task_name          => 'orcl_import_job',
       hostname           => '<remote_db_hostname>',
       port               => '<remote_db_port>',
       service_name       => '<remote_db_service_name>',
       ssl_server_cert_dn => '<cn=remote_db_cn_name>',
       directory_name     => '<walletdb>',
       credential_name    => 'db1_cred',
       schema_list        => '["admin"]'
     );
   END;
   /

   ノート
   
   

   • インポートの範囲を制限するには:

     • schema_listを使用して、1つ以上のスキーマをインポートします。

     • table_listを使用して、複数のスキーマにまたがる特定の表をインポートします。

   • table_listパラメータは、ソース・データベースがOracleであり、Oracle以外のデータベースではサポートされていない場合にのみサポートされます。
   • table_listを使用する場合:

     • 関連付けられたスキーマのスキーマ・メタデータは、必要に応じてインポートされます。

     • データは、table_listで明示的に指定された表に対してのみインポートされます。

   • schema_listとtable_listの両方に重複するオブジェクトを指定しないでください。特定のスキーマまたは表を選択するには、1つのオプションのみを使用してください。

   例: MySQLソースのインポート・タスクを作成するには、db_typeをmysqlに設定してgateway_paramsを指定し、schema_listを使用して移行する対象を識別します(ゲートウェイ構成に適用可能)。

   BEGIN
     DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASK(
       task_name        => 'mysql_import_job',
       hostname         => '<mysql_hostname>',
       port             => '<mysql_port>',
       service_name     => '<mysql_service>',
       credential_name  => '<mysql_cred>',
       gateway_params   => JSON_OBJECT('db_type' VALUE 'mysql'),
       schema_list      => '["dg4odbc"]'
     );
   END;
   /

   例: db_typeをpostgresに設定してgateway_paramsを指定することにより、PostgreSQLソースのインポート・タスクを作成します。タスクは、PostgreSQLに接続し、タスク構成に基づいてターゲットAutonomous AI Databaseにデータを移行します。

   BEGIN
     DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASK(
       task_name        => '<postgres_import_job>',
       hostname         => '<postgres_hostname>',
       port             => '<5432>',
       service_name     => '<postgres_serv>',
       credential_name  => '<postgres_cred>',
       gateway_params   => JSON_OBJECT('db_type' VALUE 'postgres')
     );
   END;
   /

   これらの例では、hostname、portおよびservice_nameはソース・データベース・エンドポイントを識別し、接続を確立するタスク(必要なデータベース・リンクの作成を含む)によって使用されます。credential_nameはソース・データベースに対して認証されるため、リンクを作成できます。Oracleソースの場合は、table_listを使用して特定の表を移行するか、schema_listを使用して1つ以上のスキーマを移行します。Oracle以外のデータベースの場合、ソース・データベース・タイプ(MySQLやPostgreSQLなど)を指定し、インポートに適切なゲートウェイベースの接続を有効にするために、gateway_paramsも必要です。

インポート操作を中断および再開する方法について説明します。

BEGIN
  DBMS_CLOUD_IMPORT.SUSPEND_IMPORT_TASK(
    task_name => 'orcl_import_job'
 );
END;
/

BEGIN
  DBMS_CLOUD_IMPORT.RESUME_IMPORT_TASK(
    task_name => 'orcl_import_job'
  );
END;
/

インポート・タスクを開始すると、スケジューラ・ジョブがバックグラウンドで実行され、Autonomous AI Databaseによってタスク・レベルと表レベルの両方で進行状況が記録されます。

BEGIN
  DBMS_CLOUD.CREATE_CREDENTIAL(
    credential_name => 'db1_cred',
    username        => '<username>',
    password        => '<password>'
  );
END;
/

IMPORT_TASK_NAME   SCHEMA_NAME   SCHEMA_OBJECT   STATUS
------------------ ------------- --------------- ----------
IMPORT_JOB1        SALES         ORDERS          SUCCEEDED
IMPORT_JOB1        SALES         CUSTOMERS       SUCCEEDED
IMPORT_JOB1        HR            EMPLOYEES       LOADING
IMPORT_JOB1        HR            DEPARTMENTS     FAILED

インポート・タスクを削除するステップについて説明します。

BEGIN
  DBMS_CLOUD_IMPORT.DROP_IMPORT_TASK(
    task_name => 'orcl_import_job'
  );
END;
/