주요글: 도커 시작하기
반응형

1년 전 작년 이맘때 새 시스템에 대한 개발을 시작했다. 새 시스템과 기존 시스템 간 데이터 연동이 필요했는데 몇 가지 이유(선택한 이유는 https://youtu.be/guVFK09yjXw 영상 참고)로 CDC(Change Data Capture)를 연동 기술로 선택했다.

MariaDB에 대한 CDC 모듈을 조사했는데 검색 결과로 많이 나온 게 Debezium이었다. 흥미롭긴 했는데 원하는 것을 하기에는 알맞지 않았다. 필요한 것은 다음과 같았다.

  • 여러 테이블이 변경되어도 한 개 이벤트 발생
    • 예를 들어 한 트랜잭션에서 A 주문의 주문 개요, 주문 상세, 계약 상세 등의 테이블이 변경되었을 때 각 테이블의 변경 내역을 이벤트로 만들지 않고 A 주문의 요약 정보를 한 개 이벤트로 생성해서 기존 시스템에 전달 필요
  • 한 모델의 변경 시 영향받는 다른 모델 데이터도 전파
    • 예를 들어 B회원의 결제 수단 정보가 변경되면 B회원과 관련된 모든 주문의 요약 정보를 이벤트로 생성해서 기존 시스템에 전달(주문 요약 정보에 결제 수단 정보가 포함되어 있어 전파 필요)
  • 변경 데이터를 칼럼명으로 접근하고 싶음
    • 변경 데이터를 칼럼 인덱스가 아닌 칼럼명으로 접근하고 싶음

이런 걸 하기에 Debezium은 적합하지 않아 요구에 맞는 CDC 모듈을 직접 만들기로 했다.

CDC 모듈 개발

다행히 MariaDB의 바이너리 로그를 읽을 수 있는 mysql-binlog-connector-java가 있어 이걸 활용해서 모듈을 만들었다(MySQL과 MariaDB가 프로토콜이 같아서 다행이었다). 다음 그림은 구현하는 과정에서 도출된 설계 결과물이다.

MariadbCdc에는 CDC 시작/중지 처리와 변경 데이터를 MariadbCdcListener에 전달하는 기능을 넣었다. 변경 데이터의 칼럼명 조회를 위해 ColumnNameGetter 인터페이스를 추가했고, (위 그림엔 표시하지 않았지만) 테이블 스키마 변경 시 칼럼명을 다시 조회할 수 있도록 스키마 변경 감지 기능을 넣었다.

MariadbCdcListener는 onDataChanged() 메서드로 변경 데이터를 RowChangedData에 담아서 전달받도록 했다. RowChangedData 클래스는 변경 데이터와 관련된 변경 타입, 변경된 테이블 이름, 변경 데이터, (UPDATE면) 변경 전 데이터를 갖도록 했다. DataRow는 데이터를 표현하며 칼럼명을 이용한 조회 기능과 칼럼 인덱스를 이용한 조회 기능을 제공하도록 구현했다.

한 트랜잭션에서 변경된 데이터를 모아서 한 번에 처리할 수 있도록 하기 위해 onXid() 메서드도 추가했다. 트랜잭션 커밋 로그를 읽을 때 이 메서드를 호출하도록 했다.

CDC 모듈 초기 버전을 만들고 https://github.com/madvirus/mariadb-cdc 리포지토리에 올리고 메이븐 의존 설정에 쉽게 추가할 수 있도록 jitpack.io를 사용했다.

개밥 먹기 1년

개발 환경에 적용한 뒤 1년이 지났다. 그 사이에 새 시스템을 오픈해서 운영 환경에도 적용했다. 이 과정에서 몇 가지 놓친 점을 발견했고 점진적으로 보완해 나갔다. 보완한 것 중에서는 다음이 기억에 남는다.

  • 동시에 두 프로세스를 실행하면 서로 연결이 끊기는 증상: 같은 슬레이브 ID를 사용하면서 발생한 것으로 슬레이브ID를 지정할 수 있는 기능 추가하고 각 CDC 모듈이 겹치지 않는 슬레이브ID를 사용하도록 처리
  • 한 테이블에서 많은 행이 변경될 때 감지가 누락되는 증상: 연속된 변경 ROWS 이벤트 발생 시 두 번째 이벤트부터 테이블 이름 처리가 잘못되어 발생한 것으로 테이블 이름 매핑 처리 버그 수정
  • 칼럼 이름을 제대로 가져오지 못하는 버그(다른 테이블에 참조키를 제공하는 테이블 변경 시 발생): TABLE_MAP 이벤트가 연속될 때 발생한 버그 수정

이 중 두 번째는 운영 환경에서 알게 되었다. 관련 데이터가 일정 개수 이상으로 증가하면서 발생하기 시작했다. 처음에는 원인을 몰라 주기적으로 손으로 보정하는 짓을 좀 했다.

세 번째는 최근에 다른 DB에 CDC를 적용하면서 발견했다. 문제를 해결하는 과정에서 리플리케이션 프로토콜에 대해 조금 더 알 수 있었다.

두 번째 개밥 먹기 중

보완을 하면서 동시에 실험 목적의 바이너리 로그 리더 구현도 병행했다. mysql-binlog-connector-java가 충분히 좋았지만 리플리케이션 프로토콜에 대한 호기심이 발동해 바이너리 로그를 직접 구현해 보고 싶은 마음이 생겼기 때문이다. 주로 주중 저녁이나 주말에 구현했는데 토요일과 일요일에 이틀 동안 꼬박 이것만 했던 날도 있었다.

MariaDB/MySQL 사이트에서 제공하는 프로토콜 문서를 주로 참조했고 프로토콜 문서만으로 감이 안 올 때는 mysql-binlog-connector-java 코드를 뒤져가면서 점진적으로 구현했고 최근에 필요한 최소 기능 개발을 완료했다. 모듈을 설계할 때 mysql-binlog-connector-java의 타입 노출을 최소화하고 MariadbCdc, MariadbCdcListener, DataRow 등으로 한 번 감싸서 구현했기에 실험용 버전을 사용하도록 변경하는 것도 간단한 설정으로 진행할 수 있었다.

마침 CDC를 다른 곳에 적용해야 할 일이 생겨 새로 구현한 바이너리 로그 리더를 사용해보고 있다. 이 과정에서 또 다른 보완점을 찾을 수 있었는데 그건 바로 enum 타입에 대한 처리였다. enum 타입 처리를 위한 코드를 보완하고 있는데 MySQL과 MariaDB에서는 enum 타입을 최대한 쓰면 안 되겠다는 생각을 갖게 되었다. 내가 결정에 영향을 줄 수 있는 한 최대한 못 쓰게 할 거다!

다음 목표는 직접 구현한 바이너리 로그 리더를 별도 모듈로 분리하고 SSL이나 GTID 등에 대한 지원을 추가하는 것이다. 생각나면 하고 틈나면 하고 그런지라 언제 될지 모르지만 언젠가는 다음 목표를 달성하고 싶다.

반응형

https://youtu.be/bBFi48Azvks

마리아DB 10.3, 10.4, 10.5에 있는 파티션 테이블과 관련된 치명적인 버그를 살펴봅니다.

반응형

MariaDB에서 grant usage ... with max_statement_time 명령어를 사용하면 사용자별로 최대 쿼리 실행 시간을 지정할 수 있다. 다음은 명령어 실행 예를 보여준다. 이때 시간은 초 단위다(MySQL도 동일한 유사한 기능이 있는데 시간 단위는 밀리초이다).

GRANT USAGE ON *.* TO batchuser@'%' WITH MAX_STATEMENT_TIME 60

사용자별로 지정한 최대 쿼리 실행 시간은 글로벌 시간에 우선한다.

반응형

요즘 MariaDB 바이너리 로그를 이용한 간단한 라이브러리를 만들고 있는데(mariadb-cdc 라이브러리) 다양한 버전의 MariaDB와 몇 가지 다른 설정으로 테스트할 필요가 있었다. 로컬에 설치한 MariaDB로는 다양한 테스트를 수행하는데 불편함이 있어 방법을 찾다가 Testcontainers가 있다는 것을 알게 되었다.

 

Testcontainers는 JUnit에서 테스트하는 동안 도커 컨테이너를 임시로 생성하고 제거해 주는 라이브러리다. Testcontainers를 사용하면 MariaDB, MongoDB, MySQL 등 다양한 DB에 대한 통합 테스트 환경을 쉽게 구성할 수 있다.

 

유튜브로 보기: youtu.be/eZbLAD2yUfE

의존 설정(JUnit5 기준)

JUnit에서 Testcontainers를 사용하려면 다음 의존 설정을 추가한다.

  • org.testcontainers:testcontainers:1.14.3
  • org.testcontainers:mariadb:1.14.3
  • org.testcontainers:junit-jupiter:1.14.3

그레이들 설정 예

dependencies {
    implementation("org.mariadb.jdbc:mariadb-java-client:2.7.0")
    implementation("ch.qos.logback:logback-classic:1.2.3")
    testImplementation(platform('org.junit:junit-bom:5.7.0'))
    testImplementation('org.junit.jupiter:junit-jupiter')
    testImplementation("org.testcontainers:testcontainers:1.14.3")
    testImplementation("org.testcontainers:mariadb:1.14.3")
    testImplementation("org.testcontainers:junit-jupiter:1.14.3")
}

test {
    useJUnitPlatform()
}

메이븐 설정 예

<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.junit</groupId>
            <artifactId>junit-bom</artifactId>
            <version>5.7.0</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

<dependencies>
    <dependency>
        <groupId>org.mariadb.jdbc</groupId>
        <artifactId>mariadb-java-client</artifactId>
        <version>2.7.0</version>
    </dependency>
    <dependency>
        <groupId>ch.qos.logback</groupId>
        <artifactId>logback-classic</artifactId>
        <version>1.2.3</version>
    </dependency>
    <dependency>
        <groupId>org.junit.jupiter</groupId>
        <artifactId>junit-jupiter</artifactId>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.testcontainers</groupId>
        <artifactId>testcontainers</artifactId>
        <version>1.14.3</version>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.testcontainers</groupId>
        <artifactId>mariadb</artifactId>
        <version>1.14.3</version>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.testcontainers</groupId>
        <artifactId>junit-jupiter</artifactId>
        <version>1.14.3</version>
        <scope>test</scope>
    </dependency>
</dependencies>

JUnit에서 MariaDB 컨테이너 구동하기

의존을 추가했다면 간단하게 MariaDB 컨테이너를 구동하고 연동할 수 있다. 다음 세 가지만 하면 된다.

  • @Testcontainers 애노테이션 테스트 클래스에 적용
  • MariaDBContainer 타입 필드를 선언하고 객체 생성
  • MariaDBContainer 필드에 @Container 애노테이션 적용

아래 코드는 작성 예이다.

import org.testcontainers.containers.MariaDBContainer;
import org.testcontainers.junit.jupiter.Container;
import org.testcontainers.junit.jupiter.Testcontainers;

@Testcontainers
public class MariadbTest {
    Logger logger = LoggerFactory.getLogger(getClass());

    @Container
    MariaDBContainer mariaDB = new MariaDBContainer();

    @Test
    void connect() {
        logger.info("host: {}", mariaDB.getHost());
        logger.info("port: {}", mariaDB.getMappedPort(3306));
        logger.info("username: {}", mariaDB.getUsername());
        logger.info("password: {}", mariaDB.getPassword());
        logger.info("jdbc url: {}", mariaDB.getJdbcUrl());
        try (Connection conn = DriverManager.getConnection(
                    mariaDB.getJdbcUrl(), 
                    mariaDB.getUsername(), 
                    mariaDB.getPassword())
        ) {
            logger.info("got connection");
            // 코드
        } catch (SQLException ex) {
            ex.printStackTrace();
        } catch (InterruptedException e) {
        }
    }
}

위 테스트 코드를 실행하면 테스트 메서드를 실행하기 전에 MariaDB 이미지를 이용해서 컨테이너를 시작한다. 컨테이너가 시작되면 MariaDBContainer가 제공하는 다양한 메서드를 이용해서 DB 연결에 필요한 정보를 구할 수 있다. 실제 위 테스트 코드를 실행하면 다음 로그 메시지가 출력된다(예제에서 사용하는 로그 포맷은 깃헙 코드를 참고한다).

23:13:30.742 [Test worker] INFO  docker[mariadb:10.3.6] - Creating container for image: mariadb:10.3.6
23:13:31.060 [Test worker] INFO  docker[mariadb:10.3.6] - Starting container with ID: 79fb2e93168247a2d9643256aba2f8fad39445be855d96e7fecb92d8fba9593e
23:13:31.656 [Test worker] INFO  docker[mariadb:10.3.6] - Container mariadb:10.3.6 is starting: 79fb2e93168247a2d9643256aba2f8fad39445be855d96e7fecb92d8fba9593e
23:13:31.692 [Test worker] INFO  docker[mariadb:10.3.6] - Waiting for database connection to become available at jdbc:mariadb://localhost:32769/test using query 'SELECT 1'
23:13:44.089 [Test worker] INFO  docker[mariadb:10.3.6] - Container is started (JDBC URL: jdbc:mariadb://localhost:32769/test)
23:13:44.090 [Test worker] INFO  docker[mariadb:10.3.6] - Container mariadb:10.3.6 started in PT17.215S
23:13:44.102 [Test worker] INFO  mariadb.MariadbTest - host: localhost
23:13:44.102 [Test worker] INFO  mariadb.MariadbTest - port: 32769
23:13:44.102 [Test worker] INFO  mariadb.MariadbTest - username: test
23:13:44.102 [Test worker] INFO  mariadb.MariadbTest - password: test
23:13:44.102 [Test worker] INFO  mariadb.MariadbTest - jdbc url: jdbc:mariadb://localhost:32769/test
23:13:44.120 [Test worker] INFO  mariadb.MariadbTest - got connection

출력한 결과를 보면 Testcontainers 1.14.3 기준으로 MariaDB 버전이 10.3.6이고 DB 사용자와 암호가 test인 것을 알 수 있다. JDBC URL을 보면 사용할 DB 이름도 test이다. 포트 번호는 32769인데 이는 컨테이너의 3306 포트에 매핑된 로컬 포트가 32769인 것을 의미한다. 실제 컨테이너가 구동될 때마다 이 포트는 바뀐다.

 

테스트 코드를 실행하는 중간에 docker ps 명령어를 실행하면 mariadb:10.3.6 이미지를 사용한 컨테이너가 생성된 것을 확인할 수 있다.

C:\work\any\testcontainer-sample>docker ps
CONTAINER ID        IMAGE                               COMMAND                  CREATED             STATUS              PORTS                     NAMES
c45c731d82ae        mariadb:10.3.6                      "docker-entrypoint.s…"   2 seconds ago       Up 1 second         0.0.0.0:32771->3306/tcp   modest_shannon
92d9b2fd807d        testcontainersofficial/ryuk:0.3.0   "/app"                   4 seconds ago       Up 2 seconds        0.0.0.0:32770->8080/tcp   testcontainers-ryuk-c2d44a10-9754-4133-830e-53c6147a1b22

@Container 애노테이션이 붙은 필드가 static이 아니면 각 테스트 메서드를 실행할 때마다 도커 컨테이너를 시작하고 종료한다. 테스트 클래스에 있는 테스트 메서드가 동일한 도커 컨테이너를 사용하게 하고 싶다면 @Container 필드를 static으로 선언하면 된다.

커스텀 설정

MariaDB 버전을 쉽게 바꿀 수도 있다. 생성자에 사용할 이미지만 입력하면 된다. 이 외에 DB 사용자와 암호를 포함해 몇 가지 설정을 쉽게 변경할 수 있다. 다음은 변경 예이다.

@Testcontainers
public class MariadbInitTest {
    
    @Container
    JdbcDatabaseContainer mariaDB = new MariaDBContainer("mariadb:10.5") // 이미지
            .withConfigurationOverride("conf.d.105") // DB 서버 추가 설정
            .withUsername("myuser") // DB 사용자
            .withPassword("mypassword") // 암호
            .withDatabaseName("mydb") // 사용할 데이터베이스
            .withInitScript("init.sql"); // 초기 실행 쿼리

withConfigurationOverride()가 아닌 다른 메서드는 (MariaDBContainer 클래스의 상위 클래스인) JdbcDatabaseContainer 클래스에 정의되어 있다. 그래서 필드 타입을 JdbcDatabaseContainer 클래스로 선언했다.

 

withInitScript()는 클래스패스에서 실행할 쿼리를 찾는다. 예제 코드는 src/test/resources 폴더에 위치한 init.sql 파일을 실행한다.

 

withConfigurationOverride() 메서드는 MariaDB 설정 파일을 변경할 때 사용한다. 이 메서드는 클래스패스에 위치한 폴더명을 인자로 받는다. MariaDBContainer는 이 폴더의 파일을 컨테이너의 "/etc/mysql/conf.d" 폴더에 복사한다(withConfigurationOverride() 메서드를 설정하지 않으면 Testcontainers MariaDB 모듈이 제공하는 my.cnf 파일을 사용한다).

참고 자료

반응형

서로 다른 MariaDB 간에 데이터를 복제할 일이 자꾸 생겨서 MariaDB 바이너리 로그 기반 CDC(Change Data Capture)를 활용하기로 했다. 이미 mysql-binlog-connector-java라는 훌륭한 라이브러리가 존재하는데 이를 직접 사용하면 코드가 다소 복잡해져서 이 라이브러리를 기반으로 한 mariadb-cdc라는 라이브러리를 만들었다.

MariaDB 설정

MariaDB 바이너리 로그 활성화

mariadb-cdc는 바이너리 로그를 사용하므로 binlog_format을 row로 설정한다.

binlog_format = row  
binlog_row_image = full  

binlog_row_image 값이 FULL이면 변경 전/후 모든 칼럼 값을 기록한다.

CDC를 위한 사용자 생성

CDC를 위한 사용자를 생성한다. 이 사용자에 REPLICATION SLAVE, REPLICATION CLIENT, SELECT 권한을 부여한다.

CREATE USER cdc@'%' IDENTIFIED BY 'password'  
GRANT REPLICATION SLAVE, REPLICATION CLIENT, SELECT ON *.* TO cdc@'%'  

메이븐 리포지토리 설정

mariadb-cdc를 사용하려면 아래 리포지토리 설정과 의존 설정을 추가한다.

<repositories>
    <repository>
        <id>jitpack.io</id>
        <url>https://jitpack.io</url>
    </repository>
</repositories>

<dependencies>
    <dependency>
        <groupId>com.github.madvirus</groupId>
        <artifactId>mariadb-cdc</artifactId>
        <version>0.11.0</version>
    </dependency>
</dependencies>

그레이들을 사용한다면 아래 설정을 추가한다.

repositories {
    mavenCentral()
    maven { url 'https://jitpack.io' }
}

dependencies {
    implementation 'com.github.madvirus:mariadb-cdc:0.11.0'
}

MariadbCdc 사용하기

기본 사용법

단계 1, MariadbCdcConfig 생성

MariadbCdcConfig config = new MariadbCdcConfig(
                "localhost", // MariaDB 호스트
                3306, // 포트
                "cdc", // CDC를 위한 사용자
                "password", // 암호
                "bin.pos"); // 바이너리 로그 위치 추적용 파일 경로

"bin.pos" 파일이 없으면 현재 바이너로 로그 위치부터 읽기 시작한다.
"bin.pos" 파일에 바이너로 로그 위치가 기록되어 있으면 해당 위치부터 읽기 시작한다.
MariadbCdc는 바이너로 로그를 읽으면 다음 위치를 "bin.pos" 파일에 기록한다.

단계 2, MariadbCdc 생성

JdbcColumnNamesGetter columnNamesGetter = new JdbcColumnNamesGetter(
            "localhost", // host
            3307, // port
            "cdc", // cdc user
            "password"); // password 

MariadbCdc cdc = new MariadbCdc(config, columnNamesGetter);

MariadbCdc는 테이블의 칼럼 이름을 구하기 위해 ColumnNamesGetter를 사용한다.

기본 제공하는 JdbcColumnNamesGetter는 다음 쿼리를 이용해서 칼럼 이름을 구한다:

select COLUMN_NAME, ORDINAL_POSITION, COLUMN_DEFAULT, IS_NULLABLE, DATA_TYPE 
from INFORMATION_SCHEMA.COLUMNS 
WHERE table_schema = '?' and TABLE_NAME = '?' 
order by ORDINAL_POSITION

단계 3, MariadbCdcListener 설정

cdc.setMariadbCdcListener(new MariadbCdcListener() {
    @Override
    public void started(BinlogPosition binlogPosition) {
        // CDC가 시작되면 호출됨
    }

    @Override
    public void startFailed(Exception e) {
        // CDC 시작에 실패하면 호출됨
    }

    @Override
    public void onDataChanged(List<RowChangedData> list) {
        // 변경된 데이터 목록(행 목록)을 받음
        list.forEach(data -> { // 변경된 각 행에 대해
            String database = data.getDatabase(); // 변경된 행의 DB 이름
            String table = data.getTable(); // 변경된 행의 테이블 이름
            DataRow dataRow = data.getDataRow(); // 변경된 데이터 행(변경 후 이미지)
            if (data.getType() == ChangeType.INSERT) { // 추가된 데이터면
                Long id = dataRow.getLong("id"); // id 칼럼 값을 Long으로 구한다.
                // ...
            } else if (data.getType() == ChangeType.UPDATE) { // 변경된 데이터면
                String name = dataRow.getString("name"); // 변경된 name 칼럼 값을 구한다.
                DataRow dataRowBeforeUpdate = data.getDataRowBeforeUpdate(); // 변경전 데이터 행(변경 전 이미지)
                String nameBeforeUpdate = dataRowBeforeUpdate.getString("name"); // 변경전 name 칼럼 값을 구한다.
                // ...
            } else if (data.getType() == ChangeType.DELETE) {
                String email = dataRow.getString("email"); // 삭제된 행의 email 칼럼 값을 구한다.
                // ...
            }
        });
    }

    @Override
    public void onXid(Long xid) {
        // 트랜잭션 커밋 로그
    }

    @Override
    public void stopped() {
        // CDC를 중지하면 호출됨
    }
});

단계 4, MariadbCdc 시작/중지

cdc.start(); // 별도 쓰레드로 바이너리 로그 조회 시작

...

cdc.stop(); // 조회 중지

MariadbCdc가 시작되면 setMariadbCdcListener()로 설정한 listener에 읽은 바이너리 로그 데이터를 전달한다.

 

MariadbCdc#start()는 별도 쓰레드로 바이너리 로그 조회를 시작한다.

특정 테이블만 포함하기/제외하기

MariadbCdcListener#onDataChanged()는 기본적으로 모든 변경에 대해 불린다. 만약 특정 테이블만 포함하거나 제외하고 싶다면 필터를 사용하면 된다.

// test.user 테이블 변경에 대해서만 onDataChanged() 호출
config.setIncludeFilters("test.user");
// test.member 테이블 변경은 onDataChanged() 호출 제외
config.setIncludeFilters("test.member");

수정한 칼럼만 포함하기

binlog_row_image가 full 이면 UPDATE/DELETE 시에 모든 칼럼 값을 포함한다. 변경된 칼럼 값만 포함하고 싶다면 binlog_row_image를 minimal로 설정한다.

binlog_format = row
binlog_row_image = minimal

MINIMAL은 수정 전 이미지에는 PK 칼럼만 기록하고(PK 칼럼이 없으면 전체 칼럼) 수정 후 이미지에는 변경된 칼럼만 기록한다.

binlog_row_image 가 minimal일 때 아래 쿼리를 실행하면

update member set name = 'newname' where id = 10

RowChangedData#getDataRowBeforeUpdate()는 PK 칼럼만 포함한 DataRow를 리턴하고
RowChangedData#getDataRow()는 변경된 칼럼만 포함한 DataRow를 리턴한다.

@Override
public void onDataChanged(List<RowChangedData> list) {
    // handle changed data
    list.forEach(data -> { // each
        String database = data.getDatabase(); // test
        String table = data.getTable(); // member
        DataRow afterDataRow = data.getDataRow(); // after image
        if (data.getType() == ChangeType.UPDATE) {
            DataRow beforeDataRow = data.getDataRowBeforeUpdate(); // before image
            Long id = beforeDataRow.getLong("id"); // before image includes only pk fields
            String name = afterDataRow.getString("name"); // after image includes only updated fields
            // ...
        }
    });
}

MariaDB 10.5: binlog_row_metadata = full

MariaDB 10.5는 binlog_row_metadata 변수를 지원한다.
binlog_row_metadata 값이 FULL이면 칼럼 이름을 포함한 모든 메타데이터가 바이너리 로그에 기록된다.
그래서 binlog_row_metadata가 FULL이면 ColumnNamesGetter가 필요 없다.

참고자료

+ Recent posts