Fuente de diccionario de MySQL

Ejemplo de configuración:

DDL
Archivo de configuración

SOURCE(MYSQL(
    port 3306
    user 'clickhouse'
    password 'qwerty'
    replica(host 'example01-1' priority 1)
    replica(host 'example01-2' priority 1)
    db 'db_name'
    table 'table_name'
    where 'id=10'
    invalidate_query 'SQL_QUERY'
    fail_on_connection_loss 'true'
    query 'SELECT id, value_1, value_2 FROM db_name.table_name'
    enable_compression 1
))

<source>
  <mysql>
      <port>3306</port>
      <user>clickhouse</user>
      <password>qwerty</password>
      <replica>
          <host>example01-1</host>
          <priority>1</priority>
      </replica>
      <replica>
          <host>example01-2</host>
          <priority>1</priority>
      </replica>
      <db>db_name</db>
      <table>table_name</table>
      <where>id=10</where>
      <invalidate_query>SQL_QUERY</invalidate_query>
      <fail_on_connection_loss>true</fail_on_connection_loss>
      <query>SELECT id, value_1, value_2 FROM db_name.table_name</query>
      <enable_compression>1</enable_compression>
  </mysql>
</source>

Campos de configuración:

Configuración	Descripción
`port`	El puerto del servidor MySQL. Puedes especificarlo para todas las réplicas o para cada una por separado (dentro de `<replica>`).
`user`	Nombre del usuario de MySQL. Puedes especificarlo para todas las réplicas o para cada una por separado (dentro de `<replica>`).
`password`	Contraseña del usuario de MySQL. Puedes especificarla para todas las réplicas o para cada una por separado (dentro de `<replica>`).
`replica`	Sección de configuración de las réplicas. Puede haber varias secciones.
`replica/host`	El host de MySQL.
`replica/priority`	La prioridad de la réplica. Al intentar conectarse, ClickHouse recorre las réplicas en orden de prioridad. Cuanto menor sea el número, mayor será la prioridad.
`db`	Nombre de la base de datos.
`table`	Nombre de la tabla.
`where`	El criterio de selección. La sintaxis de las condiciones es la misma que la de la cláusula `WHERE` de MySQL; por ejemplo, `id > 10 AND id < 20`. Opcional.
`invalidate_query`	Consulta para comprobar el estado del diccionario. Opcional. Más información en la sección Actualización de datos del diccionario mediante LIFETIME.
`fail_on_connection_loss`	Controla el comportamiento del servidor ante una pérdida de conexión. Si es `true`, se genera una excepción inmediatamente si se pierde la conexión entre el cliente y el servidor. Si es `false`, el servidor reintenta obtener datos al menos tres veces antes de informar de un error. Ten en cuenta que reintentar aumenta los tiempos de respuesta. Valor predeterminado: `false`.
`query`	La consulta personalizada. Opcional.
`enable_compression`	Habilita la compresión zlib para la conexión del protocolo MySQL. Cuando se establece en `1`, ClickHouse solicita compresión a nivel de protocolo al servidor MySQL. También puede establecerse por réplica dentro de `<replica>`. Valor predeterminado: `0`.
`enable_local_infile`	Permite que el servidor MySQL solicite a ClickHouse el contenido de un archivo local (`LOAD DATA LOCAL INFILE`). Solo puede habilitarlo un diccionario definido en un archivo de configuración del servidor; una consulta `CREATE DICTIONARY` puede dejarlo sin establecer o establecerlo en `0`. También puede establecerse por réplica dentro de `<replica>`, y una `<replica>` que no lo establezca hereda el valor anterior. Valor predeterminado: `0`.
`ssl_ca_pem`	Contenido del certificado de CA con el que se verifica el certificado del servidor MySQL. Opcional.
`ssl_cert_pem`	Contenido del certificado de cliente para la autenticación basada en certificados. Opcional.
`ssl_key_pem`	Contenido de la clave privada correspondiente a `ssl_cert_pem`. Opcional.
`ssl_ca`, `ssl_cert`, `ssl_key`	Las mismas credenciales como rutas a archivos en el servidor. Solo se permiten para un diccionario definido en un archivo de configuración del servidor o mediante una colección con nombre definida allí; consulta más abajo. Opcional.

Los campos table o where no pueden usarse junto con el campo query. Además, debe declararse uno de los campos table o query.

ssl_ca, ssl_cert y ssl_key nombran archivos que el servidor abre con sus propios privilegios, por lo que solo se aceptan para un diccionario definido en un archivo de configuración del servidor o mediante una colección con nombre definida allí. Una consulta CREATE DICTIONARY que especifique directamente las credenciales TLS debe pasar su contenido en ssl_ca_pem, ssl_cert_pem y ssl_key_pem. Esos valores se enmascaran en los registros y en las consultas SHOW, del mismo modo que las contraseñas.

enable_local_infile permite que el servidor MySQL solicite a ClickHouse el contenido de un archivo de su elección, que el servidor lee con sus propios privilegios, por lo que solo se acepta para un diccionario definido en un archivo de configuración del servidor. Una consulta CREATE DICTIONARY que lo habilite, ya sea en la fuente o en una de sus entradas <replica>, se rechaza con BAD_ARGUMENTS.

No existe un parámetro secure explícito. Al establecer una conexión SSL, la seguridad es obligatoria.

Se puede conectar a MySQL en un host local mediante sockets. Para ello, establece host y socket. Ejemplo de configuración:

DDL
Archivo de configuración

SOURCE(MYSQL(
    host 'localhost'
    socket '/path/to/socket/file.sock'
    user 'clickhouse'
    password 'qwerty'
    db 'db_name'
    table 'table_name'
    where 'id=10'
    invalidate_query 'SQL_QUERY'
    fail_on_connection_loss 'true'
    query 'SELECT id, value_1, value_2 FROM db_name.table_name'
))

<source>
  <mysql>
      <host>localhost</host>
      <socket>/path/to/socket/file.sock</socket>
      <user>clickhouse</user>
      <password>qwerty</password>
      <db>db_name</db>
      <table>table_name</table>
      <where>id=10</where>
      <invalidate_query>SQL_QUERY</invalidate_query>
      <fail_on_connection_loss>true</fail_on_connection_loss>
      <query>SELECT id, value_1, value_2 FROM db_name.table_name</query>
  </mysql>
</source>

Referencia de SQL

Tipos de datos

Motores

Funciones

Formatos

Configuración

Tablas del sistema

Lagos de datos