function Sql::getRowsNeedingUpdate

Overrides MigrateIdMapInterface::getRowsNeedingUpdate

File

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

Class

Sql

Defines the sql based ID map implementation.

Namespace

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;
}