PostgreSQL과 MySQL 간의 교차 복제

PostgreSQL과 MySQL 간의 교차 복제와 두 데이터베이스 서버 간의 교차 복제를 설정하는 방법에 대해 간략하게 설명하겠습니다. 일반적으로 교차 복제된 데이터베이스를 동종 데이터베이스라고 하며 이는 한 RDBMS 서버에서 다른 RDBMS 서버로 이동하는 편리한 방법입니다.

PostgreSQL 및 MySQL 데이터베이스는 일반적으로 관계형으로 간주되지만 추가 확장을 통해 NoSQL 기능을 제공합니다. 여기에서는 관계형 DBMS 관점에서 PostgreSQL과 MySQL 간의 복제에 대해 논의합니다.

전체 내부 작업을 설명하지는 않고 데이터베이스 서버 간 복제 구성, 장점, 제한 사항 및 사용 사례에 대한 아이디어를 얻을 수 있도록 기본 원칙만 설명합니다.

일반적으로 두 개의 동일한 데이터베이스 서버 간의 복제는 바이너리 모드에서 수행되거나 마스터(게시자, 마스터 또는 활성)와 슬레이브(구독자, 대기 또는 수동) 간의 쿼리를 사용하여 수행됩니다. 복제의 목적은 슬레이브 측에 마스터 데이터베이스의 실시간 복사본을 제공하는 것입니다. 이 경우 복제가 한 방향으로만 이루어지기 때문에 데이터가 마스터에서 슬레이브로, 즉 액티브에서 패시브로 전송됩니다. 그러나 두 데이터베이스 간에 양방향으로 복제를 설정할 수 있으므로 활성-활성 구성에서 데이터가 슬레이브에서 마스터로 전송됩니다. 계단식 복제를 포함한 이 모든 것은 둘 이상의 동일한 데이터베이스 서버 간에 가능합니다. 액티브-액티브 또는 액티브-패시브 구성은 필요, 초기 구성에서의 해당 기능의 가용성 또는 외부 구성 솔루션의 사용 및 기존 장단점에 따라 달라집니다.

설명된 구성은 서로 다른 데이터베이스 서버 간에 가능합니다. 다른 데이터베이스 서버의 복제된 데이터를 받아들이고 복제된 데이터의 실시간 스냅샷을 계속 유지하도록 서버를 구성할 수 있습니다. MySQL 및 PostgreSQL은 바이너리 로그 방법, 디스크 잠금, 명령문 및 행 기반 방법을 포함하여 이러한 구성의 대부분을 내부 또는 타사 확장을 통해 제공합니다.

한 데이터베이스 서버에서 다른 데이터베이스 서버로 일회성 마이그레이션을 수행하려면 MySQL과 PostgreSQL 간의 교차 복제가 필요합니다. 이러한 데이터베이스는 서로 다른 프로토콜을 사용하므로 직접 연결할 수 없습니다. 데이터 교환을 설정하려면 pg_chameleon과 같은 외부 오픈 소스 도구를 사용할 수 있습니다.

pg_chameleon이 무엇인가요?

pg_chameleon은 Python 3의 MySQL에서 PostgreSQL로의 복제 시스템입니다. Python에서도 오픈 소스 mysql-replication 라이브러리를 사용합니다. 행 이미지는 MySQL 테이블에서 추출되어 PostgreSQL 데이터베이스에 JSONB 개체로 저장된 후 pl/pgsql 함수로 해독되어 PostgreSQL 데이터베이스에서 재생됩니다.

pg_chameleon의 특징

동일한 클러스터의 여러 MySQL 스키마를 일대다 구성으로 단일 대상 PostgreSQL 데이터베이스에 복제할 수 있습니다.
소스 및 대상 스키마 이름은 동일할 수 없습니다.
다단계 MySQL 복제본에서 복제 데이터를 검색할 수 있습니다.
복제할 수 없거나 오류가 발생하는 테이블은 제외됩니다.
각 복제 기능은 데몬에 의해 제어됩니다.
YAML 기반 매개변수 및 구성 파일을 통해 제어합니다.

