View source
<?php
namespace Drupal\photos\Plugin\migrate\destination;
use Drupal\Core\Database\Connection;
use Drupal\migrate\Plugin\MigrationInterface;
use Drupal\migrate\Row;
use Drupal\migrate\Plugin\migrate\destination\DestinationBase;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
class PhotosCount extends DestinationBase implements ContainerFactoryPluginInterface {
protected $connection;
public function __construct(array $configuration, $plugin_id, $plugin_definition, MigrationInterface $migration, Connection $connection) {
parent::__construct($configuration, $plugin_id, $plugin_definition, $migration);
$this->connection = $connection;
}
public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition, MigrationInterface $migration = NULL) {
return new static($configuration, $plugin_id, $plugin_definition, $migration, $container
->get('database'));
}
public function import(Row $row, array $old_destination_id_values = []) {
$this->connection
->merge('photos_count')
->keys([
'id' => $row
->getDestinationProperty('id'),
])
->fields([
'cid' => $row
->getDestinationProperty('cid'),
'changed' => $row
->getDestinationProperty('changed'),
'type' => $row
->getDestinationProperty('type'),
'value' => $row
->getDestinationProperty('value'),
])
->execute();
return [
$row
->getDestinationProperty('id'),
];
}
public function getIds() {
$ids['id']['type'] = 'integer';
return $ids;
}
public function fields(MigrationInterface $migration = NULL) {
return [
'id' => $this
->t('Unique ID'),
'cid' => $this
->t('Entity ID'),
'changed' => $this
->t('Last updated'),
'type' => $this
->t('Type of count'),
'value' => $this
->t('Count value'),
];
}
}