Syntaxe SQL dans Query Service

Adobe Experience Platform Query Service permet d’utiliser le langage SQL ANSI standard pour SELECT et autres commandes limitées. Ce document couvre la syntaxe SQL prise en charge par Query Service.

SELECT requêtes

La syntaxe suivante définit une requête SELECT compatible avec Query Service:

[ WITH with_query [, ...] ]
SELECT [ ALL | DISTINCT [( expression [, ...] ) ] ]
    [ * | expression [ [ AS ] output_name ] [, ...] ]
    [ FROM from_item [, ...] ]
    [ SNAPSHOT { SINCE start_snapshot_id | AS OF end_snapshot_id | BETWEEN start_snapshot_id AND end_snapshot_id } ]
    [ WHERE condition ]
    [ GROUP BY grouping_element [, ...] ]
    [ HAVING condition [, ...] ]
    [ WINDOW window_name AS ( window_definition ) [, ...] ]
    [ { UNION | INTERSECT | EXCEPT | MINUS } [ ALL | DISTINCT ] select ]
    [ ORDER BY expression [ ASC | DESC | USING operator ] [ NULLS { FIRST | LAST } ] [, ...] ]
    [ LIMIT { count | ALL } ]
    [ OFFSET start ]

where from_item peut être l’une des options suivantes :

table_name [ * ] [ [ AS ] alias [ ( column_alias [, ...] ) ] ]

[ LATERAL ] ( select ) [ AS ] alias [ ( column_alias [, ...] ) ]

with_query_name [ [ AS ] alias [ ( column_alias [, ...] ) ] ]

from_item [ NATURAL ] join_type from_item [ ON join_condition | USING ( join_column [, ...] ) ]

et grouping_element peut être l’une des options suivantes :

( )

expression

( expression [, ...] )

ROLLUP ( { expression | ( expression [, ...] ) } [, ...] )

CUBE ( { expression | ( expression [, ...] ) } [, ...] )

GROUPING SETS ( grouping_element [, ...] )

et with_query correspond à :

 with_query_name [ ( column_name [, ...] ) ] AS ( select | values )

Les sous-sections suivantes fournissent des détails sur les clauses supplémentaires que vous pouvez utiliser dans vos requêtes, à condition qu’elles suivent le format indiqué ci-dessus.

Clause SNAPSHOT

Cette clause peut être utilisée pour lire de manière incrémentielle les données d’une table en fonction des ID d’instantané. Un ID d’instantané est un marqueur de point de contrôle représenté par un nombre de type Long appliqué à un tableau de lac de données chaque fois que des données y sont écrites. Le SNAPSHOT se lie à la relation de table à laquelle elle est utilisée.

    [ SNAPSHOT { SINCE start_snapshot_id | AS OF end_snapshot_id | BETWEEN start_snapshot_id AND end_snapshot_id } ]

Exemple

SELECT * FROM Customers SNAPSHOT SINCE 123;

SELECT * FROM Customers SNAPSHOT AS OF 345;

SELECT * FROM Customers SNAPSHOT BETWEEN 123 AND 345;

SELECT * FROM Customers SNAPSHOT BETWEEN HEAD AND 123;

SELECT * FROM Customers SNAPSHOT BETWEEN 345 AND TAIL;

SELECT * FROM (SELECT id FROM CUSTOMERS BETWEEN 123 AND 345) C 

SELECT * FROM Customers SNAPSHOT SINCE 123 INNER JOIN Inventory AS OF 789 ON Customers.id = Inventory.id;

Veuillez noter qu’une SNAPSHOT fonctionne avec un alias de table ou de table, mais pas sur une sous-requête ou une vue. A SNAPSHOT fonctionne partout où une clause SELECT sur une table peut être appliquée.

En outre, vous pouvez utiliser HEAD et TAIL comme valeurs de décalage spéciales pour les clauses d’instantané. Utilisation HEAD fait référence à un décalage avant le premier instantané, tandis que TAIL fait référence à un décalage après le dernier instantané.

Clause WHERE