예

주인
vm1
vm2

OS 버전
CentOS 리눅스 7.6 x86_64
CentOS 리눅스 7.5 x86_64

DB 서버 버전
MySQL의 5.7.26
PostgreSQL 10.5

DB 포트
3306
5433

IP 주소
192.168.56.102
192.168.56.106

시작하려면 pg_chameleon을 설치하는 데 필요한 모든 구성 요소를 준비하십시오. 이 예제에서는 가상 환경을 생성하고 활성화하는 Python 3.6.8을 설치합니다.

$> wget https://www.python.org/ftp/python/3.6.8/Python-3.6.8.tar.xz
$> tar -xJf Python-3.6.8.tar.xz
$> cd Python-3.6.8
$> ./configure --enable-optimizations
$> make altinstall

Python3.6을 성공적으로 설치한 후에는 가상 환경 생성 및 활성화와 같은 나머지 요구 사항을 완료해야 합니다. 또한 pip 모듈이 최신 버전으로 업데이트되어 pg_chameleon을 설치하는 데 사용됩니다. 아래 명령은 최신 버전이 2.0.9이지만 의도적으로 pg_chameleon 2.0.10를 설치합니다. 이는 업데이트된 버전에서 새로운 버그를 방지하는 데 필요합니다.

$> python3.6 -m venv venv
$> source venv/bin/activate
(venv) $> pip install pip --upgrade
(venv) $> pip install pg_chameleon==2.0.9

그런 다음 set_configuration_files 인수를 사용하여 pg_chameleon(카멜레온은 명령)을 호출하여 pg_chameleon을 활성화하고 기본 디렉터리와 구성 파일을 만듭니다.

(venv) $> chameleon set_configuration_files
creating directory /root/.pg_chameleon
creating directory /root/.pg_chameleon/configuration/
creating directory /root/.pg_chameleon/logs/
creating directory /root/.pg_chameleon/pid/
copying configuration  example in /root/.pg_chameleon/configuration//config-example.yml

이제 기본 구성 파일이 되도록 config-example.yml의 복사본을 default.yml로 생성합니다. 이 예에 대한 샘플 구성 파일이 아래에 제공됩니다.

$> cat default.yml
---
#global settings
pid_dir: '~/.pg_chameleon/pid/'
log_dir: '~/.pg_chameleon/logs/'
log_dest: file
log_level: info
log_days_keep: 10
rollbar_key: ''
rollbar_env: ''

# type_override allows the user to override the default type conversion into a different one.
type_override:
  "tinyint(1)":
    override_to: boolean
    override_tables:
      - "*"

#postgres  destination connection
pg_conn:
  host: "192.168.56.106"
  port: "5433"
  user: "usr_replica"
  password: "pass123"
  database: "db_replica"
  charset: "utf8"

sources:
  mysql:
    db_conn:
      host: "192.168.56.102"
      port: "3306"
      user: "usr_replica"
      password: "pass123"
      charset: 'utf8'
      connect_timeout: 10
    schema_mappings:
      world_x: pgworld_x
    limit_tables:
#      - delphis_mediterranea.foo
    skip_tables:
#      - delphis_mediterranea.bar
    grant_select_to:
      - usr_readonly
    lock_timeout: "120s"
    my_server_id: 100
    replica_batch_size: 10000
    replay_max_rows: 10000
    batch_retention: '1 day'
    copy_max_memory: "300M"
    copy_mode: 'file'
    out_dir: /tmp
    sleep_loop: 1
    on_error_replay: continue
    on_error_read: continue
    auto_maintenance: "disabled"
    gtid_enable: No
    type: mysql
    skip_events:
      insert:
        - delphis_mediterranea.foo #skips inserts on the table delphis_mediterranea.foo
      delete:
        - delphis_mediterranea #skips deletes on schema delphis_mediterranea
      update:

