classes/db/DBDataXMLParser.inc.php

<?php

// $Id: DBDataXMLParser.inc.php,v 1.12 2008/07/01 01:16:09 asmecher Exp $


import('xml.XMLParser');

class DBDataXMLParser {

   var $parser;

   var $dbconn;

   var $sql;

   function DBDataXMLParser() {
      $this->parser = &new XMLParser();
      $this->sql = array();
   }

   function setDBConn(&$dbconn) {
      $this->dbconn = &$dbconn;
   }

   function parseData($file) {      
      $this->sql = array();
      $tree = $this->parser->parse($file);
      if ($tree !== false) {
         foreach ($tree->getChildren() as $table) {
            if ($table->getName() == 'table') {
               $fieldDefaultValues = array();

               // Match table element
               foreach ($table->getChildren() as $row) {
                  if ($row->getName() == 'field_default') {
                     // Match a default field element
                     $fieldName = $row->getAttribute('name');
                     $value = $row->getValue();
                     if ($value === null || $row->getAttribute('null') == 1) {
                        $value = 'NULL';
                     } else if (!is_numeric($value)) {
                        $value = $this->quoteString($value);
                     }
                     $fieldDefaultValues[$fieldName] = $value;

                  } else if ($row->getName() == 'row') {
                     // Match a row element
                     $fieldValues = array();

                     foreach ($row->getChildren() as $field) {
                        // Get the field names and values for this INSERT
                        $fieldName = $field->getAttribute('name');
                        $value = $field->getValue();
                        if ($value === null || $field->getAttribute('null') == 1) {
                           $value = 'NULL';
                        } else if (!is_numeric($value)) {
                           $value = $this->quoteString($value);
                        }
                        $fieldValues[$fieldName] = $value;
                     }

                     $fieldValues = array_merge($fieldDefaultValues, $fieldValues);

                     if (count($fieldValues) > 0) {
                        $this->sql[] = sprintf(
                              'INSERT INTO %s (%s) VALUES (%s)',
                              $table->getAttribute('name'),
                              join(', ', array_keys($fieldValues)),
                              join(', ', array_values($fieldValues))
                           );
                     }
                  }
               }

            } else if ($table->getName() == 'sql') {
               // Match sql element (set of SQL queries)
               foreach ($table->getChildren() as $query) {
                  // FIXME This code
                  if ($query->getName() == 'drop') {
                     if (!isset($dbdict)) {
                        $dbdict = @NewDataDictionary($this->dbconn);
                     }
                     $table = $query->getAttribute('table');
                     $column = $query->getAttribute('column');
                     if ($column) {
                        // NOT PORTABLE; do not use this
                        $this->sql[] = $dbdict->DropColumnSql($table, $column);
                     } else {
                        $this->sql[] = $dbdict->DropTableSQL($table);
                     }

                  } else if ($query->getName() == 'rename') {
                     if (!isset($dbdict)) {
                        $dbdict = @NewDataDictionary($this->dbconn);
                     }
                     $table = $query->getAttribute('table');
                     $column = $query->getAttribute('column');
                     $to = $query->getAttribute('to');
                     if ($column) {
                        $columns = &$this->dbconn->MetaColumns($table, true);
                        $colId = strtoupper($column);
                        $flds = '';
                        if (isset($columns[$colId])) {
                           $col = $columns[$colId];
                           $fld = array('NAME' => $col->name, 'TYPE' => $dbdict->MetaType($col), 'SIZE' => $col->max_length);
                           if ($col->primary_key) $fld['KEY'] = 'KEY';
                           if ($col->auto_increment) $fld['AUTOINCREMENT'] = 'AUTOINCREMENT';
                           if ($col->not_null) $fld['NOTNULL'] = 'NOTNULL';
                           if ($col->has_default) $fld['DEFAULT'] = $col->default_value;
                           $flds = array($colId => $fld);
                        }
                        $this->sql[] = $dbdict->RenameColumnSQL($table, $column, $to, $flds);
                     } else {
                        $this->sql[] = $dbdict->RenameTableSQL($table, $to);
                     }
                  } else {
                     $driver = $query->getAttribute('driver');
                     if (empty($driver) || $this->dbconn->databaseType === $driver) {
                        $this->sql[] = $query->getValue();
                     }
                  }
               }
            }
         }
      }
      return $this->sql;
   }

   function executeData($continueOnError = false) {
      $this->errorMsg = null;
      $dbconn = $this->dbconn == null ? DBConnection::getConn() : $this->dbconn;
      foreach ($this->sql as $stmt) {
         $dbconn->execute($stmt);
         if (!$continueOnError && $dbconn->errorNo() != 0) {
            return false;
         }
      }
      return true;
   }

   function extractData() {
   }

   function getSQL() {
      return $this->sql;
   }

   function quoteString($str) {
      return '\'' . str_replace('\'', '\\\'', str_replace('\\', '\\\\', $str)) . '\'';
   }

   function destroy() {
      $this->parser->destroy();
      unset($this);
   }
}

?>

---