다음 예제는 SQL 인터페이스를 사용하여 논리 디코딩 제어를 보여줍니다.
논리적 토토 결과을 사용하기 전에 설정해야합니다Wal_levelto논리andmax_replication_slots~ 1 개 이상. 그러면 대상 데이터베이스에 연결해야합니다 (아래 예제에서토토 결과) 슈퍼업자로서.
postgres =# - 출력 플러그인 'test_decoding'을 사용하여 'regression_slot'이라는 슬롯을 만듭니다.
postgres =# select * from pg_create_logical_replication_slot ( 'regression_slot', 'test_decoding', false, true);
slot_name | LSN
----------------+-----------
회귀 _slot | 0/16B1970
(1 줄)
postgres =# select selt_name, 플러그인, slot_type, database, active, retart_lsn, pg_replication_slots에서 volucted_flush_lsn;
slot_name | 플러그인 | slot_type | 데이터베이스 | 활성 | RETART_LSN | 확인 된_flush_lsn
-----------------------------------------------------------------------------------------------------------------
회귀 _slot | test_decoding | 논리적 | 토토 결과 | f | 0/16A4408 | 0/16A4440
(1 줄)
토토 결과 =# - 아직 볼 수있는 변경 사항이 없습니다
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----+-----+------
(0 줄)
postgres =# 테이블 데이터 생성 (ID 직렬 기본 키, 데이터 텍스트);
테이블을 만듭니다
토토 결과 =# - DDL은 복제되지 않았으므로 볼 수있는 것은 거래입니다.
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-------+-------------
0/ba2da58 | 10297 | 시작 10297 시작
0/ba5a5a0 | 10297 | 커밋 10297
(2 줄)
토토 결과 =# - 일단 변경되면 소비되고 방출되지 않습니다.
토토 결과 =# - 후속 호출에서 :
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----+-----+------
(0 줄)
postgres =# 시작;
postgres =*# 데이터에 삽입 (데이터) 값 ( '1');
postgres =*# 데이터에 삽입 (데이터) 값 ( '2');
토토 결과 =*# 커밋;
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-------+----------------------------------------------------------------
0/ba5a688 | 10298 | 10298을 시작하십시오
0/ba5a6f0 | 10298 | 테이블 public.data : 삽입 : id [정수] : 1 데이터 [텍스트] : '1'
0/ba5a7f8 | 10298 | table public.data : 삽입 : id [정수] : 2 데이터 [텍스트] : '2'
0/ba5a8a8 | 10298 | 커밋 10298
(4 줄)
postgres =# 데이터에 삽입 (데이터) 값 ( '3');
토토 결과 =# - 변경 스트림에서도 앞서 나갈 수 있습니다.
postgres =# select * from pg_logical_slot_peek_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-------+----------------------------------------------------------------
0/ba5a8e0 | 10299 | 시작 10299 시작
0/ba5a8e0 | 10299 | table public.data : 삽입 : ID [정수] : 3 데이터 [텍스트] : '3'
0/ba5a990 | 10299 | 10299 커밋
(3 줄)
postgres =# - pg_logical_slot_peek_changes ()에 대한 다음 호출은 동일한 변경 사항을 다시 반환합니다.
postgres =# select * from pg_logical_slot_peek_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-------+----------------------------------------------------------------
0/ba5a8e0 | 10299 | 시작 10299 시작
0/ba5a8e0 | 10299 | table public.data : 삽입 : ID [정수] : 3 데이터 [텍스트] : '3'
0/ba5a990 | 10299 | 10299 커밋
(3 줄)
토토 결과 = #- 옵션을 출력 플러그인으로 전달하여 서식에 영향을 줄 수 있습니다.
postgres =# select * from pg_logical_slot_peek_changes ( 'regression_slot', null, null, 'clude-timestamp', 'on');
LSN | xid | 데이터
-----------+-------+----------------------------------------------------------------
0/ba5a8e0 | 10299 | 시작 10299 시작
0/ba5a8e0 | 10299 | table public.data : 삽입 : ID [정수] : 3 데이터 [텍스트] : '3'
0/ba5a990 | 10299 | Commit 10299 (2017-05-10 12 : 07 : 21.272494-04)
(3 줄)
토토 결과 =# - 더 이상 소비를 멈출 필요가없는 슬롯을 파괴하는 것을 잊지 마십시오.
토토 결과 =# - 서버 리소스 :
토토 결과 =# 선택 PG_DROP_REPLICATION_SLOT ( 'regression_slot');
PG_DROP_REPLICATION_SLOT
-------------------------
(1 행)
다음 예제는 프로그램을 사용하여 스트리밍 복제 프로토콜을 통해 논리적 디코딩이 어떻게 제어되는지 보여줍니다PG_RECVLOGICAL토토 결과QL 분포에 포함됩니다. 이를 위해서는 클라이언트 인증이 복제 연결을 허용하도록 설정되어 있어야합니다 (참조섹션 26.2.5.1) 그리고 그max_wal_senders추가 연결을 허용하기 위해 충분히 높게 설정되어 있습니다. 두 번째 예는 2 상 트랜잭션을 스트리밍하는 방법을 보여줍니다. 2 단계 명령을 사용하기 전에 설정해야합니다max_prepared_transactions최소 1
예 1 : $ PG_RECVLOGICAL -D POSTGRES-SLOT = TEST -CREATE -SLOT $ PG_RECVLOGICAL -D POSTGRES-- 슬롯 = 테스트 -시작 -F -컨트롤+Z$ psql -d 토토 결과 -c "데이터에 삽입 (데이터) 값 ( '4');" $ fg 693을 시작하십시오 table public.data : 삽입 : id [정수] : 4 데이터 [텍스트] : '4' 커밋 693컨트롤+C$ pg_recvlogical -d 토토 결과 --- 슬롯 = test -drop -slot Example 2: $ PG_RECVLOGICAL -D POSTGRES-SLOT = TEST-CREATE-SLOT--TWO-CHASE $ PG_RECVLOGICAL -D POSTGRES-- 슬롯 = 테스트 -시작 -F -컨트롤+Z$ psql -d 토토 결과 -c "시작; 데이터에 삽입 (데이터) 값 ( '5'); 트랜잭션 '테스트'준비;" $ fg 694 시작 table public.data : 삽입 : id [정수] : 5 데이터 [텍스트] : '5' 거래 '테스트'준비, TXID 694컨트롤+Z$ psql -d 토토 결과 -c "준비된 '테스트';" $ fg 준비된 '테스트', TXID 694 커밋컨트롤+C$ pg_recvlogical -d 토토 결과 --- 슬롯 = test -drop -slot
다음 예제는 준비된 트랜잭션을 해독하는 데 사용할 수있는 SQL 인터페이스를 보여줍니다. 2 단계 커밋 명령을 사용하기 전에 설정해야합니다max_prepared_transactions~ 1 개 이상.를 사용하여 슬롯을 작성하는 동안 2 단계 매개 변수를 'true'로 설정해야합니다pg_create_logical_replication_slot아직 토토 결과되지 않은 경우 커밋 후 전체 트랜잭션을 스트리밍 할 것입니다.
postgres =# 시작;
postgres =*# 데이터에 삽입 (데이터) 값 ( '5');
postgres =*# 거래 준비 'test_prepared1';
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-----+--------------------------------------------------------------
0/1689dc0 | 529 | 시작 529 시작
0/1689dc0 | 529 | table public.data : 삽입 : id [정수] : 3 데이터 [텍스트] : '5'
0/1689FC0 | 529 | 거래 'test_prepared1', txid 529 준비
(3 줄)
postgres =# commit 준비 'test_prepared1';
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-----+---------------------------------------------
0/168a060 | 529 | 준비된 'test_prepared1', txid 529 커밋
(4 줄)
토토 결과 =#- 준비된 거래를 롤백 할 수도 있습니다
postgres =# 시작;
postgres =*# 데이터에 삽입 (데이터) 값 ( '6');
postgres =*# 거래 준비 'test_prepared2';
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-----+--------------------------------------------------------------
0/168A180 | 530 | 시작 530을 시작하십시오
0/168a1e8 | 530 | table public.data : 삽입 : id [정수] : 4 데이터 [텍스트] : '6'
0/168a430 | 530 | 트랜잭션 'test_prepared2', txid 530을 준비하십시오
(3 줄)
postgres =# 롤백 준비 'test_prepared2';
postgres =# select * from pg_logical_slot_get_changes ( 'regression_slot', null, null);
LSN | xid | 데이터
-----------+-----+--------------------------------------------------
0/168A4B8 | 530 | 롤백 준비 'test_prepared2', txid 530
(1 행)