<?php

class XMLConnection
{
    var $phptype = 'myxml';
    var $caseFolding = true;
    var $xmldoc = null;
    var $xmlFile = '';

    /**
     * XMLConnection
     *
     * @param string $file
     * @return void
     */
    public function XMLConnection ($file)
    {
        $this->xmldoc = new Xml_Document();
        $this->xmldoc->parseXmlFile( $file );
        $this->xmlFile = $file;
    }

    /**
     * &query
     * Actualy the only one supported query is simple SELECT.
     *
     * @param string $sql
     * @return object(XMLResult) $result
     */
    public function &query ($sql)
    {
        if (! isset( $this->xmldoc )) {
            $err = new DB_Error( "Error: Closed xmlConnection." );
            return $err;
        }
        if (1 === preg_match( '/^\s*SELECT\s+([\w\W]+?)(?:\s+FROM\s+`?([^`]+?)`?)(?:\s+WHERE\s+([\w\W]+?))?(?:\s+GROUP\s+BY\s+([\w\W]+?))?(?:\s+ORDER\s+BY\s+([\w\W]+?))?(?:\s+BETWEEN\s+([\w\W]+?)\s+AND\s+([\w\W]+?))?(?:\s+LIMIT\s+(\d+)\s*,\s*(\d+))?\s*$/im', $sql, $matches )) {
            $sqlColumns = $matches[1];
            $sqlFrom = isset( $matches[2] ) ? $matches[2] : '';
            $sqlWhere = isset( $matches[3] ) ? $matches[3] : '';
            $sqlGroupBy = isset( $matches[4] ) ? $matches[4] : '';
            $sqlOrderBy = isset( $matches[5] ) ? $matches[5] : '';
            $sqlLowLimit = isset( $matches[8] ) ? $matches[8] : '';
            $sqlHighLimit = isset( $matches[9] ) ? $matches[9] : '';
            /* Start Block: Fields list */
            $count = preg_match_all( '/\s*(\*|[\w\.]+)(?:\s+AS\s+([\w\.]+))?/im', $sqlColumns, $match, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE );
            $fieldsList = array ();
            for ($r = 0; $r < $count; $r ++) {
                $name = (is_array( $match[2][$r] ) && $match[2][$r][0] !== '') ? $match[2][$r][0] : $match[1][$r][0];
                $fieldsList[$name] = $match[1][$r][0];
            }
            /* End Block */
            /* Start Block: Order list */
            $count = preg_match_all( '/\s*(\*|[\w\.]+)(\s+ASC|\s+DESC)?\s*,?/im', $sqlOrderBy, $match, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE );
            $orderList = array ();
            for ($r = $count - 1; $r >= 0; $r --) {
                $direction = (is_array( $match[2][$r] ) && $match[2][$r][0] !== '') ? $match[2][$r][0] : 'ASC';
                $direction = strtoupper( $direction );
                $orderList[$match[1][$r][0]] = $direction;
            }
            /* End Block */
            $xmlFrom = '/' . str_replace( '.', '/', $sqlFrom );
            $node = & $this->xmldoc->findNode( $xmlFrom );
            if (! isset( $node )) {
                //$err = new DB_Error( "$xmlFrom node not found in $dsn." );
                throw new Exception( "$xmlFrom node not found in " . $this->xmlFile . "." );
                return $err;
            } else {
                $res = $this->fetchChildren( $node );
            }
            /* Start Block: WHERE*/
            if ($sqlWhere !== '') {
                /*Start Block: Replace the operator */
                $blocks = preg_split( '/("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\')/im', $sqlWhere, - 1, PREG_SPLIT_DELIM_CAPTURE );
                $sqlWhere = '';
                for ($r = 0; $r < sizeof( $blocks ); $r ++) {
                    if (($r % 2) === 0) {
                        $blocks[$r] = str_replace( '=', '==', $blocks[$r] );
                        $blocks[$r] = str_replace( '<>', '!=', $blocks[$r] );
                        $blocks[$r] = str_replace( 'AND', '&&', $blocks[$r] );
                        $blocks[$r] = str_replace( 'and', '&&', $blocks[$r] );
                        $blocks[$r] = str_replace( 'OR', '||', $blocks[$r] );
                        $blocks[$r] = str_replace( 'or', '||', $blocks[$r] );
                        $blocks[$r] = str_replace( 'NOT', '!', $blocks[$r] );
                        $blocks[$r] = str_replace( 'not', '!', $blocks[$r] );
                        $blocks[$r] = preg_replace( '/\b[a-zA-Z_][\w\.]*\b/im', '$res[$r][\'$0\']', $blocks[$r] );
                        $blocks[$r] = preg_replace( '/\$res\[\$r\]\[\'(like)\'\]/im', '$1', $blocks[$r] );
                    }
                    $sqlWhere .= $blocks[$r];
                }
                $sqlWhere = preg_replace_callback( '/(.+)\s+like\s+("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\')/im', array ('XMLConnection','sqlWhereLike'
                ), $sqlWhere );
                $sqlWhere = preg_replace_callback( '/"(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\'/im', array ('XMLConnection','sqlString'
                ), $sqlWhere );
                $newRes = array ();
                for ($r = 0; $r < sizeof( $res ); $r ++) {
                    $evalWhere = false;
                    @eval( '$evalWhere = ' . $sqlWhere . ';' );
                    if ($evalWhere) {
                        $newRes[] = $res[$r];
                    }
                }
                $res = $newRes;
            }
            /* End Block */
            /* Start Block: Expands the resultant data according to fill an array
             *              with the required fields in the query.
             */
            for ($r = 0; $r < sizeof( $res ); $r ++) {
                $res[$r] = $this->expandFields( $res[$r], $fieldsList );
            }
            /* End Block */
            /* Start Block: ORDER BY*/
            foreach ($orderList as $field => $direction) {
                for ($i = 0; $i < sizeof( $res ); $i ++) {
                    for ($j = $i + 1; $j < sizeof( $res ); $j ++) {
                        $condition = ($direction === 'ASC') ? ($res[$j] < $res[$i]) : ($res[$j] > $res[$i]);
                        if ($condition) {
                            $swap = $res[$i];
                            $res[$i] = $res[$j];
                            $res[$j] = $swap;
                        }
                    }
                }
            }
            /* End Block */
            /* Start Block: Apply limits */
            if ($sqlLowLimit != '' && $sqlHighLimit != '') {
                $sqlLowLimit = (int) $sqlLowLimit;
                $sqlHighLimit = (int) $sqlHighLimit;
                $res = array_slice( $res, $sqlLowLimit, $sqlHighLimit );
            }
            /* End Block */
            $result = new XMLResult( $res );
            return $result;
        } elseif (1 === preg_match( '/^\s*DELETE\s+FROM\s+`?([^`]+?)`?(?:\s+WHERE\s+([\w\W]+?))?\s*$/im', $sql, $matches )) {
            $sqlFrom = isset( $matches[1] ) ? $matches[1] : '';
            $sqlWhere = isset( $matches[2] ) ? $matches[2] : '1';
            /* Start Block: WHERE*/
            /*Start Block: Replace the operator */
            $blocks = preg_split( '/("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\')/im', $sqlWhere, - 1, PREG_SPLIT_DELIM_CAPTURE );
            $sqlWhere = '';
            for ($r = 0; $r < sizeof( $blocks ); $r ++) {
                if (($r % 2) === 0) {
                    $blocks[$r] = str_replace( '=', '==', $blocks[$r] );
                    $blocks[$r] = str_replace( '<>', '!=', $blocks[$r] );
                    $blocks[$r] = str_replace( 'AND', '&&', $blocks[$r] );
                    $blocks[$r] = str_replace( 'and', '&&', $blocks[$r] );
                    $blocks[$r] = str_replace( 'OR', '||', $blocks[$r] );
                    $blocks[$r] = str_replace( 'or', '||', $blocks[$r] );
                    $blocks[$r] = str_replace( 'NOT', '!', $blocks[$r] );
                    $blocks[$r] = str_replace( 'not', '!', $blocks[$r] );
                    $blocks[$r] = preg_replace( '/\b[a-zA-Z_][\w\.]*\b/im', '$res[$r][\'$0\']', $blocks[$r] );
                    $blocks[$r] = preg_replace( '/\$res\[\$r\]\[\'(like)\'\]/im', '$1', $blocks[$r] );
                }
                $sqlWhere .= $blocks[$r];
            }
            /* End Block */
            $sqlWhere = preg_replace_callback( '/(.+)\s+like\s+("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\')/im', array ('XMLConnection','sqlWhereLike'
            ), $sqlWhere );
            $sqlWhere = preg_replace_callback( '/"(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\'/im', array ('XMLConnection','sqlString'
            ), $sqlWhere );

            /*Start Block: Removing fields */
            $xmlFrom = '/' . str_replace( '.', '/', $sqlFrom );
            $node = & $this->xmldoc->findNode( $xmlFrom );
            if (! isset( $node )) {
                $err = new DB_Error( "$xmlFrom node not found!." );
                return $err;
            } else {
                $res = $this->fetchChildren( $node );
            }
            $newRes = array ();
            for ($r = 0; $r < sizeof( $res ); $r ++) {
                $evalWhere = false;
                @eval( '$evalWhere = ' . $sqlWhere . ';' );
                if ($evalWhere) {
                    unset( $node->children[$r] );
                    $newRes[] = $res[$r];
                }
            }
            //Re-index
            $node->children = array_values( $node->children );
            /* End Block */
            $this->xmldoc->save( $this->xmlFile );
            $result = new XMLResult( $newRes );
            return $result;
        } elseif (1 === preg_match( '/^\s*INSERT\s+INTO\s+`?([^`]+?)`?\s*\(([\w\W]+?)\)\s+VALUES\s*\(([\w\W]+?)\)\s*$/im', $sql, $matches )) {
            $sqlFrom = isset( $matches[1] ) ? $matches[1] : '';
            $sqlColumns = isset( $matches[2] ) ? $matches[2] : '1';
            $sqlValues = isset( $matches[3] ) ? $matches[3] : '1';
            $xmlFrom = '/' . str_replace( '.', '/', $sqlFrom );
            $node = & $this->xmldoc->findNode( $xmlFrom );
            /* Start Block: Fields list */
            $count = preg_match_all( '/([\w\.]+)/im', $sqlColumns, $match, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE );
            $fieldsList = array ();
            for ($r = 0; $r < $count; $r ++) {
                $fieldsList[] = $match[1][$r][0];
            }
            /* End Block */
            /* Start Block: Fields Values */
            $count = preg_match_all( '/("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\'|\d+)/im', $sqlValues, $match, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE );
            $fieldsValues = array ();
            for ($r = 0; $r < $count; $r ++) {
                if (substr( $match[1][$r][0], 0, 1 ) === '"') {
                    $match[1][$r][0] = substr( $match[1][$r][0], 1, - 1 );
                    $match[1][$r][0] = str_replace( '""', '"', $match[1][$r][0] );
                    $match[1][$r][0] = str_replace( "''", "'", $match[1][$r][0] );
                }
                if (substr( $match[1][$r][0], 0, 1 ) === "'") {
                    $match[1][$r][0] = substr( $match[1][$r][0], 1, - 1 );
                    $match[1][$r][0] = str_replace( "''", "'", $match[1][$r][0] );
                    $match[1][$r][0] = str_replace( '""', '"', $match[1][$r][0] );
                }
                $fieldsValues[$fieldsList[$r]] = $match[1][$r][0];
            }
            /* End Block */
            $AAA = getNames( $this->xmldoc->children[0]->children );
            $this->insertRow( $node, $fieldsValues );
            $DDD = getNames( $this->xmldoc->children[0]->children );
            $this->xmldoc->save( $this->xmlFile );
            $result = new XMLResult( array ($fieldsValues
            ) );
            return $result;
        } elseif (1 === preg_match( '/^\s*UPDATE\s+`?([^`]+?)`?\s+SET\s+((?:(?:[a-z][\w\.]*)\s*=\s*(?:"(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\'|\d+)\s*(?:,\s*)?)+)(?:\s+WHERE\s+([\w\W]+?))?\s*$/im', $sql, $matches )) {
            $sqlFrom = isset( $matches[1] ) ? $matches[1] : '';
            $sqlColumns = isset( $matches[2] ) ? $matches[2] : '';
            $sqlWhere = isset( $matches[3] ) ? $matches[3] : '1';
            $count = preg_match_all( '/([a-z][\w\.]*)\s*=\s*("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\'|\d+)/im', $sqlColumns, $match, PREG_PATTERN_ORDER | PREG_OFFSET_CAPTURE );
            $fieldsValues = array ();
            for ($r = 0; $r < $count; $r ++) {
                if (substr( $match[2][$r][0], 0, 1 ) === '"') {
                    $match[2][$r][0] = substr( $match[2][$r][0], 1, - 1 );
                    $match[2][$r][0] = str_replace( '""', '"', $match[2][$r][0] );
                    $match[2][$r][0] = str_replace( "''", "'", $match[2][$r][0] );
                }
                if (substr( $match[2][$r][0], 0, 1 ) === "'") {
                    $match[2][$r][0] = substr( $match[2][$r][0], 1, - 1 );
                    $match[2][$r][0] = str_replace( "''", "'", $match[2][$r][0] );
                    $match[2][$r][0] = str_replace( '""', '"', $match[2][$r][0] );
                }
                $fieldsValues[$match[1][$r][0]] = $match[2][$r][0];
            }
            /* Start Block: WHERE*/
            /*Start Block: Replace the operator */
            $blocks = preg_split( '/("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\')/im', $sqlWhere, - 1, PREG_SPLIT_DELIM_CAPTURE );
            $sqlWhere = '';
            for ($r = 0; $r < sizeof( $blocks ); $r ++) {
                if (($r % 2) === 0) {
                    $blocks[$r] = str_replace( '=', '==', $blocks[$r] );
                    $blocks[$r] = str_replace( '<>', '!=', $blocks[$r] );
                    $blocks[$r] = str_replace( 'AND', '&&', $blocks[$r] );
                    $blocks[$r] = str_replace( 'and', '&&', $blocks[$r] );
                    $blocks[$r] = str_replace( 'OR', '||', $blocks[$r] );
                    $blocks[$r] = str_replace( 'or', '||', $blocks[$r] );
                    $blocks[$r] = str_replace( 'NOT', '!', $blocks[$r] );
                    $blocks[$r] = str_replace( 'not', '!', $blocks[$r] );
                    $blocks[$r] = preg_replace( '/\b[a-zA-Z_][\w\.]*\b/im', '$res[$r][\'$0\']', $blocks[$r] );
                    $blocks[$r] = preg_replace( '/\$res\[\$r\]\[\'(like)\'\]/im', '$1', $blocks[$r] );
                }
                $sqlWhere .= $blocks[$r];
            }
            /* End Block */
            $sqlWhere = preg_replace_callback( '/(.+)\s+like\s+("(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\')/im', array ('XMLConnection','sqlWhereLike'
            ), $sqlWhere );
            $sqlWhere = preg_replace_callback( '/"(?:(?:[^"]|"")*)"|\'(?:(?:[^\']|\'\')*)\'/im', array ('XMLConnection','sqlString'
            ), $sqlWhere );
            /*Start Block: Removing fields */
            $xmlFrom = '/' . str_replace( '.', '/', $sqlFrom );
            $node = & $this->xmldoc->findNode( $xmlFrom );
            if (! isset( $node )) {
                $err = new DB_Error( "$xmlFrom node not found in $dsn." );
                return $err;
            } else {
                $res = $this->fetchChildren( $node );
            }
            $newRes = array ();
            for ($r = 0; $r < sizeof( $res ); $r ++) {
                $evalWhere = false;
                @eval( '$evalWhere = ' . $sqlWhere . ';' );
                if ($evalWhere) {
                    $this->updateRow( $node->children[$r], $fieldsValues );
                    $newRes[] = array_merge( $res[$r], $fieldsValues );
                }
            }
            /* End Block */
            $nodeTEST = & $this->xmldoc->findNode( $xmlFrom );
            $this->xmldoc->save( $this->xmlFile );
            $result = new XMLResult( $newRes );
            return $result;
        } else {
            echo ($sql);
            $err = new DB_Error( "SQL Query is not well formed." );
            return $err;
        }
    }