Par défaut, les correspondances générées par un WHERE sur une clause SELECT les requêtes sont sensibles à la casse. Si vous souhaitez que les correspondances ne soient pas sensibles à la casse, vous pouvez utiliser le mot-clé ILIKE au lieu de LIKE.

    [ WHERE condition { LIKE | ILIKE | NOT LIKE | NOT ILIKE } pattern ]

La logique des clauses LIKE et ILIKE est expliquée dans le tableau suivant :

Clause	Opérateur
WHERE condition LIKE pattern	~~
WHERE condition NOT LIKE pattern	!~~
WHERE condition ILIKE pattern	~~*
WHERE condition NOT ILIKE pattern	!~~*

Exemple

SELECT * FROM Customers
WHERE CustomerName ILIKE 'a%';

Cette requête renvoie les clients dont le nom commence par "A" ou "a".

JOINDRE

A SELECT La requête qui utilise des jointures présente la syntaxe suivante :

SELECT statement
FROM statement
[JOIN | INNER JOIN | LEFT JOIN | LEFT OUTER JOIN | RIGHT JOIN | RIGHT OUTER JOIN | FULL JOIN | FULL OUTER JOIN]
ON join condition

UNION, INTERSECT et EXCEPT

Le UNION, INTERSECT, et EXCEPT des clauses sont utilisées pour combiner ou exclure des lignes similaires de plusieurs tables :

SELECT statement 1
[UNION | UNION ALL | UNION DISTINCT | INTERSECT | EXCEPT | MINUS]
SELECT statement 2

CREATE TABLE AS SELECT

La syntaxe suivante définit une CREATE TABLE AS SELECT Requête (CTAS) :

CREATE TABLE table_name [ WITH (schema='target_schema_title', rowvalidation='false') ] AS (select_query)

Paramètres

• schema: Titre du schéma XDM. Utilisez cette clause uniquement si vous souhaitez utiliser un schéma XDM existant pour le nouveau jeu de données créé par la requête CTAS.
• rowvalidation: (Facultatif) Indique si l’utilisateur souhaite une validation au niveau des lignes de tous les nouveaux lots ingérés pour le jeu de données nouvellement créé. La valeur par défaut est true.
• select_query: A SELECT . La syntaxe de la variable SELECT La requête se trouve dans la variable Section SELECT query.

Exemple

CREATE TABLE Chairs AS (SELECT color, count(*) AS no_of_chairs FROM Inventory i WHERE i.type=="chair" GROUP BY i.color)

CREATE TABLE Chairs WITH (schema='target schema title') AS (SELECT color, count(*) AS no_of_chairs FROM Inventory i WHERE i.type=="chair" GROUP BY i.color)

CREATE TABLE Chairs AS (SELECT color FROM Inventory SNAPSHOT SINCE 123)

INSERT INTO

Le INSERT INTO est définie comme suit :

INSERT INTO table_name select_query

Paramètres

• table_name: Nom de la table dans laquelle vous souhaitez insérer la requête.
• select_query: A SELECT . La syntaxe de la variable SELECT La requête se trouve dans la variable Section SELECT query.

Exemple

INSERT INTO Customers SELECT SupplierName, City, Country FROM OnlineCustomers;

INSERT INTO Customers AS (SELECT * from OnlineCustomers SNAPSHOT AS OF 345)

DROP TABLE

Le DROP TABLE supprime du système de fichiers une table existante et supprime le répertoire associé à la table s’il ne s’agit pas d’une table externe. Si la table n’existe pas, une exception se produit.

DROP TABLE [IF EXISTS] [db_name.]table_name

Paramètres

• IF EXISTS: Si cette valeur est spécifiée, aucune exception n’est générée si la table not existent.

DROP DABASE

Le DROP DATABASE supprime une base de données existante.

DROP DATABASE [IF EXISTS] db_name

Paramètres

• IF EXISTS: Si cette valeur est spécifiée, aucune exception n’est générée si la base de données not existent.

DÉPOSER LE SCHÉMA

Le DROP SCHEMA supprime un schéma existant.

DROP SCHEMA [IF EXISTS] db_name.schema_name [ RESTRICT | CASCADE]

