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

(collection) can handle connection error for sql collection (#3639)

This commit is contained in:
qgarnier 2022-05-05 09:25:48 +02:00 committed by GitHub
parent 3f13066ccd
commit 1b8457753f
1 changed files with 22 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
centreon-plugins/centreon/common/protocols/sql/mode/collection.pm
View File

@ -356,6 +356,25 @@ sub collect_sql_sampling {
$self->{sql_cache}->write(data => { sql_collected_sampling => $self->{sql_collected_sampling} });
}
sub connect_sql {
my ($self, %options) = @_;
my ($status, $dontquit) = ('succeeded', 0);
if (defined($self->{config}->{sql}->{connectHandleError}) && $self->{config}->{sql}->{connectHandleError} == 1) {
$dontquit = 1;
}
my ($rv, $message) = $options{sql}->connect(dontquit => $dontquit);
if ($rv == -1) {
$status = 'failed';
}
$self->add_builtin(name => 'connectStatus', value => $status);
$self->add_builtin(name => 'connectMessage', value => defined($message) ? $message : '-');
return $rv;
}
sub collect_sql {
my ($self, %options) = @_;
@ -369,8 +388,9 @@ sub collect_sql {
$self->{sql_collected_sampling} = { tables => {}, epoch => time() };
$self->{sql_collected} = { tables => {}, epoch => time(), sampling => 0 };
$options{sql}->connect();
$self->collect_sql_tables(sql => $options{sql});
if ($self->connect_sql(%options) == 0) {
$self->collect_sql_tables(sql => $options{sql});
}
$self->{sql_collected}->{sampling} = 1 if (
scalar(keys(%{$self->{sql_collected_sampling}->{tables}})) > 0