tyler.durden
/
centreon-plugins
mirror of https://github.com/centreon/centreon-plugins.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

(plugin) database::postgres - mode query-time fix exclude filters (#4197)

This commit is contained in:
qgarnier 2023-02-03 10:20:13 +00:00 committed by GitHub
parent 5e3f52fd1d
commit c4f4f0face
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 7 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
src/database/postgres/mode/querytime.pm
View File

@ -93,25 +93,24 @@ sub run {
); );
my $dbquery = {}; my $dbquery = {};
while ((my $row = $options{sql}->fetchrow_hashref())) { while ((my $row = $options{sql}->fetchrow_hashref())) {
if (defined($self->{option_results}->{exclude}) && $row->{datname} !~ /$self->{option_results}->{exclude}/) { next if (defined($self->{option_results}->{exclude}) && $self->{option_results}->{exclude} ne '' && $row->{datname} =~ /$self->{option_results}->{exclude}/);
next;
}
if (!defined($dbquery->{$row->{datname}})) { if (!defined($dbquery->{$row->{datname}})) {
$dbquery->{ $row->{datname} } = { total => 0, code => {} }; $dbquery->{ $row->{datname} } = { total => 0, code => {} };
} }
next if (!defined($row->{datid}) || $row->{datid} eq ''); # No joint next if (!defined($row->{datid}) || $row->{datid} eq ''); # No joint
if (defined($self->{option_results}->{exclude_user}) && $row->{usename} !~ /$self->{option_results}->{exclude_user}/) { next if (defined($self->{option_results}->{exclude_user}) && $self->{option_results}->{exclude_user} ne '' && $row->{usename} =~ /$self->{option_results}->{exclude_user}/);
next;
}
my $exit_code = $self->{perfdata}->threshold_check(value => $row->{seconds}, threshold => [ { label => 'critical', exit_litteral => 'critical' }, { label => 'warning', exit_litteral => 'warning' } ]); my $exit_code = $self->{perfdata}->threshold_check(value => $row->{seconds}, threshold => [ { label => 'critical', exit_litteral => 'critical' }, { label => 'warning', exit_litteral => 'warning' } ]);
if (!$self->{output}->is_status(value => $exit_code, compare => 'ok', litteral => 1)) { if (!$self->{output}->is_status(value => $exit_code, compare => 'ok', litteral => 1)) {
$self->{output}->output_add( $self->{output}->output_add(
long_msg => sprintf( long_msg => sprintf(
"Request from client '%s' too long (%d sec) on database '%s': %s", "Request from client '%s' too long (%s sec) on database '%s': %s",
$row->{client_addr}, $row->{seconds}, $row->{datname}, $row->{current_query} defined($row->{client_addr}) ? $row->{client_addr} : 'unknown',
defined($row->{seconds}) ? $row->{seconds} : '-',
defined($row->{datname}) ? $row->{datname} : '-',
defined($row->{current_query}) ? $row->{current_query} : '-'
) )
); );
$dbquery->{ $row->{datname} }->{total}++; $dbquery->{ $row->{datname} }->{total}++;