Paramètres

• IF EXISTS: Si celle-ci est spécifiée, aucune exception n’est générée si le schéma le fait not existent.

• RESTRICT: Valeur par défaut du mode. Si celle-ci est spécifiée, le schéma ne sera supprimé que s’il ne contiennent tous les tableaux.

• CASCADE: Si celle-ci est spécifiée, le schéma sera déposé avec toutes les tables présentes dans le schéma.

CREATE VIEW

La syntaxe suivante définit une CREATE VIEW query :

CREATE VIEW view_name AS select_query

Paramètres

• view_name: Nom de la vue à créer.
• select_query: A SELECT . La syntaxe de la variable SELECT La requête se trouve dans la variable Section SELECT query.

Exemple

CREATE VIEW V1 AS SELECT color, type FROM Inventory

CREATE OR REPLACE VIEW V1 AS SELECT model, version FROM Inventory

DROP VIEW

La syntaxe suivante définit une DROP VIEW query :

DROP VIEW [IF EXISTS] view_name

Paramètre

• IF EXISTS: Si cette valeur est spécifiée, aucune exception n’est générée si la vue not existent.
• view_name: Nom de la vue à supprimer.

Exemple

DROP VIEW v1
DROP VIEW IF EXISTS v1

Bloc anonyme

Un bloc anonyme se compose de deux sections : sections exécutables et de gestion des exceptions. Dans un bloc anonyme, la section exécutable est obligatoire. Toutefois, la section de gestion des exceptions est facultative.

L'exemple suivant montre comment créer un bloc avec une ou plusieurs instructions à exécuter ensemble :

BEGIN
  statementList
[EXCEPTION exceptionHandler]
END

exceptionHandler:
      WHEN OTHER
      THEN statementList

statementList:
    : (statement (';')) +

Voici un exemple utilisant un bloc anonyme.

$$
BEGIN
   SET @v_snapshot_from = select parent_id  from (select history_meta('email_tracking_experience_event_dataset') ) tab where is_current;
   SET @v_snapshot_to = select snapshot_id from (select history_meta('email_tracking_experience_event_dataset') ) tab where is_current;
   SET @v_log_id = select now();
   CREATE TABLE tracking_email_id_incrementally
     AS SELECT _id AS id FROM email_tracking_experience_event_dataset SNAPSHOT BETWEEN @v_snapshot_from AND @v_snapshot_to;

EXCEPTION
  WHEN OTHER THEN
    DROP TABLE IF EXISTS tracking_email_id_incrementally;
    SELECT 'ERROR';
END$$;

Spark Commandes SQL

La sous-section ci-dessous couvre les commandes Spark SQL prises en charge par Query Service.

SET

Le SET définit une propriété et renvoie la valeur d’une propriété existante ou répertorie toutes les propriétés existantes. Si une valeur est fournie pour une clé de propriété existante, l’ancienne valeur est remplacée.

SET property_key = property_value

Paramètres

• property_key: Nom de la propriété que vous souhaitez répertorier ou modifier.
• property_value: La valeur sous laquelle vous souhaitez que la propriété soit définie.

Pour renvoyer la valeur d’un paramètre, utilisez SET [property key] sans property_value.

Commandes PostgreSQL

Les sous-sections ci-dessous couvrent les commandes PostgreSQL prises en charge par Query Service.

BEGIN

Le BEGIN ou le BEGIN WORK ou BEGIN TRANSACTION lance un bloc de transaction. Toutes les instructions saisies après la commande de début sont exécutées dans une seule transaction jusqu’à ce qu’une commande de COMMIT ou ROLLBACK explicite soit donnée. Cette commande est identique à START TRANSACTION.

BEGIN
BEGIN WORK
BEGIN TRANSACTION

CLOSE

Le CLOSE libère les ressources associées à un curseur ouvert. Une fois le curseur fermé, aucune opération n’est autorisée sur celui-ci. Un curseur doit être fermé lorsqu’il n’est plus nécessaire.

CLOSE name
CLOSE ALL

