DataWorks：Kembangkan node ODPS SQL

Perintah SQL

Perintah SQL MaxCompute menggunakan sintaks yang mirip dengan SQL standar. Perintah ini mendukung pernyataan Data Definition Language (DDL), Data Manipulation Language (DML), dan Data Query Language (DQL), serta perintah khusus MaxCompute. Untuk informasi lebih lanjut tentang persyaratan sintaks dan contoh penggunaan setiap perintah SQL, lihat Ikhtisar SQL. Contoh berikut menunjukkan cara mengembangkan dan menjalankan perintah SQL sederhana.

• Buat Tabel

  Anda dapat menggunakan pernyataan `CREATE TABLE` untuk membuat tabel non-partisi, tabel partisi, tabel eksternal, dan tabel terkluster. Untuk informasi lebih lanjut, lihat CREATE TABLE. Kode berikut memberikan contohnya:

  -- Buat tabel partisi bernama students.
  CREATE TABLE if NOT EXISTS students
  ( id BIGINT,
    name STRING,
    age BIGINT,
    birth DATE)
  partitioned BY (gender STRING); 

• Masukkan Data

  Anda dapat menggunakan pernyataan `INSERT INTO` atau `INSERT OVERWRITE` untuk memasukkan atau memperbarui data di tabel tujuan. Untuk informasi lebih lanjut, lihat Masukkan atau timpa data (INSERT INTO | INSERT OVERWRITE). Kode berikut memberikan contohnya:

  -- Masukkan data.
  INSERT INTO students PARTITION(gender='boy') VALUES (1,'Zhang San',15,DATE '2008-05-15') ;
  INSERT INTO students PARTITION(gender='boy') VALUES (2,'Li Si',17,DATE '2006-07-20') ;
  INSERT INTO students PARTITION(gender='girl') VALUES (3,'Li Xia',20,DATE '2003-04-20') ;
  INSERT INTO students PARTITION(gender='girl') VALUES (4,'Wang Lan',21,DATE '2002-01-08') ;
  INSERT INTO students PARTITION(gender='boy') VALUES (5,'Wang Wu',17,DATE '2006-09-12') ;

  Penting

  Hindari menggunakan pernyataan `INSERT INTO` untuk memasukkan data karena hal ini dapat menyebabkan duplikasi data yang tidak diinginkan. Kami menyarankan Anda menggunakan pernyataan `INSERT OVERWRITE` sebagai gantinya. Untuk informasi lebih lanjut, lihat Masukkan atau timpa data.

• Kueri Data

  Anda dapat menggunakan pernyataan `SELECT` untuk melakukan operasi seperti kueri bersarang, kueri kelompok, dan pengurutan. Untuk informasi lebih lanjut, lihat Sintaks SELECT. Kode berikut memberikan contohnya:

  -- Aktifkan pemindaian tabel penuh. Pengaturan ini hanya berlaku untuk sesi saat ini.
  SET odps.sql.allow.fullscan=true; 
  
  -- Kueri informasi semua siswa laki-laki dan urutkan hasil berdasarkan ID secara menaik.
  SELECT * FROM students WHERE gender='boy' ORDER BY id;

  Catatan

  Secara default, pengguna Resource Access Management (RAM) tidak memiliki izin untuk mengkueri data dari tabel produksi. Untuk mendapatkan izin tersebut, Anda harus mengajukannya di Security Center. Untuk informasi lebih lanjut tentang izin database preset dan kontrol akses MaxCompute di DataWorks, lihat Kontrol izin data MaxCompute. Untuk informasi lebih lanjut tentang cara memberikan izin menggunakan perintah MaxCompute, lihat Kelola izin pengguna menggunakan perintah.

Fungsi SQL

MaxCompute mendukung fungsi bawaan dan user-defined function (UDF) untuk pengembangan dan analisis data. Untuk informasi lebih lanjut tentang fungsi bawaan, lihat Fungsi bawaan. Untuk informasi lebih lanjut tentang UDF, lihat UDF MaxCompute. Contoh berikut menunjukkan cara menggunakan fungsi SQL sederhana.

• Fungsi bawaan: Fungsi bawaan telah dipreset di MaxCompute dan dapat dipanggil langsung. Misalnya, berdasarkan tabel di atas, Anda dapat menggunakan fungsi `dateadd` untuk mengubah nilai-nilai dalam kolom `birth` berdasarkan interval tertentu. Kode berikut memberikan contohnya:

  -- Aktifkan pemindaian tabel penuh. Pengaturan ini hanya berlaku untuk sesi saat ini.
  SET odps.sql.allow.fullscan=true; 
  SELECT id, name, age, birth, dateadd(birth,1,'mm') AS birth_dateadd FROM students;

• User-defined functions (UDFs): Untuk menggunakan UDF, Anda harus menulis kode fungsi, mengunggah kode tersebut sebagai sumber daya, dan mendaftarkan fungsi tersebut. Untuk informasi lebih lanjut, lihat Buat dan gunakan UDF.

Menjalankan dan hasil

• Hasil eksekusi ditampilkan dalam buku kerja. Anda dapat melakukan operasi pada hasil tersebut di DataWorks, membuka hasilnya di buku kerja, atau menyalin dan menempel kontennya ke file Excel lokal. Untuk informasi lebih lanjut, lihat Proses debugging tugas.

  Catatan

  Karena penyesuaian informasi zona waktu Tiongkok yang dirilis oleh Organisasi Internasional untuk Standardisasi, selisih waktu mungkin terjadi untuk periode tertentu saat Anda menjalankan pernyataan SQL terkait di DataWorks. Hal ini mencakup selisih 5 menit 52 detik untuk tanggal dan waktu antara tahun 1900 hingga 1928, serta selisih 9 detik untuk tanggal dan waktu sebelum tahun 1900.

• Log eksekusi: Anda dapat mengklik tab Running Log untuk melihat detail Logview. Untuk informasi lebih lanjut, lihat Gunakan Logview V2.0 untuk melihat informasi eksekusi pekerjaan.

• Hasil:

  • Kueri informasi semua siswa laki-laki dan urutkan hasil berdasarkan ID secara menaik.

    +------------+------------+------------+------------+------------+
    | id         | name       | age        | birth      | gender     |
    +------------+------------+------------+------------+------------+
    | 1          | Zhang San  | 15         | 2008-05-15 | boy        |
    | 2          | Li Si      | 17         | 2006-07-20 | boy        |
    | 5          | Wang Wu    | 17         | 2006-09-12 | boy        |
    +------------+------------+------------+------------+------------+

  • Ubah nilai dalam kolom birth berdasarkan satuan dan interval tertentu.

    +------------+------------+------------+------------+---------------+
    | id         | name       | age        | birth      | birth_dateadd |
    +------------+------------+------------+------------+---------------+
    | 4          | Wang Lan   | 21         | 2002-01-08 | 2002-02-08    |
    | 3          | Li Xia     | 20         | 2003-04-20 | 2003-05-20    |
    | 2          | Li Si      | 17         | 2006-07-20 | 2006-08-20    |
    | 1          | Zhang San  | 15         | 2008-05-15 | 2008-06-15    |
    | 5          | Wang Wu    | 17         | 2006-09-12 | 2006-10-12    |
    +------------+------------+------------+------------+---------------+

  Di halaman hasil kueri, Anda dapat mengurutkan hasil berdasarkan bidang tertentu dan melakukan operasi seperti mengunduh hasilnya. Untuk informasi lebih lanjut, lihat Proses hasil kueri.