public function MigrateDestinationNode::import in Migrate 6.2

Same name and namespace in other branches

1. 7.2 plugins/destinations/node.inc \MigrateDestinationNode::import()

Import a single node.

Parameters

$node: Node object to build. Prefilled with any fields mapped in the Migration.

$row: Raw source data object - passed through to prepare/complete handlers.

Return value

array Array of key fields (nid only in this case) of the node that was saved if successful. FALSE on failure.

Overrides MigrateDestination::import

File

plugins/destinations/node.inc, line 130

Support for node destinations.

Class

MigrateDestinationNode

Destination class implementing migration into nodes.

Code

public function import(stdClass $node, stdClass $row) {
  $migration = Migration::currentMigration();

  // Updating previously-migrated content?
  if (isset($row->migrate_map_destid1)) {
    if (isset($node->nid)) {
      if ($node->nid != $row->migrate_map_destid1) {
        throw new MigrateException(t("Incoming nid !nid and map destination nid !destid1 don't match", array(
          '!nid' => $node->nid,
          '!destid1' => $row->migrate_map_destid1,
        )));
      }
    }
    else {
      $node->nid = $row->migrate_map_destid1;
    }

    // Get the existing vid, so updates don't generate notices
    $node->vid = db_select('node', 'n')
      ->fields('n', array(
      'vid',
    ))
      ->condition('nid', $node->nid)
      ->execute()
      ->fetchField();
    if (!$node->vid) {
      throw new MigrateException(t("Incoming node ID !nid no longer exists", array(
        '!nid' => $node->nid,
      )));
    }
  }
  if ($migration
    ->getSystemOfRecord() == Migration::DESTINATION) {
    if (!isset($node->nid)) {
      throw new MigrateException(t('System-of-record is DESTINATION, but no destination nid provided'));
    }
    $old_node = node_load($node->nid);
    if (empty($old_node)) {
      throw new MigrateException(t('System-of-record is DESTINATION, but node !nid does not exist', array(
        '!nid' => $node->nid,
      )));
    }
    if (!isset($node->created)) {
      $node->created = $old_node->created;
    }
    if (!isset($node->vid)) {
      $node->vid = $old_node->vid;
    }
    if (!isset($node->status)) {
      $node->status = $old_node->status;
    }
    if (!isset($node->uid)) {
      $node->uid = $old_node->uid;
    }
  }
  else {
    if (!isset($node->type)) {

      // Default the type to our designated destination bundle (by doing this
      // conditionally, we permit some flexibility in terms of implementing
      // migrations which can affect more than one type).
      $node->type = $this->bundle;
    }
  }

  // Set some required properties.
  $type_info = node_get_types('type', $node->type);
  if (empty($node->nid)) {

    // Avoids notice in forum module and maybe more - http://drupal.org/node/839770 is similar.
    $node->nid = NULL;
  }

  // Save changed timestamp and set it later, node_save sets it unconditionally
  if (isset($node->changed)) {
    $changed = MigrationBase::timestamp($node->changed);
  }
  if (isset($node->created)) {
    $node->created = MigrationBase::timestamp($node->created);
  }

  // Generate teaser from Body if teaser not specified and Body is in use.
  if ($type_info->has_body && empty($node->teaser) && !empty($node->body)) {
    $node->teaser = node_teaser($node->body);
  }

  // Set defaults as per content type settings. Can't call node_object_prepare()
  // since that clobbers existing values.
  $node_options = variable_get('node_options_' . $node->type, array(
    'status',
    'promote',
  ));
  foreach (array(
    'status',
    'promote',
    'sticky',
  ) as $key) {
    if (!isset($node->{$key})) {
      $node->{$key} = in_array($key, $node_options);
    }
  }
  if (!isset($node->comment) && module_exists('comment')) {
    $node->comment = variable_get("comment_{$node->type}", COMMENT_NODE_READ_WRITE);
  }
  if (!isset($node->revision)) {
    $node->revision = 0;

    // Saves disk space and writes. Can be overridden.
  }

  // Invoke migration prepare handlers
  $this
    ->prepare($node, $row);

  // Trying to update an existing node
  if ($migration
    ->getSystemOfRecord() == Migration::DESTINATION) {

    // Incoming data overrides existing data, so only copy non-existent fields
    foreach ($old_node as $field => $value) {

      // An explicit NULL in the source data means to wipe to old value (i.e.,
      // don't copy it over from $old_node)
      if (property_exists($node, $field) && $node->{$field} === NULL) {

        // Ignore this field
      }
      elseif (!isset($node->{$field})) {
        $node->{$field} = $old_node->{$field};
      }
    }
  }
  if (isset($node->nid)) {
    $updating = TRUE;
  }
  else {
    $updating = FALSE;
  }
  migrate_instrument_start('node_save');
  node_save($node);
  migrate_instrument_stop('node_save');
  if (isset($node->nid)) {
    if ($updating) {
      $this->numUpdated++;
    }
    else {
      $this->numCreated++;
    }

    // Unfortunately, http://drupal.org/node/722688 was not accepted, so fix
    // the changed timestamp
    if (isset($changed)) {
      db_update('node')
        ->fields(array(
        'changed' => $changed,
      ))
        ->condition('nid', $node->nid)
        ->execute();
      $node->changed = $changed;
    }

    // Potentially fix uid and timestamp in node_revisions.
    $query = db_update('node_revisions')
      ->condition('vid', $node->vid);
    if (isset($changed)) {
      $fields['timestamp'] = $changed;
      $node->timestamp = $changed;
    }
    $revision_uid = isset($node->revision_uid) ? $node->revision_uid : $node->uid;
    if ($revision_uid != $GLOBALS['user']->uid) {
      $fields['uid'] = $revision_uid;
    }
    if (!empty($fields)) {

      // We actually have something to update.
      $query
        ->fields($fields);
      $query
        ->execute();
    }
    $return = array(
      $node->nid,
    );
  }
  else {
    $return = FALSE;
  }
  $this
    ->complete($node, $row);

  // Clear the node cache periodically
  static $count = 0;
  if ($count++ > 100) {
    node_load('foo', NULL, TRUE);
    $count = 0;
  }
  return $return;
}