AnalyticDB:INSERT OVERWRITE SELECT

Como funciona

A instrução INSERT OVERWRITE SELECT limpa primeiro todos os dados existentes de uma partição e, em seguida, grava novos dados nela em lotes.

• Se a tabela de destino for particionada, INSERT OVERWRITE SELECT substitui apenas as partições às quais os novos dados pertencem. As demais partições permanecem inalteradas.

• Caso a tabela de destino não seja particionada, INSERT OVERWRITE SELECT remove todos os dados existentes na tabela e grava os novos dados em lotes.

Visualize

Precauções

Não utilize INSERT OVERWRITE SELECT juntamente com métodos de gravação em tempo real (como INSERT INTO, REPLACE INTO, DELETE e UPDATE) para gravar na mesma tabela simultaneamente. Caso contrário, os dados das gravações em tempo real serão perdidos.

Sintaxe

INSERT OVERWRITE table_name (column_name[,...])
select_statement

Parâmetros

• table_name: Nome da tabela de destino.

• column_name: Nome de uma coluna na tabela de destino.

• select_statement: Instrução SELECT.

  O tipo de dados de cada coluna na instrução SELECT deve corresponder ao tipo de dados da coluna respectiva na tabela de destino.

  Se o número de colunas na instrução SELECT for maior que o da tabela de destino, a operação de gravação falhará. Se for menor, as colunas restantes na tabela de destino serão preenchidas com seus valores padrão. Caso uma coluna não possua valor padrão, o sistema a preencherá com NULL.

Exemplos

Dados de amostra

Prepare as tabelas de teste e os dados para os exemplos de substituição.

1. Crie uma tabela de source chamada test_source e uma tabela de destino chamada test_target.

   CREATE TABLE test_source (a BIGINT, b BIGINT) 
   DISTRIBUTED BY HASH(a);

   CREATE TABLE test_target (a BIGINT, b BIGINT) 
   DISTRIBUTED BY HASH(a) 
   PARTITION BY VALUE(b) LIFECYCLE 10;

2. Grave dados de teste na tabela de source test_source.

   INSERT INTO test_source VALUES (1,1);  
   INSERT INTO test_source VALUES (1,2); 
   INSERT INTO test_source VALUES (1,3);  
   INSERT INTO test_source VALUES (2,1); 
   INSERT INTO test_source VALUES (2,2); 
   INSERT INTO test_source VALUES (2,3);

Substituir dados

1. Insira dados iniciais na tabela test_target.

   INSERT OVERWRITE test_target 
   SELECT * FROM test_source WHERE a = 1;

   Consulte a tabela test_target. A consulta retorna o seguinte resultado:

   +-----+------+
   |1    |1     |
   |1    |2     |
   |1    |3     |
   +-----+------+

2. Substitua a partição onde b=1 na tabela test_target.

   INSERT OVERWRITE test_target (a,b)
   SELECT a,b FROM test_source 
   WHERE a = 2 AND b = 1;

   Após a substituição, a consulta a test_target retorna:

   +-----+------+
   |2    |1     |
   |1    |2     |
   |1    |3     |
   +-----+------+

3. Substitua as partições onde b=2 e b=3 na tabela test_target.

   INSERT OVERWRITE test_target
   SELECT * FROM test_source 
   WHERE a = 2 AND b >= 2 AND b <= 3;

   Após a substituição, a consulta a test_target retorna:

   +-----+------+
   |2    |1     |
   |2    |2     |
   |2    |3     |
   +-----+------+

Gravações assíncronas

Envie um job

SUBMIT JOB
INSERT OVERWRITE adb_table
SELECT * FROM adb_external_table;

Otimize o desempenho de gravação

/* direct_batch_load=true*/
SUBMIT JOB
INSERT OVERWRITE adb_table
SELECT * FROM adb_external_table;

Consulte o progresso do job

SHOW JOB STATUS WHERE job='<job_id>';

O status SUCCEEDED indica que o job foi concluído.