Exemples : interroger une table à partir d'un partage Delta et analyser la vue

Supposons que nous travaillons sur une base de données d'inventaire où nous avons des données sur les informations collectées par les États-Unis. Service de recensement concernant le logement dans la région de Boston, et nous avons besoin d'une requête qui renvoie la valeur maximale de la taxe foncière sur la valeur totale.

  1. Créez un fournisseur et des informations d'identification Oracle Delta Share :

    Pour créer un fournisseur Delta Share, vous devez généralement interagir avec la plate-forme Delta Sharing, qui implique la création d'informations d'identification appropriées pour une utilisation avec les fournisseurs de partage delta. Dans cet exemple, vous pouvez créer DATABRICKS_PROVIDER.

    BEGIN
          dbms_share.create_or_replace_share_provider(
                 provider_name=>   'DATABRICKS_PROVIDER',
                 endpoint=>        'https://sharing.delta.io/delta-sharing');
          dbms_cloud.create_credential(
                 credential_name => 'CREDENTIAL_NAME',
                 username =>        'BEARER_TOKEN',
                 password =>        '*********************************');
          dbms_share.set_share_provider_credential(
                 'DATABRICKS_PROVIDER', 'CREDENTIAL_NAME');
       END;
       //

    La sortie de cette procédure crée un fournisseur de partage delta.

  2. Montage d'un catalogue de partage de base de données :

    Une fois les informations d'identification créées, vous pouvez monter le fournisseur de partage enregistré à partir de l'étape 1 en tant que catalogue pour permettre aux utilisateurs du catalogue de rechercher et de repérer des données à partir du partage, et d'interroger ces données à l'aide de SQL.

    BEGIN
          dbms_catalog.mount_share(
                 catalog_name=>'databricks',
                 share_provider=>'databricks_provider',
                 share_name=>'delta_sharing');
          END;
        /

    Le résultat de cette procédure crée une intégration de catalogue qui permet à l'outil Catalogue d'interroger les tables stockées dans Databricks.

  3. Exécuter une requête simple :
    Vous pouvez désormais exécuter une requête simple sur la table :
    select max(tax) from "DEFAULT"."BOSTON-HOUSING"@catalogname;

    La sortie renvoie la valeur maximale de la valeur totale du taux d'imposition foncière présent dans le tableau.

    MAX(TAX)
    ----------       
    711