이 예제의 구성 파일은 소스 및 대상 환경에 맞게 약간 수정된 샘플 pg_chameleon 파일이며, 아래는 구성 파일의 다양한 섹션에 대한 개요입니다.

default.yml 구성 파일에는 잠금 파일 위치, 로그 위치, 로그 저장 기간 등과 같은 설정을 관리할 수 있는 전역 설정 섹션이 있습니다. 다음은 유형 재정의 섹션입니다. 복제 중에 유형을 재정의하기 위한 규칙 집합입니다. 이 예제에서는 기본적으로tinyint(1)을 부울 값으로 변환하는 유형 재정의 규칙이 사용됩니다. 다음 섹션에서는 대상 데이터베이스에 대한 연결 세부 정보를 지정합니다. 우리의 경우 이는 pg_conn으로 지정된 PostgreSQL 데이터베이스입니다. 마지막 섹션에서는 소스 데이터, 즉 소스 데이터베이스의 연결 매개 변수, 소스 데이터베이스와 대상 데이터베이스 간의 매핑 방식, 건너뛰어야 하는 테이블, 대기 시간, 메모리, 패키지 크기를 나타냅니다. "소스"는 복수형입니다. 즉, 단일 대상 데이터베이스에 여러 소스 데이터베이스를 추가하여 다대일 구성을 설정할 수 있다는 의미입니다.

예제 데이터베이스 world_x에는 MySQL 커뮤니티에서 예제로 제공하는 행이 포함된 4개의 테이블이 포함되어 있습니다. 다운로드 가능 여기에. 샘플 데이터베이스는 행 생성 및 가져오기 지침이 포함된 tar 및 압축 아카이브로 제공됩니다.

MySQL 및 PostgreSQL 데이터베이스에서는 usr_replica라는 이름으로 특수 사용자가 생성됩니다. MySQL에서는 복제된 모든 테이블에 대한 추가 읽기 권한이 부여됩니다.

mysql> CREATE USER usr_replica ;
mysql> SET PASSWORD FOR usr_replica='pass123';
mysql> GRANT ALL ON world_x.* TO 'usr_replica';
mysql> GRANT RELOAD ON *.* to 'usr_replica';
mysql> GRANT REPLICATION CLIENT ON *.* to 'usr_replica';
mysql> GRANT REPLICATION SLAVE ON *.* to 'usr_replica';
mysql> FLUSH PRIVILEGES;

PostgreSQL 측에서는 MySQL 데이터베이스의 변경 사항을 허용하는 db_replica 데이터베이스가 생성됩니다. PostgreSQL의 usr_replica 사용자는 실제 복제된 테이블과 복제 디렉터리 테이블이 각각 포함된 두 스키마 pgworld_x 및 sch_chameleon의 소유자로 자동 구성됩니다. create_replica_schema 인수는 아래에서 볼 수 있듯이 자동 구성을 담당합니다.

postgres=# CREATE USER usr_replica WITH PASSWORD 'pass123';
CREATE ROLE
postgres=# CREATE DATABASE db_replica WITH OWNER usr_replica;
CREATE DATABASE

MySQL 데이터베이스는 아래와 같이 복제를 준비하기 위해 일부 매개변수 변경으로 구성되었습니다. 변경 사항을 적용하려면 데이터베이스 서버를 다시 시작해야 합니다.

$> vi /etc/my.cnf
binlog_format= ROW
binlog_row_image=FULL
log-bin = mysql-bin
server-id = 1

이제 pg_chameleon 명령을 실행할 때 문제가 발생하지 않도록 두 데이터베이스 서버에 대한 연결을 확인하는 것이 중요합니다.

PostgreSQL 노드에서:

$> mysql -u usr_replica -Ap'admin123' -h 192.168.56.102 -D world_x

MySQL 노드에서:

$> psql -p 5433 -U usr_replica -h 192.168.56.106 db_replica

