function Sql::getRowsNeedingUpdate

Same name in other branches
  1. 8.9.x core/modules/migrate/src/Plugin/migrate/id_map/Sql.php \Drupal\migrate\Plugin\migrate\id_map\Sql::getRowsNeedingUpdate()
  2. 10 core/modules/migrate/src/Plugin/migrate/id_map/Sql.php \Drupal\migrate\Plugin\migrate\id_map\Sql::getRowsNeedingUpdate()
  3. 11.x core/modules/migrate/src/Plugin/migrate/id_map/Sql.php \Drupal\migrate\Plugin\migrate\id_map\Sql::getRowsNeedingUpdate()

Overrides MigrateIdMapInterface::getRowsNeedingUpdate

File

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

Class

Sql
Defines the sql based ID map implementation.

Namespace

Drupal\migrate\Plugin\migrate\id_map

Code

public function getRowsNeedingUpdate($count) {
    $rows = [];
    $result = $this->getDatabase()
        ->select($this->mapTableName(), 'map')
        ->fields('map')
        ->condition('source_row_status', MigrateIdMapInterface::STATUS_NEEDS_UPDATE)
        ->range(0, $count)
        ->execute();
    foreach ($result as $row) {
        $rows[] = $row;
    }
    return $rows;
}

Buggy or inaccurate documentation? Please file an issue. Need support? Need help programming? Connect with the Drupal community.