2024-01-11 18:47:28 +01:00
|
|
|
# Copyright (c) 2021-2023, PostgreSQL Global Development Group
|
|
|
|
|
|
|
|
use strict;
|
|
|
|
use warnings;
|
|
|
|
use File::Compare;
|
|
|
|
use PostgreSQL::Test::Cluster;
|
|
|
|
use PostgreSQL::Test::Utils;
|
|
|
|
use Test::More;
|
|
|
|
|
|
|
|
# Set up a new database instance.
|
|
|
|
my $node1 = PostgreSQL::Test::Cluster->new('node1');
|
|
|
|
$node1->init(has_archiving => 1, allows_streaming => 1);
|
|
|
|
$node1->append_conf('postgresql.conf', 'summarize_wal = on');
|
|
|
|
$node1->start;
|
|
|
|
|
|
|
|
# See what's been summarized up until now.
|
|
|
|
my $progress = $node1->safe_psql('postgres', <<EOM);
|
|
|
|
SELECT summarized_tli, summarized_lsn FROM pg_get_wal_summarizer_state()
|
|
|
|
EOM
|
|
|
|
my ($summarized_tli, $summarized_lsn) = split(/\|/, $progress);
|
|
|
|
note("before insert, summarized TLI $summarized_tli through $summarized_lsn");
|
|
|
|
|
|
|
|
# Create a table and insert a few test rows into it. VACUUM FREEZE it so that
|
|
|
|
# autovacuum doesn't induce any future modifications unexpectedly. Then
|
|
|
|
# trigger a checkpoint.
|
|
|
|
$node1->safe_psql('postgres', <<EOM);
|
|
|
|
CREATE TABLE mytable (a int, b text);
|
|
|
|
INSERT INTO mytable
|
|
|
|
SELECT
|
|
|
|
g, random()::text||random()::text||random()::text||random()::text
|
|
|
|
FROM
|
|
|
|
generate_series(1, 400) g;
|
|
|
|
VACUUM FREEZE;
|
|
|
|
CHECKPOINT;
|
|
|
|
EOM
|
|
|
|
|
|
|
|
# Wait for a new summary to show up.
|
|
|
|
$node1->poll_query_until('postgres', <<EOM);
|
|
|
|
SELECT EXISTS (
|
|
|
|
SELECT * from pg_available_wal_summaries()
|
|
|
|
WHERE tli = $summarized_tli AND end_lsn > '$summarized_lsn'
|
|
|
|
)
|
|
|
|
EOM
|
|
|
|
|
|
|
|
# Again check the progress of WAL summarization.
|
|
|
|
$progress = $node1->safe_psql('postgres', <<EOM);
|
|
|
|
SELECT summarized_tli, summarized_lsn FROM pg_get_wal_summarizer_state()
|
|
|
|
EOM
|
|
|
|
($summarized_tli, $summarized_lsn) = split(/\|/, $progress);
|
|
|
|
note("after insert, summarized TLI $summarized_tli through $summarized_lsn");
|
2024-01-26 19:25:19 +01:00
|
|
|
note_wal_summary_dir("after insert", $node1);
|
2024-01-11 18:47:28 +01:00
|
|
|
|
|
|
|
# Update a row in the first block of the table and trigger a checkpoint.
|
|
|
|
$node1->safe_psql('postgres', <<EOM);
|
|
|
|
UPDATE mytable SET b = 'abcdefghijklmnopqrstuvwxyz' WHERE a = 2;
|
|
|
|
CHECKPOINT;
|
|
|
|
EOM
|
|
|
|
|
|
|
|
# Again wait for a new summary to show up.
|
|
|
|
$node1->poll_query_until('postgres', <<EOM);
|
|
|
|
SELECT EXISTS (
|
|
|
|
SELECT * from pg_available_wal_summaries()
|
|
|
|
WHERE tli = $summarized_tli AND end_lsn > '$summarized_lsn'
|
|
|
|
)
|
|
|
|
EOM
|
|
|
|
|
2024-01-15 17:50:44 +01:00
|
|
|
# Figure out the exact details for the new summary file.
|
2024-01-11 18:47:28 +01:00
|
|
|
my $details = $node1->safe_psql('postgres', <<EOM);
|
|
|
|
SELECT tli, start_lsn, end_lsn from pg_available_wal_summaries()
|
|
|
|
WHERE tli = $summarized_tli AND end_lsn > '$summarized_lsn'
|
|
|
|
EOM
|
|
|
|
my ($tli, $start_lsn, $end_lsn) = split(/\|/, $details);
|
|
|
|
note("examining summary for TLI $tli from $start_lsn to $end_lsn");
|
2024-01-26 19:25:19 +01:00
|
|
|
note_wal_summary_dir("after new summary", $node1);
|
2024-01-11 18:47:28 +01:00
|
|
|
|
|
|
|
# Reconstruct the full pathname for the WAL summary file.
|
|
|
|
my $filename = sprintf "%s/pg_wal/summaries/%08s%08s%08s%08s%08s.summary",
|
|
|
|
$node1->data_dir, $tli,
|
|
|
|
split(m@/@, $start_lsn),
|
|
|
|
split(m@/@, $end_lsn);
|
|
|
|
ok(-f $filename, "WAL summary file exists");
|
2024-01-26 19:25:19 +01:00
|
|
|
note_wal_summary_dir("after existence check", $node1);
|
2024-01-11 18:47:28 +01:00
|
|
|
|
2024-01-11 21:01:51 +01:00
|
|
|
# Run pg_walsummary on it. We expect block 0 to be modified, but depending
|
|
|
|
# on where the new tuple ends up, block 1 might also be modified, so we
|
|
|
|
# pass -i to pg_walsummary to make sure we don't end up with a 0..1 range.
|
|
|
|
my ($stdout, $stderr) = run_command([ 'pg_walsummary', '-i', $filename ]);
|
2024-01-11 18:47:28 +01:00
|
|
|
like($stdout, qr/FORK main: block 0$/m, "stdout shows block 0 modified");
|
|
|
|
is($stderr, '', 'stderr is empty');
|
2024-01-26 19:25:19 +01:00
|
|
|
note_wal_summary_dir("after pg_walsummary run", $node1);
|
2024-01-11 18:47:28 +01:00
|
|
|
|
|
|
|
done_testing();
|
2024-01-26 19:25:19 +01:00
|
|
|
|
|
|
|
# XXX. Temporary debugging code.
|
|
|
|
sub note_wal_summary_dir
|
|
|
|
{
|
|
|
|
my ($flair, $node) = @_;
|
|
|
|
|
|
|
|
my $wsdir = sprintf "%s/pg_wal/summaries", $node->data_dir;
|
|
|
|
my @wsfiles = grep { $_ ne '.' && $_ ne '..' } slurp_dir($wsdir);
|
|
|
|
note("$flair pg_wal/summaries has: @wsfiles");
|
|
|
|
}
|