앞에서 언급했듯이 각 (활성) 토토 커뮤니티은 원격 (게시) 측면의 복제 슬롯으로부터 변경 사항을 수신합니다.

추가 테이블 동기화 슬롯은 일반적으로 과도하여 내부적으로 생성되어 초기 테이블 동기화를 수행하고 더 이상 필요하지 않을 때 자동으로 삭제됩니다. 이 테이블 동기화 슬롯은 이름을 생성했습니다.“pg_%u_sync_%u_%llu”(매개 변수 : 토토 커뮤니티OID, 테이블Relid, 시스템 식별자Sysid)

일반적으로 토토 커뮤니티을 사용하여 생성 될 때 원격 복제 슬롯이 자동으로 생성됩니다.토토 커뮤니티 생성그리고 토토 커뮤니티을 사용하여 삭제하면 자동으로 삭제됩니다삭제 토토 커뮤니티. 그러나 일부 상황에서는 토토 커뮤니티 및 기본 복제 슬롯을 별도로 조작하는 것이 유용하거나 필요할 수 있습니다. 몇 가지 시나리오는 다음과 같습니다.

게시자에서 테스트 테이블을 만듭니다.

test_pub =# 테이블 생성 t1 (a int, b 텍스트, 기본 키 (a));
테이블을 만듭니다
test_pub =# 생성 테이블 t2 (c int, d 텍스트, 기본 키 (c));
테이블을 만듭니다
test_pub =# 생성 테이블 t3 (e int, f 텍스트, 기본 키 (e));
테이블 작성

가입자에 동일한 테이블을 만듭니다.

test_sub =# 테이블 생성 t1 (a int, b 텍스트, 기본 키 (a));
테이블을 만듭니다
test_sub =# 생성 테이블 t2 (c int, d 텍스트, 기본 키 (c));
테이블을 만듭니다
test_sub =# 생성 테이블 t3 (e int, f 텍스트, 기본 키 (e));
테이블 작성

게시자 측의 테이블에 데이터를 삽입하십시오.

test_pub =# t1 값에 삽입 (1, one '), (2,'two '), (3,'Three ');
삽입 0 3
test_pub =# t2 값 (1, 'a'), (2, 'b'), (3, 'c')에 삽입;
삽입 0 3
test_pub =# t3 값 (1, 'i'), (2, 'ii'), (3, 'iii')에 삽입;
삽입 0 3

테이블에 대한 출판물을 만듭니다. 간행물pub2andpub3a일부를 허용하지 않음게시운영. 출판물pub3b행 필터가 있습니다 (참조섹션 29.4).

test_pub =# 표 T1 용 출판물 생성 Pub1;
출판물을 만듭니다
test_pub =# (publish = 'truncate')와 함께 표 t2 용 Pub2를 작성합니다.
출판물을 만듭니다
test_pub =# (publish = 'truncate')와 표 t3에 대한 pub3a를 작성합니다.
출판물을 만듭니다
test_pub =# 표 T3에 대한 pub3b 생성 (e 5);
출판물 만들기

출판물 토토 커뮤니티 생성. 토토 커뮤니티sub3둘 다 토토 커뮤니티pub3aandpub3b. 모든 토토 커뮤니티은 기본적으로 초기 데이터를 복사합니다.

test_sub =# 토토 커뮤니티 sub1 생성
test_sub-# connection 'host = localhost dbname = test_pub application_name = sub1'
test_sub-# publication pub1;
토토 커뮤니티 생성
test_sub =# 토토 커뮤니티 sub2 생성
test_sub-# connection 'host = localhost dbname = test_pub application_name = sub2'
test_sub-# publication pub2;
토토 커뮤니티 생성
test_sub =# 토토 커뮤니티 sub3 생성
test_sub-# connection 'host = localhost dbname = test_pub application_name = sub3'
test_sub-# publication pub3a, pub3b;
토토 커뮤니티 생성

초기 테이블 데이터가 복사되었는지 확인하십시오.게시출판물 운영.

test_sub =# select * from t1;
 A |   비
---+------
 1 | 하나
 2 | 둘
 3 | 삼
(3 줄)

test_sub =# select * from t2;
 C | 디
---+---
 1 | 에이
 2 | 비
 3 | 기음
(3 줄)

초기 데이터 사본이 무시하기 때문에게시​​운영, 그리고 출판pub3a행 필터가 없으므로 복사 된 테이블을 의미합니다T3출판의 행 필터와 일치하지 않더라도 모든 행을 포함합니다pub3b.

test_sub =# select * from t3;
 e |  에프
---+-----
 1 | 나
 2 | II
 3 | III
(3 줄)

게시자 측의 테이블에 더 많은 데이터를 삽입합니다.

test_pub =# t1 값 (4, '4'), (5, '5'), (6, 'six')에 삽입;
삽입 0 3
test_pub =# t2 값 (4, 'd'), (5, 'e'), (6, 'f')에 삽입;
삽입 0 3
test_pub =# t3 값 (4, 'iv'), (5, 'v'), (6, 'vi')에 삽입;
삽입 0 3

이제 게시자 측 데이터는 다음과 같습니다.

test_pub =# select * from t1;
 A |   비
---+------
 1 | 하나
 2 | 둘
 3 | 삼
 4 | 네
 5 | 다섯
 6 | 육
(6 줄)

test_pub =# select * from t2;
 C | 디
---+---
 1 | 에이
 2 | 비
 3 | 기음
 4 | 디
 5 | 이자형
 6 | 에프
(6 줄)

test_pub =# select * from t3;
 e |  에프
---+-----
 1 | 나
 2 | II
 3 | III
 4 | IV
 5 | 다섯
 6 | VI
(6 줄)

정상 복제 중에 적절한 것을 관찰하십시오게시작동이 사용됩니다. 이것은 출판물을 의미합니다pub2andpub3a복제하지 않습니다삽입. 또한 출판물pub3b의 행 필터와 일치하는 데이터 만 복제합니다.pub3b. 이제 가입자 측 데이터는 다음과 같습니다.

test_sub =# select * from t1;
 A |   비
---+------
 1 | 하나
 2 | 둘
 3 | 삼
 4 | 네
 5 | 다섯
 6 | 육
(6 줄)

test_sub =# select * from t2;
 C | 디
---+---
 1 | 에이
 2 | 비
 3 | 기음
(3 줄)

test_sub =# select * from t3;
 e |  에프
---+-----
 1 | 나
 2 | II
 3 | III
 6 | VI
(4 줄)

어떤 경우도 있습니다 (예 :섹션 29.2.1) 원격 복제 슬롯이 자동으로 생성되지 않은 경우 토토 커뮤니티을 활성화하기 전에 수동으로 생성해야합니다. 슬롯을 생성하고 토토 커뮤니티을 활성화하는 단계는 다음 예제에 나와 있습니다. 이 예제는 표준 논리 디코딩 출력 플러그인 (을 지정합니다.pgoutput), 이것이 내장 논리 복제가 사용하는 것입니다.

먼저, 예제를 사용할 출판물을 만듭니다.

test_pub =# 모든 테이블에 대한 출판물 생성 pub1;
출판물 만들기

예 1 : 토토 커뮤니티이 말하는 곳connect = false

예제 2 : 토토 커뮤니티이 말하는 곳connect = falseSLOT_NAME옵션.

예 3 : 토토 커뮤니티이 지정하는 위치slot_name = none