    /**
     * sqlLike
     *
     * @param string $a
     * @return void $b
     */
    public function sqlLike ($a, $b)
    {
        $b = addcslashes( $b, '[]()\/{}.?' );
        $b = str_replace( "%", '.*', $b );
        $b = '/^' . $b . '$/im';
        return preg_match( $b, $a );
    }

    /**
     * expandFields
     *
     * @param string $resRow
     * @param string $fieldsList
     * @return array $res
     */
    public function expandFields ($resRow, $fieldsList)
    {
        $res = array ();
        foreach ($fieldsList as $key => $value) {
            if ($key === '*') {
                foreach ($resRow as $k => $v) {
                    $res[$k] = $v;
                }
            } else {
                $res[$key] = array_key_exists( $value, $resRow ) ? $resRow[$value] : null;
            }
        }
        return $res;
    }

    /**
     * fetchNode
     *
     * @param object &$node
     * @return array $res
     */
    public function fetchNode (&$node)
    {
        $res = array ('XMLNODE_NAME' => $node->name,'XMLNODE_TYPE' => $node->type,'XMLNODE_VALUE' => $node->value
        );
        foreach ($node->attributes as $name => $value) {
            if ($this->caseFolding) {
                $name = strtoupper( $name );
            }
            $res[$name] = $value;
        }
        return $res;
    }

