AnalyticDB:INSERT OVERWRITE SELECT

Çalışma mantığı

INSERT OVERWRITE SELECT deyimi önce bir bölümdeki tüm mevcut verileri temizler, ardından yeni verileri toplu olarak bu bölüme yazar.

• Hedef tablo bölümlenmiş bir tabloyse, INSERT OVERWRITE SELECT yalnızca yeni verilerin ait olduğu bölümlerin üzerine yazar. Diğer bölümler etkilenmez.

• Hedef tablo bölümlenmemiş bir tabloyse, INSERT OVERWRITE SELECT tablodaki tüm mevcut verileri temizler ve ardından yeni verileri toplu olarak yazar.

Genel Bakış

Dikkat edilmesi gerekenler

Aynı tabloya eşzamanlı olarak yazma yapmak için INSERT OVERWRITE SELECT ifadesini ve gerçek zamanlı yazma yöntemlerini (INSERT INTO, REPLACE INTO, DELETE ve UPDATE gibi) birlikte kullanmayın. Aksi takdirde gerçek zamanlı yazma işlemlerinden gelen veriler kaybolur.

Söz dizimi

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

Parametreler

• table_name: Hedef tablonun adı.

• column_name: Hedef tablodaki bir sütunun adı.

• select_statement: SELECT ifadesi.

  SELECT ifadesindeki her sütunun veri türü, hedef tablodaki karşılık gelen sütunun veri türüyle eşleşmelidir.

  SELECT ifadesindeki sütun sayısı hedef tablodakinden fazlaysa yazma işlemi başarısız olur. SELECT ifadesindeki sütun sayısı hedef tablodakinden azsa hedef tablodaki kalan sütunlar varsayılan değerleriyle doldurulur. Bir sütunun varsayılan değeri yoksa sistem bu sütunu NULL olarak doldurur.

Örnekler

Örnek veriler

Üzerine yazma örnekleri için test tablolarını ve verilerini hazırlayın.

1. test_source adında bir kaynak tablo ve test_target adında bir hedef tablo oluşturun.

   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. Kaynak tablo test_source içine test verilerini yazın.

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

Verilerin üzerine yazma

1. test_target tablosuna ilk verileri ekleyin.

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

   test_target tablosunu sorgulayın. Sorgu aşağıdaki sonucu döndürür.

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

2. test_target tablosunda b=1 olan bölümün üzerine yazın.

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

   Üzerine yazma işleminden sonra test_target sorgulandığında aşağıdaki sonuç döner:

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

3. test_target tablosunda b=2 ve b=3 olan bölümlerin üzerine yazın.

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

   Üzerine yazma işleminden sonra test_target sorgulandığında aşağıdaki sonuç döner:

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

Eşzamansız yazma işlemleri

İş gönderme

SUBMIT JOB
INSERT OVERWRITE adb_table
SELECT * FROM adb_external_table;

Yazma performansını optimize etme

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

İş ilerlemesini sorgulama

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

SUCCEEDED durumu işin tamamlandığını gösterir.