Code Coverage  | 
     ||||||||||
Classes and Traits  | 
      Functions and Methods  | 
      Lines  | 
     ||||||||
| Total |         | 
      0.00%  | 
      0 / 1  | 
              | 
      66.67%  | 
      2 / 3  | 
      CRAP |         | 
      51.72%  | 
      15 / 29  | 
     
| User |         | 
      0.00%  | 
      0 / 1  | 
              | 
      75.00%  | 
      3 / 4  | 
      21.25 |         | 
      51.72%  | 
      15 / 29  | 
     
| query |         | 
      100.00%  | 
      1 / 1  | 
      1 |         | 
      100.00%  | 
      3 / 3  | 
     |||
| fields |         | 
      100.00%  | 
      1 / 1  | 
      2 |         | 
      100.00%  | 
      0 / 0  | 
     |||
| prepareRow |         | 
      0.00%  | 
      0 / 1  | 
      12.32 |         | 
      44.00%  | 
      11 / 25  | 
     |||
| getIds |         | 
      100.00%  | 
      1 / 1  | 
      1 |         | 
      100.00%  | 
      1 / 1  | 
     |||
| <?php | |
| /** | |
| * @file | |
| * Contains \Drupal\user\Plugin\migrate\source\d7\User. | |
| */ | |
| namespace Drupal\user\Plugin\migrate\source\d7; | |
| use Drupal\migrate\Row; | |
| use Drupal\migrate_drupal\Plugin\migrate\source\d7\FieldableEntity; | |
| /** | |
| * Drupal 7 user source from database. | |
| * | |
| * @MigrateSource( | |
| * id = "d7_user" | |
| * ) | |
| */ | |
| class User extends FieldableEntity { | |
| /** | |
| * {@inheritdoc} | |
| */ | |
| public function query() { | |
| return $this->select('users', 'u') | |
| ->fields('u') | |
| ->condition('uid', 0, '>'); | |
| } | |
| /** | |
| * {@inheritdoc} | |
| */ | |
| public function fields() { | |
| $fields = array( | |
| 'uid' => $this->t('User ID'), | |
| 'name' => $this->t('Username'), | |
| 'pass' => $this->t('Password'), | |
| 'mail' => $this->t('Email address'), | |
| 'signature' => $this->t('Signature'), | |
| 'signature_format' => $this->t('Signature format'), | |
| 'created' => $this->t('Registered timestamp'), | |
| 'access' => $this->t('Last access timestamp'), | |
| 'login' => $this->t('Last login timestamp'), | |
| 'status' => $this->t('Status'), | |
| 'timezone' => $this->t('Timezone'), | |
| 'language' => $this->t('Language'), | |
| 'picture' => $this->t('Picture'), | |
| 'init' => $this->t('Init'), | |
| 'data' => $this->t('User data'), | |
| 'roles' => $this->t('Roles'), | |
| ); | |
| // Profile fields. | |
| if ($this->moduleExists('profile')) { | |
| $fields += $this->select('profile_fields', 'pf') | |
| ->fields('pf', array('name', 'title')) | |
| ->execute() | |
| ->fetchAllKeyed(); | |
| } | |
| return $fields; | |
| } | |
| /** | |
| * {@inheritdoc} | |
| */ | |
| public function prepareRow(Row $row) { | |
| $roles = $this->select('users_roles', 'ur') | |
| ->fields('ur', ['rid']) | |
| ->condition('ur.uid', $row->getSourceProperty('uid')) | |
| ->execute() | |
| ->fetchCol(); | |
| $row->setSourceProperty('roles', $roles); | |
| $row->setSourceProperty('data', unserialize($row->getSourceProperty('data'))); | |
| // Get Field API field values. | |
| foreach (array_keys($this->getFields('user')) as $field) { | |
| $row->setSourceProperty($field, $this->getFieldValues('user', $field, $row->getSourceProperty('uid'))); | |
| } | |
| // Get profile field values. This code is lifted directly from the D6 | |
| // ProfileFieldValues plugin. | |
| if ($this->getDatabase()->schema()->tableExists('profile_value')) { | |
| $query = $this->select('profile_value', 'pv') | |
| ->fields('pv', array('fid', 'value')); | |
| $query->leftJoin('profile_field', 'pf', 'pf.fid=pv.fid'); | |
| $query->fields('pf', array('name', 'type')); | |
| $query->condition('uid', $row->getSourceProperty('uid')); | |
| $results = $query->execute(); | |
| foreach ($results as $profile_value) { | |
| if ($profile_value['type'] == 'date') { | |
| $date = unserialize($profile_value['value']); | |
| $date = date('Y-m-d', mktime(0, 0, 0, $date['month'], $date['day'], $date['year'])); | |
| $row->setSourceProperty($profile_value['name'], array('value' => $date)); | |
| } | |
| elseif ($profile_value['type'] == 'list') { | |
| // Explode by newline and comma. | |
| $row->setSourceProperty($profile_value['name'], preg_split("/[\r\n,]+/", $profile_value['value'])); | |
| } | |
| else { | |
| $row->setSourceProperty($profile_value['name'], array($profile_value['value'])); | |
| } | |
| } | |
| } | |
| return parent::prepareRow($row); | |
| } | |
| /** | |
| * {@inheritdoc} | |
| */ | |
| public function getIds() { | |
| return array( | |
| 'uid' => array( | |
| 'type' => 'integer', | |
| 'alias' => 'u', | |
| ), | |
| ); | |
| } | |
| } |