    /**
     * fetchChildren
     *
     * @param string &$node
     * @return array $res
     */
    public function fetchChildren (&$node)
    {
        $res = array ();
        foreach ($node->children as $name => $child) {
            $res[] = $this->fetchNode( $child );
        }
        return $res;
    }

    /**
     * disconnect
     *
     * @return void
     */
    public function disconnect ()
    {
        unset( $this->xmldoc );
    }

    /**
     *
     * @param array $match
     * @return object(DB_Error) $err
     */
    public function sqlWhereLike ($match)
    {
        switch (substr( $match[2], 0, 1 )) {
            case '"':
                return ' $this->sqlLike( ' . $match[1] . ', ' . $match[2] . ' ) ';
                break;
            case "'":
                return ' $this->sqlLike( ' . $match[1] . ', ' . $match[2] . ' ) ';
                break;
            default:
                $err = new DB_Error( "XMLDB: Syntax error on $match[0]" );
                die();
                return $err;
        }
    }

    /**
     * sqlString
     *
     * @param array $match
     * @return object(DB_Error) $err
     */
    public function sqlString ($match)
    {
        switch (substr( $match[0], 0, 1 )) {
            case '"':
                $match[0] = substr( $match[0], 1, - 1 );
                $match[0] = str_replace( '""', '"', $match[0] );
                $match[0] = str_replace( "''", "'", $match[0] );
                $match[0] = addcslashes( $match[0], '\\\'' );
                return "'$match[0]'";
                break;
            case "'":
                $match[0] = substr( $match[0], 1, - 1 );
                $match[0] = str_replace( "''", "'", $match[0] );
                $match[0] = str_replace( '""', '"', $match[0] );
                $match[0] = addcslashes( $match[0], '\\\'' );
                return "'$match[0]'";
                break;
            default:
                $err = new DB_Error( "XMLDB: Syntax error on $match[0]" );
                die();
                return $err;
        }
    }

