diff --git a/core/modules/migrate/src/Plugin/migrate/id_map/Sql.php b/core/modules/migrate/src/Plugin/migrate/id_map/Sql.php index 766e61d..f1be15e 100644 --- a/core/modules/migrate/src/Plugin/migrate/id_map/Sql.php +++ b/core/modules/migrate/src/Plugin/migrate/id_map/Sql.php @@ -655,13 +655,12 @@ public function delete(array $source_id_values, $messages_only = FALSE) { $map_query = $this->getDatabase()->delete($this->mapTableName()); } $message_query = $this->getDatabase()->delete($this->messageTableName()); - $count = 1; - foreach ($source_id_values as $id_value) { + + foreach ($this->sourceIdFields() as $field_name => $source_id) { if (!$messages_only) { - $map_query->condition('sourceid' . $count, $id_value); + $map_query->condition($source_id, $source_id_values[$field_name]); } - $message_query->condition('sourceid' . $count, $id_value); - $count++; + $message_query->condition($source_id, $source_id_values[$field_name]); } if (!$messages_only) {