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

Merge branch 'deadlocks-base-de-datos-en-cluster-de-percona-4137' into 'develop' 

Retry queries when a deadlock is found.

See merge request !936
This commit is contained in:
vgilc 2017-10-18 11:15:54 +02:00
parent 157670c21c 702bed8c13
commit 7121d4a343
1 changed files with 37 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

56
pandora_server/lib/PandoraFMS/DB.pm
View File

@ -805,25 +805,20 @@ sub db_delete_limit ($$$$;@) {
sub db_insert ($$$;@) {
my ($dbh, $index, $query, @values) = @_;
my $insert_id = undef;
# MySQL
if ($RDBMS eq 'mysql') {
eval {
$dbh->do($query, undef, @values);
$insert_id = $dbh->{'mysql_insertid'};
}
# PostgreSQL
elsif ($RDBMS eq 'postgresql') {
$insert_id = get_db_value ($dbh, $query . ' RETURNING ' . $RDBMS_QUOTE . $index . $RDBMS_QUOTE, @values);
}
# Oracle
elsif ($RDBMS eq 'oracle') {
my $sth = $dbh->prepare($query . ' RETURNING ' . $RDBMS_QUOTE . (uc ($index)) . $RDBMS_QUOTE . ' INTO ?');
for (my $i = 0; $i <= $#values; $i++) {
$sth->bind_param ($i+1, $values[$i]);
};
if ($@) {
my $exception = @_;
if ($DBI::err == 1213) {
$dbh->do($query, undef, @values);
$insert_id = $dbh->{'mysql_insertid'};
}
else {
die($exception);
}
$sth->bind_param_inout($#values + 2, \$insert_id, 99);
$sth->execute ();
}
return $insert_id;
@ -834,8 +829,20 @@ sub db_insert ($$$;@) {
##########################################################################
sub db_update ($$;@) {
my ($dbh, $query, @values) = @_;
my $rows = $dbh->do($query, undef, @values);
my $rows;
eval {
$rows = $dbh->do($query, undef, @values);
};
if ($@) {
my $exception = @_;
if ($DBI::err == 1213) {
$rows = $dbh->do($query, undef, @values);
}
else {
die($exception);
}
}
return $rows;
}
@ -1016,7 +1023,18 @@ sub db_do ($$;@) {
my ($dbh, $query, @values) = @_;
#DBI->trace( 3, '/tmp/dbitrace.log' );
$dbh->do($query, undef, @values);
eval {
$dbh->do($query, undef, @values);
};
if ($@) {
my $exception = @_;
if ($DBI::err == 1213) {
$dbh->do($query, undef, @values);
}
else {
die($exception);
}
}
}
########################################################################