다음 예제는 SQL 인터페이스를 사용하여 논리 디코딩 제어를 보여줍니다.
논리적 디코딩을 사용하기 전에 설정해야합니다Wal_levelto논리적andmax_replication_slots~ 1 개 이상. 그러면 대상 데이터베이스에 연결해야합니다 (아래 예제에서토토 사이트 순위) 슈퍼 사용자로서.
postgres =# - 출력 플러그인 'test_decoding'을 사용하여 'regression_slot'이라는 슬롯을 만듭니다.
postgres =# select * from pg_create_logical_replication_slot ( 'regression_slot', 'test_decoding');
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 =# 시작;
토토 사이트 순위 =# 데이터에 삽입 (데이터) 값 ( '1');
토토 사이트 순위 =# 데이터에 삽입 (데이터) 값 ( '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 행)
다음 예제는 프로그램을 사용하여 스트리밍 복제 프로토콜을 통해 논리적 디코딩이 어떻게 제어되는지 보여줍니다postgresql : 문서토토 사이트 순위QL 분포에 포함됩니다. 이를 위해서는 클라이언트 인증이 복제 연결을 허용하도록 설정되어 있어야합니다 (참조섹션 26.2.5.1) 그리고 그max_wal_senders추가 연결을 허용하기에 충분히 높게 설정되어 있습니다.
$ 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 POSTGRES-- 슬롯 = TEST -DROP -SLOT