<?php

class PeopleOrgMigration extends Migration {

  public function __construct() {
    parent::__construct();

    $query = db_select('link_people_organization', 'l');
    $query->fields('l', array(
      'people_id',
      'organization_id',
      'people_title',
    );

    $this->source = new MigrateSourceSQL($query);
    $this->destination = new MigrateDestinationFieldCollection('field_person_section', array('hostEntityType' => 'node'));

    $this->map = new MigrateSQLMap(
      $this->machineName,
      array(
        'people_id' => array(
          'type' => 'int',
          'unsigned' => TRUE,
          'not null' => TRUE,
          'alias' => 'l',
        ),
      ),
      MigrateDestinationFieldCollection::getKeySchema()
    );

    $this->addFieldMapping('hostEntityId', 'people_id')->sourceMigration('People');

    $this->addFieldMapping('field_organization', 'organization_id')
      ->sourceMigration('Organization')
      ->arguments(array('source_type' => 'tid'));
    $this->addFieldMapping('field_organization_title', 'people_title');
  }

}