sgbd_csv.php

<?php
/*
This file is part of Mkframework.

Mkframework is free software: you can redistribute it and/or modify
it under the terms of the GNU Lesser General Public License as published by
the Free Software Foundation, either version 3 of the License.

Mkframework 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 Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General Public License
along with Mkframework.  If not, see <http://www.gnu.org/licenses/>.

*/
class sgbd_csv extends abstract_sgbd{
    
    
    public static function getInstance($sConfig){
        return self::_getInstance(__CLASS__,$sConfig);
    }
    
    public function findMany($tSql,$sClassRow){
        $tRows=$this->query($this->bind($tSql),$sClassRow);
        
        if(!$tRows){
            return null;
        }
        
        return $tRows;
    }
    public function findManySimple($tSql,$sClassRow){
        return $this->findMany($tSql,$sClassRow);
    }
    public function findOne($tSql,$sClassRow){
        $tRs=$this->query($this->bind($tSql),$sClassRow);
        
        if(empty($tRs)){
            return null;
        }
        
        return $tRs[0];
    }
    public function findOneSimple($tSql,$sClassRow){
        return $this->findOne($tSql,$sClassRow);
    }
    public function execute($tSql){
        return $this->query($this->bind($tSql));
    }
    
    public function update($sTable,$tProperty,$tWhere){
        $iId=$this->getIdFromTab($tWhere);
        
        $tProperty['id']=$iId;
        
        $tFile=$this->getTabFromTable($sTable);
        
        $tHeader=$this->getListColumn($sTable);
        
        foreach($tFile as $i => $sLigne){
            if($i < 2){ continue; }
            $tLigne=preg_split('/;/',$sLigne);
            if($tLigne[0] == $iId){
                foreach($tHeader as $sHeader){
                    $tUpdate[]=$this->encode($tProperty[ $sHeader]);
                }
            
                $tFile[$i]=implode(';',$tUpdate).';';
            }
        }
        
        
        $this->save($tFile,$sTable);
    }
    public function delete($sTable,$tWhere){
        $iId=$this->getIdFromTab($tWhere);
        
        $tFile=$this->getTabFromTable($sTable);
        
        foreach($tFile as $i => $sLigne){
            if($i < 2){ continue; }
            $tLigne=preg_split('/;/',$sLigne);
            if($tLigne[0] == $iId){
            
                unset( $tFile[$i] );
            }
        }
        
        $this->save($tFile,$sTable);
        
    }
    public function insert($sTable,$tProperty){
        $iId=$this->getMaxId($sTable);
        
        $iMax=($iId+1);
        
        $tProperty['id']=$iId;
        
        $tHeader=$this->getListColumn($sTable);
        foreach($tHeader as $sHeader){
            $tInsert[]=$this->encode($tProperty[ $sHeader]);
        }
        
        $tFile=$this->getTabFromTable($sTable);
        $tFile[]=implode(';',$tInsert).';';
        $tFile[0]=$iMax;
        
        $this->save($tFile,$sTable);
        
        return $iId;
    }

    public function getListColumn($sTable){
        
        $tFile=$this->getTabFromTable($sTable);
        
        $tHeader=preg_split('/;/',$tFile[1]);
        
        if( trim($tHeader[ count($tHeader)-1 ])==''){
            unset($tHeader[ count($tHeader)-1 ]);
        }
        
        return $tHeader;
        
    }
    public function getListTable(){
        $oDir=new _dir( $this->_tConfig[$this->_sConfig.'.database']);
        $tDir=$oDir->getList();
        $tSDir=array();
        foreach($tDir as $oDir){
            $tSDir[]= preg_replace('/\.csv/','',$oDir->getName());
        }
        return $tSDir;
    }
    
