public function MigrateXMLReader::next in Migrate 6.2

Same name and namespace in other branches

1. 7.2 plugins/sources/xml.inc \MigrateXMLReader::next()

Implementation of Iterator::next().

Return value

void

1 call to MigrateXMLReader::next()

MigrateXMLReader::rewind in plugins/sources/xml.inc

Implementation of Iterator::rewind().

File

plugins/sources/xml.inc, line 731

Support for migration from XML sources.

Class

MigrateXMLReader

Makes an XMLReader object iterable, returning elements matching a restricted xpath-like syntax.

Code

public function next() {
  migrate_instrument_start('MigrateXMLReader::next');
  $this->currentElement = $this->currentId = NULL;

  // Loop over each node in the XML file, looking for elements at a path
  // matching the input query string (represented in $this->elementsToMatch).
  while ($this->reader
    ->read()) {
    if ($this->reader->nodeType == XMLREADER::ELEMENT) {
      $this->currentPath[$this->reader->depth] = $this->reader->localName;
      if ($this->currentPath == $this->elementsToMatch) {

        // We're positioned to the right element path - if filtering on an
        // attribute, check that as well before accepting this element.
        if (empty($this->attributeName) || $this->reader
          ->getAttribute($this->attributeName) == $this->attributeValue) {

          // We've found a matching element - get a SimpleXML object representing it.
          // We must associate the DOMNode with a DOMDocument to be able to import
          // it into SimpleXML.
          // Despite appearances, this is almost twice as fast as
          // simplexml_load_string($this->readOuterXML());
          $node = $this->reader
            ->expand();
          if ($node) {
            $dom = new DOMDocument();
            $node = $dom
              ->importNode($node, TRUE);
            $dom
              ->appendChild($node);
            $this->currentElement = simplexml_import_dom($node);
            $idnode = $this->currentElement
              ->xpath($this->idQuery);
            $this->currentId = (string) reset($idnode);
            break;
          }
          else {
            foreach (libxml_get_errors() as $error) {
              $error_string = MigrateItemsXML::parseLibXMLError($error);
              if ($migration = Migration::currentMigration()) {
                $migration
                  ->saveMessage($error_string);
              }
              else {
                Migration::displayMessage($error_string);
              }
            }
          }
        }
      }
    }
    elseif ($this->reader->nodeType == XMLREADER::END_ELEMENT) {

      // Remove this element and any deeper ones from the current path
      foreach ($this->currentPath as $depth => $name) {
        if ($depth >= $this->reader->depth) {
          unset($this->currentPath[$depth]);
        }
      }
    }
  }
  migrate_instrument_stop('MigrateXMLReader::next');
}