Daten mit DBMS_CLOUD_IMPORT migrieren

Beschreibt die Schritte zum Erstellen einer Importaufgabe.

1. Erstellen Sie Zugangsdaten für die Quelldatenbank. Diese Zugangsdaten werden für die sichere Authentifizierung und Verbindung zum Quellsystem verwendet. Beispiel:

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

   Weitere Informationen finden Sie unter Prozedur CREATE_CREDENTIAL.

2. Importaufgabe erstellen:

   Nachdem Sie die Zugangsdaten erstellt haben, erstellen und starten Sie mit der Prozedur DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASK eine Importaufgabe. Bei diesem Verfahren werden Daten aus Oracle und unterstützten Nicht-Oracle-Datenbanken wie MySQL, PostgreSQL und Amazon Redshift importiert.

   Wenn Sie diese Prozedur ausführen, geben Sie die erforderlichen Verbindungsdetails und Zugangsdaten an. Sie können auch steuern, welche Daten importiert werden, indem Sie Parameter wie schema_list oder table_list verwenden.

   Oracle Database führt den Import als Oracle Scheduler-Job aus, der den Vorgang verwaltet und den Fortschritt verfolgt. Der Job verwaltet den Status des Imports auf Tabellenebene. Wenn der Import unterbrochen wird, wird er automatisch fortgesetzt, indem die letzten unvollständigen Tabellen fortgesetzt werden, anstatt den gesamten Vorgang neu zu starten.

   Die folgenden Beispiele zeigen, wie Sie Importaufgaben für verschiedene Quelldatenbanktypen erstellen, indem Sie die erforderlichen Verbindungsdetails und Zugangsdaten angeben.

   Beispiel: Erstellt eine Importaufgabe, die eine Verbindung zu einer Oracle-Quelle herstellt und nur die angegebenen Tabellen (z.B. ADMIN.TABLE1 und ADMIN.TABLE2) in die autonome KI-Zieldatenbank migriert.

   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;
   /

   Beispiel: Erstellt eine Importaufgabe, die mit den angegebenen Verbindungsdetails und Zugangsdaten eine Verbindung zur Oracle-Quelldatenbank herstellt und das gesamte ADMIN-Schema migriert. Verwenden Sie schema_list, wenn Sie ein oder mehrere Schemas migrieren möchten, anstatt einzelne Tabellen anzugeben.

   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;
   /

   Hinweis
   
   

   • So beschränken Sie den Umfang des Imports:

     • Verwenden Sie schema_list, um mindestens ein Schema zu importieren.

     • Verwenden Sie table_list, um bestimmte Tabellen über mehrere Schemas zu importieren.

   • Der Parameter table_list wird nur unterstützt, wenn die Quelldatenbank Oracle ist und nicht für Nicht-Oracle-Datenbanken unterstützt wird.
   • Wenn table_list verwendet wird:

     • Schemametadaten für die zugehörigen Schemas werden nach Bedarf importiert.

     • Daten werden nur für die Tabellen importiert, die explizit in table_list angegeben sind.

   • Geben Sie keine sich überschneidenden Objekte in schema_list und table_list an. Verwenden Sie nur eine Option, um ein bestimmtes Schema oder eine bestimmte Tabelle auszuwählen.

   Beispiel: Erstellt eine Importaufgabe für eine MySQL-Quelle, indem gateway_params angegeben wird und db_type auf mysql gesetzt ist. Außerdem wird angegeben, was mit schema_list migriert werden soll (wie für die Gatewaykonfiguration anwendbar).

   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;
   /

   Beispiel: Erstellt eine Importaufgabe für eine PostgreSQL-Quelle, indem gateway_params angegeben wird und db_type auf postgres gesetzt ist. Die Aufgabe stellt eine Verbindung zu PostgreSQL her und migriert Daten basierend auf der Aufgabenkonfiguration in die autonome KI-Zieldatenbank.

   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;
   /

   In diesen Beispielen identifizieren hostname, port und service_name den Quelldatenbankendpunkt und werden von der Aufgabe zum Herstellen der Konnektivität verwendet (einschließlich des Erstellens des erforderlichen Datenbanklinks). credential_name authentifiziert sich bei der Quelldatenbank, sodass der Link erstellt werden kann. Verwenden Sie für Oracle-Quellen table_list, um bestimmte Tabellen zu migrieren, oder schema_list, um ein oder mehrere Schemas zu migrieren. Bei Nicht-Oracle-Datenbanken ist gateway_params auch erforderlich, um den Quelldatenbanktyp (z.B. MySQL oder PostgreSQL) anzugeben und die entsprechende Gateway-basierte Konnektivität für den Import zu aktivieren.

Beschreibt, wie Sie einen Importvorgang unterbrechen und wiederaufnehmen.

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;
/

Nachdem Sie eine Importaufgabe gestartet haben, wird der Scheduler-Job im Hintergrund ausgeführt, und die autonome KI-Datenbank zeichnet den Fortschritt sowohl auf Aufgaben- als auch auf Tabellenebene auf.

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

Beschreibt die Schritte zum Löschen einer Importaufgabe.

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