Drupal → Пример миграции контента из vBulletin 3 в Drupal 7: темы (топики)

class ThreadsMigration extends Migration {
  public function __construct($arguments) {
    parent::__construct($arguments);
    $this->dependencies = array(
      'Structure', // http://xandeadx.ru/blog/drupal/512
      'Users',     // http://xandeadx.ru/blog/drupal/510
    );
 
    // Source
    $query = Database::getConnection('default', 'vbulletin')->select('thread', 't');
    $query->leftJoin('post', 'p', 'p.postid = t.firstpostid');
    $query->fields('t', array('threadid', 'title', 'forumid', 'open', 'visible', 'postuserid', 'dateline', 'sticky', 'firstpostid'));
    $query->fields('p', array('pagetext'));
    $query->condition('open', 10, '!=');
    $this->source = new MigrateSourceSQL($query, drupal_map_assoc(array('attachments', 'attachments_name')), NULL, array('map_joinable' => FALSE));
 
    // Destination
    $this->destination = new MigrateDestinationNode('post');
 
    // Key schema
    $source_key_schema = array('threadid' => array('type' => 'int', 'unsigned' => TRUE, 'not null' => TRUE));
    $this->map = new MigrateSQLMap($this->machineName, $source_key_schema, MigrateDestinationNode::getKeySchema());
 
    // Mapping
    $this->addFieldMapping('title', 'title');
    $this->addFieldMapping('uid', 'userid')->sourceMigration('Users');
    $this->addFieldMapping('is_new')->defaultValue(TRUE);
    $this->addFieldMapping('created', 'dateline');
    $this->addFieldMapping('status', 'visible');
    $this->addFieldMapping('sticky', 'sticky');
    $this->addFieldMapping('comment', 'open');
    $this->addFieldMapping('body', 'pagetext');
    $this->addFieldMapping('body:format')->defaultValue('filtered_html');
    $this->addFieldMapping('field_section', 'forumid')->sourceMigration('Structure');
    $this->addFieldMapping('field_section:source_type')->defaultValue('tid');
    $this->addFieldMapping('field_section:create_term')->defaultValue(FALSE);
    $this->addFieldMapping('field_attachments', 'attachments');
    $this->addFieldMapping('field_attachments:destination_dir')->defaultValue('public://attachments');
    $this->addFieldMapping('field_attachments:destination_file', 'attachments_name');
    $this->addFieldMapping('field_attachments:file_replace')->defaultValue(FILE_EXISTS_ERROR);
    $this->addFieldMapping('field_attachments:source_dir')->defaultValue('/path/to/vbulletin/attachments/');
  }
 
  public function prepareRow($row) {
    if (parent::prepareRow($row) === FALSE) {
      return FALSE;
    }
 
    // Title
    $row->title = htmlspecialchars_decode($row->title);
 
    // Comment status
    if ($row->open == 1) {
      $row->open = 2;
    }
    else {
      $row->open = 1;
    }
 
    // Body
    $row->pagetext = bbcode_to_html($row->pagetext); // http://bit.ly/OrFVN5
 
    // Attachments
    $attachments = Database::getConnection('default', 'vbulletin')
      ->select('attachment', 'a')
      ->fields('a', array('attachmentid', 'filename', 'extension', 'userid'))
      ->condition('postid', $postid)
      ->execute();
    foreach ($attachments as $attachment) {
      $row->attachments[] = $attachment->userid . '/' . $attachment->attachmentid . '.attach';
      $row->attachments_name[] = $attachment->filename;
    }
  }
}

$row->attachments[] = $attachment->userid . '/' . $attachment->attachmentid . '.attach';

$row->attachments[] = implode('/', preg_split('//', $attachment->userid,  -1, PREG_SPLIT_NO_EMPTY)) . '/' . $attachment->attachmentid . '.attach';