VariableTranslation.php in Drupal 8
File
core/modules/migrate_drupal/src/Plugin/migrate/source/d7/VariableTranslation.php
View source
<?php
namespace Drupal\migrate_drupal\Plugin\migrate\source\d7;
use Drupal\Core\Entity\EntityTypeManagerInterface;
use Drupal\Core\State\StateInterface;
use Drupal\migrate\Plugin\MigrationInterface;
use Drupal\migrate_drupal\Plugin\migrate\source\DrupalSqlBase;
class VariableTranslation extends DrupalSqlBase {
protected $variables;
public function __construct(array $configuration, $plugin_id, $plugin_definition, MigrationInterface $migration, StateInterface $state, EntityTypeManagerInterface $entity_type_manager) {
parent::__construct($configuration, $plugin_id, $plugin_definition, $migration, $state, $entity_type_manager);
$this->variables = $this->configuration['variables'];
}
protected function initializeIterator() {
return new \ArrayIterator($this
->values());
}
protected function values() {
$values = [];
$result = $this
->prepareQuery()
->execute()
->FetchAllAssoc('realm_key');
foreach ($result as $variable_store) {
$values[]['language'] = $variable_store['realm_key'];
}
$result = $this
->prepareQuery()
->execute()
->FetchAll();
foreach ($result as $variable_store) {
foreach ($values as $key => $value) {
if ($values[$key]['language'] === $variable_store['realm_key']) {
if ($variable_store['serialized']) {
$values[$key][$variable_store['name']] = unserialize($variable_store['value']);
break;
}
else {
$values[$key][$variable_store['name']] = $variable_store['value'];
break;
}
}
}
}
return $values;
}
public function count($refresh = FALSE) {
return $this
->initializeIterator()
->count();
}
public function fields() {
return array_combine($this->variables, $this->variables);
}
public function getIds() {
$ids['language']['type'] = 'string';
return $ids;
}
public function query() {
return $this
->select('variable_store', 'vs')
->fields('vs')
->condition('realm', 'language')
->condition('name', (array) $this->configuration['variables'], 'IN');
}
}