mirror of
https://github.com/postgres/postgres.git
synced 2025-05-02 11:44:50 +03:00
cf26a8d8a7
It turns out that the instability complained of in commit d3c09b9b1 has an embarrassingly simple explanation. The test script waits for the standby to flush incoming WAL to disk, but it should wait for the WAL to be replayed, since we are testing for the effects of that to be visible. While at it, use wait_for_catchup instead of reinventing that logic, and adjust $Test::Builder::Level to improve future error reports. Back-patch to v12 where the necessary infrastructure came in (cf. aforesaid commit). Also back-patch 7d1aa6bf1 so that the test will actually get run. Discussion: https://postgr.es/m/2854602.1632852664@sss.pgh.pa.us
80 lines
2.4 KiB
Perl
80 lines
2.4 KiB
Perl
# Test generic xlog record work for bloom index replication.
|
|
use strict;
|
|
use warnings;
|
|
use PostgresNode;
|
|
use TestLib;
|
|
use Test::More tests => 31;
|
|
|
|
my $node_master;
|
|
my $node_standby;
|
|
|
|
# Run few queries on both master and standby and check their results match.
|
|
sub test_index_replay
|
|
{
|
|
my ($test_name) = @_;
|
|
|
|
local $Test::Builder::Level = $Test::Builder::Level + 1;
|
|
|
|
# Wait for standby to catch up
|
|
$node_master->wait_for_catchup($node_standby);
|
|
|
|
my $queries = qq(SET enable_seqscan=off;
|
|
SET enable_bitmapscan=on;
|
|
SET enable_indexscan=on;
|
|
SELECT * FROM tst WHERE i = 0;
|
|
SELECT * FROM tst WHERE i = 3;
|
|
SELECT * FROM tst WHERE t = 'b';
|
|
SELECT * FROM tst WHERE t = 'f';
|
|
SELECT * FROM tst WHERE i = 3 AND t = 'c';
|
|
SELECT * FROM tst WHERE i = 7 AND t = 'e';
|
|
);
|
|
|
|
# Run test queries and compare their result
|
|
my $master_result = $node_master->safe_psql("postgres", $queries);
|
|
my $standby_result = $node_standby->safe_psql("postgres", $queries);
|
|
|
|
is($master_result, $standby_result, "$test_name: query result matches");
|
|
return;
|
|
}
|
|
|
|
# Initialize master node
|
|
$node_master = get_new_node('master');
|
|
$node_master->init(allows_streaming => 1);
|
|
$node_master->start;
|
|
my $backup_name = 'my_backup';
|
|
|
|
# Take backup
|
|
$node_master->backup($backup_name);
|
|
|
|
# Create streaming standby linking to master
|
|
$node_standby = get_new_node('standby');
|
|
$node_standby->init_from_backup($node_master, $backup_name,
|
|
has_streaming => 1);
|
|
$node_standby->start;
|
|
|
|
# Create some bloom index on master
|
|
$node_master->safe_psql("postgres", "CREATE EXTENSION bloom;");
|
|
$node_master->safe_psql("postgres", "CREATE TABLE tst (i int4, t text);");
|
|
$node_master->safe_psql("postgres",
|
|
"INSERT INTO tst SELECT i%10, substr(md5(i::text), 1, 1) FROM generate_series(1,100000) i;"
|
|
);
|
|
$node_master->safe_psql("postgres",
|
|
"CREATE INDEX bloomidx ON tst USING bloom (i, t) WITH (col1 = 3);");
|
|
|
|
# Test that queries give same result
|
|
test_index_replay('initial');
|
|
|
|
# Run 10 cycles of table modification. Run test queries after each modification.
|
|
for my $i (1 .. 10)
|
|
{
|
|
$node_master->safe_psql("postgres", "DELETE FROM tst WHERE i = $i;");
|
|
test_index_replay("delete $i");
|
|
$node_master->safe_psql("postgres", "VACUUM tst;");
|
|
test_index_replay("vacuum $i");
|
|
my ($start, $end) = (100001 + ($i - 1) * 10000, 100000 + $i * 10000);
|
|
$node_master->safe_psql("postgres",
|
|
"INSERT INTO tst SELECT i%10, substr(md5(i::text), 1, 1) FROM generate_series($start,$end) i;"
|
|
);
|
|
test_index_replay("insert $i");
|
|
}
|