acquia / df

class DFSMEDEditorialComments extends ImportBaseComments {

  public function __construct($arguments) {

    parent::__construct($arguments);

    $this->description = t('Import comments.');

    // Create a map object for tracking the relationships between source rows

    $this->map = new MigrateSQLMap($this->machineName,

      array(

        'subject' => array(

          'type' => 'varchar',

          'length' => 255,

          'not null' => TRUE,

        ),

      ),

      MigrateDestinationComment::getKeySchema()

    );

    $import_path = drupal_get_path('module', 'dfs_med') . '/import/';

    $this->source = new MigrateSourceCSV($import_path . 'dfs_med.comments.article.csv', $this->csvcolumns(), array('header_rows' => 1));

    $this->destination = new MigrateDestinationComment('comment_node_article');

    $this->addFieldMapping('nid', 'node')->sourceMigration('DFSMEDEditorialNodes');

    $this->addFieldMapping('uid', 'author')->sourceMigration('DFSMEDUsers');

    $this->addFieldMapping('created', 'created');

  }

  function csvcolumns() {

    $columns[0] = array('subject', 'Subject');

class DFSWEMTweetNodes extends DemoFrameworkBaseNodesUUID {

  public function __construct($arguments) {

    parent::__construct($arguments);

    $this->description = t('Import nodes.');

    // Create a map object for tracking the relationships between source rows

    $this->map = new MigrateSQLMap($this->machineName,

      array(

        'tweet_id' => array(

          'type' => 'varchar',

          'length' => 255,

          'not null' => TRUE,

        ),

      ),

      MigrateDestinationNode::getKeySchema()

    );

    $import_path = drupal_get_path('module', 'dfs_wem') . '/import/';

    // Create a MigrateSource object.

    $this->source = new MigrateSourceCSV($import_path . 'dfs_wem.nodes.wem_tweets.csv', $this->csvcolumns(), array('header_rows' => 1));

    $this->destination = new MigrateDestinationNode('wem_tweet');

    // Tweet Fields

    $this->addFieldMapping('title', 'tweet_id');

    $this->addFieldMapping('body', 'tweet');

    $this->addFieldMapping('field_wem_tweet_id', 'tweet_id');

    $this->addFieldMapping('field_wem_tweet_from', 'tweet_from');

  }

  function csvcolumns() {

    $columns[0] = array('tweet', 'Tweet');

class DFSWEMProducts extends DemoFrameworkBaseProducts {

  public function __construct($arguments) {

    parent::__construct($arguments);

    $this->description = t('Import DFS WEM products.');

    // Create a map object for tracking the relationships between source rows

    $this->map = new MigrateSQLMap($this->machineName,

      array(

        'sku' => array(

          'type' => 'varchar',

          'length' => 32,

          'not null' => TRUE,

        ),

      ),

      MigrateDestinationEntityAPI::getKeySchema('commerce_product', 'wem_product')

    );

    $this->destination = new MigrateDestinationEntityAPI('commerce_product', 'wem_product');

    // Define a default import path.

    $import_path = drupal_get_path('module', 'dfs_wem') . '/import/';

    // Create a MigrateSource object.

    $this->source = new MigrateSourceCSV($import_path . 'dfs_wem.products.csv', $this->csvcolumns(), array('header_rows' => 1));

    $this->addFieldMapping('field_images:source_dir')->defaultValue($import_path . 'images');

    $this->addFieldMapping('field_wem_product_interests', 'interests');

  }

  function csvcolumns() {

    $columns[0] = array('title', 'Title');