다음 세 가지 pg_chameleon(카멜레온) 명령은 환경을 준비하고, 소스를 추가하고, 복제본을 초기화합니다. pg_chameleon에 대한 create_replica_schema 인수는 이미 설명한 대로 PostgreSQL 데이터베이스에 기본 스키마(sch_chameleon)와 복제 스키마(pgworld_x)를 생성합니다. add_source 인수는 구성 파일(default.yml)을 읽어 구성에 소스 데이터베이스를 추가하는데, 우리의 경우에는 mysql이고 init_replica는 구성 파일의 매개변수를 기반으로 구성을 초기화합니다.

$> chameleon create_replica_schema --debug
$> chameleon add_source --config default --source mysql --debug
$> chameleon init_replica --config default --source mysql --debug

이 세 가지 명령의 출력은 성공적으로 실행되었음을 분명히 나타냅니다. 충돌이나 구문 오류는 문제 해결 방법에 대한 힌트와 함께 간단하고 명확한 메시지로 보고됩니다.

마지막으로 start_replica를 사용하여 복제를 시작하고 성공 메시지를 받습니다.

$> chameleon start_replica --config default --source mysql 
output: Starting the replica process for source mysql

show_status 인수를 사용하여 복제 상태를 쿼리할 수 있으며 show_errors 인수를 사용하여 오류를 볼 수 있습니다.

그 결과.

이미 말했듯이 각 복제 기능은 데몬에 의해 제어됩니다. 이를 보려면 아래와 같이 Linux ps 명령을 사용하여 프로세스 테이블을 쿼리합니다.

그 결과.

아래와 같이 실시간으로 테스트할 때까지 복제는 구성된 것으로 간주되지 않습니다. 테이블을 생성하고 몇 개의 레코드를 MySQL 데이터베이스에 삽입한 다음 pg_chameleon에서 sync_tables 인수를 호출하여 데몬을 업데이트하고 레코드가 포함된 테이블을 PostgreSQL 데이터베이스에 복제합니다.

mysql> create table t1 (n1 int primary key, n2 varchar(10));
Query OK, 0 rows affected (0.01 sec)
mysql> insert into t1 values (1,'one');
Query OK, 1 row affected (0.00 sec)
mysql> insert into t1 values (2,'two');
Query OK, 1 row affected (0.00 sec)

$> chameleon sync_tables --tables world_x.t1 --config default --source mysql
Sync tables process for source mysql started.

테스트 결과를 확인하기 위해 PostgreSQL 데이터베이스에서 테이블을 쿼리하고 행을 출력합니다.

$> psql -p 5433 -U usr_replica -d db_replica -c "select * from pgworld_x.t1";
 n1 |  n2
----+-------
  1 | one
  2 | two

마이그레이션을 수행하는 경우 다음 pg_chameleon 명령으로 마이그레이션이 종료됩니다. 모든 대상 테이블의 행이 복제되었음을 확인한 후에 명령을 실행해야 하며, 그 결과 원본 데이터베이스 또는 복제 체계(sch_chameleon)를 참조하지 않고 깔끔하게 마이그레이션된 PostgreSQL 데이터베이스가 됩니다.

$> chameleon stop_replica --config default --source mysql 
$> chameleon detach_replica --config default --source mysql --debug

원하는 경우 다음 명령을 사용하여 원래 구성 및 복제 체계를 삭제할 수 있습니다.

$> chameleon drop_source --config default --source mysql --debug
$> chameleon drop_replica_schema --config default --source mysql --debug

pg_chameleon의 장점

간편한 설정 및 구성.
명확한 오류 메시지를 통해 이상 현상을 쉽게 해결하고 식별할 수 있습니다.
나머지 구성을 변경하지 않고도 초기화 후에 추가 특수 테이블을 복제에 추가할 수 있습니다.
단일 대상 데이터베이스에 대해 여러 소스 데이터베이스를 구성할 수 있으며 이는 하나 이상의 MySQL 데이터베이스의 데이터를 단일 PostgreSQL 데이터베이스로 결합하는 경우 매우 유용합니다.
선택한 테이블을 복제할 필요는 없습니다.

