DataWorks:Develop a MaxCompute SQL task

SQL statements

The MaxCompute SQL syntax is similar to standard SQL syntax. DDL, DML, and DQL statements and MaxCompute-specific statements are supported. For information about the syntax requirements and usage examples of each SQL statement, see Overview of MaxCompute SQL. The following example shows how to write and execute SQL statements.

• Create a table

  You can execute the CREATE TABLE statement to create a non-partitioned table, a partitioned table, an external table, or a clustered table. For more information, see CREATE TABLE. Sample SQL statement:

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

• Insert data

  You can execute the INSERT INTO or INSERT OVERWRITE statement to insert data into a destination table. For more information, see Insert data into or overwrite data in a table or a static partition (INSERT INTO and INSERT OVERWRITE). Sample SQL statements:

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

  The INSERT INTO statement may result in unexpected data duplication. We recommend that you execute the INSERT OVERWRITE statement, instead of the INSERT INTO statement. For more information, see Insert data into or overwrite data in a table or a static partition (INSERT INTO and INSERT OVERWRITE).

• Query data

  You can execute SELECT statements to perform operations, such as nested queries, sorting, and queries by group. For more information, see SELECT syntax. Sample SQL statements:

  -- Enable the full table scan feature, which is valid only for the current session.
  SET odps.sql.allow.fullscan=true; 
  
  -- Query the information about all boys and sort the information by ID in ascending order.
  SELECT * FROM students WHERE gender='boy' ORDER BY id;

  Note

  By default, RAM users do not have the required permissions to query MaxCompute tables in the production environment. If you want to query MaxCompute tables in the production environment as a RAM user, you must request the required permissions for the RAM user in Security Center in the DataWorks console. For information about the permissions of built-in workspace-level roles on MaxCompute data and how to manage the permissions, see Manage permissions on data in a MaxCompute compute engine instance. For information about how to grant permissions to users by running commands, see Manage user permissions using commands.

SQL functions

MaxCompute lets you use built-in functions and user-defined functions (UDFs) for data development and analysis. For information about built-in functions, see Overview of built-in functions. For information about UDFs, see Overview of UDFs. The following example shows how to use SQL functions.

• Built-in functions

  MaxCompute provides many built-in functions. You can directly call these built-in functions. You can use the dateadd function to change data in the birth column by specified unit and specified interval based on the example in the preceding section. Sample SQL statements:

  -- Enable the full table scan feature, which 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;

• UDFs

  To use a UDF, you must write the code, upload the code as a resource, and register the function. For more information, see Create and use a MaxCompute UDF.

Running results and returned data

• Running results are displayed in a workbook. You can perform operations on the running results in DataWorks, view or manage the running results in the workbook, or copy the running results to an Excel file on your local computer. For more information, see Debugging procedure.

  Note

  Due to the adjustment made by the International Organization for Standardization (ISO) on the UTC+8 time zone, differences exist between the actual time and the output time when you execute related SQL statements in DataWorks. In a year from 1900 to 1928, the time difference is 352 seconds. Before the year of 1900, the time difference is 9 seconds.

• Operation logs: You can click the Runtime Log tab to view the operation logs in LogView. For more information, see Use LogView V2.0 to view job information.

• Returned data:

  • Query the information about all boys and sort the information by ID in ascending order.

    +------------+------------+------------+------------+------------+
    | 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        |
    +------------+------------+------------+------------+------------+

  • Change data in the birth column by specified unit and specified interval.

    +------------+------------+------------+------------+---------------+
    | 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    |
    +------------+------------+------------+------------+---------------+

  On the Result tab, you can sort result data by specific field and perform operations such as download on the result data. For more information, see Process query results.