Package DBMS_CLOUD_IMPORT

DBMS_CLOUD_IMPORT facilita l'importazione dei dati dai database Oracle e dai database non Oracle utilizzando il gateway eterogeneo di Oracle in Autonomous AI Database. Durante il processo di importazione, i tipi di dati di origine vengono convertiti in tipi di dati compatibili con Oracle. Di conseguenza, tutte le limitazioni e le restrizioni di Oracle Heterogeneous Gateway si applicano anche alle operazioni eseguite tramite questo pacchetto.

Riepilogo dei sottoprogrammi DBMS_CLOUD_IMPORT

Questa tabella riassume i sottoprogrammi inclusi DBMS_CLOUD_IMPORT nel pacchetto.

Sottoprogramma Descrizione

Procedura ADD_BY_LIKE

Crea un task di importazione per l'importazione di dati da un'origine specificata in Oracle, con filtro facoltativo in base allo schema o alla tabella e opzioni di pianificazione configurabili.

Procedura ADD_FILE

Sospensione temporanea di un task di importazione in esecuzione in modo che possa essere ripreso in seguito.

Procedura ADD_LATEST_FILES

Riavvia un task di importazione precedentemente sospeso e continua l'elaborazione dal momento in cui è stato sospeso.

Procedura ADD_TABLE

Elimina un task di importazione e rimuove la definizione e i metadati del task associati.

Procedura CREATE_IMPORT_TASK

La procedura DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASK crea e configura un job di importazione per importare i dati da un sistema di origine specificato in un Autonomous AI Database.

Per eseguire questa procedura, è necessario aver eseguito il login come utente ADMIN.

Sintassi

DBMS_CLOUD_IMPORT.CREATE_IMPORT_TASK(
    task_name          IN VARCHAR2,
    hostname           IN VARCHAR2,
    port               IN VARCHAR2,
    service_name       IN VARCHAR2,
    credential_name    IN VARCHAR2,
    directory_name     IN VARCHAR2,
    ssl_server_cert_dn IN VARCHAR2 DEFAULT NULL,
    gateway_params     IN VARCHAR2 DEFAULT NULL,
    schema_list        IN CLOB     DEFAULT NULL,
    table_list         IN CLOB     DEFAULT NULL
);

Parametri

Parametro Descrizione

task_name

Identifica in modo univoco il task di importazione. Nome assegnato al task di migrazione. Utilizzato per identificare il task e il relativo job scheduler associato.

hostname

Il nome host per il database di destinazione.

Non è consentito specificare localhost per hostname.

port

Specifica la porta per le connessioni al database di destinazione.

Quando si specifica una connessione alla connettività eterogenea gestita da Oracle utilizzando il parametro gateway_params, impostare la porta in base al valore db_type.

Per ulteriori informazioni, vedere Tipi e porte di database di connettività eterogenea gestiti da Oracle.

service_name

service_name per il database a cui collegarsi. Per un Autonomous AI Database di destinazione, trovare il nome del servizio in base a uno dei metodi riportati di seguito.

  • Cercare il file tnsnames.ora nel file wallet.zip scaricato da un Autonomous AI Database per la connessione.

  • Fare clic su Connessione al database nella console di Oracle Cloud Infrastructure. Nell'area Stringhe di connessione, ogni stringa di connessione include una voce service_name con la stringa di connessione per il servizio corrispondente. Quando sono consentite entrambe le connessioni Mutual TLS (mTLS) e TLS, in TLS authentication selezionare TLS per visualizzare i nomi TNS e le stringhe di connessione per le connessioni con l'autenticazione TLS. Per ulteriori informazioni, vedere Visualizza nomi TNS e stringhe di connessione per un'istanza di Autonomous AI Database.

  • Eseguire una query sulla vista V$SERVICES. Ad esempio:

    SELECT name FROM V$SERVICES;

    Quando si specifica una connessione alla connettività eterogenea gestita da Oracle utilizzando il parametro gateway_params, service_name è il nome del database del database non Oracle.