If CLOSE name est utilisé, name représente le nom d’un curseur ouvert qui doit être fermé. If CLOSE ALL est utilisée, tous les curseurs ouverts seront fermés.

DEALLOCATE

Le DEALLOCATE vous permet de désaffecter une instruction SQL préparée précédemment. Si vous ne désaffectez pas explicitement une instruction préparée, elle est désaffectée en fin de session. Vous trouverez plus d’informations sur les instructions préparées dans la section PREPARE, commande .

DEALLOCATE name
DEALLOCATE ALL

If DEALLOCATE name est utilisé, name représente le nom de l’instruction préparée qui doit être désaffectée. If DEALLOCATE ALL est utilisée, toutes les instructions préparées seront désaffectées.

DECLARE

Le DECLARE permet à un utilisateur de créer un curseur qui peut être utilisé pour récupérer un petit nombre de lignes à partir d’une requête plus grande. Une fois le curseur créé, les lignes sont récupérées à l’aide de FETCH.

DECLARE name CURSOR FOR query

Paramètres

• name : le nom du curseur à créer.
• query : une commande SELECT ou VALUES qui fournit les lignes à renvoyer par le curseur.

EXECUTE

Le EXECUTE sert à exécuter une instruction préparée au préalable. Comme les instructions préparées existent uniquement pour la durée d’une session, l’instruction préparée doit avoir été créée par une PREPARE exécutée plus tôt dans la session en cours. Vous trouverez plus d’informations sur l’utilisation des instructions préparées dans la section PREPARE command .

Si la variable PREPARE qui a créé l’instruction spécifie certains paramètres, un ensemble compatible de paramètres doit être transmis à l’instruction EXECUTE . Si ces paramètres ne sont pas transmis, une erreur s’affiche.

EXECUTE name [ ( parameter ) ]

Paramètres

• name : le nom de l’instruction préparée à exécuter.
• parameter : la valeur réelle du paramètre d’une instruction préparée. Ce paramètre doit être une expression donnant une valeur compatible avec le type de données de ce paramètre, tel que déterminé lors de la création de l’instruction préparée. S’il existe plusieurs paramètres pour l’instruction préparée, ils sont séparés par des virgules.

EXPLAIN

Le EXPLAIN affiche le plan d’exécution de l’instruction fournie. Le plan d’exécution indique comment les tables référencées par l’instruction seront analysées. Si plusieurs tableaux sont référencés, les algorithmes de jointure utilisés pour rassembler les lignes requises de chaque tableau d’entrée s’affichent.

EXPLAIN option statement

Où option peut être l’un des suivants :

ANALYZE
FORMAT { TEXT | JSON }

Paramètres

• ANALYZE: Si la variable option contains ANALYZE, les heures d’exécution et autres statistiques s’affichent.
• FORMAT: Si la variable option contains FORMAT, il spécifie le format de sortie, qui peut être TEXT ou JSON. Les sorties autres que text contiennent les mêmes informations que le format de sortie text, mais les programmes pourront plus facilement les analyser. Ce paramètre est défini par défaut sur TEXT.
• statement : toute instruction SELECT, INSERT, UPDATE, DELETE, VALUES, EXECUTE, DECLARE, CREATE TABLE AS ou CREATE MATERIALIZED VIEW AS, dont vous souhaitez afficher le plan d’exécution.

Exemple

L’exemple suivant montre le plan d’une requête simple sur une table avec une seule integer et 1 000 lignes :

EXPLAIN SELECT * FROM foo;

                       QUERY PLAN
---------------------------------------------------------
 Seq Scan on foo  (cost=0.00..155.00 rows=10000 width=4)
(1 row)

FETCH

Le FETCH récupère les lignes à l’aide d’un curseur créé précédemment.

FETCH num_of_rows [ IN | FROM ] cursor_name

Paramètres

• num_of_rows: Nombre de lignes à récupérer.
• cursor_name: Le nom du curseur à partir duquel vous récupérez des informations.

PREPARE

Le PREPARE permet de créer une instruction préparée. Une instruction préparée est un objet côté serveur qui peut être utilisé pour modéliser des instructions SQL similaires.

