MaxCompute:Betik Modu SQL

Sözdizimi

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

Kullanım Notları

• Tablo türündeki bir değişkeni belirli bir veri türüne sahip bir değişkene atayamazsınız. Örneğin, aşağıdaki sözdizimine izin verilmez:

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

• Değişkenler sabit değerleri depolayabilir. SELECT * FROM @var kullanarak bir değişkenin değerini skaler değere dönüştürebilirsiniz. Aşağıdaki örnekte gösterildiği gibi bir sabit, tek satırlık bir tabloda da depolanabilir. Dönüşüm sözdizimi hakkında daha fazla bilgi için bkz. alt sorgu.

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

Sözdizimi

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

Kullanım Notları

• Bir dal yalnızca tek bir ifade içeriyorsa, BEGIN ve END anahtar sözcükleri isteğe bağlıdır (Java'daki { } benzeri).

• CREATE TABLE, ALTER TABLE ve TRUNCATE TABLE gibi DDL ifadeleri bir IF dalı içinde desteklenmez.

• Koşul iki türü destekler:

  • Boolean ifadesi: Dal derleme zamanında belirlenir.

  • Boolean skaler alt sorgusu: Dal çalışma zamanında belirlenir. MaxCompute birden fazla iş gönderebilir.

Örnek 1: IF ifadesinde koşul BOOLEAN türünde bir ifadedir. Bu tür IF ELSE ifadesi, aşağıdaki örnekte gösterildiği gibi hangi dalın yürütüleceğini derleme zamanında belirleyebilir:

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

Örnek 2: IF ifadesindeki koşul bir Boolean skaler alt sorgusudur. Bu tür IF ELSE ifadesi için yürütme dalı çalışma zamanında belirlenir; bu durum MaxCompute'in birden fazla iş göndermesini gerektirir:

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