diff options
Diffstat (limited to 'src/test/modules/commit_ts/t/001_base.pl')
| -rw-r--r-- | src/test/modules/commit_ts/t/001_base.pl | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/test/modules/commit_ts/t/001_base.pl b/src/test/modules/commit_ts/t/001_base.pl index 122b51557ad..f076a2739d4 100644 --- a/src/test/modules/commit_ts/t/001_base.pl +++ b/src/test/modules/commit_ts/t/001_base.pl @@ -13,17 +13,17 @@ $node->append_conf('postgresql.conf', 'track_commit_timestamp = on'); $node->start; # Create a table, compare "now()" to the commit TS of its xmin -$node->psql('postgres', 'create table t as select now from (select now(), pg_sleep(1)) f'); -my $true = $node->psql('postgres', +$node->safe_psql('postgres', 'create table t as select now from (select now(), pg_sleep(1)) f'); +my $true = $node->safe_psql('postgres', 'select t.now - ts.* < \'1s\' from t, pg_class c, pg_xact_commit_timestamp(c.xmin) ts where relname = \'t\''); is($true, 't', 'commit TS is set'); -my $ts = $node->psql('postgres', +my $ts = $node->safe_psql('postgres', 'select ts.* from pg_class, pg_xact_commit_timestamp(xmin) ts where relname = \'t\''); # Verify that we read the same TS after crash recovery $node->stop('immediate'); $node->start; -my $recovered_ts = $node->psql('postgres', +my $recovered_ts = $node->safe_psql('postgres', 'select ts.* from pg_class, pg_xact_commit_timestamp(xmin) ts where relname = \'t\''); is($recovered_ts, $ts, 'commit TS remains after crash recovery'); |