AnalyticDB:Refresh materialized views

Aktifkan binary logging

Sebelum membuat tampilan yang di-materialisasi dengan refresh cepat, Anda harus mengaktifkan binary logging untuk kluster dan tabel dasarnya.

SET ADB_CONFIG BINLOG_ENABLE=true; -- Untuk kluster dengan versi engine sebelum 3.2.0.0, jalankan perintah ini untuk mengaktifkan binary logging. Fitur ini diaktifkan secara default pada versi 3.2.0.0 dan yang lebih baru.
ALTER TABLE customer binlog=true;
ALTER TABLE sales binlog=true;
ALTER TABLE product binlog=true;

Tampilan yang di-materialisasi satu tabel

• Buat tampilan yang di-materialisasi satu tabel fast_mv1 dengan refresh cepat tanpa agregasi, yang merefresh setiap 10 detik.

  CREATE MATERIALIZED VIEW fast_mv1
  REFRESH FAST NEXT now() + INTERVAL 10 second
  AS
  SELECT sale_id, sale_date, price
  FROM sales
  WHERE price > 10;

• Buat tampilan yang dimaterialisasi fast_mv2 berbasis satu tabel, yang menggunakan penyegaran cepat dengan agregasi GROUP BY dan diperbarui setiap 5 detik.

  CREATE MATERIALIZED VIEW fast_mv2
  REFRESH FAST NEXT now() + INTERVAL 5 second
  AS
  SELECT
     customer_id, sale_date,                 -- Sistem menggunakan kolom GROUP BY sebagai primary key tampilan yang di-materialisasi.
     COUNT(sale_id) AS cnt_sale_id,          -- Kolom output agregasi.
     SUM(price * quantity) AS total_revenue, -- Kolom output agregasi.
     customer_id / 100 AS new_customer_id    -- Kolom output non-agregasi dapat menggunakan ekspresi apa pun.
  FROM sales
  WHERE ifnull(price, 1) > 0                 -- Kondisi dapat menggunakan ekspresi apa pun.
  GROUP BY customer_id, sale_date;

• Buat tampilan yang dimaterialisasi fast_mv3 berbasis satu tabel dengan refresh cepat tanpa agregasi GROUP BY, yang diperbarui setiap menit.

  CREATE MATERIALIZED VIEW fast_mv3
  REFRESH FAST NEXT now() + INTERVAL 1 minute
  AS
  SELECT count(*) AS cnt   -- Sistem menghasilkan primary key konstan untuk memastikan tampilan yang di-materialisasi hanya berisi satu catatan.
  FROM sales;

Tampilan yang di-materialisasi multi-tabel

• Buat tampilan yang di-materialisasi multi-tabel fast_mv4 dengan refresh cepat tanpa agregasi, yang merefresh setiap 5 detik.

  CREATE MATERIALIZED VIEW fast_mv4
  REFRESH FAST NEXT now() + INTERVAL 5 second
  AS
  SELECT 
      c.customer_id,
      c.customer_name,
      p.product_id,
      s.sale_id,
      (s.price * s.quantity) AS revenue
  FROM 
      sales s
  JOIN 
      customer c ON s.customer_id = c.customer_id
  JOIN 
      product p ON s.product_id = p.product_id;

• Buat tampilan yang dimaterialisasi multi-tabel fast_mv5 dengan refresh cepat menggunakan agregasi GROUP BY, yang diperbarui setiap 10 detik.

  CREATE MATERIALIZED VIEW fast_mv5
  REFRESH FAST NEXT now() + INTERVAL 10 second
  AS
  SELECT 
      s.sale_id,
      c.customer_name,
      p.product_name,
      COUNT(*) AS cnt,           
      SUM(s.price * s.quantity) AS revenue,         
      SUM(p.unit_price) AS sum_p          
  FROM 
      sales s
  JOIN 
      (SELECT customer_id, customer_name FROM customer) c ON c.customer_id = s.customer_id
  JOIN 
      (SELECT * FROM product WHERE stock_quantity > 0) p ON p.product_id = s.product_id
  GROUP BY 
      s.sale_id, c.customer_name, p.product_name;

Catatan

Jika tabel dasar mengalami operasi TRUNCATE atau INSERT OVERWRITE, atau terjadi anomali internal yang memengaruhi kebenaran data, tampilan yang di-materialisasi inkremental secara otomatis beralih ke refresh lengkap satu kali. Setelah refresh lengkap berhasil, refresh berikutnya dilanjutkan secara otomatis dalam mode inkremental.

Keterbatasan

Keterbatasan berikut berlaku untuk tampilan yang di-materialisasi dengan refresh cepat:

• Untuk kluster dengan versi engine sebelum 3.2.3.0, tabel partisi tidak dapat menjadi tabel dasar tampilan yang di-materialisasi dengan refresh cepat.

• Untuk kluster dengan versi engine sebelum 3.2.3.1, operasi INSERT OVERWRITE dan TRUNCATE tidak didukung pada tabel dasar tampilan yang di-materialisasi dengan refresh cepat. Menjalankan operasi ini akan menyebabkan error.

• Refresh cepat hanya mendukung refresh terjadwal dengan interval antara 5 detik hingga 5 menit.

• query_body tampilan yang di-materialisasi dengan refresh cepat memiliki keterbatasan berikut:

  • Tampilan yang di-materialisasi harus menghasilkan data identik dengan kueri langsung pada tabel dasar dan mendukung semua perubahan DML. Jika query_body tidak mendukung refresh cepat, pernyataan CREATE MATERIALIZED VIEW akan mengembalikan error.

  • Kondisi tidak boleh mengandung ekspresi non-deterministik, seperti now() atau rand().

  • Hanya fungsi agregat berikut yang didukung: COUNT, SUM, MAX, MIN, AVG, APPROX_DISTINCT, dan COUNT(DISTINCT).

  • Ketika query_body menggunakan fungsi agregat MAX, MIN, APPROX_DISTINCT, atau COUNT(DISTINCT), hanya operasi INSERT yang diizinkan pada tabel dasar. Operasi penghapusan data seperti DELETE, UPDATE, REPLACE, dan INSERT ON DUPLICATE KEY UPDATE dilarang.

  • Kata kunci DISTINCT tidak didukung untuk fungsi agregat selain COUNT(DISTINCT).

  • COUNT(DISTINCT) hanya mendukung tipe INTEGER.

  • AVG tidak mendukung tipe DECIMAL.

  • Kata kunci HAVING tidak didukung untuk operasi agregasi.

  • Fungsi window tidak didukung.

  • Operasi pengurutan tidak didukung.

  • Operasi himpunan seperti UNION, EXCEPT, dan INTERSECT tidak didukung.

• Tampilan yang di-materialisasi multi-tabel dengan refresh cepat memiliki keterbatasan tambahan berikut:

  • Tampilan yang di-materialisasi multi-tabel saat ini hanya mendukung INNER JOIN.

  • Secara default, tampilan yang di-materialisasi multi-tabel dapat menggabungkan maksimal lima tabel.

  • Kolom join dalam tampilan yang di-materialisasi multi-tabel harus merupakan kolom asli dari tabel, memiliki tipe data yang sama, dan setiap kolom join harus memiliki indeks.