linq in php

<?php
 /**
 * @name        D3Linq | Linq In Php
 * @version     1.0.1 
 * @author      Tufan Barış YILDIRIM
 * @link        htpp://www.tufyta.com
 * @since       20.10.2009
 * v2
 * =====
 * @todo Sql Group Funcs <SUM,AVG,COUNT etc.>
 * v1.0.1
 * ======
 * - Delete Statemend added. Can Delete any object from an array ( global )        
 * v1.0
 * ======
 * - This Class can be used for select from arrays as a sql query
 * - You;
 * - Can use php codes in Where clauses
 * - Can also use alias for key and value
 * - And can select array in array as  arrayname.elementname
 */
    class D3Linq{
 
      public    $OnError;
 
      private   $Index=0,
                $Result=False,
                $ResultKeys=array(),
                $ResultValues=array(),
                $isBasic=False,
                $isComplicated=False,
                $Tokens,
                $ErrorMsg,
                $ErrorCode;
       #Tokens Index
       const    QR_IDNEX    =0,     // Query Index
                ST_INDEX    =1,     // Statement type Index
                AR_INDEX    =7,     // Array name Index
                CL_INDEX    =3,     // Column Index                          
                AL_COUNT    =8,     // Count of matches for a basic query (without WHERE clause)
                WH_COUNT    =13,    // Count Of matches for a complicated query (with WHERE clauses)
                CM_WHINDEX  =12;    // Where clause index when is complicated
 
       # Errors with Codes        
       const    INVALID_SQL         ='010|Invalid SQL',
                MISSING_OPERATORS   ='020|Missing Operators',
                MISSING_P           ='021|Missing %1 parenthesis',
                UNEXCEPTED_ERROR    ='030|Unexcepted "<b><i>%1</i></b>"',
                EXCEPTED_BUT        ='031|Excepted "<b><i>%1</i></b>"  but found "<i>%2</i>"',
                NOT_AN_ARRAY        ='040|%1 is not an array',             
                NOT_AN_INTEGER      ='041|%1 is not an integer value on %2';                 
      /**
      * Constructor
      */
       public function D3Linq(){
            $this->Index=0;
            $this->ErrorMsg='';
            $this->ErrorCode='';
            $this->ResultKeys=array();
            $this->ResultValues=array();
            $this->Result=False;
            $this->isBasic=False;
            $this->isComplicated=False;
            $this->Tokens=array();
       }
 
       /**
       * Main Qery Parser
       * @param mixed $SQL it must be valid sql query string
       */
       public function Query($SQL){
           $this->D3Linq();    
 
           preg_match('/(SELECT|DELETE)([\s]+)([a-zA-Z0-9\s,]+|\*|.*)?([\s]+)?(FROM)([\s]+)([A-Za-z_0-9\.]+)([\s]+)*((WHERE)([\s]+)([^;]+))*/is',$SQL,$this->Tokens);
 
            switch(count($this->Tokens)) {
               case self::WH_COUNT:
               $this->isComplicated=True;
               break;
               case self::AL_COUNT:
               $this->isBasic=True;
               break;
               default:
                $this->Error(self::INVALID_SQL);
               break;
           }
 
              $RpCount=self::CountIn('\)',$this->Tokens[self::QR_IDNEX]);
              $LpCount=self::CountIn('\(',$this->Tokens[self::QR_IDNEX]);
           if($RpCount!=$LpCount) {
               if($RpCount<$LpCount){
                  $this->Error(self::MISSING_P,'right');
               }else{
                   $this->Error(self::MISSING_P,'left');
               }
           }
           switch (strtoupper($this->Tokens[self::ST_INDEX])){
               case 'SELECT':
               $this->Select($this->Tokens);
               break;
               case 'DELETE':
               $this->Delete($this->Tokens);
               break;
               default:
                $this->Error(self::UNEXCEPTED_ERROR,$this->FirstOf(explode(' ',$SQL)));
               break;
           }
 
       }
       /**
       * Set the index of current Row
       *
       * @param mixed $Int
       */
       public function data_seek($Int){
            if(is_numeric($Int)){
                $this->Index=$Int;
            }else {
                $this->Error(self::NOT_AN_INTEGER,array($Int,__FUNCTION__));
            }
       }
       /**
       * Get Unfetched Count
       * @return int
       */
       public  function num_rows(){
           return count($this->ResultKeys)-$this->Index;
       }
       /**
       * Fetch Result As D3Field. Return false if no result.
       * @return D3Object or False
       */
       public function fetch_object(){
           if($Object=$this->fetch_assoc()){
               return  (object)$Object;
           }
           else {
               return false;
           }
       }
       /**
       * Convert the obje name as  arrayname.indname ..to array arrayname[indname]
       *                              
       * @param mixed $dottedObject
       */
       private function dotObjectToArray($dottedObject){
             if(preg_match('/([A-z0-9_\.]+)/',$dottedObject)){
                 $objs=explode('.',$dottedObject);
                 $arrName=$objs[0];
                 global $$arrName;
                 $globalEleman=$$arrName;
 
                 foreach($objs as  $index=>$name){
                    if($index>0){
                          $globalEleman=$globalEleman[$name];
                          $globalName.=$globalname.'['.$name.']';
                      }else {
                          $globalName=$name;
                      }
                 }  
                 if(!is_array($globalEleman)){
                     $this->Error(self::NOT_AN_ARRAY,$dottedObject);
                 }else {
                     return array('array'=>$globalEleman,'global'=>$globalName,'arrName'=>$arrName);
                 }
             }else {
                 $this->Error(self::NOT_AN_ARRAY,$dottedObject);
             }                   
             return $dottedObject;
 
       }
       /**
       * Fetch Result as an Array. return false if not result
       * @return Array or False
       */
       public function fetch_assoc(){
                if($this->ResultKeys[$this->Index] AND $this->ResultValues[$this->Index]){
                    if($this->Tokens[self::CL_INDEX]=='*')  {
                            $Assoc=array('key'=>$this->ResultKeys[$this->Index],'value'=>$this->ResultValues[$this->Index]);
                    }else {
 
                        preg_match_all('/(key|value)((([\s]+)as)?([\s]+)([^,]+))?/i',$this->Tokens[self::CL_INDEX],$ColumnsWithAlias);
                        foreach($ColumnsWithAlias[1] as $colndx=>$colname){
                            $Assoc[trim($ColumnsWithAlias[6][$colndx] ? $ColumnsWithAlias[6][$colndx] : $colname)]=$colname=='key'?$this->ResultKeys[$this->Index]:$this->ResultValues[$this->Index];
                        }
 
                    }
                    $this->Index++;
                    return $Assoc;
                }
                else {
                    return False;
                }
       }
       /**
       * Main Selector Function
       *
       * @param mixed $Matches Tokens.
       */
       private function Select($Matches){
           $getObj=$this->dotObjectToArray($Matches[self::AR_INDEX]);
           $Dizimiz=$getObj['array'];
           if(!is_array($Dizimiz)){
             $this->Error(self::NOT_AN_ARRAY,$Matches[self::AR_INDEX]);
           }
           if($this->isComplicated){
                    $sart=$Matches[self::CM_WHINDEX];
                    $sart=preg_replace('/(key|value)(=|==|<|>|<=|>=)/i','$$1$2',$sart);
                    $Find=array('key=','value=','\'.key.\'','\'.value.\'');
                    $Replace=array('key==','value==','$key','$value');
                    $sart=str_replace($Find,$Replace,$sart);
                    $sart=preg_replace('/(key|value)([\s]+)(LIKE)*([\s]+)(\')*([^\'\n]+)(\')*/i','preg_match(\'/(\'.str_replace(\'%\',\'(.*)\',\'$6\').\')/i\',$$1)',$sart);
               }else {
                   $sart=true;
               }
 
           foreach ($Dizimiz as $key=>$value){
               @eval('$SartSaglandi=('.$sart.');');
             if($this->isBasic || $SartSaglandi){
                  $this->ResultValues[]=$value;
                  $this->ResultKeys[]=$key;
               }
           }                                                            
           return $this;
       }
 
       /**
       * Main Deleter Function
       *
       * @param mixed $Matches Tokens.
       */
       private function Delete($Matches){
           $getObj=$this->dotObjectToArray($Matches[self::AR_INDEX]);
           $Dizimiz=$getObj['array'];
           if(!is_array($Dizimiz)){
             $this->Error(self::NOT_AN_ARRAY,$Matches[self::AR_INDEX]);
           }
           if($this->isComplicated){
                    $sart=$Matches[self::CM_WHINDEX];
                    $sart=preg_replace('/(key|value)(=|==|<|>|<=|>=)/i','$$1$2',$sart);
                    $Find=array('key=','value=','\'.key.\'','\'.value.\'');
                    $Replace=array('key==','value==','$key','$value');
                    $sart=str_replace($Find,$Replace,$sart);
                    $sart=preg_replace('/(key|value)([\s]+)(LIKE)*([\s]+)(\')*([^\'\n]+)(\')*/i','preg_match(\'/(\'.str_replace(\'%\',\'(.*)\',\'$6\').\')/i\',$$1)',$sart);
               }else {
                   $sart=true;
               }
 
           foreach ($Dizimiz as $key=>$value){
               @eval('$SartSaglandi=('.$sart.');');
             if($this->isBasic || $SartSaglandi){   
                 $deleteCode='global $'.$getObj['arrName'].'; unset($'.$getObj['global'].'['.$key.']);';
                 eval($deleteCode);
 
               }else {
                  $this->ResultValues[]=$value;
                  $this->ResultKeys[]=$key;
               }
           }                                                            
           return $this;
       }
 
       /**
       * Error Creating Function
       *
       * @param mixed $String Error Template
       * @param mixed $Vals  Replace Values
       */
       private function Error($String,$Vals=False){
            $ErrAndCode =explode('|',$String);
            $Error      =strip_tags($ErrAndCode[1]);
            $ErrCode    =$ErrAndCode[0];
 
            if(is_array($Vals)) {
                  foreach($Vals AS $key=>$value){
                      $Error=str_replace('%'.($key+1),$value,$Error);
                  }
                }elseif($Vals){
                    $Error=str_replace('%1',$Vals,$Error);
                }
                $this->ErrorP($Error,$ErrCode);
 
       }
       /**
       * Print Error with Code.
       *
       * @param mixed $String  Error Message
       * @param mixed $Code    Error Code
       */
       private function ErrorP($String,$Code=000){
           $this->ErrorMsg  =$String;
           $this->ErrorCode =$Code;
          if($this->OnError)  {
            $this->RunEvent($this->OnError);
          }else{
            echo '<div><b>#'.$Code.'</b> '.$String."</div>\n";
          }
       }
       /**
       * Return First of Given Array
       *
       * @param mixed $Array
       * @return mixed  First of Array Element
       */
       private function FirstOf($Array){
           return $Array[0];
       }
       /**
       * Find Char Count in a string
       *
       * @param mixed $Needle 
       * @param mixed $Haystack
       * @return int  Char Count
       */
       private function CountIn($Needle,$Haystack){
                 preg_match_all('/([^\\\]['.$Needle.'])/i',$Haystack,$Found);
                 return count($Found[1]);
       }
       /**
       * Event Runner
       *
       * @param mixed $EventName Func Name
       * @param mixed $Param  Func Param(s)
       * @return mixed Func Result which called
       */
       private function RunEvent($EventName,$Param=False){
          if(function_exists($EventName)){
              if($Param){
 
               if(is_array($Param)){
                 return call_user_func_array($EventName,$Param); 
 
               } else {
                 return call_user_func($EventName,$Param);
               }
 
              }else {
                 return call_user_func($EventName);
                   }
            }
      }         
      /**
      * Get Last D3Linq Error Message
      * @return String               
      */
      public function ErrorMsg(){
          return $this->ErrorMsg;
      }
      /**
      * GEt Last D3Linq Error Code
      * @return String                           
      */
      public function ErrorCode(){
          return $this->ErrorCode;
      }
 
   }    
 
?>