PHP Classes
elePHPant
Icontem

File: Sql_Parser/Sql_ParserSelect.class.php

Recommend this page to a friend!
Stumble It! Stumble It! Bookmark in del.icio.us Bookmark in del.icio.us
  Classes of Tom Schaefer  >  SQL Parse and Compile  >  Sql_Parser/Sql_ParserSelect.class.php  >  Download  
File: Sql_Parser/Sql_ParserSelect.class.php
Role: Class source
Content type: text/plain
Description: parses select statement into object
Class: SQL Parse and Compile
Parse and compose SQL queries programatically
Author: By
Last change: update
Date: 6 years ago
Size: 8,653 bytes
 

Contents

Class file image Download
<?php

/**
 *
 * Sql_ParserSelect
 * @package Sql
 * @subpackage Sql_Parser
 * @author Thomas Schaefer
 * @since 30.11.2008
 * @desc parses a sql select into object
 */

/**
 *
 * Sql_ParserSelect
 * @package Sql
 * @subpackage Sql_Parser
 * @author Thomas Sch&#65533;fer
 * @since 30.11.2008 07:49:30
 * @desc parses a sql select into object
 */
class Sql_ParserSelect {

   
/**
     * parse select
     *
     * @param bool $subSelect
     * @return array
     */
   
public static function doParse($subSelect = false)
    {
       
$tree = array('Command' => 'select');
       
       
Sql_Parser::getTok();
               
        if ((
Sql_Object::token() == 'distinct') || (Sql_Object::token() == 'all')) {
           
$tree['Quantifier'] = Sql_Object::token();
           
Sql_Parser::getTok();
        }

       
$tree = Sql_Parser::parseColumns($tree);
               
        if (
Sql_Object::token() != 'from') {
            return
Sql_Parser::raiseError('Expected "from"', __LINE__);
        }

       
####################
               
       
Sql_Parser::getTok();
       
$tree['TableNames'] = array();
       
        while (
Sql_Object::token() == 'ident')
        {
           
$tableNameToken = Sql_Object::lexer()->tokText;
           
// added 2008-01-16
           
if(strpos($tableNameToken,".")>0)
            {
               
$arrTableNameToken = explode(".",$tableNameToken);
                switch(
count($arrTableNameToken)) {
                    case
2:
                        if(empty(
$tree['DatabaseNames'])) $tree['DatabaseNames'] = array();
                       
$tree['DatabaseNames'][] = $arrTableNameToken[0];
                       
$tree['TableNames'][] = $arrTableNameToken[1];
                    break;
                    default:
                      
$tree['TableNames'][] = Sql_Object::lexer()->tokText;
                        break;
                }
            }
            else
            {
               
$tree['TableNames'][] = Sql_Object::lexer()->tokText;
            }
           
           
Sql_Parser::getTok();
           
            if (
Sql_Object::token() == 'ident')
            {
               
$tree['TableAliases'][] = Sql_Object::lexer()->tokText;
               
Sql_Parser::getTok();
            }
            elseif (
Sql_Object::token() == 'as')
            {
               
Sql_Parser::getTok();
                if (
Sql_Object::token() == 'ident')
                {
                   
$tree['TableAliases'][] = Sql_Object::lexer()->tokText;
                }
                else
                {
                    return
Sql_Parser::raiseError('Expected table alias', __LINE__);
                }
               
               
Sql_Parser::getTok();
               
            } else {
               
$tree['TableAliases'][] = '';
            }
           
            if (
Sql_Object::token() == 'on')
            {
               
$clause = Sql_Parser::parseSearchClause();
           
                if (
Sql_Parser::isError($clause))
                {
                    return
$clause;
                }
               
               
$tree['Joins'][] = $clause;
            }
            else
            {
               
$tree['Joins'][] = '';
            }
           
            if (
Sql_Object::token() == ',')
            {
               
$tree['Join'][] = ',';
               
Sql_Parser::getTok();
            }
            elseif (
Sql_Object::token() == 'join')
            {
               
$tree['Join'][] = 'JOIN';
               
Sql_Parser::getTok();
            }
            elseif ((
Sql_Object::token() == 'cross') or (Sql_Object::token() == 'inner'))
            {
               
$join = Sql_Object::lexer()->tokText;
               
Sql_Parser::getTok();
                if (
Sql_Object::token() != 'join') {
                    return
Sql_Parser::raiseError('Expected token "join"', __LINE__);
                }
               
$tree['Join'][] = strtoupper($join).' JOIN';
           
               
Sql_Parser::getTok();
            }
            elseif ((
Sql_Object::token() == 'left') or (Sql_Object::token() == 'right'))
            {
               
$join = Sql_Object::lexer()->tokText;
           
               
Sql_Parser::getTok();
           
                if (
Sql_Object::token() == 'join')
                {
                   
$tree['Join'][] = strtoupper($join).' JOIN';
                }
                elseif (
Sql_Object::token() == 'outer')
                {
                   
$join .= ' outer';
                   
Sql_Parser::getTok();
                    if (
Sql_Object::token() == 'join') {
                       
$tree['Join'][] = strtoupper($join).' JOIN';
                    } else {
                        return
Sql_Parser::raiseError('Expected token "join"', __LINE__);
                    }
                }
                else
                {
                    return
Sql_Parser::raiseError('Expected token "outer" or "join"', __LINE__);
                }
               
               
Sql_Parser::getTok();
               
            }
            elseif (
Sql_Object::token() == 'natural')
            {
               
$join = Sql_Object::lexer()->tokText;
           
               
Sql_Parser::getTok();
           
                if (
Sql_Object::token() == 'join')
                {
                   
$tree['Join'][] = strtoupper($join).' JOIN';
                }
                elseif ((
Sql_Object::token() == 'left') or (Sql_Object::token() == 'right'))
                {
                   
$join .= ' '. Sql_Object::token();
                   
                   
Sql_Parser::getTok();
                   
                    if (
Sql_Object::token() == 'join')
                    {
                       
$tree['Join'][] = strtoupper($join).' JOIN';
                    }
                    elseif (
Sql_Object::token() == 'outer')
                    {
                       
$join .= ' '.Sql_Object::token();
                       
Sql_Parser::getTok();
                        if (
Sql_Object::token() == 'join')
                        {
                           
$tree['Join'][] = strtoupper($join).' JOIN';
                        }
                        else
                        {
                            return
Sql_Parser::raiseError('Expected token "join" or "outer"', __LINE__);
                        }
                    }
                    else
                    {
                        return
Sql_Parser::raiseError('Expected token "join" or "outer"', __LINE__);
                    }
                }
                else
                {
                    return
Sql_Parser::raiseError('Expected token "left", "right" or "join"', __LINE__);
                }
               
               
Sql_Parser::getTok();
               
            }
            elseif ((
Sql_Object::token() == 'where') or
            (
Sql_Object::token() == 'order') or
            (
Sql_Object::token() == 'limit') or
            (
is_null(Sql_Object::token())))
            {
                break;
            }
        }
       
       
###############################
       
while (
            !
is_null(Sql_Object::token()) and
            (!
$subSelect or Sql_Object::token() != Sql_Parser::OPENBRACE) and
           
Sql_Object::token() != Sql_Parser::CLOSEBRACE and
           
Sql_Object::token() != Sql_Parser::SEMICOLON
       
) {
           
            switch (
Sql_Object::token())
            {
                case
'where':
                   
$clause = Sql_Parser::parseSearchClause();
                   
                    if (
Sql_Parser::isError($clause))
                    {
                        return
$clause;
                    }
                   
                   
$tree['Where'] = $clause;
                   
                    break;
                case
'order':
                   
                   
Sql_Parser::getTok();
                   
                    if (
Sql_Object::token() != 'by')
                    {
                        return
Sql_Parser::raiseError('Expected "by"', __LINE__);
                    }
                   
                   
Sql_Parser::getTok();
                   
                    while (
Sql_Object::token() == 'ident')
                    {
                       
$col = Sql_Object::lexer()->tokText;
                       
                       
Sql_Parser::getTok();
                       
                        if (
Sql_Object::has("synonyms.".Sql_Object::token()))
                        {
                           
$order = Sql_Object::get("synonyms.".Sql_Object::token());
                            if ((
$order != 'asc') && ($order != 'desc'))
                            {
                                return
Sql_Parser::raiseError('Unexpected token', __LINE__);
                            }
                           
Sql_Parser::getTok();
                        }
                        else
                        {
                           
$order = 'ASC';
                        }
                       
                        if (
Sql_Object::token() == ',')
                        {
                           
Sql_Parser::getTok();
                        }
                       
                       
$tree['SortOrder'][$col] = strtoupper($order);
                    }
                    break;
                case
'limit':
                   
                   
Sql_Parser::getTok();
                   
                    if (
Sql_Object::token() != 'int_val')
                    {
                        return
Sql_Parser::raiseError('Expected an integer value', __LINE__);
                    }
                   
                   
$length = Sql_Object::lexer()->tokText;
                   
$start = 0;
                   
                   
Sql_Parser::getTok();
                   
                    if (
Sql_Object::token() == ',')
                    {
                       
Sql_Parser::getTok();
                   
                        if (
Sql_Object::token() != 'int_val')
                        {
                            return
Sql_Parser::raiseError('Expected an integer value', __LINE__);
                        }
                   
                       
$start = $length;
                       
$length = Sql_Object::lexer()->tokText;
                   
                       
Sql_Parser::getTok();
                   
                    }
                   
$tree['Limit'] = array('Start'=>$start, 'Length'=>$length);
                    break;
                case
'group':
                   
                   
Sql_Parser::getTok();
                   
                    if (
Sql_Object::token() != 'by')
                    {
                        return
Sql_Parser::raiseError('Expected "by"', __LINE__);
                    }
                   
                   
Sql_Parser::getTok();
                   
                    while (
Sql_Object::token() == 'ident')
                    {
                       
$col = Sql_Object::lexer()->tokText;
                   
                       
Sql_Parser::getTok();
                   
                        if (
Sql_Object::token() == ',')
                        {
                           
Sql_Parser::getTok();
                        }
                       
                       
$tree['GroupBy'][] = $col;
                       
                    }
                    break;
                case
'having':
                   
                   
$clause = Sql_Parser::parseSearchClause();
                   
                    if (
Sql_Parser::isError($clause))
                    {
                        return
$clause;
                    }
                   
                   
$tree['Having'] = $clause;
                   
                    break;
                default:
                    return
Sql_Parser::raiseError('Unexpected clause', __LINE__);
            }
        }
       
       
       
// added due to Alireza Eliaderani's mail from 2008-01-16
       
if(isset($tree['ColumnTables']) and count($tree['ColumnTables']) )
        {
           
$tree['ColumnTableAliases'] = array();
            foreach(
$tree['ColumnTables'] as &$colTbls){
                if(
in_array($colTbls,$tree['TableAliases'])){
                   
$tree['ColumnTableAliases'][]=$colTbls;
                   
$index=array_search($colTbls,$tree['TableAliases']);
                   
$colTbls=$tree['TableNames'][$index];
                }else{
                   
$tree['ColumnTableAliases'][]="";
                }
            }
           
        }
        return
$tree;
    }

    public static function
parse(){
        return
self::doParse();
    }
}