PolarDB:Fully refreshing a materialized view

Los parámetros de un clúster de PolarDB difieren entre la consola y una sesión de base de datos. A continuación se describen las diferencias:

• En la consola de PolarDB:

  • Compatibilidad: para ser compatibles con los archivos de configuración de MySQL, algunos parámetros del clúster en la consola de PolarDB tienen el prefijo loose_.

  • Procedimiento: busque y modifique los parámetros que tienen el prefijo loose_.

• En una sesión de base de datos (mediante la línea de comandos o un cliente)

  • Procedimiento: cuando use el comando SET para modificar un parámetro en una sesión de base de datos, quite el prefijo loose_ y utilice el nombre original del parámetro.

Sintaxis

CREATE
  MATERIALIZED VIEW view_name [(column_list)]
  [REFRESH [COMPLETE|FAST]]
  [ON [COMMIT|DEMAND]]
  [START WITH now()] [NEXT now() + interval 1 hour]
  [[DISABLE|ENABLE] QUERY REWRITE]
  [MATERIALIZED OPTIONS = 'json_options']
  AS select_statement

Permisos

• El permiso CREATE sobre la base de datos donde se encuentra la vista materializada.

• El permiso SELECT sobre las columnas correspondientes (o sobre toda la tabla) de todas las tablas base de la vista materializada.

Parámetros

Uso de mv_options

mv_options se especifica mediante la cláusula MATERIALIZED OPTIONS = 'json_options'. Dicha cláusula debe aparecer antes de AS select_statement, y json_options debe ser un objeto JSON válido.

• Versiones compatibles:

  • MySQL 8.0.1, versión secundaria del kernel 8.0.1.1.55 o posterior.

  • MySQL 8.0.2, versión secundaria del kernel 8.0.2.2.35 o posterior.

• mv_options admite los siguientes campos:

  Campo	Tipo	Valor	Descripción
  order_key	STRING	Un nombre de columna o un texto de expresión.	Establece el valor order_key de la tabla contenedora de la vista materializada.
  engine	STRING	InnoDB XEngine	Especifica el motor de almacenamiento que usa la tabla contenedora de la vista materializada. El valor no distingue entre mayúsculas y minúsculas.
  table_format	STRING	row column	Especifica el formato de almacenamiento por filas o por columnas de la tabla contenedora. El valor no distingue entre mayúsculas y minúsculas. El motor InnoDB solo admite row. El motor XEngine admite tanto row como column, y suele usarse junto con engine: "xengine".
  refresh_policy	STRING	MASTER PREFER_TPRO PREFER_IMCI FORCE_TPRO FORCE_IMCI COST	Especifica la política de descarga para la tarea de actualización completa. El valor no distingue entre mayúsculas y minúsculas. Una cadena vacía o un valor desconocido hace que el sistema aplique la política predeterminada definida por la variable del sistema. MASTER: actualiza en el nodo principal. PREFER_TPRO: prefiere actualizar en un nodo de solo lectura (RO) con almacenamiento por filas. Si no existe ningún nodo RO con almacenamiento por filas, actualiza en el nodo principal. PREFER_IMCI: prefiere actualizar en un nodo RO con índice de almacenamiento por columnas. Si no existe ningún nodo RO con índice de almacenamiento por columnas, actualiza en el nodo principal. FORCE_TPRO: fuerza la actualización en un nodo RO con almacenamiento por filas. Devuelve un error si no existe ningún nodo RO con almacenamiento por filas. FORCE_IMCI: fuerza la actualización en un nodo RO con índice de almacenamiento por columnas. Devuelve un error si no existe ningún nodo RO con índice de almacenamiento por columnas. COST: elige entre un nodo RO con almacenamiento por filas y un nodo RO con índice de almacenamiento por columnas según el costo de la consulta para ejecutar la actualización.
  unique_check	INT	1 0	Se usa para las tablas contenedoras con almacenamiento por columnas de XEngine. 0 relaja la comprobación de unicidad durante la actualización. 1 u omitir el campo mantiene la comprobación predeterminada.

  Nota

  Por ahora, engine, table_format, refresh_policy y unique_check solo son compatibles con MySQL 8.0.2.