pg_chameleon의 단점

소스로는 MySQL 5.5 이상, 대상 데이터베이스로는 PostgreSQL 9.5 이상에서만 지원됩니다.
각 테이블에는 기본 키 또는 고유 키가 있어야 합니다. 그렇지 않으면 init_replica 프로세스 중에 테이블이 초기화되지만 복제되지는 않습니다.
단방향 복제 - MySQL에서 PostgreSQL로만 가능합니다. 따라서 "액티브-패시브" 회로에만 적합합니다.
소스는 MySQL 데이터베이스만 가능하며 PostgreSQL 데이터베이스를 소스로 지원하는 것은 실험적이며 제한이 있습니다(자세히 알아보기) 여기에)

pg_chameleon에 대한 결과

pg_chameleon의 복제 방법은 MySQL에서 PostgreSQL로 데이터베이스를 마이그레이션하는 데 적합합니다. 중요한 단점은 복제가 단방향으로만 수행되므로 데이터베이스 전문가가 마이그레이션 이외의 용도로 복제를 사용하기를 원하지 않는다는 것입니다. 그러나 단방향 복제 문제는 또 다른 오픈 소스 도구인 SymmetricDS를 사용하여 해결할 수 있습니다.

공식 문서에서 자세한 내용을 읽어보세요. 여기에. 명령줄 도움말을 찾을 수 있습니다. 여기에.

SymmetricDS 개요

SymmetricDS는 Oracle, MongoDB, PostgreSQL, MySQL, SQL Server, MariaDB, DB2, Sybase, Greenplum, Informix, H2, Firebird 및 기타 클라우드 데이터베이스 인스턴스(예: Redshift)와 같은 다른 일반적인 데이터베이스에 데이터베이스를 복제하는 오픈 소스 도구입니다. Azure 등 사용 가능한 기능: 데이터베이스 및 파일 동기화, 다중 마스터 데이터베이스 복제, 필터링된 동기화, 변환 등. 이는 Java 도구이며 JRE 또는 JDK(버전 8.0 이상)의 표준 릴리스가 필요합니다. 여기서 소스 데이터베이스의 트리거에 대한 데이터 변경 사항을 기록하고 배치 형태로 해당 대상 데이터베이스에 보낼 수 있습니다.

대칭DS 기능

이 도구는 플랫폼 독립적입니다. 즉, 두 개 이상의 서로 다른 데이터베이스가 데이터를 교환할 수 있습니다.
관계형 데이터베이스는 데이터 변경 기록을 사용하여 동기화되는 반면, 파일 시스템 기반 데이터베이스는 파일 동기화를 사용합니다.
일련의 규칙을 기반으로 하는 Push 및 Pull 방법을 사용한 양방향 복제입니다.
안전한 저대역폭 네트워크를 통해 데이터 전송이 가능합니다.
장애 후 노드가 작동을 재개할 때 자동 복구 및 자동 충돌 해결.
클라우드와 호환되고 강력한 확장 API.

예

SymmetricDS는 다음 두 가지 방법 중 하나로 구성할 수 있습니다.
두 슬레이브(자식) 노드 간의 데이터 복제를 중앙에서 조정하는 마스터(상위) 노드이며, 하위 노드 간의 통신은 상위를 통해서만 발생합니다.
활성 노드(노드 1)는 중개자 없이 다른 활성 노드(노드 2)와 복제를 위해 통신할 수 있습니다.

두 옵션 모두 푸시 및 풀을 사용하여 데이터 교환이 발생합니다. 이 예에서는 활성-활성 구성을 고려합니다. 전체 아키텍처를 설명하려면 시간이 너무 오래 걸리므로 조사해 보세요. 지도력SymmetricDS 장치에 대해 자세히 알아보세요.

