You are here

class MigrateLookup in Drupal 8

Same name and namespace in other branches
  1. 9 core/modules/migrate/src/MigrateLookup.php \Drupal\migrate\MigrateLookup
  2. 10 core/modules/migrate/src/MigrateLookup.php \Drupal\migrate\MigrateLookup

Provides a migration lookup service.

Hierarchy

Expanded class hierarchy of MigrateLookup

1 file declares its use of MigrateLookup
MigrateLookupTest.php in core/modules/migrate/tests/src/Unit/MigrateLookupTest.php
1 string reference to 'MigrateLookup'
migrate.services.yml in core/modules/migrate/migrate.services.yml
core/modules/migrate/migrate.services.yml
1 service uses MigrateLookup
migrate.lookup in core/modules/migrate/migrate.services.yml
Drupal\migrate\MigrateLookup

File

core/modules/migrate/src/MigrateLookup.php, line 12

Namespace

Drupal\migrate
View source
class MigrateLookup implements MigrateLookupInterface {

  /**
   * The migration plugin manager.
   *
   * @var \Drupal\migrate\Plugin\MigrationPluginManagerInterface
   */
  protected $migrationPluginManager;

  /**
   * Constructs a MigrateLookup object.
   *
   * @param \Drupal\migrate\Plugin\MigrationPluginManagerInterface $migration_plugin_manager
   *   The migration plugin manager.
   */
  public function __construct(MigrationPluginManagerInterface $migration_plugin_manager) {
    $this->migrationPluginManager = $migration_plugin_manager;
  }

  /**
   * {@inheritdoc}
   */
  public function lookup($migration_id, array $source_id_values) {
    $results = [];
    $migrations = $this->migrationPluginManager
      ->createInstances($migration_id);
    if (!$migrations) {
      throw new PluginNotFoundException($migration_id);
    }
    foreach ($migrations as $migration) {
      if ($result = $this
        ->doLookup($migration, $source_id_values)) {
        $results = array_merge($results, $result);
      }
    }
    return $results;
  }

  /**
   * Performs a lookup.
   *
   * @param \Drupal\migrate\Plugin\MigrationInterface $migration
   *   The migration upon which to perform the lookup.
   * @param array $source_id_values
   *   The source ID values to look up.
   *
   * @return array
   *   An array of arrays of destination identifier values.
   *
   * @throws \Drupal\migrate\MigrateException
   *   Thrown when $source_id_values contains unknown keys, or the wrong number
   *   of keys.
   */
  protected function doLookup(MigrationInterface $migration, array $source_id_values) {
    $destination_keys = array_keys($migration
      ->getDestinationPlugin()
      ->getIds());
    $indexed_ids = $migration
      ->getIdMap()
      ->lookupDestinationIds($source_id_values);
    $keyed_ids = [];
    foreach ($indexed_ids as $id) {
      $keyed_ids[] = array_combine($destination_keys, $id);
    }
    return $keyed_ids;
  }

}

Members

Namesort descending Modifiers Type Description Overrides
MigrateLookup::$migrationPluginManager protected property The migration plugin manager.
MigrateLookup::doLookup protected function Performs a lookup.
MigrateLookup::lookup public function Retrieves destination ids from a migration lookup. Overrides MigrateLookupInterface::lookup
MigrateLookup::__construct public function Constructs a MigrateLookup object.