    /**
     * insertRow
     *
     * @param string &$node
     * @param object $values
     * @return void
     */
    public function insertRow (&$node, $values)
    {
        $attributes = array ();
        foreach ($values as $field => $value) {
            switch ($field) {
                case 'XMLNODE_NAME':
                case 'XMLNODE_TYPE':
                case 'XMLNODE_VALUE':
                    break;
                default:
                    $attributes[strtolower( $field )] = $value;
            }
        }
        $values['XMLNODE_NAME'] = ! isset( $values['XMLNODE_NAME'] ) ? '' : $values['XMLNODE_NAME'];
        $values['XMLNODE_TYPE'] = ! isset( $values['XMLNODE_TYPE'] ) ? 'open' : $values['XMLNODE_TYPE'];
        $values['XMLNODE_VALUE'] = ! isset( $values['XMLNODE_VALUE'] ) ? '' : $values['XMLNODE_VALUE'];
        $node->addChildNode( new Xml_Node( $values['XMLNODE_NAME'], $values['XMLNODE_TYPE'], $values['XMLNODE_VALUE'], $attributes ) );
    }

    /**
     * updateRow
     *
     * @param string &$node
     * @param object $values
     * @return void
     */
    public function updateRow (&$node, $values)
    {
        foreach ($values as $field => $value) {
            switch ($field) {
                case 'XMLNODE_NAME':
                    $node->name = $value;
                    break;
                case 'XMLNODE_TYPE':
                    $node->type = $value;
                    break;
                case 'XMLNODE_VALUE':
                    $node->value = $value;
                    break;
                default:
                    $node->attributes[strtolower( $field )] = $value;
            }
        }
    }
}