credential_name

Nome di una credenziale memorizzata creata con DBMS_CLOUD.CREATE_CREDENTIAL. Queste sono le credenziali per accedere al database di origine.

directory_name

La directory del file cwallet.sso. Il valore predefinito di questo parametro è 'data_pump_dir'.

La connettività eterogenea gestita da Oracle è preconfigurata con un wallet che contiene la maggior parte dei comuni certificati SSL root e intermedi sicuri. Il parametro directory_name non è obbligatorio quando si fornisce il parametro gateway_params.

ssl_server_cert_dn

Il valore DN trovato nel certificato del server.

La connettività eterogenea gestita da Oracle è preconfigurata con un wallet che contiene la maggior parte dei comuni certificati SSL root e intermedi sicuri. Il valore ssl_server_cert_dn deve essere NULL quando si fornisce il parametro gateway_params o non si include il parametro ssl_server_cert_dn (il valore predefinito è NULL).

gateway_params

Specifica le impostazioni di connessione e tipo di origine utilizzate per le migrazioni eterogenee, ovvero quando l'origine è un database non Oracle.

Viene passato come oggetto JSON e include valori quali il tipo di database di origine, ad esempio:gateway_params => JSON_OBJECT('db_type' VALUE 'mysql').

Questi parametri indicano al job di migrazione il comportamento del gateway o del driver da utilizzare durante la connessione e l'importazione dei dati dal sistema di origine. Questo parametro è facoltativo e il valore predefinito è NULL.

schema_list

Lista degli schemi da includere nell'importazione.

Si tratta di un parametro facoltativo. Se non si specifica alcun valore, viene utilizzato l'impostazione predefinita NULL. Viene eseguita la migrazione di tutti gli schemi nel database di origine.

table_list

Specifica le tabelle di cui eseguire la migrazione come array JSON di voci '[{"schema_name":"public","table_name":"sales_data"}]'.

Utilizzare table_list per eseguire una migrazione (parziale) a livello di tabella. Viene eseguita la migrazione solo delle tabelle specificate.

Non specificare oggetti sovrapposti in schema_list e table_list. Questo parametro è supportato solo se il database di origine è Oracle.

Questo parametro è facoltativo e il valore predefinito è NULL.

Esempio

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

Procedura SUSPEND_IMPORT_TASK

La procedura DBMS_CLOUD_IMPORT.SUSPEND_IMPORT_TASK sospende temporaneamente un task di importazione in esecuzione e ne consente la ripresa in un secondo momento.

Sintassi

DBMS_CLOUD_IMPORT.SUSPEND_IMPORT_TASK(
   task_name IN VARCHAR2 );

Parametri

Parametro Descrizione

task_name

Identifica in modo univoco il task di importazione.

Esempio

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

Procedura RESUME_IMPORT_TASK

La procedura DBMS_CLOUD_IMPORT.RESUME_IMPORT_TASK riprende un task di importazione precedentemente sospeso. Riavvia l'esecuzione dei task per il task_name specificato e continua l'operazione di importazione dal momento in cui è stata sospesa.

Per eseguire questa procedura, è necessario aver eseguito il login come utente ADMIN.

Sintassi

DBMS_CLOUD_IMPORT.RESUME_IMPORT_TASK(
   task_name IN VARCHAR2 );

Parametri

Parametro Descrizione

task_name

Identifica in modo univoco il task di importazione.

Esempio

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

Procedura DROP_IMPORT_TASK

La procedura DBMS_CLOUD_IMPORT.DROP_IMPORT_TASK elimina un task di importazione e rimuove la definizione e i metadati di task associati.

Per eseguire questa procedura, è necessario aver eseguito il login come utente ADMIN.

Sintassi

DBMS_CLOUD_IMPORT.DROP_IMPORT_TASK(
   task_name IN VARCHAR2 );

Parametri

Parametro Descrizione

task_name

Identifica in modo univoco il task di importazione.

Esempio

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