설정 예시:
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'
))
<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>
</mysql>
</source>
설정 필드:
| 설정 | 설명 |
|---|
port | MySQL 서버의 포트입니다. 모든 레플리카에 대해 지정하거나, 각 레플리카별로(<replica> 내부에) 개별 지정할 수 있습니다. |
user | MySQL 사용자 이름입니다. 모든 레플리카에 대해 지정하거나, 각 레플리카별로(<replica> 내부에) 개별 지정할 수 있습니다. |
password | MySQL 사용자의 비밀번호입니다. 모든 레플리카에 대해 지정하거나, 각 레플리카별로(<replica> 내부에) 개별 지정할 수 있습니다. |
replica | 레플리카 구성 섹션입니다. 여러 개를 지정할 수 있습니다. |
replica/host | MySQL 호스트입니다. |
replica/priority | 레플리카 우선순위입니다. 연결을 시도할 때 ClickHouse는 우선순위 순서대로 레플리카를 탐색합니다. 숫자가 낮을수록 우선순위가 높습니다. |
db | DB 이름입니다. |
table | 테이블 이름입니다. |
where | 선택 조건입니다. 조건 구문은 MySQL의 WHERE 절과 동일하며, 예를 들어 id > 10 AND id < 20처럼 작성합니다. 선택 사항입니다. |
invalidate_query | 딕셔너리 상태를 확인하는 쿼리입니다. 선택 사항입니다. 자세한 내용은 LIFETIME을 사용한 딕셔너리 데이터 갱신 섹션을 참조하십시오. |
fail_on_connection_loss | 연결이 끊어졌을 때 서버 동작을 제어합니다. true이면 클라이언트와 서버 간 연결이 끊어진 경우 즉시 예외가 발생합니다. false이면 ClickHouse 서버는 예외를 발생시키기 전에 쿼리 실행을 세 번 재시도합니다. 재시도하면 응답 시간이 늘어날 수 있습니다. 기본값은 false입니다. |
query | 사용자 지정 쿼리입니다. 선택 사항입니다. |
table 또는 where 필드는 query 필드와 함께 사용할 수 없습니다. 또한 table 또는 query 필드 중 하나는 반드시 선언해야 합니다.
명시적인 secure 매개변수는 없습니다. SSL 연결을 설정할 때는 보안 사용이 필수입니다.
MySQL은 소켓을 통해 로컬 호스트에 연결할 수 있습니다. 이를 위해 host와 socket을 설정하십시오.
설정 예시:
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>