Written by oskar.thornblad@gmail.com.
Contributions from:
- Valiton GmbH
- Michael Härtl
Free for everyone for everything, attribution voluntary
Extend the class and implement the processNode() method.
<?php
class SimpleXmlStreamer extends XmlStreamer
{
public function processNode($xmlString, $elementName, $nodeIndex)
{
$xml = simplexml_load_string($xmlString);
$something = (string)$xml->Something->SomethingElse->ReadThis;
$this->setparseNodeOut($data);
echo "$nodeIndex: Extracted string '$something' from parent node '$elementName'\n";
return true;
}
}
$streamer = new SimpleXmlStreamer("myLargeXmlFile.xml");
if ($streamer->parse()) {
echo "Finished successfully";
} else {
echo "Couldn't find root node";
}
echo $this->getparseNodeOut();To improve performance on DB inserts you can also make use of the chunkCompleted() method.
It gets called after a chunk of data was processed.
<?php
class SimpleXmlStreamer extends XmlStreamer
{
protected $pdo;
protected $sql = array();
protected $values = array();
/**
* Called after the constructor completed class setup
*/
public function init()
{
$this->pdo = new PDO('mysql:host=localhost;dbname=test', 'user','pass');
}
public function processNode($xmlString, $elementName, $nodeIndex)
{
$xml = simplexml_load_string($xmlString);
$this->sql[] = '(?,?,?)';
$this->values[] = (string)$xml->name;
$this->values[] = (string)$xml->email;
$this->values[] = (string)$xml->phone;
}
/**
* Called after a file chunk was processed (16KB by default, see constructor)
*/
public function chunkCompleted()
{
if($this->sql===array()) {
return;
}
$command = $this->pdo->prepare('INSERT INTO mytable VALUES '.implode(',',$this->sql));
$command->execute($this->values);
$this->sql = $this->values = array();
}
}