libraries/import/xml.php

   1 <?php
   2 /* vim: set expandtab sw=4 ts=4 sts=4: */
   3 /**
   4  * XML import plugin for phpMyAdmin
   5  *
   6  * @todo    Improve efficiency
   7  * @version 0.5-beta
   8  * @package phpMyAdmin-Import
   9  */
  10
  11 if (! defined('PHPMYADMIN')) {
  12     exit;
  13 }
  14
  15 /**
  16  * The possible scopes for $plugin_param are: 'table', 'database', and 'server'
  17  */
  18
  19 if (isset($plugin_list)) {
  20     $plugin_list['xml'] = array(
  21         'text' => __('XML'),
  22         'extension' => 'xml',
  23         'options' => array(
  24             ),
  25         'options_text' => __('Options'),
  26         );
  27     /* We do not define function when plugin is just queried for information above */
  28     return;
  29 }
  30
  31 ini_set('memory_limit', '128M');
  32 set_time_limit(120);
  33
  34 $i = 0;
  35 $len = 0;
  36 $buffer = "";
  37
  38 /**
  39  * Read in the file via PMA_importGetNextChunk so that
  40  * it can process compressed files
  41  */
  42 while (! ($finished && $i >= $len) && ! $error && ! $timeout_passed) {
  43     $data = PMA_importGetNextChunk();
  44     if ($data === FALSE) {
  45         /* subtract data we didn't handle yet and stop processing */
  46         $offset -= strlen($buffer);
  47         break;
  48     } elseif ($data === TRUE) {
  49         /* Handle rest of buffer */
  50     } else {
  51         /* Append new data to buffer */
  52         $buffer .= $data;
  53         unset($data);
  54     }
  55 }
  56
  57 unset($data);
  58
  59 /**
  60  * Load the XML string
  61  *
  62  * The option LIBXML_COMPACT is specified because it can
  63  * result in increased performance without the need to
  64  * alter the code in any way. It's basically a freebee.
  65  */
  66 $xml = simplexml_load_string($buffer, "SimpleXMLElement", LIBXML_COMPACT);
  67
  68 unset($buffer);
  69
  70 /**
  71  * The XML was malformed
  72  */
  73 if ($xml === FALSE) {
  74     PMA_Message::error(__('The XML file specified was either malformed or incomplete. Please correct the issue and try again.'))->display();
  75     unset($xml);
  76     $GLOBALS['finished'] = false;
  77     return;
  78 }
  79
  80 /**
  81  * Table accumulator
  82  */
  83 $tables = array();
  84 /**
  85  * Row accumulator
  86  */
  87 $rows = array();
  88
  89 /**
  90  * Temp arrays
  91  */
  92 $tempRow = array();
  93 $tempCells = array();
  94
  95 /**
  96  * CREATE code included (by default: no)
  97  */
  98 $struct_present = false;
  99
 100 /**
 101  * Analyze the data in each table
 102  */
 103 $namespaces = $xml->getNameSpaces(true);
 104
 105 /**
 106  * Get the database name, collation and charset
 107  */
 108 $db_attr = $xml->children($namespaces['pma'])->{'structure_schemas'}->{'database'};
 109
 110 if ($db_attr instanceof SimpleXMLElement) {
 111     $db_attr = $db_attr->attributes();
 112     $db_name = (string)$db_attr['name'];
 113     $collation = (string)$db_attr['collation'];
 114     $charset = (string)$db_attr['charset'];
 115 } else {
 116     /**
 117      * If the structure section is not present
 118      * get the database name from the data section
 119      */
 120     $db_attr = $xml->children()->attributes();
 121     $db_name = (string)$db_attr['name'];
 122     $collation = NULL;
 123     $charset = NULL;
 124 }
 125
 126 /**
 127  * The XML was malformed
 128  */
 129 if ($db_name === NULL) {
 130     PMA_Message::error(__('The XML file specified was either malformed or incomplete. Please correct the issue and try again.'))->display();
 131     unset($xml);
 132     $GLOBALS['finished'] = false;
 133     return;
 134 }
 135
 136 /**
 137  * Retrieve the structure information
 138  */
 139 if (isset($namespaces['pma'])) {
 140     /**
 141      * Get structures for all tables
 142      */
 143     $struct = $xml->children($namespaces['pma']);
 144
 145     $create = array();
 146
 147     foreach ($struct as $tier1 => $val1) {
 148         foreach($val1 as $tier2 => $val2) {
 149             /* Need to select the correct database for the creation of tables, views, triggers, etc. */
 150             /**
 151              * @todo    Generating a USE here blocks importing of a table
 152              *          into another database.
 153              */
 154             $attrs = $val2->attributes();
 155             $create[] = "USE " . PMA_backquote($attrs["name"]);
 156
 157             foreach ($val2 as $val3) {
 158                 /**
 159                  * Remove the extra cosmetic spacing
 160                  */
 161                 $val3 = str_replace("                ", "", (string)$val3);
 162                 $create[] = $val3;
 163             }
 164         }
 165     }
 166
 167     $struct_present = true;
 168 }
 169
 170 /**
 171  * Move down the XML tree to the actual data
 172  */
 173 $xml = $xml->children()->children();
 174
 175 $data_present = false;
 176
 177 /**
 178  * Only attempt to analyze/collect data if there is data present
 179  */
 180 if (@count($xml->children())) {
 181     $data_present = true;
 182
 183     /**
 184      * Process all database content
 185      */
 186     foreach ($xml as $k1 => $v1) {
 187         $tbl_attr = $v1->attributes();
 188
 189         $isInTables = false;
 190         for ($i = 0; $i < count($tables); ++$i) {
 191             if (! strcmp($tables[$i][TBL_NAME], (string)$tbl_attr['name'])) {
 192                 $isInTables = true;
 193                 break;
 194             }
 195         }
 196
 197         if ($isInTables == false) {
 198             $tables[] = array((string)$tbl_attr['name']);
 199         }
 200
 201         foreach ($v1 as $k2 => $v2) {
 202             $row_attr = $v2->attributes();
 203             if (! array_search((string)$row_attr['name'], $tempRow))
 204             {
 205                 $tempRow[] = (string)$row_attr['name'];
 206             }
 207             $tempCells[] = (string)$v2;
 208         }
 209
 210         $rows[] = array((string)$tbl_attr['name'], $tempRow, $tempCells);
 211
 212         $tempRow = array();
 213         $tempCells = array();
 214     }
 215
 216     unset($tempRow);
 217     unset($tempCells);
 218     unset($xml);
 219
 220     /**
 221      * Bring accumulated rows into the corresponding table
 222      */
 223     $num_tbls = count($tables);
 224     for ($i = 0; $i < $num_tbls; ++$i) {
 225         for ($j = 0; $j < count($rows); ++$j) {
 226             if (! strcmp($tables[$i][TBL_NAME], $rows[$j][TBL_NAME])) {
 227                 if (! isset($tables[$i][COL_NAMES])) {
 228                     $tables[$i][] = $rows[$j][COL_NAMES];
 229                 }
 230
 231                 $tables[$i][ROWS][] = $rows[$j][ROWS];
 232             }
 233         }
 234     }
 235
 236     unset($rows);
 237
 238     if (! $struct_present) {
 239         $analyses = array();
 240
 241         $len = count($tables);
 242         for ($i = 0; $i < $len; ++$i) {
 243             $analyses[] = PMA_analyzeTable($tables[$i]);
 244         }
 245     }
 246 }
 247
 248 unset($xml);
 249 unset($tempRows);
 250 unset($tempCells);
 251 unset($rows);
 252
 253 /**
 254  * Only build SQL from data if there is data present
 255  */
 256 if ($data_present) {
 257     /**
 258      * Set values to NULL if they were not present
 259      * to maintain PMA_buildSQL() call integrity
 260      */
 261     if (! isset($analyses)) {
 262         $analyses = NULL;
 263         if (! $struct_present) {
 264             $create = NULL;
 265         }
 266     }
 267 }
 268
 269 /**
 270  * string $db_name (no backquotes)
 271  *
 272  * array $table = array(table_name, array() column_names, array()() rows)
 273  * array $tables = array of "$table"s
 274  *
 275  * array $analysis = array(array() column_types, array() column_sizes)
 276  * array $analyses = array of "$analysis"s
 277  *
 278  * array $create = array of SQL strings
 279  *
 280  * array $options = an associative array of options
 281  */
 282
 283 /* Set database name to the currently selected one, if applicable */
 284 if (strlen($db)) {
 285     /* Override the database name in the XML file, if one is selected */
 286     $db_name = $db;
 287     $options = array('create_db' => false);
 288 } else {
 289     if ($db_name === NULL) {
 290         $db_name = 'XML_DB';
 291     }
 292
 293     /* Set database collation/charset */
 294     $options = array(
 295         'db_collation' => $collation,
 296         'db_charset'   => $charset,
 297     );
 298 }
 299
 300 /* Created and execute necessary SQL statements from data */
 301 PMA_buildSQL($db_name, $tables, $analyses, $create, $options);
 302
 303 unset($analyses);
 304 unset($tables);
 305 unset($create);
 306
 307 /* Commit any possible data in buffers */
 308 PMA_importRunQuery();
 309 ?>