MaxCompute:SQL en modo script

Sintaxis

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

Notas de uso

• No se puede asignar una variable de tipo tabla a una variable con un tipo de datos específico. Por ejemplo, la siguiente sintaxis no está permitida:

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

• Las variables pueden almacenar valores constantes. Puede convertir el valor de una variable a un valor escalar mediante SELECT * FROM @var. Una constante también se puede almacenar en una tabla de una sola fila, como se muestra en el siguiente ejemplo. Para obtener más información sobre la sintaxis de conversión, consulte 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;

Sintaxis

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

Notas de uso

• Si una rama contiene solo una instrucción, las palabras clave BEGIN y END son opcionales, de manera similar a { } en Java.

• Las instrucciones DDL como CREATE TABLE, ALTER TABLE y TRUNCATE TABLE no son compatibles dentro de una rama IF.

• La condición admite dos tipos:

  • Expresión booleana: la rama se determina en tiempo de compilación.

  • Subconsulta escalar booleana: la rama se determina en tiempo de ejecución. MaxCompute podría enviar varios trabajos.

Ejemplo 1: en una instrucción IF, la condición es una expresión de tipo BOOLEAN. Este tipo de instrucción IF ELSE puede determinar qué rama ejecutar en tiempo de compilación, como se muestra en el siguiente ejemplo:

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

Ejemplo 2: la condición de la instrucción IF es una subconsulta escalar booleana. Para este tipo de instrucción IF ELSE, la rama de ejecución se determina en tiempo de ejecución, lo que obliga a MaxCompute a enviar varios trabajos:

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