SymmetricDS 설치는 매우 간단합니다. zip 파일의 오픈 소스 버전을 다운로드하세요. 따라서 그리고 원하는 곳에 꺼내보세요. 아래 표에는 이 예의 SymmetricDS 설치 위치 및 버전에 대한 정보뿐만 아니라 두 노드의 데이터베이스 버전, Linux 버전, IP 주소 및 포트도 제공됩니다.

주인
vm1
vm2

OS 버전
CentOS 리눅스 7.6 x86_64
CentOS 리눅스 7.6 x86_64

DB 서버 버전
MySQL의 5.7.26
PostgreSQL 10.5

DB 포트
3306
5832

IP 주소
192.168.1.107
192.168.1.112

대칭DS 버전
대칭DS 3.9
대칭DS 3.9

대칭DS 설치 경로
/usr/local/대칭-서버-3.9.20
/usr/local/대칭-서버-3.9.20

대칭DS 노드 이름
기업-000
상점-001

여기서는 /usr/local/symmetric-server-3.9.20에 SymmetricDS를 설치하고 다양한 하위 디렉터리와 파일이 여기에 저장됩니다. 우리는 샘플과 엔진 하위 디렉터리에 관심이 있습니다. 샘플 디렉터리에는 빠르게 시작하는 데 도움이 되는 예제 SQL 스크립트뿐만 아니라 노드 속성이 포함된 예제 구성 파일이 포함되어 있습니다.

샘플 디렉터리에는 노드 속성이 포함된 세 가지 구성 파일이 있습니다. 이름은 특정 체계에서 노드의 특성을 보여줍니다.

corp-000.properties
store-001.properties
store-002.properties

SymmetricDS에는 기본 3노드 설계(옵션 1)에 필요한 모든 구성 파일이 있으며, 2노드 설계(옵션 2)에도 동일한 파일을 사용할 수 있습니다. 필요한 구성 파일을 샘플 디렉터리에서 vm1 호스트의 엔진으로 복사합니다. 다음과 같이 밝혀졌습니다.

$> cat engines/corp-000.properties
engine.name=corp-000
db.driver=com.mysql.jdbc.Driver
db.url=jdbc:mysql://192.168.1.107:3306/replica_db?autoReconnect=true&useSSL=false
db.user=root
db.password=admin123
registration.url=
sync.url=http://192.168.1.107:31415/sync/corp-000
group.id=corp
external.id=000

SymmetricDS 구성의 이 노드를 corp-000이라고 하며, 데이터베이스 연결은 위의 연결 문자열과 로그인 자격 증명을 사용하는 mysql jdbc 드라이버에 의해 처리됩니다. Replica_db 데이터베이스에 연결하면 스키마 생성 중에 테이블이 생성됩니다. sync.url은 동기화를 위해 노드에 접속할 위치를 보여줍니다.

호스트 vm2의 노드 2는 store-001로 구성되고 나머지는 아래 node.properties 파일에 지정됩니다. Node store-001은 PostgreSQL 데이터베이스를 실행하고 pgdb_replica는 복제 데이터베이스입니다. Registration.url을 사용하면 호스트 vm2가 호스트 vm1에 접속하고 호스트로부터 구성 세부정보를 받을 수 있습니다.

$> cat engines/store-001.properties
engine.name=store-001
db.driver=org.postgresql.Driver
db.url=jdbc:postgresql://192.168.1.112:5832/pgdb_replica
db.user=postgres
db.password=admin123
registration.url=http://192.168.1.107:31415/sync/corp-000
group.id=store
external.id=001

완성된 SymmetricDS 예제에는 두 데이터베이스 서버(두 노드) 간의 양방향 복제를 설정하기 위한 매개변수가 포함되어 있습니다. 아래 단계는 호스트 vm1(corp-000)에서 수행되며, 이는 4개의 테이블이 있는 예제 스키마를 생성합니다. 그런 다음 Symadmin 명령으로 create-sym-tables를 실행하면 노드 간 복제 규칙과 방향이 저장되는 디렉터리 테이블이 생성됩니다. 마지막으로 샘플 데이터가 테이블에 로드됩니다.

