MaxCompute:SQL en mode script

Syntaxe

-- Declare a variable by using @. Supported types include TABLE and any MaxCompute data type.
@var1 <type>
-- Assign a value by using :=
@var1 := <select_statement>

Remarques d'utilisation

• Vous ne pouvez pas affecter une variable de type table à une variable dont le type de données est spécifié. Par exemple, la syntaxe suivante n'est pas autorisée :

  @a TABLE (name STRING);
  @a := SELECT 'tom';
  @b STRING;
  @b := SELECT * FROM @a;

• Les variables peuvent stocker des valeurs constantes. Vous pouvez convertir la valeur d'une variable en scalaire en utilisant SELECT * FROM @var. Une constante peut également être stockée dans une table à ligne unique, comme illustré dans l'exemple suivant. Pour plus d'informations sur la syntaxe de conversion, consultez subquery.

  @a := SELECT 10;                                         -- Assign the constant 10
  @b := SELECT key, value + (SELECT * FROM @a) FROM t2;   -- Use @a as a scalar
  SELECT * FROM @b;

Syntaxe

-- Single branch
IF (condition) BEGIN
  statements
END
-- Multi-branch
IF (condition) BEGIN
  statements
END ELSE IF (condition2) BEGIN
  statements
END ELSE BEGIN
  statements
END

Remarques d'utilisation

• Si une branche contient une seule instruction, les mots-clés BEGIN et END sont facultatifs, à l'instar de { } en Java.

• Les instructions DDL telles que CREATE TABLE, ALTER TABLE et TRUNCATE TABLE ne sont pas prises en charge au sein d'une branche IF.

• La condition prend en charge deux types :

  • Expression booléenne : la branche est déterminée au moment de la compilation.

  • Sous-requête scalaire booléenne : la branche est déterminée au moment de l'exécution. MaxCompute peut soumettre plusieurs jobs.

Exemple 1 : dans une instruction IF, la condition est une expression de type BOOLEAN. Ce type d'instruction IF ELSE permet de déterminer quelle branche exécuter au moment de la compilation, comme illustré dans l'exemple suivant :

@date := '20190101';
@row TABLE(id STRING);
IF (CAST(@date AS BIGINT) % 2 == 0) BEGIN
  @row := SELECT id FROM src1;
END ELSE BEGIN
  @row := SELECT id FROM src2;
END
INSERT OVERWRITE TABLE dest SELECT * FROM @row;

Exemple 2 : la condition de l'instruction IF est une sous-requête scalaire booléenne. Pour ce type d'instruction IF ELSE, la branche d'exécution est déterminée au moment de l'exécution, ce qui nécessite que MaxCompute soumette plusieurs jobs :

@i BIGINT;
@t TABLE(id BIGINT, value BIGINT);
IF ((SELECT COUNT(*) FROM src WHERE a = '5') > 1) BEGIN
  @i := 1;
  @t := SELECT @i, @i*2;
END ELSE BEGIN
  @i := 2;
  @t := SELECT @i, @i*2;
END
SELECT id, value FROM @t;

CREATE TABLE IF NOT EXISTS dest(key STRING, value BIGINT) PARTITIONED BY (d STRING);
CREATE TABLE IF NOT EXISTS dest2(key STRING, value BIGINT) PARTITIONED BY (d STRING);
@a := SELECT * FROM src  WHERE value > 0;
@b := SELECT * FROM src2 WHERE key IS NOT NULL;
@c := SELECT * FROM src3 WHERE value IS NOT NULL;
@d := SELECT a.key, b.value FROM @a LEFT OUTER JOIN @b ON a.key = b.key AND b.value > 0;
@e := SELECT a.key, c.value FROM @a INNER JOIN @c ON a.key = c.key;
@f := SELECT * FROM @d UNION SELECT * FROM @e UNION SELECT * FROM @a;
INSERT OVERWRITE TABLE dest  PARTITION (d='20171111') SELECT * FROM @f;
@g := SELECT e.key, c.value FROM @e JOIN @c ON e.key = c.key;
INSERT OVERWRITE TABLE dest2 PARTITION (d='20171111') SELECT * FROM @g;

SET odps.sql.step.script.mode=true;
DROP TABLE IF EXISTS foo_t1;
DROP TABLE IF EXISTS foo_t2;
CREATE TABLE foo_t1(a STRING) LIFECYCLE 1;
CREATE TABLE foo_t2(a STRING) LIFECYCLE 1;
@x := SELECT 'hello, world' AS a;
INSERT OVERWRITE TABLE foo_t1 SELECT * FROM @x;
INSERT INTO foo_t2 SELECT * FROM foo_t1 UNION ALL SELECT * FROM foo_t1;
SELECT * FROM foo_t2;

CREATE TABLE src(key BIGINT, value BIGINT) LIFECYCLE 1;
CREATE TABLE src2(key BIGINT, value BIGINT) LIFECYCLE 1;
INSERT INTO src VALUES(1, 2), (3, 3);

INSERT OVERWRITE TABLE src2 SELECT * FROM src WHERE key > 0;
@a := SELECT * FROM src2;   -- Error: src2 is written to and then read from in the same script.
SELECT * FROM @a;

SET odps.sql.step.script.mode=true;
INSERT OVERWRITE TABLE src2 SELECT * FROM src WHERE key > 0;
@a := SELECT * FROM src2;
SELECT * FROM @a;

@a := SELECT * FROM src WHERE key > 0;
INSERT OVERWRITE TABLE src2 SELECT * FROM @a;
SELECT * FROM @a;

-- Enable step-by-step execution mode (required for temporary tables).
SET odps.sql.step.script.mode=true;
DROP TABLE IF EXISTS foo_t1;
CREATE TABLE foo_t1(a BIGINT, b BIGINT);
-- Create a temporary table by using a JOIN.
CREATE TEMPORARY TABLE t AS
SELECT t1.a AS a, t2.d AS b FROM
  (SELECT 1 a, 2 b) t1
JOIN
  (SELECT 1 c, 10 d) t2
ON t1.a = t2.c;
INSERT INTO foo_t1 SELECT * FROM t UNION ALL SELECT * FROM t;
SELECT * FROM foo_t1;
-- Drop the temporary table (must be the last statement in the script).
DROP TABLE t;