class ProfileFieldValues

class ProfileFieldValues extends DrupalSqlBase {

  /**
   * {@inheritdoc}
   */
  public function query() {
    $query = $this
      ->select('profile_values', 'pv')
      ->distinct()
      ->fields('pv', [
      'uid',
    ]);
    return $query;
  }

  /**
   * {@inheritdoc}
   */
  public function prepareRow(Row $row) {

    // Find profile values for this row.
    $query = $this
      ->select('profile_values', 'pv')
      ->fields('pv', [
      'fid',
      'value',
    ]);
    $query
      ->leftJoin('profile_fields', 'pf', '[pf].[fid] = [pv].[fid]');
    $query
      ->fields('pf', [
      'name',
      'type',
    ]);
    $query
      ->condition('uid', $row
      ->getSourceProperty('uid'));
    $results = $query
      ->execute();
    foreach ($results as $profile_value) {

      // Check special case for date. We need to unserialize.
      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'], [
          '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'], [
          $profile_value['value'],
        ]);
      }
    }
    return parent::prepareRow($row);
  }

  /**
   * {@inheritdoc}
   */
  public function fields() {
    $fields = [
      'fid' => $this
        ->t('Unique profile field ID.'),
      'uid' => $this
        ->t('The user Id.'),
      'value' => $this
        ->t('The value for this field.'),
    ];
    $query = $this
      ->select('profile_values', 'pv')
      ->fields('pv', [
      'fid',
      'value',
    ]);
    $query
      ->leftJoin('profile_fields', 'pf', '[pf].[fid] = [pv].[fid]');
    $query
      ->fields('pf', [
      'name',
      'title',
    ]);
    $results = $query
      ->execute();
    foreach ($results as $profile) {
      $fields[$profile['name']] = $this
        ->t($profile['title']);
    }
    return $fields;
  }

  /**
   * {@inheritdoc}
   */
  public function getIds() {
    return [
      'uid' => [
        'type' => 'integer',
        'alias' => 'pv',
      ],
    ];
  }

}