vm1$> cd /usr/local/symmetric-server-3.9.20/bin
vm1$> ./dbimport --engine corp-000 --format XML create_sample.xml
vm1$> ./symadmin --engine corp-000 create-sym-tables
vm1$> ./dbimport --engine corp-000 insert_sample.sql

예제에서 item 및 item_판매_price 테이블은 corp-000에서 store-001로 복제되도록 자동으로 구성되고, 판매 테이블(sale_transaction 및 sale_return_line_item)은 store-001에서 corp-000으로 복제되도록 자동으로 구성됩니다. 이제 호스트 vm2(store-001)의 PostgreSQL 데이터베이스에 스키마를 생성하여 corp-000에서 데이터를 수신할 수 있도록 준비합니다.

vm2$> cd /usr/local/symmetric-server-3.9.20/bin
vm2$> ./dbimport --engine store-001 --format XML create_sample.xml

vm1의 MySQL 데이터베이스에 예제 테이블과 SymmetricDS 카탈로그 테이블이 있는지 확인하세요. SymmetricDS 시스템 테이블(sym_ 접두어)은 현재 노드 corp-000에서만 사용할 수 있습니다. 노드 corp-001에서 create-sym-tables 명령을 실행하고 복제를 관리할 것이기 때문입니다. 그리고 노드 store-4의 데이터베이스에는 데이터가 없는 예제 테이블이 XNUMX개만 있습니다.

모두. 아래와 같이 두 노드 모두에서 Sym 서버 프로세스를 실행할 수 있는 환경이 준비되었습니다.

vm1$> cd /usr/local/symmetric-server-3.9.20/bin
vm1$> sym 2>&1 &

로그 항목은 SymmetricDS가 설치된 디렉터리의 로그 폴더에 있는 백그라운드 로그 파일(symmetric.log)과 표준 출력으로 전송됩니다. 이제 노드 store-001에서 Sym 서버를 시작할 수 있습니다.

vm2$> cd /usr/local/symmetric-server-3.9.20/bin
vm2$> sym 2>&1 &

vm2 호스트에서 Sym 서버 프로세스를 실행하면 PostgreSQL 데이터베이스에 SymmetricDS 카탈로그 테이블도 생성됩니다. 두 노드 모두에서 Sym 서버 프로세스를 실행하면 서로 조정하여 corp-000에서 store-001로 데이터를 복제합니다. 몇 초 후에 양쪽의 4개 테이블을 모두 쿼리하면 복제가 성공한 것을 확인할 수 있습니다. 또는 다음 명령을 사용하여 corp-001에서 노드 store-000로 부트스트랩을 보낼 수 있습니다.

vm1$> ./symadmin --engine corp-000 reload-node 001

이 시점에서 노드 corp-000(호스트: vm1)의 MySQL 데이터베이스에 있는 항목 테이블에 새 레코드가 삽입되고, 노드 store-001(호스트: vm2)의 PostgreSQL 데이터베이스에 대한 복제를 확인할 수 있습니다. corp-000에서 store-001로 데이터를 이동하는 Pull 작업이 보입니다.

mysql> insert into item values ('22000002','Jelly Bean');
Query OK, 1 row affected (0.00 sec)

vm2$> psql -p 5832 -U postgres pgdb_replica -c "select * from item"
 item_id  |   name
----------+-----------
 11000001 | Yummy Gum
 22000002 | Jelly Bean
(2 rows)

store-001에서 corp-000으로 데이터를 이동하는 푸시 작업을 수행하려면 sale_transaction 테이블에 레코드를 삽입하고 복제가 성공했는지 확인합니다.

그 결과.

