committing streamed transaction

(17 rows)

-- Test that accessing a TOAST table in streaming mode is allowed.

-- Create a table with a column that uses a TOASTed default value.

-- (temporarily hide query, to avoid the long CREATE TABLE stmt)

\set ECHO none

SET debug_logical_replication_streaming = immediate;

BEGIN;

INSERT INTO test_tab VALUES(1);

-- Force WAL flush, so that the above changes will be streamed.

SELECT 'force flush' FROM pg_switch_wal();

?column?

-------------

force flush

(1 row)

SELECT count(*) FROM pg_logical_slot_get_changes('regression_slot', NULL, NULL, 'include-xids', '0', 'skip-empty-xacts', '1', 'stream-changes', '1');

count

-------

3

(1 row)

COMMIT;

RESET debug_logical_replication_streaming;

DROP TABLE stream_test;

SELECT pg_drop_replication_slot('regression_slot');

pg_drop_replication_slot

SELECT dataFROM pg_logical_slot_get_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1','stream-changes','1');

\set ECHO none

SELECT'CREATE TABLE test_tab (a text DEFAULT'''|| string_agg('toast value','')||''');'FROM generate_series(1,4000)

\gexec

\set ECHO all

SET debug_logical_replication_streaming= immediate;

BEGIN;

INSERT INTO test_tabVALUES(1);

SELECT'force flush'FROM pg_switch_wal();

SELECTcount(*)FROM pg_logical_slot_get_changes('regression_slot',NULL,NULL,'include-xids','0','skip-empty-xacts','1','stream-changes','1');

COMMIT;

RESET debug_logical_replication_streaming;

DROPTABLE stream_test;

SELECT pg_drop_replication_slot('regression_slot');

index_rescan(sysscan->iscan,key,nkeys,NULL,0);

sysscan->scan=NULL;

if (TransactionIdIsValid(CheckXidAlive))

bsysscan= true;

returnsysscan;

}

index_endscan(sysscan->iscan);

if (sysscan->snapshot)

UnregisterSnapshot(sysscan->snapshot);

if (TransactionIdIsValid(CheckXidAlive))

bsysscan= false;

pfree(sysscan);

}