Code Coverage |
||||||||||
Classes and Traits |
Functions and Methods |
Lines |
||||||||
| Total | |
0.00% |
0 / 1 |
|
80.00% |
20 / 25 |
CRAP | |
95.50% |
191 / 200 |
| sgbd_csv | |
0.00% |
0 / 1 |
|
80.00% |
20 / 25 |
74 | |
95.50% |
191 / 200 |
| getInstance | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| findMany | |
100.00% |
1 / 1 |
2 | |
100.00% |
4 / 4 |
|||
| findManySimple | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| findOne | |
100.00% |
1 / 1 |
2 | |
100.00% |
4 / 4 |
|||
| findOneSimple | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| execute | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| update | |
100.00% |
1 / 1 |
5 | |
100.00% |
16 / 16 |
|||
| delete | |
100.00% |
1 / 1 |
4 | |
100.00% |
11 / 11 |
|||
| insert | |
100.00% |
1 / 1 |
2 | |
100.00% |
12 / 12 |
|||
| getListColumn | |
0.00% |
0 / 1 |
2.15 | |
66.67% |
4 / 6 |
|||
| getListTable | |
100.00% |
1 / 1 |
2 | |
100.00% |
7 / 7 |
|||
| query | |
0.00% |
0 / 1 |
7.01 | |
94.74% |
18 / 19 |
|||
| explainSql | |
0.00% |
0 / 1 |
9.33 | |
84.00% |
21 / 25 |
|||
| findListCritere | |
100.00% |
1 / 1 |
8 | |
100.00% |
23 / 23 |
|||
| sortResult | |
100.00% |
1 / 1 |
4 | |
100.00% |
17 / 17 |
|||
| findInTableWithCritere | |
0.00% |
0 / 1 |
8.02 | |
93.75% |
15 / 16 |
|||
| quote | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| getWhereAll | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| getIdFromTab | |
0.00% |
0 / 1 |
2.15 | |
66.67% |
2 / 3 |
|||
| save | |
100.00% |
1 / 1 |
3 | |
100.00% |
10 / 10 |
|||
| getMaxId | |
100.00% |
1 / 1 |
1 | |
100.00% |
3 / 3 |
|||
| getTabFromFile | |
100.00% |
1 / 1 |
4 | |
100.00% |
13 / 13 |
|||
| getTabFromTable | |
100.00% |
1 / 1 |
1 | |
100.00% |
3 / 3 |
|||
| encode | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| decode | |
100.00% |
1 / 1 |
1 | |
100.00% |
1 / 1 |
|||
| <?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){ | |
| throw new Exception('method execute not available for this driver'); | |
| } | |
| 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); | |
| }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); | |
| }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); | |
| } | |
| } |