When doing a delete of a target, use the escaped version of the primary key columns.

diff --git a/Bucardo.pm b/Bucardo.pm
index 6fbe3482aab587145438212c378c140b4f85f608..0869423a36061e8a65f723ebf18930ad8661bc83 100644 (file)
--- a/Bucardo.pm
+++ b/Bucardo.pm
@@ -9220,7 +9220,7 @@ sub delete_rows {
             $SQL{IN}{$tname} = sprintf '%sDELETE FROM %s WHERE %s IN (',
                 $self->{sqlprefix},
                 $tname,
-                $pkcols;
+                $goat->{pklist};
             my $inner;
             if ($t->{has_mysql_timestamp_issue}) {
                 for my $key (keys %$rows) {