abstract_sgbd_pdo.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/>.

*/
abstract class abstract_sgbd_pdo{

    protected $_tConfig;
    protected $_sConfig;
    protected $_sClassRow;
    protected $_pDb;
    protected $_sReq;
    protected $_tId;
    
    private static $_tInstance=array();
    
    protected static function _getInstance($class,$sConfig) {
        if ( !isset(self::$_tInstance[$class][$sConfig]) ){
            $oSgbd = new $class();
            $oSgbd->chooseConfig($sConfig);
            self::$_tInstance[$class][$sConfig]=$oSgbd;
            
        }
        return self::$_tInstance[$class][$sConfig];
    }
    
    public function setClassRow($sClassRow){
        $this->_sClassRow=$sClassRow;
    }
    public function chooseConfig($sConfig){
        $this->_sConfig=$sConfig;
    }
    public function setConfig($tConfig){
        $this->_tConfig=$tConfig;
    }
    public function getRequete(){
        return $this->_sReq;
    }
    
    public function getInsertFromTab($tProperty){
        
        $sCols='';
        $sVals='';
        
        if($tProperty){
            $tKey=array_keys($tProperty);
            foreach($tKey as $sVar){
                $sCols.=$sVar.',';
                $sVals.='?,';
            }
        }
        return '('.substr($sCols,0,-1).') VALUES ('.substr($sVals,0,-1).') ';
    }
    public function getUpdateFromTab($tProperty){
        $sReq='';
        if($tProperty){
            $tKey=array_keys($tProperty);
            foreach($tKey as $sVar){
                $sReq.=$sVar.'=?,';
            }
        }
        return substr($sReq,0,-1);
    }
    public function setId($tId){
        $this->_tId=$tId;
    }
    public function getWhereFromTab($tId){
        $sWhere='';
        if(is_array($tId)){
            $tKeyId=array_keys($tId);
            foreach($tKeyId as $sVar){
                if($sWhere!=''){ $sWhere.=' AND '; }
                $sWhere.=$sVar.'=?';
            }
        }
        
        return $sWhere;
    }


    private function getRequestAndParam($tReq){
        $sReq=null;
        $tParam=null;
        if(is_array($tReq)){
            $sReq=$tReq[0];
            if(isset($tReq[1]) and is_array($tReq[1])){
                $tParam=$tReq[1];
            }else{
                unset($tReq[0]);
                $tParam=array_values($tReq);
            }
        }else{
            $sReq=$tReq;
        }

        return array($sReq,$tParam);
    }
    
    public function findManySimple($tSql,$sClassRow){
        list($sReq,$tParam)=$this->getRequestAndParam($tSql);

        $pRs=$this->query($sReq,$tParam);
        
        if(!$pRs){
            return null;
        }
        
        return $pRs->fetchAll(PDO::FETCH_OBJ);
    }
    public function findMany($tSql,$sClassRow){
        list($sReq,$tParam)=$this->getRequestAndParam($tSql);

        $pRs=$this->query($sReq,$tParam);
        
        if(!$pRs){
            return null;
        }
            
        $tObj=array();
        while($tRow=$pRs->fetch(PDO::FETCH_ASSOC)){
            $oRow=new $sClassRow($tRow);
            $tObj[]=$oRow;
        }
        return $tObj;
    }
    public function findOne($tSql,$sClassRow){
        list($sReq,$tParam)=$this->getRequestAndParam($tSql);

        $pRs=$this->query($sReq,$tParam);

        $tRow=$pRs->fetch(PDO::FETCH_ASSOC);
        
        if(empty($tRow) ){
            return null;
        }
            
        $oRow=new $sClassRow($tRow);
        
        return $oRow;
    }
    public function findOneSimple($tSql,$sClassRow){
        list($sReq,$tParam)=$this->getRequestAndParam($tSql);

        $pRs=$this->query($sReq,$tParam);

        $oRow=$pRs->fetch(PDO::FETCH_OBJ);
        
        if(empty($oRow) ){
            return null;
        }
        
        return $oRow;
    }
    public function execute($tSql){
        list($sReq,$tParam)=$this->getRequestAndParam($tSql);

        return $this->query($sReq,$tParam);
    }
    
    public function update($sTable,$tProperty,$tWhere){

        $sReq='UPDATE '.$sTable.' SET '.$this->getUpdateFromTab($tProperty).' WHERE '.$this->getWhereFromTab($tWhere);

        $tPropertyAndWhere=array_merge($tProperty,$tWhere);
        $tParam=array_values($tPropertyAndWhere);

        $this->query($sReq,$tParam);
    }
    public function insert($sTable,$tProperty){
        $sReq='INSERT INTO '.$sTable.' '.$this->getInsertFromTab($tProperty);
        $tParam=array_values($tProperty);

        $this->query($sReq,$tParam);
        
        return $this->getLastInsertId();
    }

    public function delete($sTable,$tWhere){

        $sReq='DELETE FROM '.$sTable.' WHERE '.$this->getWhereFromTab($tWhere);
        $tParam=array_values($tWhere);

        $this->query($sReq,$tParam);
    }

    public function getPdo(){
        $this->connect();
        return $this->_pDb;
    }
    
    protected function query($sReq,$tParam=null){
        if($tParam==null){
            $tParam=array();
        }
        
        $tATTRERRMODE=array(
            'SILENT' => PDO::ERRMODE_SILENT,
            'WARNING' => PDO::ERRMODE_WARNING,
            'EXCEPTION' => PDO::ERRMODE_EXCEPTION,
        );
        $tATTRCASE=array(
            'LOWER' => PDO::CASE_LOWER,
            'NATURAL' => PDO::CASE_NATURAL,
            'UPPER' => PDO::CASE_UPPER,
        );
        
        
        $this->connect();
        $this->_sReq=$sReq.' [ '.implode(' | ',$tParam).' ]';
        $this->_pDb->setAttribute(PDO::ATTR_ERRMODE, $tATTRERRMODE[ trim(_root::getConfigVar('pdo.ATTR_ERRMODE','WARNING')) ] ); 
        $this->_pDb->setAttribute(PDO::ATTR_CASE, $tATTRCASE[ trim(_root::getConfigVar('pdo.ATTR_CASE','NATURAL')) ] ); 
        $sth = $this->_pDb->prepare($sReq);
        if(is_array($tParam)){
            $sth->execute($tParam);
        }else{
            $sth->execute();
        }
        return $sth;
    }

    public function erreur($sErreur){
        throw new Exception($sErreur);
    }
    
}