function Sql::saveMessage

Overrides MigrateIdMapInterface::saveMessage

File

core/modules/migrate/src/Plugin/migrate/id_map/Sql.php, line 716

Class

Sql

Defines the sql based ID map implementation.

Namespace

Code

public function saveMessage(array $source_id_values, $message, $level = MigrationInterface::MESSAGE_ERROR) {
    foreach ($this->sourceIdFields() as $field_name => $source_id) {
        // If any key value is not set, we can't save.
        if (!isset($source_id_values[$field_name])) {
            return;
        }
    }
    $fields[$this::SOURCE_IDS_HASH] = $this->getSourceIdsHash($source_id_values);
    $fields['level'] = $level;
    $fields['message'] = $message;
    $this->getDatabase()
        ->insert($this->messageTableName())
        ->fields($fields)
        ->execute();
    // Notify anyone listening of the message we've saved.
    $this->eventDispatcher
        ->dispatch(new MigrateIdMapMessageEvent($this->migration, $source_id_values, $message, $level), MigrateEvents::IDMAP_MESSAGE);
}