Les instructions préparées peuvent prendre des paramètres, qui sont des valeurs qui sont substituées dans l’instruction lors de son exécution. Les paramètres sont référencés par position, à l’aide de $1, $2, etc., lors de l’utilisation d’instructions préparées.

Vous pouvez éventuellement spécifier une liste de types de données de paramètre. Si le type de données d’un paramètre n’est pas répertorié, le type peut être déduit du contexte.

PREPARE name [ ( data_type [, ...] ) ] AS SELECT

Paramètres

• name: Nom de l’instruction préparée.
• data_type: Types de données des paramètres de l’instruction préparée. Si le type de données d’un paramètre n’est pas répertorié, le type peut être déduit du contexte. Si vous devez ajouter plusieurs types de données, vous pouvez les ajouter dans une liste séparée par des virgules.

ROLLBACK

Le ROLLBACK annule la transaction en cours et ignore toutes les mises à jour effectuées par la transaction.

ROLLBACK
ROLLBACK WORK

SELECT INTO

Le SELECT INTO crée une nouvelle table et la remplit avec des données calculées par une requête. Les données ne sont pas renvoyées au client, comme c’est le cas avec une SELECT . Les noms et les types de données des colonnes de la nouvelle table sont associés aux colonnes de sortie de la colonne SELECT .

[ WITH [ RECURSIVE ] with_query [, ...] ]
SELECT [ ALL | DISTINCT [ ON ( expression [, ...] ) ] ]
    * | expression [ [ AS ] output_name ] [, ...]
    INTO [ TEMPORARY | TEMP | UNLOGGED ] [ TABLE ] new_table
    [ FROM from_item [, ...] ]
    [ WHERE condition ]
    [ GROUP BY expression [, ...] ]
    [ HAVING condition [, ...] ]
    [ WINDOW window_name AS ( window_definition ) [, ...] ]
    [ { UNION | INTERSECT | EXCEPT } [ ALL | DISTINCT ] select ]
    [ ORDER BY expression [ ASC | DESC | USING operator ] [ NULLS { FIRST | LAST } ] [, ...] ]
    [ LIMIT { count | ALL } ]
    [ OFFSET start [ ROW | ROWS ] ]
    [ FETCH { FIRST | NEXT } [ count ] { ROW | ROWS } ONLY ]
    [ FOR { UPDATE | SHARE } [ OF table_name [, ...] ] [ NOWAIT ] [...] ]

Paramètres

Vous trouverez plus d’informations sur les paramètres de requête SELECT standard dans la section Section de requête SELECT. Cette section répertorie uniquement les paramètres qui sont exclusifs à la variable SELECT INTO .

• TEMPORARY ou TEMP: Paramètre facultatif. Si spécifié, la table créée sera une table temporaire.
• UNLOGGED: Paramètre facultatif. Si spécifié, la table créée sera une table non enregistrée. Vous trouverez plus d’informations sur les tables non enregistrées dans la section Documentation PostgreSQL.
• new_table: Nom de la table à créer.

Exemple

La requête suivante crée une nouvelle table. films_recent constitué uniquement des entrées récentes de la table films:

SELECT * INTO films_recent FROM films WHERE date_prod >= '2002-01-01';

SHOW

Le SHOW affiche la configuration actuelle des paramètres d’exécution. Ces variables peuvent être définies à l’aide de la variable SET en modifiant l’instruction postgresql.conf fichier de configuration, via le PGOPTIONS Variable d’environnement (lors de l’utilisation de libpq ou d’une application basée sur libpq) ou par le biais d’indicateurs de ligne de commande lors du démarrage du serveur Postgres.

SHOW name
SHOW ALL

Paramètres

• name: Nom du paramètre d’exécution dont vous souhaitez obtenir des informations. Les valeurs possibles du paramètre d’exécution sont les suivantes :

  • SERVER_VERSION: Ce paramètre affiche le numéro de version du serveur.

  • SERVER_ENCODING: Ce paramètre affiche le codage du jeu de caractères côté serveur.

  • LC_COLLATE: Ce paramètre affiche les paramètres régionaux de la base de données pour le classement (tri de texte).

  • LC_CTYPE: Ce paramètre affiche le paramètre régional de la base de données pour la classification des caractères.

    IS_SUPERUSER: Ce paramètre indique si le rôle actuel possède des privilèges de super-utilisateur.

