You are here

public function User::prepareRow in Zircon Profile 8

Same name in this branch
  1. 8 core/modules/user/src/Plugin/migrate/source/d6/User.php \Drupal\user\Plugin\migrate\source\d6\User::prepareRow()
  2. 8 core/modules/user/src/Plugin/migrate/source/d7/User.php \Drupal\user\Plugin\migrate\source\d7\User::prepareRow()
Same name and namespace in other branches
  1. 8.0 core/modules/user/src/Plugin/migrate/source/d7/User.php \Drupal\user\Plugin\migrate\source\d7\User::prepareRow()

Add additional data to the row.

Parameters

\Drupal\Migrate\Row $row: The row object.

Return value

bool FALSE if this row needs to be skipped.

Overrides SourcePluginBase::prepareRow

File

core/modules/user/src/Plugin/migrate/source/d7/User.php, line 68
Contains \Drupal\user\Plugin\migrate\source\d7\User.

Class

User
Drupal 7 user source from database.

Namespace

Drupal\user\Plugin\migrate\source\d7

Code

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);
}