version: "3"

services: 

   mypg:

     image: dalongrong/wal2json:1.0

     ports: 

     - "5432:5432"

     environment: 

     - "POSTGRES_PASSWORD:dalong"

docker-compose up -d

pg_recvlogical -h 127.0.0.1 -U postgres -d postgres --slot test_slot --create-slot -P wal2json

pg_recvlogical -h 127.0.0.1 -U postgres -d postgres --slot test_slot --start -o pretty-print=1 -f -

CREATE TABLE table_with_pk (a SERIAL, b VARCHAR(30), c TIMESTAMP NOT NULL, PRIMARY KEY(a, c));

CREATE TABLE table_without_pk (a SERIAL, b NUMERIC(5,2), c TEXT);

​

BEGIN;

INSERT INTO table_with_pk (b, c) VALUES('Backup and Restore', now());

INSERT INTO table_with_pk (b, c) VALUES('Tuning', now());

INSERT INTO table_with_pk (b, c) VALUES('Replication', now());

DELETE FROM table_with_pk WHERE a < 3;

​

INSERT INTO table_without_pk (b, c) VALUES(2.34, 'Tapir');

-- it is not added to stream because there isn't a pk or a replica identity

UPDATE table_without_pk SET c = 'Anta' WHERE c = 'Tapir';

COMMIT;

psql -At -f example1.sql -h 127.0.0.1 -U postgres -d postgres