CheckMediaDuplicate.php in Migrate File Entities to Media Entities 8

Namespace

Drupal\migrate_file_to_media\Plugin\migrate\process

File

src/Plugin/migrate/process/CheckMediaDuplicate.php

<?php

namespace Drupal\migrate_file_to_media\Plugin\migrate\process;

use Drupal\migrate\MigrateExecutableInterface;
use Drupal\migrate\MigrateSkipRowException;
use Drupal\migrate\ProcessPluginBase;
use Drupal\migrate\Row;

/**
 *
 * @MigrateProcessPlugin(
 *   id = "check_media_duplicate"
 * )
 */
class CheckMediaDuplicate extends ProcessPluginBase {

  /**
   * {@inheritdoc}
   */
  public function transform($value, MigrateExecutableInterface $migrate_executable, Row $row, $destination_property) {
    if ($value) {
      $query = \Drupal::database()
        ->select('migrate_file_to_media_mapping', 'map');
      $query
        ->fields('map');
      $query
        ->condition('fid', $value, '=');
      $query
        ->isNotNull('media_id');
      $result = $query
        ->execute()
        ->fetchObject();
      if (!empty($result->fid)) {
        throw new MigrateSkipRowException();
      }
    }
  }

}

Classes

Name	Description
CheckMediaDuplicate	Plugin annotation @MigrateProcessPlugin( id = "check_media_duplicate" )