AnalyticDB:Atualizar visualizações materializadas

Ativar log binário

Antes de criar uma visualização materializada com atualização rápida, ative o log binário para o cluster e suas tabelas base.

SET ADB_CONFIG BINLOG_ENABLE=true; -- For clusters with an engine version before 3.2.0.0, run this command to enable binary logging. It is enabled by default in 3.2.0.0 and later.
ALTER TABLE customer binlog=true;
ALTER TABLE sales binlog=true;
ALTER TABLE product binlog=true;

Visualizações materializadas de tabela única

• Crie uma visualização materializada de tabela única fast_mv1 que usa atualização rápida sem operação de agregação e atualiza a cada 10 segundos.

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

• Crie uma visualização materializada de tabela única fast_mv2 que usa atualização rápida com agregação GROUP BY e atualiza a cada 5 segundos.

  CREATE MATERIALIZED VIEW fast_mv2
  REFRESH FAST NEXT now() + INTERVAL 5 second
  AS
  SELECT
     customer_id, sale_date,                 -- The system uses the GROUP BY columns as the primary key of the materialized view.
     COUNT(sale_id) AS cnt_sale_id,          -- Aggregate output column.
     SUM(price * quantity) AS total_revenue, -- Aggregate output column.
     customer_id / 100 AS new_customer_id    -- Non-aggregate output columns can use any expression.
  FROM sales
  WHERE ifnull(price, 1) > 0                 -- Conditions can use any expression.
  GROUP BY customer_id, sale_date;

• Crie uma visualização materializada de tabela única fast_mv3 que usa atualização rápida sem agregação GROUP BY e atualiza a cada minuto.

  CREATE MATERIALIZED VIEW fast_mv3
  REFRESH FAST NEXT now() + INTERVAL 1 minute
  AS
  SELECT count(*) AS cnt   -- The system generates a constant primary key to ensure that the materialized view contains only one record.
  FROM sales;

Visualizações materializadas de múltiplas tabelas

• Crie uma visualização materializada de múltiplas tabelas fast_mv4 que usa atualização rápida sem operação de agregação e atualiza a cada 5 segundos.

  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;

• Crie uma visualização materializada de múltiplas tabelas fast_mv5 que usa atualização rápida com agregação GROUP BY e atualiza a cada 10 segundos.

  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;

Observação

Se uma tabela base for submetida a uma operação TRUNCATE ou INSERT OVERWRITE, ou se ocorrer uma anomalia interna que possa afetar a correção dos dados, uma visualização materializada incremental reverte automaticamente para uma atualização completa única. Após o sucesso da atualização completa, as atualizações subsequentes retomam automaticamente o modo incremental.

Limitações

As seguintes limitações aplicam-se a visualizações materializadas com atualização rápida:

• Em clusters com versão do mecanismo anterior a 3.2.3.0, uma tabela particionada não pode ser tabela base para uma visualização materializada com atualização rápida.

• Em clusters com versão do mecanismo anterior a 3.2.3.1, as operações INSERT OVERWRITE e TRUNCATE não são suportadas nas tabelas base de uma visualização materializada com atualização rápida. A execução dessas operações causa erro.

• A atualização rápida suporta apenas atualizações agendadas com intervalo entre 5 segundos (s) e 5 minutos (min).

• O query_body de uma visualização materializada com atualização rápida possui as seguintes limitações:

  • A visualização materializada deve garantir resultados idênticos aos de uma consulta direta em suas tabelas base e deve suportar todas as alterações DML. Se o query_body não suportar atualização rápida, a instrução CREATE MATERIALIZED VIEW retornará erro.

  • As condições não podem conter expressões não determinísticas, como now() ou rand().

  • Apenas as seguintes funções de agregação são suportadas: COUNT, SUM, MAX, MIN, AVG, APPROX_DISTINCT e COUNT(DISTINCT).

  • Quando o query_body usa a função de agregação MAX, MIN, APPROX_DISTINCT ou COUNT(DISTINCT), apenas operações INSERT são permitidas nas tabelas base. Operações de exclusão de dados, como DELETE, UPDATE, REPLACE e INSERT ON DUPLICATE KEY UPDATE, são proibidas.

  • A palavra-chave DISTINCT não é suportada para funções de agregação diferentes de COUNT(DISTINCT).

  • COUNT(DISTINCT) suporta apenas o tipo INTEGER.

  • AVG não suporta o tipo DECIMAL.

  • A palavra-chave HAVING não é suportada para operações de agregação.

  • Funções de janela não são suportadas.

  • Operações de ordenação não são suportadas.

  • Operações de conjunto como UNION, EXCEPT e INTERSECT não são suportadas.

• Visualizações materializadas de múltiplas tabelas com atualização rápida têm as seguintes limitações adicionais:

  • Atualmente, visualizações materializadas de múltiplas tabelas suportam apenas INNER JOIN.

  • Por padrão, uma visualização materializada de múltiplas tabelas pode unir no máximo cinco tabelas.

  • As colunas de junção em uma visualização materializada de múltiplas tabelas devem ser colunas originais das tabelas, ter o mesmo tipo de dados e cada coluna de junção deve ter um índice.

SELECT * FROM information_schema.mv_auto_refresh_jobs where mv_name = '<mv_name>';

KILL PROCESS <process_id>;