function Sql::getMessages

File

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

Class

Sql

Defines the sql based ID map implementation.

Namespace

Code

public function getMessages(array $source_id_values = [], $level = NULL) {
  $query = $this->getDatabase()
    ->select($this->messageTableName(), 'msg');
  $condition = sprintf('[msg].[%s] = [map].[%s]', $this::SOURCE_IDS_HASH, $this::SOURCE_IDS_HASH);
  $query->addJoin('LEFT', $this->mapTableName(), 'map', $condition);
  // Explicitly define the fields we want. The order will be preserved: source
  // IDs, destination IDs (if possible), and then the rest.
  foreach ($this->sourceIdFields() as $id => $column_name) {
    $query->addField('map', $column_name, "src_{$id}");
  }
  foreach ($this->destinationIdFields() as $id => $column_name) {
    $query->addField('map', $column_name, "dest_{$id}");
  }
  $query->fields('msg', [
    'msgid',
    $this::SOURCE_IDS_HASH,
    'level',
    'message',
  ]);
  if ($source_id_values) {
    $query->condition('msg.' . $this::SOURCE_IDS_HASH, $this->getSourceIdsHash($source_id_values));
  }
  if ($level) {
    $query->condition('msg.level', $level);
  }
  return $query->execute();
}