function SourcePluginBase::next

File

core/modules/migrate/src/Plugin/migrate/source/SourcePluginBase.php, line 391

Class

SourcePluginBase

The base class for source plugins.

Namespace

Code

public function next() {
  $this->currentSourceIds = NULL;
  $this->currentRow = NULL;
  // In order to find the next row we want to process, we ask the source
  // plugin for the next possible row.
  while (!isset($this->currentRow) && $this->getIterator()
    ->valid()) {
    $row_data = $this->getIterator()
      ->current() + $this->configuration;
    $this->fetchNextRow();
    $row = new Row($row_data, $this->getIds());
    // Populate the source key for this row.
    $this->currentSourceIds = $row->getSourceIdValues();
    // Pick up the existing map row, if any, unless fetchNextRow() did it.
    if (!$this->mapRowAdded && ($id_map = $this->idMap
      ->getRowBySource($this->currentSourceIds))) {
      $row->setIdMap($id_map);
    }
    // Clear any previous messages for this row before potentially adding
    // new ones.
    if (!empty($this->currentSourceIds)) {
      $this->idMap
        ->delete($this->currentSourceIds, TRUE);
    }
    // Preparing the row gives source plugins the chance to skip.
    if ($this->prepareRow($row) === FALSE) {
      continue;
    }
    // Check whether the row needs processing.
    // 1. This row has not been imported yet.
    // 2. Explicitly set to update.
    // 3. The row is newer than the current high-water mark.
    // 4. If no such property exists then try by checking the hash of the row.
    if (!$row->getIdMap() || $row->needsUpdate() || $this->aboveHighWater($row) || $this->rowChanged($row)) {
      $this->currentRow = $row->freezeSource();
    }
    if ($this->getHighWaterProperty()) {
      $this->saveHighWater($row->getSourceProperty($this->highWaterProperty['name']));
    }
  }
}