Sql.class.php

gehe zur Dokumentation dieser Datei

<?php
// ---------------------------------------------------------------------------
// $Id$
// ---------------------------------------------------------------------------
// OpenRat Content Management System
// Copyright (C) 2002-2006 Jan Dankert, jandankert@jandankert.de
//
// This program is free software; you can redistribute it and/or
// modify it under the terms of the GNU General Public License
// as published by the Free Software Foundation; either version 2
// of the License, or (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
// ---------------------------------------------------------------------------



class Sql
{
     var $src      = '';
     
     var $query    = '';
     
     
     var $data     = Array();
     
     var $param    = array();
     
     
     var $dbid     = '';
     
     
     function Sql( $query = '', $dbid='' )
     {
          $this->dbid  = $dbid;
          $this->parseSourceQuery( $query );

          $this->data  = array();
     }



     function parseSourceQuery( $query )
     {
          $this->src   = $query; // Wir merken uns die Ur-Abfrage, evtl. für Fehlermeldungen interessant.
          
          while( true )  // Schleife wird solange durchlaufen, solange Parameter gefunden werden.
          {
               $posKlLinks  = strpos($query,'{');
               $posKlRechts = strpos($query,'}');
               
               if   ( $posKlLinks === false )
                    break; // Schleife abbrechen, wenn kein Parameter mehr gefunden wird.
                    
               $nameParam = substr($query,$posKlLinks+1,$posKlRechts-$posKlLinks-1);  // Name Parameter
               
               if   ( !isset($this->param[$nameParam ]))
                    $this->param   [$nameParam ] = array();
                    
               $this->param[$nameParam ][] = $posKlLinks;
               
               $query = substr($query,0,$posKlLinks).substr($query,$posKlRechts+1);
          }
          
          $this->query = $query;

          // Tabellennamen in die Platzhalter setzen.
          // Dies ist noch OpenRat-spezifisch und sollte bei einer sauberen Abstraktion woanders gemacht werden. Aber wo?
          foreach( table_names($this->dbid) as $t=>$name )
          {
               $this->setParam($t,$name,false );
          }
          
//        Html::debug($this->param);    
     }



     function setQuery( $query = '' )
     {
          $this->parseSourceQuery( $query );

          // Bereits vorhande Parameter setzen.        
          foreach( $this->data as $name=>$data )
          {
               if   ( $data['type']=='string'     ) $this->setString    ($name,$data['value'] );
               if   ( $data['type']=='stringlist' ) $this->setStringList($name,$data['value'] );
               if   ( $data['type']=='int'        ) $this->setInt       ($name,$data['value'] );
               if   ( $data['type']=='intlist'    ) $this->setIntList   ($name,$data['value'] );
               if   ( $data['type']=='null'       ) $this->setNull      ($name                );
          }
     }



     function setParam( $name,$value,$dieIfUnknown=true)
     {

          //   Nett gemeint, führt aber aktuell zu Fehlern, weil an vielen Stellen zu viele Parameter gefüllt werden.
          //   Daher erstmal deaktiviert.
          //        if   ( !isset($this->param[$name]) )
          //        {
          //             if   ( $dieIfUnknown )
          //                  die("parameter '$name' unknown. SQL=".$this->src);
          //             else
          //                  return;
          //        }

          if   ( !isset($this->param[$name]) )
               return; // Parameter nicht vorhanden.

          if   ( is_array($this->param[$name]) )
          {
               foreach( $this->param[$name] as $idx=>$xyz )
               {
                    $pos = $this->param[$name][$idx];
                    
                    $this->query = substr( $this->query,0,$pos ).$value.substr( $this->query,$pos );
               
                    foreach( $this->param as $pn=>$par)
                    {
                         foreach( $par as $i=>$p )
                         {
                              if   ( $p > $pos )
                                   $this->param[$pn][$i]=$p+strlen($value);
                         }
                    }
                    
               }
          }
          
          unset( $this->param[$name] );
     }
     


     function setVar( $name,$value )
     {
          if   ( is_string($value) )
               $this->setString( $name,$value );

          if   ( is_null($value) )
               $this->setNull( $name );
          
          if   ( is_int($value) )
               $this->setInt( $name,$value );
     }


     
     function setInt( $name,$value )
     {
          $this->data[ $name ] = array( 'type'=>'int','value'=>$value );
          
          $this->setParam($name,intval($value));
//        $this->query = str_replace( '{'.$name.'}',intval($value),$this->query );
     }



     function setIntList( $name,$values )
     {
          $this->data[ $name ] = array( 'type'=>'intlist','value'=>$values );
          
          $values  = array_map('intval',$values);
          $this->setParam($name,implode(',',$values) );
//        $this->query = str_replace( '{'.$name.'}',intval($value),$this->query );
     }



     function setString( $name,$value )
     {
          $this->data[ $name ] = array( 'type'=>'string','value'=>$value );

          //if ( defined('CONF_ADDSLASHES') && CONF_ADDSLASHES )
          
          $value = addslashes( $value );

          $value = "'".$value."'";

          $this->setParam($name,$value);
//        $this->query = str_replace( '{'.$name.'}',$value,$this->query );
     }



     function setStringList( $name,$values )
     {
          $this->data[ $name ] = array( 'type'=>'stringlist','value'=>$values );

          $values  = array_map('addslashes',$values);
          
          $value = "'".implode("','",$values)."'";

          $this->setParam($name,$value);
     }



     function setBoolean( $name,$value )
     {
          if   ( $value )
               $this->setInt( $name,1 );
          else $this->setInt( $name,0 );
     }



     function setNull( $name )
     {
          $this->data[ $name ] = array( 'type'=>'null' );
          $this->setParam($name,'NULL');
     }
     


     function &query()
     {
          return $this->getQuery();
     }



     function &getQuery()
     {
// Abbruch, wenn es noch nicht gefüllte Parameter gibt.
// Da diese Methode eh kaum verwendet wird, erstmal deaktiviert.
//        if   ( count($this->param) > 0 )
//             die('parameters not bound: '+implode(',',$this->param) );
               
          return $this->query;
     }
}

 
?>