MySQL과 PostgreSQL 데이터베이스 간의 예제 테이블의 성공적인 양방향 복제 설정을 확인합니다. 새 사용자 테이블에 대한 복제를 설정하려면 다음 단계를 따르세요. 예를 들어 테이블 t1을 생성하고 다음과 같이 복제 규칙을 구성합니다. 이 방법으로 corp-000에서 store-001로의 복제만 구성합니다.

mysql> create table  t1 (no integer);
Query OK, 0 rows affected (0.01 sec)

mysql> insert into sym_channel (channel_id,create_time,last_update_time) 
values ('t1',current_timestamp,current_timestamp);
Query OK, 1 row affected (0.01 sec)

mysql> insert into sym_trigger (trigger_id, source_table_name,channel_id,
last_update_time, create_time) values ('t1', 't1', 't1', current_timestamp,
current_timestamp);
Query OK, 1 row affected (0.01 sec)

mysql> insert into sym_trigger_router (trigger_id, router_id,
Initial_load_order, create_time,last_update_time) values ('t1',
'corp-2-store-1', 1, current_timestamp,current_timestamp);
Query OK, 1 row affected (0.01 sec)

그런 다음 테이블 정의를 매핑하기 위해 트리거를 다시 생성하는 sync-triggers 인수와 함께 Symadmin 명령을 사용하여 스키마 변경, 즉 새 테이블 추가에 대한 알림을 구성에 보냅니다. send-schema를 실행하여 스키마 변경 사항을 node store-001로 보내고 테이블 t1의 복제를 구성합니다.

vm1$> ./symadmin -e corp-000 --node=001 sync-triggers    
vm1$> ./symadmin send-schema -e corp-000 --node=001 t1

SymmetricDS의 이점

XNUMX노드 또는 XNUMX노드 회로 생성을 위한 매개변수가 포함된 기성 파일 세트를 포함하여 간편한 설치 및 구성.
서버, 노트북, 모바일 장치를 포함한 크로스 플랫폼 데이터베이스 및 플랫폼 독립성.
모든 데이터베이스를 로컬, WAN 또는 클라우드의 다른 데이터베이스에 복제하세요.
편리한 복제를 위해 몇 개의 데이터베이스 또는 수천 개의 데이터베이스로 최적의 작업이 가능합니다.
GUI와 탁월한 지원을 갖춘 유료 버전입니다.

SymmetricDS의 단점

카탈로그 테이블을 로드하려면 SQL 문을 통해 명령줄에서 복제 규칙과 방향을 수동으로 정의해야 하는데 이는 불편할 수 있습니다.
복제 규칙과 방향을 정의하는 SQL 문을 생성하기 위해 스크립트를 사용하지 않는 한 복제를 위해 많은 테이블을 설정하는 것은 지루할 수 있습니다.
로그에 기록되는 정보가 너무 많아 공간을 많이 차지하지 않도록 로그 파일을 정리해야 할 때도 있습니다.

SymmetricDS에 대한 결과

SymmetricDS를 사용하면 XNUMX개, XNUMX개 또는 수천 개의 노드 간에 양방향 복제를 설정하여 파일을 복제하고 동기화할 수 있습니다. 이는 노드에서 장기간 다운타임이 발생한 후 자동 데이터 복구, HTTPS를 통한 노드 간 안전하고 효율적인 데이터 교환, 일련의 규칙에 따른 자동 충돌 관리 등 많은 작업을 독립적으로 수행하는 고유한 도구입니다. SymmetricDS는 따라서 데이터베이스 간의 복제는 플랫폼 간 데이터 마이그레이션, 마이그레이션, 배포, 필터링 및 변환을 비롯한 다양한 시나리오에 사용될 수 있습니다.

예제는 공식 문서를 기반으로 합니다. 빠른 가이드 SymmetricDS에 의해. 안에 사용자 매뉴얼 SymmetricDS를 사용한 복제 설정과 관련된 다양한 개념을 자세히 설명합니다.

출처 : habr.com