diff options
author | Michael Paquier <michael@paquier.xyz> | 2021-04-01 09:48:17 +0900 |
---|---|---|
committer | Michael Paquier <michael@paquier.xyz> | 2021-04-01 09:48:17 +0900 |
commit | 0d1a33438d3a88938264e12e94c22818307d2f4d (patch) | |
tree | b5f41e9584570ab2750af52c5a6703292a9efe89 /src/test/perl/PostgresNode.pm | |
parent | 28b3e3905c982c42fb10ee800e6f881e9742c89d (diff) | |
download | postgresql-0d1a33438d3a88938264e12e94c22818307d2f4d.tar.gz postgresql-0d1a33438d3a88938264e12e94c22818307d2f4d.zip |
Move some client-specific routines from SSLServer to PostgresNode
test_connect_ok() and test_connect_fails() have always been part of the
SSL tests, and check if a connection to the backend should work or not,
and there are sanity checks done on specific error patterns dropped by
libpq if the connection fails.
This was fundamentally wrong on two aspects. First, SSLServer.pm works
mostly on setting up and changing the SSL configuration of a
PostgresNode, and has really nothing to do with the client. Second,
the situation became worse in light of b34ca595, where the SSL tests
would finish by using a psql command that may not come from the same
installation as the node set up.
This commit moves those client routines into PostgresNode, making easier
the refactoring of SSLServer to become more SSL-implementation aware.
This can also be reused by the ldap, kerberos and authentication test
suites for connection checks, and a follow-up patch should extend those
interfaces to match with backend log patterns.
Author: Michael Paquier
Reviewed-by: Andrew Dunstan, Daniel Gustafsson, Álvaro Herrera
Discussion: https://postgr.es/m/YGLKNBf9zyh6+WSt@paquier.xyz
Diffstat (limited to 'src/test/perl/PostgresNode.pm')
-rw-r--r-- | src/test/perl/PostgresNode.pm | 72 |
1 files changed, 64 insertions, 8 deletions
diff --git a/src/test/perl/PostgresNode.pm b/src/test/perl/PostgresNode.pm index 1e96357d7ed..d6e10544bb9 100644 --- a/src/test/perl/PostgresNode.pm +++ b/src/test/perl/PostgresNode.pm @@ -1511,6 +1511,11 @@ the B<timed_out> parameter is also given. If B<timeout> is set and this parameter is given, the scalar it references is set to true if the psql call times out. +=item connstr => B<value> + +If set, use this as the connection string for the connection to the +backend. + =item replication => B<value> If set, add B<replication=value> to the conninfo string. @@ -1550,14 +1555,20 @@ sub psql my $replication = $params{replication}; my $timeout = undef; my $timeout_exception = 'psql timed out'; - my @psql_params = ( - 'psql', - '-XAtq', - '-d', - $self->connstr($dbname) - . (defined $replication ? " replication=$replication" : ""), - '-f', - '-'); + + # Build the connection string. + my $psql_connstr; + if (defined $params{connstr}) + { + $psql_connstr = $params{connstr}; + } + else + { + $psql_connstr = $self->connstr($dbname); + } + $psql_connstr .= defined $replication ? " replication=$replication" : ""; + + my @psql_params = ('psql', '-XAtq', '-d', $psql_connstr, '-f', '-'); # If the caller wants an array and hasn't passed stdout/stderr # references, allocate temporary ones to capture them so we @@ -1849,6 +1860,51 @@ sub interactive_psql =pod +=item $node->connect_ok($connstr, $test_name) + +Attempt a connection with a custom connection string. This is expected +to succeed. + +=cut + +sub connect_ok +{ + local $Test::Builder::Level = $Test::Builder::Level + 1; + my ($self, $connstr, $test_name) = @_; + my ($ret, $stdout, $stderr) = $self->psql( + 'postgres', + "SELECT \$\$connected with $connstr\$\$", + connstr => "$connstr", + on_error_stop => 0); + + ok($ret == 0, $test_name); +} + +=pod + +=item $node->connect_fails($connstr, $expected_stderr, $test_name) + +Attempt a connection with a custom connection string. This is expected +to fail with a message that matches the regular expression +$expected_stderr. + +=cut + +sub connect_fails +{ + local $Test::Builder::Level = $Test::Builder::Level + 1; + my ($self, $connstr, $expected_stderr, $test_name) = @_; + my ($ret, $stdout, $stderr) = $self->psql( + 'postgres', + "SELECT \$\$connected with $connstr\$\$", + connstr => "$connstr"); + + ok($ret != 0, $test_name); + like($stderr, $expected_stderr, "$test_name: matches"); +} + +=pod + =item $node->poll_query_until($dbname, $query [, $expected ]) Run B<$query> repeatedly, until it returns the B<$expected> result |