• Notas:

  • MATERIALIZED OPTIONS = '' se interpreta como si no se hubieran establecido parámetros extendidos.

  • Cuando SHOW CREATE TABLE muestra la definición de la vista materializada, incluye la cláusula MATERIALIZED OPTIONS configurada.

  • La capa de sintaxis solo acepta una cadena. Si el análisis posterior falla, se registra un WARNING y el procesamiento continúa con el comportamiento predeterminado, como si no se hubiera analizado ningún parámetro correspondiente.

• Ejemplo:

  CREATE MATERIALIZED VIEW mv1
    REFRESH COMPLETE
    ON DEMAND
    START WITH now()
    NEXT now() + INTERVAL 1 hour
    MATERIALIZED OPTIONS = '{"engine":"xengine","table_format":"column","order_key":"col1"}'
    AS SELECT col1, col2 FROM tbl1;

Ejemplo

1. Cree las tablas table1 y table2 para usarlas como tablas base de la vista materializada.

   -- Create the base tables.
   CREATE TABLE table1 (col1 INT PRIMARY KEY, col2 VARCHAR(20), col3 INT);
   CREATE TABLE table2 (col1 INT PRIMARY KEY, col2 VARCHAR(20), col3 INT);
   
   -- Insert data into the base tables.
   INSERT INTO table1 VALUES (1, 'A', 100), (2, 'B', 200), (3, 'C', 300), (4, 'D', 400);
   INSERT INTO table2 VALUES (1, 'X', 10), (2, 'Y', 20), (3, 'Z', 30), (5, 'W', 50);

2. Cree una vista materializada.

   CREATE MATERIALIZED VIEW mv1
   REFRESH COMPLETE
   ON DEMAND
   START WITH now() NEXT now() + INTERVAL 1 hour
   AS
   SELECT
       SUM(t1.col3) AS sum_value,
       AVG(t1.col3) AS avg_value
   FROM table1 t1
   JOIN table2 t2 ON t1.col1 = t2.col1;

3. Cree una vista materializada con mv_options.

   CREATE MATERIALIZED VIEW mv2
     REFRESH COMPLETE
     ON DEMAND
     START WITH now()
     NEXT now() + INTERVAL 1 hour
     MATERIALIZED OPTIONS = '{"engine":"xengine","table_format":"column","refresh_policy":"FORCE_IMCI"}'
     AS
       SELECT t1.col1, t1.col2, t1.col3
       FROM table1 t1 JOIN table2 t2 ON t1.col1 = t2.col1;

Sintaxis

DROP MATERIALIZED VIEW <view_name>;

Ejemplo

DROP MATERIALIZED VIEW mv1;

Consultar la cola de tareas

Consulte la vista del sistema information_schema.materialized_view_refresh_queue para ver la cola de actualizaciones.

SELECT * FROM information_schema.materialized_view_refresh_queue;

Pausar la cola de tareas

STOP MATERIALIZED VIEW task FOR TABLE mv1;

STOP MATERIALIZED VIEW task FOR DATABASE mv1;

STOP MATERIALIZED VIEW task FOR ALL;

Reiniciar la cola de tareas

RESTART MATERIALIZED VIEW task FOR TABLE mv1;

RESTART MATERIALIZED VIEW task FOR DATABASE mv1;

RESTART MATERIALIZED VIEW task FOR ALL;

Comprobar el estado de pausa o reinicio

Después de ejecutar el comando STOP o RESTART, consulte la columna IS_STOPPED de la tabla mysql.view_materialized_info para confirmar si la operación surtió efecto:

SELECT TABLE_SCHEMA, TABLE_NAME, IS_STOPPED FROM mysql.view_materialized_info;

• IS_STOPPED=1: La tarea de actualización programada está en pausa.

• IS_STOPPED=0: La tarea de actualización programada se está ejecutando.