public function MigrateExecutable::import in Zircon Profile 8

Same name and namespace in other branches

1. 8.0 core/modules/migrate/src/MigrateExecutable.php \Drupal\migrate\MigrateExecutable::import()

Performs an import operation - migrate items from source to destination.

Overrides MigrateExecutableInterface::import

File

core/modules/migrate/src/MigrateExecutable.php, line 175

Contains \Drupal\migrate\MigrateExecutable.

Class

MigrateExecutable

Defines a migrate executable class.

Namespace

Drupal\migrate

Code

public function import() {

  // Only begin the import operation if the migration is currently idle.
  if ($this->migration
    ->getStatus() !== MigrationInterface::STATUS_IDLE) {
    $this->message
      ->display($this
      ->t('Migration @id is busy with another operation: @status', array(
      '@id' => $this->migration
        ->id(),
      '@status' => $this
        ->t($this->migration
        ->getStatusLabel()),
    )), 'error');
    return MigrationInterface::RESULT_FAILED;
  }
  $this
    ->getEventDispatcher()
    ->dispatch(MigrateEvents::PRE_IMPORT, new MigrateImportEvent($this->migration));

  // Knock off migration if the requirements haven't been met.
  try {
    $this->migration
      ->checkRequirements();
  } catch (RequirementsException $e) {
    $this->message
      ->display($this
      ->t('Migration @id did not meet the requirements. @message @requirements', array(
      '@id' => $this->migration
        ->id(),
      '@message' => $e
        ->getMessage(),
      '@requirements' => $e
        ->getRequirementsString(),
    )), 'error');
    return MigrationInterface::RESULT_FAILED;
  }
  $this->migration
    ->setStatus(MigrationInterface::STATUS_IMPORTING);
  $return = MigrationInterface::RESULT_COMPLETED;
  $source = $this
    ->getSource();
  $id_map = $this->migration
    ->getIdMap();
  try {
    $source
      ->rewind();
  } catch (\Exception $e) {
    $this->message
      ->display($this
      ->t('Migration failed with source plugin exception: @e', array(
      '@e' => $e
        ->getMessage(),
    )), 'error');
    $this->migration
      ->setStatus(MigrationInterface::STATUS_IDLE);
    return MigrationInterface::RESULT_FAILED;
  }
  $destination = $this->migration
    ->getDestinationPlugin();
  while ($source
    ->valid()) {
    $row = $source
      ->current();
    $this->sourceIdValues = $row
      ->getSourceIdValues();
    try {
      $this
        ->processRow($row);
      $save = TRUE;
    } catch (MigrateException $e) {
      $this->migration
        ->getIdMap()
        ->saveIdMapping($row, array(), $e
        ->getStatus());
      $this
        ->saveMessage($e
        ->getMessage(), $e
        ->getLevel());
      $save = FALSE;
    } catch (MigrateSkipRowException $e) {
      $id_map
        ->saveIdMapping($row, array(), MigrateIdMapInterface::STATUS_IGNORED);
      $save = FALSE;
    }
    if ($save) {
      try {
        $this
          ->getEventDispatcher()
          ->dispatch(MigrateEvents::PRE_ROW_SAVE, new MigratePreRowSaveEvent($this->migration, $row));
        $destination_id_values = $destination
          ->import($row, $id_map
          ->lookupDestinationId($this->sourceIdValues));
        $this
          ->getEventDispatcher()
          ->dispatch(MigrateEvents::POST_ROW_SAVE, new MigratePostRowSaveEvent($this->migration, $row, $destination_id_values));
        if ($destination_id_values) {

          // We do not save an idMap entry for config.
          if ($destination_id_values !== TRUE) {
            $id_map
              ->saveIdMapping($row, $destination_id_values, $this->sourceRowStatus, $destination
              ->rollbackAction());
          }
        }
        else {
          $id_map
            ->saveIdMapping($row, array(), MigrateIdMapInterface::STATUS_FAILED);
          if (!$id_map
            ->messageCount()) {
            $message = $this
              ->t('New object was not saved, no error provided');
            $this
              ->saveMessage($message);
            $this->message
              ->display($message);
          }
        }
      } catch (MigrateException $e) {
        $this->migration
          ->getIdMap()
          ->saveIdMapping($row, array(), $e
          ->getStatus());
        $this
          ->saveMessage($e
          ->getMessage(), $e
          ->getLevel());
      } catch (\Exception $e) {
        $this->migration
          ->getIdMap()
          ->saveIdMapping($row, array(), MigrateIdMapInterface::STATUS_FAILED);
        $this
          ->handleException($e);
      }
    }
    if ($high_water_property = $this->migration
      ->get('highWaterProperty')) {
      $this->migration
        ->saveHighWater($row
        ->getSourceProperty($high_water_property['name']));
    }

    // Reset row properties.
    unset($sourceValues, $destinationValues);
    $this->sourceRowStatus = MigrateIdMapInterface::STATUS_IMPORTED;

    // Check for memory exhaustion.
    if (($return = $this
      ->checkStatus()) != MigrationInterface::RESULT_COMPLETED) {
      break;
    }

    // If anyone has requested we stop, return the requested result.
    if ($this->migration
      ->getStatus() == MigrationInterface::STATUS_STOPPING) {
      $return = $this->migration
        ->getInterruptionResult();
      $this->migration
        ->clearInterruptionResult();
      break;
    }
    try {
      $source
        ->next();
    } catch (\Exception $e) {
      $this->message
        ->display($this
        ->t('Migration failed with source plugin exception: @e', array(
        '@e' => $e
          ->getMessage(),
      )), 'error');
      $this->migration
        ->setStatus(MigrationInterface::STATUS_IDLE);
      return MigrationInterface::RESULT_FAILED;
    }
  }
  $this
    ->getEventDispatcher()
    ->dispatch(MigrateEvents::POST_IMPORT, new MigrateImportEvent($this->migration));
  $this->migration
    ->setStatus(MigrationInterface::STATUS_IDLE);
  return $return;
}