DataWorks:Développer une tâche ODPS SQL

Commandes SQL

Les commandes MaxCompute SQL utilisent une syntaxe similaire au SQL standard et prennent en charge les instructions DDL, DML et DQL, ainsi que la syntaxe spécifique à MaxCompute. Pour plus d'informations sur les exigences de syntaxe et les exemples d'utilisation de chaque commande SQL, consultez Vue d'ensemble de MaxCompute SQL. L'exemple simple suivant montre comment développer et exécuter des commandes SQL.

• Créer une table

  Utilisez l'instruction CREATE TABLE pour créer une table non partitionnée, une table partitionnée, une table externe ou une table clusterisée. Pour plus d'informations, consultez CREATE TABLE. Exemple d'instruction SQL :

  -- Create a partitioned table named test1.
  CREATE TABLE if NOT EXISTS students
  ( id BIGINT,
    name STRING,
    age BIGINT,
    birth DATE)
  partitioned BY (gender STRING); 

• Insérer des données

  Utilisez l'instruction INSERT INTO ou INSERT OVERWRITE pour insérer ou mettre à jour des données dans une table de destination. Pour plus d'informations, consultez Insérer ou écraser des données (INSERT INTO | INSERT OVERWRITE). Exemples d'instructions SQL :

  -- Insert data.
  INSERT INTO students PARTITION(gender='boy') VALUES (1,'John',15,DATE '2008-05-15') ;
  INSERT INTO students PARTITION(gender='boy') VALUES (2,'Jack',17,DATE '2006-07-20') ;
  INSERT INTO students PARTITION(gender='girl') VALUES (3,'Alice',20,DATE '2003-04-20') ;
  INSERT INTO students PARTITION(gender='girl') VALUES (4,'Lily',21,DATE '2002-01-08') ;
  INSERT INTO students PARTITION(gender='boy') VALUES (5,'Bob',17,DATE '2006-09-12') ;

  Important

  Évitez d'utiliser l'instruction INSERT INTO pour insérer des données, car cela peut entraîner une duplication accidentelle des données. Nous vous recommandons d'utiliser plutôt l'instruction INSERT OVERWRITE. Pour plus d'informations, consultez Insérer ou écraser des données.

• Interroger des données

  Utilisez l'instruction SELECT pour effectuer des opérations telles que des requêtes imbriquées, des requêtes groupées et le tri. Pour plus d'informations, consultez Syntaxe SELECT. Exemples d'instructions SQL :

  -- (Optional) Enable full table scan at the project level. This operation requires high-level permissions.
  -- SETPROJECT odps.sql.allow.fullscan=true;  
  
  -- Enable full table scan at the session level. This setting is valid only for the current session.
  SET odps.sql.allow.fullscan=true; 
  -- Query the information about all boys and sort the results by ID in ascending order.
  SELECT * FROM students WHERE gender='boy' ORDER BY id;

  Remarque

  Par défaut, un utilisateur RAM ne dispose pas d'autorisations de requête sur les tables de production. Pour interroger les tables de production, soumettez une demande dans Security Center. Pour obtenir des informations sur les préréglages d'autorisation de données MaxCompute et le contrôle d'accès dans DataWorks, consultez Détails du contrôle des autorisations de données MaxCompute. Pour savoir comment accorder des autorisations à l'aide de commandes dans MaxCompute, consultez Gérer les autorisations des utilisateurs à l'aide de commandes.

Fonctions SQL

MaxCompute prend en charge les fonctions intégrées et les fonctions définies par l'utilisateur (UDF) pour le développement et l'analyse de données. Pour plus d'informations sur les fonctions intégrées, consultez Vue d'ensemble des fonctions intégrées. Pour plus d'informations sur les UDF, consultez Vue d'ensemble des UDF MaxCompute. L'exemple suivant montre comment utiliser les fonctions SQL.

• Fonctions intégrées : Ces fonctions sont préinstallées dans MaxCompute et peuvent être appelées directement. Sur la base de l'exemple précédent, vous pouvez utiliser la fonction dateadd pour modifier la colonne birth selon une unité et un intervalle spécifiés. Exemple de commande :

  -- Enable full table scan at the session level. This setting is valid only for the current session.
  SET odps.sql.allow.fullscan=true; 
  SELECT id, name, age, birth, dateadd(birth,1,'mm') AS birth_dateadd FROM students;

• Fonctions définies par l'utilisateur (UDF) : Pour utiliser une UDF, vous devez écrire le code de la fonction, le télécharger en tant que ressource et enregistrer la fonction. Pour plus d'informations, consultez Créer et utiliser une UDF.

Exécution et résultats

• Les résultats d'exécution apparaissent directement sous forme de feuille de calcul. Vous pouvez effectuer des opérations dans DataWorks, ouvrir les résultats dans une feuille de calcul ou copier-coller le contenu dans un fichier Excel local. Pour plus d'informations, consultez Déboguer les tâches.

  Remarque

  En raison d'un ajustement des informations de fuseau horaire pour la Chine publié par l'Organisation internationale de normalisation (ISO), un décalage temporel peut apparaître dans l'affichage des dates lors de l'exécution de requêtes SQL pertinentes dans DataWorks. La différence de temps est de 5 minutes et 52 secondes pour les dates comprises entre 1900 et 1928, et de 9 secondes pour les dates antérieures à 1900.

• Journal d'exécution : Cliquez sur l'onglet Operational Logs pour afficher le Logview. Pour plus d'informations, consultez Afficher les informations du job à l'aide de Logview V2.0.

• Résultats renvoyés :

  • Interroger les informations sur tous les garçons et trier les résultats par ID par ordre croissant.

    +------------+------------+------------+------------+------------+
    | id         | name       | age        | birth      | gender     |
    +------------+------------+------------+------------+------------+
    | 1          | John       | 15         | 2008-05-15 | boy        |
    | 2          | Jack       | 17         | 2006-07-20 | boy        |
    | 5          | Bob        | 17         | 2006-09-12 | boy        |
    +------------+------------+------------+------------+------------+

  • Modifier la colonne birth selon une unité et un intervalle spécifiés.

    +------------+------------+------------+------------+---------------+
    | id         | name       | age        | birth      | birth_dateadd |
    +------------+------------+------------+------------+---------------+
    | 4          | Lily       | 21         | 2002-01-08 | 2002-02-08    |
    | 3          | Alice      | 20         | 2003-04-20 | 2003-05-20    |
    | 2          | Jack       | 17         | 2006-07-20 | 2006-08-20    |
    | 1          | John       | 15         | 2008-05-15 | 2008-06-15    |
    | 5          | Bob        | 17         | 2006-09-12 | 2006-10-12    |
    +------------+------------+------------+------------+---------------+

  Sur la page des résultats de la requête, vous pouvez trier les résultats par champ spécifique et télécharger les résultats. Pour plus d'informations, consultez Traiter les résultats de requête.