• ALL : affiche les valeurs de tous les paramètres de configuration avec des descriptions.

Exemple

La requête suivante affiche la configuration actuelle du paramètre . DateStyle.

SHOW DateStyle;

 DateStyle
-----------
 ISO, MDY
(1 row)

COPY

Le COPY La commande vide la sortie de n’importe quel SELECT à un emplacement spécifié. L’utilisateur doit avoir accès à cet emplacement pour que cette commande réussisse.

COPY query
    TO '%scratch_space%/folder_location'
    [  WITH FORMAT 'format_name']

Paramètres

• query: La requête que vous souhaitez copier.
• format_name: Format dans lequel vous souhaitez copier la requête. Le format_name peut être l’un des parquet, csvou json. Par défaut, la valeur est parquet.

ALTER TABLE

Le ALTER TABLE vous permet d'ajouter ou de déposer des contraintes de clé Principale ou étrangère, ainsi que d'ajouter des colonnes dans le tableau.

AJOUTER OU DÉPOSER UNE CONTRAINTE

Les requêtes SQL suivantes montrent des exemples d’ajout ou de suppression de contraintes dans un tableau.

ALTER TABLE table_name ADD CONSTRAINT constraint_name PRIMARY KEY ( column_name )

ALTER TABLE table_name ADD CONSTRAINT constraint_name FOREIGN KEY ( column_name ) REFERENCES referenced_table_name ( primary_column_name )

ALTER TABLE table_name ADD CONSTRAINT constraint_name PRIMARY KEY column_name NAMESPACE namespace

ALTER TABLE table_name DROP CONSTRAINT constraint_name PRIMARY KEY ( column_name )

ALTER TABLE table_name DROP CONSTRAINT constraint_name FOREIGN KEY ( column_name )

Paramètres

• table_name: Nom de la table que vous modifiez.
• constraint_name: Nom de la contrainte que vous souhaitez ajouter ou supprimer.
• column_name: Nom de la colonne à laquelle vous ajoutez une contrainte.
• referenced_table_name: Nom de la table référencée par la clé étrangère.
• primary_column_name: Nom de la colonne référencée par la clé étrangère.

AJOUTER UNE COLONNE

Les requêtes SQL suivantes présentent des exemples d’ajout de colonnes à un tableau.

ALTER TABLE table_name ADD COLUMN column_name data_type

ALTER TABLE table_name ADD COLUMN column_name_1 data_type1, column_name_2 data_type2 

Paramètres

• table_name: Nom de la table que vous modifiez.
• column_name: Nom de la colonne à ajouter.
• data_type: Type de données de la colonne à ajouter. Les types de données pris en charge sont les suivants : bigint, char, chaîne, date, datetime, double, double précision, entier, petit, minuscule, minuscule, varchar.

AFFICHER LES CLÉS PRINCIPAL

Le SHOW PRIMARY KEYS liste toutes les Principales contraintes de clé pour la base de données donnée.

SHOW PRIMARY KEYS

    tableName | columnName    | datatype | namespace
------------------+----------------------+----------+-----------
 table_name_1 | column_name1  | text     | "ECID"
 table_name_2 | column_name2  | text     | "AAID"

AFFICHER LES CLÉS ÉTRANGÈRES

Le SHOW FOREIGN KEYS liste toutes les contraintes de clé étrangère pour la base de données donnée.

SHOW FOREIGN KEYS

    tableName   |     columnName      | datatype | referencedTableName | referencedColumnName | namespace 
------------------+---------------------+----------+---------------------+----------------------+-----------
 table_name_1   | column_name1        | text     | table_name_3        | column_name3         |  "ECID"
 table_name_2   | column_name2        | text     | table_name_4        | column_name4         |  "AAID"