CREATE DICTIONARY ... SOURCE MySQL

CREATE DICTIONARY ... SOURCE MySQL

MySQL 소스는 MySQL 데이터베이스에서 딕셔너리 데이터를 로드해요.

출처: 문서

본문

설정 예시:

• DDL
• Configuration file

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>

설정 필드:

table 또는 where 필드는 query 필드와 함께 사용할 수 없어요. 그리고 table 또는 query 필드 중 하나는 반드시 선언해야 합니다.

ssl_ca, ssl_cert, ssl_key는 서버가 자기 권한으로 여는 파일을 지정하므로, 서버 구성 파일 또는 거기에 정의된 named collection으로 정의된 딕셔너리에서만 허용됩니다. TLS 자격 증명을 직접 지정하는 CREATE DICTIONARY 쿼리는 대신 내용을 ssl_ca_pem, ssl_cert_pem, ssl_key_pem으로 전달해야 해요. 이 값들은 비밀번호와 같은 방식으로 로그 및 SHOW 쿼리에서 마스킹됩니다.

enable_local_infile은 MySQL 서버가 ClickHouse에 자기 선택의 파일 내용을 요청하게 하는데, 서버는 자기 권한으로 그 파일을 읽으므로 서버 구성 파일에 정의된 딕셔너리에서만 허용됩니다. 소스 또는 해당 <replica> 항목 중 하나에서 활성화하는 CREATE DICTIONARY 쿼리는 BAD_ARGUMENTS로 거부됩니다.

명시적인 secure 파라미터는 없어요. SSL 연결을 설정할 때 보안은 필수입니다.

MySQL은 소켓으로 로컬 호스트에 연결될 수 있어요. 이렇게 하려면 host와 socket을 설정하세요.

설정 예시:

• DDL
• Configuration file

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>

더 알아보기 (Learn more)

• Sources 개요
• LIFETIME