    private function query($sReq,$sClassRow){
        //traitement de la requete $sReq
        $sReq=trim($sReq);
        $this->_sReq=$sReq;
        if(substr($sReq,0,6)== 'SELECT'){
            
            $tReq=$this->explainSql($sReq);

            //count
            $bCount=false;
            $iCount=0;
            if(isset($tReq['select']) and preg_match('/COUNT\(/i',$tReq['select'])){
                $bCount=true;
            }
            
            $tCritere=$this->findListCritere($tReq);
            
            $sTable=trim($tReq['from']);
            
            $tObj=$this->findInTableWithCritere($sClassRow,$sTable,$tCritere);

            //count
            if($bCount){
                $iCount=count($tObj);
                return array($iCount);
            }else if(isset($tReq['order']) and $tObj!=null){
                return $this->sortResult($tObj,$tReq);
            }else{
                return $tObj;
            }
        }
        
        
        
    }
    private function explainSql($sReq){
        if(
            preg_match_all('/^SELECT(?<select>.*)FROM(?<from>.*)WHERE(?<where>.*)ORDER BY(?<order>.*)/i'
            ,$sReq,$tResult,PREG_SET_ORDER)
            or
            preg_match_all('/^SELECT(?<select>.*)FROM(?<from>.*)ORDER BY(?<order>.*)/i',$sReq,$tResult,PREG_SET_ORDER)
            or
            preg_match_all('/^SELECT(?<select>.*)FROM(?<from>.*)WHERE(?<where>.*)/i',$sReq,$tResult,PREG_SET_ORDER)
            or
            preg_match_all('/^SELECT(?<select>.*)FROM(?<from>.*)/i',$sReq,$tResult,PREG_SET_ORDER)
        ){
            if(isset($tResult[0]['where']) and preg_match('/ or /i',$tResult[0]['where'])){
                $this->erreur('Requete non supportee : '.$sReq.$msg);
            }elseif(isset($tResult[0]['order']) and !preg_match('/\s[ASC|DESC]/i',trim($tResult[0]['order'])) ){
                $this->erreur('Il faut definir un sens de tri: ASC ou DESC dans la requete'.$sReq.$msg);
            }else{
                return $tResult[0];
            }
            
        }else{
            $msg="\n\n";
            $msg.="Le driver xml gere les requetes de type : \n";
            $msg.="- SELECT liste_des_champs FROM ma_table WHERE champ=valeur ORDER BY champ DESC/ASC \n";
            $msg.="- SELECT liste_des_champs FROM ma_table ORDER BY champ DESC/ASC \n";
            $msg.="- SELECT liste_des_champs FROM ma_table WHERE champ=valeur \n";
            $msg.="- SELECT liste_des_champs FROM ma_table  \n";
            $msg.=" la clause where accepte uniquement champ=valeur, champ!=valeur et AND \n";
            
            $this->erreur('Requete non supportee : '.$sReq.$msg);
        }
    }
    private function findListCritere($tReq){
        $tCritere=array();
        
        if(isset($tReq['where'])){
            if(preg_match('/ and /i',$tReq['where'])){
                $tWhere=preg_split('/ AND /i',$tReq['where']);
                foreach($tWhere as $sWhereVal){
                    if(preg_match('/!=/',$sWhereVal)){ 
                        list($sVar,$sVal)=preg_split('/!=/',$sWhereVal);
                        $tCritere[trim($sVar)]='!'.trim($sVal);
                    }elseif(preg_match('/=/',$sWhereVal)){
                        list($sVar,$sVal)=preg_split('/=/',$sWhereVal);
                        $tCritere[trim($sVar)]='='.trim($sVal);
                    }
                }
            }else{
                if(preg_match('/!=/',$tReq['where'])){
                    list($sVar,$sVal)=preg_split('/!=/',$tReq['where']);
                    $tCritere[trim($sVar)]='!'.trim($sVal);
                }elseif(preg_match('/=/',$tReq['where'])){
                    list($sVar,$sVal)=preg_split('/=/',$tReq['where']);
                    $tCritere[trim($sVar)]='='.trim($sVal);
                }
            }
            
        }
        return $tCritere;
    }
    private function sortResult($tObj,$tReq){
        
        list($sChamp,$sSens)=preg_split('/ /',trim($tReq['order']));
        
        $tTri=array();
        $tIdObj=array();
        foreach($tObj as $i => $oObj){
            $tIdObj[ $i ]=$oObj;
            $tTri[ $i ]=(string)$oObj->$sChamp;
        }
        
        if($sSens=='DESC'){
            arsort($tTri);
        }else{
            asort($tTri);
        }
        
        $tOrderedObj=array();
        $tId= array_keys($tTri);
        foreach($tId as $id){
            $tOrderedObj[]=$tIdObj[$id];
        }

        return $tOrderedObj;
    }
    private function findInTableWithCritere($sClassRow,$sTable,$tCritere){
        $tFile=$this->getTabFromFile($this->getTabFromTable($sTable));
            
        $tObj=array();
        foreach($tFile as $tRow){
            
            foreach($tCritere as $sCritereField => $sCritereVal){
                
                if(!isset($tRow[$sCritereField]) or 
                    (
                        ($sCritereVal[0]=='=' and (string)$sCritereVal!=(string)'='.$tRow[$sCritereField])
                        
                        or
                        
                        ($sCritereVal[0]=='!' and (string)$sCritereVal==(string)'!'.$tRow[$sCritereField])
                    )
                ){
                    continue 2;
                }
            }
            
            
            $oRow=new $sClassRow($tRow);
            $tObj[]=$oRow;
            
        }
            
        return $tObj;
        
        
    }
    
    public function quote($sVal){
        return $sVal;
    }
    public function getWhereAll(){
        return '1=1';
    }
    
    
    private function getIdFromTab($tId){
        if(is_array($tId)){
            return current($tId);
        }else{
            return $tId;
        }
    }
    private function save($tFile,$sTable){
        $oFile=new _file($this->_tConfig[$this->_sConfig.'.database'].$sTable.'.csv');
        $sRet="\n";
        
        $sFile='';
        if($tFile){
            foreach($tFile as $sLigne){
                $sFile.=trim($sLigne).$sRet;
            }
        }
        $oFile->write($sFile);
    }
    private function getMaxId($sTable){
        $tFile=$this->getTabFromTable($sTable);
        
        $iMax=trim($tFile[0]);
        
        return (int)$iMax;
    }
    
    
    public function getTabFromFile($tContent){
        
        $tHeader=preg_split('/;/',$tContent[1]);
        
        $tab=array();
        foreach($tContent as $i => $sLigne){
            if($i < 2){ continue;}
            $sLigne=html_entity_decode($sLigne,ENT_QUOTES);
            $tLigne=preg_split('/;/',$sLigne);
            
            $tab2=array();
            foreach($tHeader as $i => $sHeader){
                $tab2[ $sHeader ]=$this->decode($tLigne[$i]);
            }
            $tab[]=$tab2;
            
        }
        return $tab;
        
    }
    public function getTabFromTable($sTable){
        $oFile=new _file($this->_tConfig[$this->_sConfig.'.database'].$sTable.'.csv');
        $tFile=$oFile->getTab();
        return $tFile;
    }
    
    public function encode($text){
        return preg_replace('/\r/','',preg_replace('/\n/','##retour_chariot_fmk##',$text));
    }
    public function decode($text){
        return preg_replace('/##retour_chariot_fmk##/',"\n",$text);
    }
    
    
}