granicus.if.org Git - postgresql/blob - contrib/test_decoding/sql/rewrite.sql

   1 -- predictability
   2 SET synchronous_commit = on;
   3
   4 DROP TABLE IF EXISTS replication_example;
   5
   6 SELECT 'init' FROM pg_create_logical_replication_slot('regression_slot', 'test_decoding');
   7 CREATE TABLE replication_example(id SERIAL PRIMARY KEY, somedata int, text varchar(120));
   8 INSERT INTO replication_example(somedata) VALUES (1);
   9 SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL, NULL, 'include-xids', '0', 'skip-empty-xacts', '1');
  10
  11 BEGIN;
  12 INSERT INTO replication_example(somedata) VALUES (2);
  13 ALTER TABLE replication_example ADD COLUMN testcolumn1 int;
  14 INSERT INTO replication_example(somedata, testcolumn1) VALUES (3,  1);
  15 COMMIT;
  16
  17 BEGIN;
  18 INSERT INTO replication_example(somedata) VALUES (3);
  19 ALTER TABLE replication_example ADD COLUMN testcolumn2 int;
  20 INSERT INTO replication_example(somedata, testcolumn1, testcolumn2) VALUES (4,  2, 1);
  21 COMMIT;
  22
  23 VACUUM FULL pg_am;
  24 VACUUM FULL pg_amop;
  25 VACUUM FULL pg_proc;
  26 VACUUM FULL pg_opclass;
  27 VACUUM FULL pg_type;
  28 VACUUM FULL pg_index;
  29 VACUUM FULL pg_database;
  30
  31 -- repeated rewrites that fail
  32 BEGIN;
  33 CLUSTER pg_class USING pg_class_oid_index;
  34 CLUSTER pg_class USING pg_class_oid_index;
  35 ROLLBACK;
  36
  37 -- repeated rewrites that succeed
  38 BEGIN;
  39 CLUSTER pg_class USING pg_class_oid_index;
  40 CLUSTER pg_class USING pg_class_oid_index;
  41 CLUSTER pg_class USING pg_class_oid_index;
  42 COMMIT;
  43
  44  -- repeated rewrites in different transactions
  45 VACUUM FULL pg_class;
  46 VACUUM FULL pg_class;
  47
  48 INSERT INTO replication_example(somedata, testcolumn1) VALUES (5, 3);
  49
  50 BEGIN;
  51 INSERT INTO replication_example(somedata, testcolumn1) VALUES (6, 4);
  52 ALTER TABLE replication_example ADD COLUMN testcolumn3 int;
  53 INSERT INTO replication_example(somedata, testcolumn1, testcolumn3) VALUES (7, 5, 1);
  54 COMMIT;
  55
  56 -- make old files go away
  57 CHECKPOINT;
  58
  59 SELECT data FROM pg_logical_slot_get_changes('regression_slot', NULL, NULL, 'include-xids', '0', 'skip-empty-xacts', '1');
  60 SELECT pg_drop_replication_slot('regression_slot');
  61
  62 DROP TABLE IF EXISTS replication_example;