public function Sql::getRowsNeedingUpdate in Drupal 8
Same name and namespace in other branches
- 9 core/modules/migrate/src/Plugin/migrate/id_map/Sql.php \Drupal\migrate\Plugin\migrate\id_map\Sql::getRowsNeedingUpdate()
Retrieves an array of map rows marked as needing update.
Parameters
int $count: The maximum number of rows to return.
Return value
array Array of map row objects that need updating.
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
Drupal\migrate\Plugin\migrate\id_mapCode
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;
}