__'; const COND_INF = '__<__'; const COND_SUP = '__>__'; const COND_INFEQ = '__<=__'; const COND_SUPEQ = '__>=__'; const COND_LIKE = '__LIKE__'; const COND_IN = '__IN__'; const DEFAULT = '__DEFAULT__'; // Valeur DEFAULT (pour insertion) /* Attributs */ private $where; // Tableau associatif contenant les conditions private $select; // Tableau contenant la liste des champs à afficher private $unique; // VRAI si on attend une valeur unique private $schema; // Tableau contenant les informations associées aux données private $joined; // Tableau contenant les Rows liés /* CONSTRUCTEUR * * @schema Tableau contenant les informations de la requête * */ public function __construct($schema){ /* (1) On récupère les informations */ $this->schema = $schema; /* (2) On initialise les conditions */ $this->where = []; /* (3) On initialise les champs à retourner */ $this->select = []; /* (4) On initialise le caractère 'unique' du résultat */ $this->unique = false; /* (5) On initialise les jointures */ $this->joined = []; } /* FILTRE LES ENTREES D'UNE TABLE AVEC LA CLE PRIMAIRE SPECIFIEE * * @primary Clé primaire simple * OU * @primary Clé primaire composée * * @return Rows Tableau contenant toutes les entrées de la table * */ public function whereId($primary){ /* [0] Vérification des paramètres =========================================================*/ if( $primary == null ) return $this; /* [1] On récupère les clés primaires =========================================================*/ $keys = []; foreach($this->schema['columns'] as $k=>$v) if( $v['primary'] ) $keys[] = $k; /* [2] Si clé simple =========================================================*/ /* (1) On met au même format qu'une clé composée */ if( count($keys) == 1 ) $primary = [ $primary ]; /* [3] Si clé composée =========================================================*/ $defaultWhere = $this->where; /* (1) Pour chaque clé, On vérifie les TYPES */ foreach($keys as $i=>$key){ $inCond = is_array($primary[$i]) && count($primary[$i]) >= 2 && is_array($primary[$i][0]) && $primary[$i][1] == self::COND_IN; /* (1) Si c'est une condition "IN" ---------------------------------------------------------*/ if( $inCond ){ /* (1) On vérifie le type de chaque valeur du IN */ $type = $this->schema['columns'][$key]['type']; foreach($primary[$i][0] as $value){ if( $type == 'int' && !is_numeric($value) ){ $this->where = $defaultWhere; return $this; } if( $type == 'float' && !is_numeric($value) ){ $this->where = $defaultWhere; return $this; } if( in_array($type, ['text', 'varchar']) && !is_string($value) ){ $this->where = $defaultWhere; return $this; } } /* (2) Si c'est une condition "simple" ---------------------------------------------------------*/ }else{ /* (1) Si le type de condition est manquant, on met EQUAL par défaut */ if( !is_array($primary[$i]) ) $primary[$i] = [ $primary[$i], self::COND_EQUAL ]; /* (2) On vérifie le type de chaque valeur */ $type = $this->schema['columns'][$key]['type']; if( $type == 'int' && !is_numeric($primary[$i][0]) ){ $this->where = $defaultWhere; return $this; } if( $type == 'float' && !is_numeric($primary[$i][0]) ){ $this->where = $defaultWhere; return $this; } if( in_array($type, ['text', 'varchar']) && !is_string($primary[$i][0]) ){ $this->where = $defaultWhere; return $this; } } /* (6) Si type OK, on enregistre la condition */ if( !isset($this->where[$key]) ) $this->where[$key] = []; /* (7) On ajoute la condition */ $this->where[$key][] = $primary[$i]; } /* [4] On renvoie l'object courant =========================================================*/ return $this; } /* FILTRAGE DYNAMIQUES * * @method Nom de la méthode * @parameter Valeur du paramètre * @parameter Valeur du paramètre + type de vérification (tableau) * * @return this Retourne l'object courant * */ public function __call($m, $a){ /* [0] On vérifie que la requête est du type 'getBy{Attribute}' =========================================================*/ if( !preg_match('/^where(.+)$/', $m, $regex) ) // si requête incorrecte, on ne fais rien return $this; /* [1] On récupère le nom de la colonne =========================================================*/ $column_name = ''; /* (1) formatte la requête 'MyAttribute' -> 'my_attribute' */ for( $l = 0 ; $l < strlen($regex[1]) ; $l++ ){ $letter = $regex[1][$l]; // Si la lettre est en majuscule mais que c'est pas la première if( strtoupper($letter) == $letter && $l > 0 ) $column_name .= '_'; $column_name .= strtolower($letter); } /* (2) On vérifie que la colonne existe */ if( !isset($this->schema['columns'][$column_name]) ) return $this; // si n'existe pas, on ne fait rien /* [2] On vérifie le type du paramètre =========================================================*/ /* (1) Si aucun param, on quitte */ if( count($a) == 0 ) return $this; /* (2) Si c'est un paramètre seul, on ajoute par défaut self::COND_EQUAL */ if( !is_array($a[0]) ) $a[0] = [ $a[0], self::COND_EQUAL ]; /* (3) Si type INT et pas numérique */ if( $this->schema['columns'][$column_name]['type'] == 'int' && !is_numeric($a[0][0]) ) return $this; /* (4) Si type FLOAT et pas numérique */ if( $this->schema['columns'][$column_name]['type'] == 'float' && !is_numeric($a[0][0]) ) return $this; /* (5) Si type STRING et pas string */ if( $this->schema['columns'][$column_name]['type'] == 'text' && !is_string($a[0][0]) ) return $this; /* [3] Si type OK, on enregistre la condition =========================================================*/ /* (1) Si aucune condition pour ce champ, on crée un tableau */ if( !isset($this->where[$column_name]) ) $this->where[$column_name] = []; /* (2) On ajoute la condition */ $this->where[$column_name][] = $a[0]; // On retourne l'object courant return $this; } /* SELECTIONNE UNIQUEMENT LES CHAMPS SELECTIONNES * * @fields Libellé du champ à afficher * * @return this Retourne l'object courant * */ public function select($fields=[]){ /* [1] On formatte les champs =========================================================*/ /* (1) On met en tableau quoi qu'il en soit */ $fields = is_array($fields) ? $fields : [$fields]; /* (2) On vérifie que chaque champ existe, sinon on le retire */ foreach($fields as $f=>$field) if( !isset($this->schema['columns'][$field]) && $field != '*' ) unset($fields[$f]); /* (3) Permet d'avoir les indices de 0 à count-1 */ sort($fields); /* [2] On enregistre la liste des champs =========================================================*/ foreach($fields as $f=>$field) if( !in_array($field, $this->select) ) // On ajoute si pas déja $this->select[] = $field; /* [3] On retourne l'object courant =========================================================*/ return $this; } /* JOINT UNE SECONDE TABLE () * * @localField Nom d'une colonne locale * @rows Rows d'une autre table * * @return this Retourne l'object courant * */ public function join($localField, $rows){ /* [0] Vérification / Formattage des paramètres =========================================================*/ /* (1) Si le champ n'est pas au bon format */ if( !is_string($localField) ) return $this; /* (2) Si @rows n'est pas au bon format */ if( !($rows instanceof Rows) ) return $this; /* (3) Si le champ n'existe pas dans la table */ if( !isset($this->schema['columns'][$localField]) ) return $this; /* (4) On récupère les données du champ local dans une variable */ $localFieldData = $this->schema['columns'][$localField]; /* [1] On vérifie que la clé étrangère est correcte =========================================================*/ /* (1) Si la colonne n'existe pas et qu'elle n'est pas primaire, on ne fait rien */ if( !isset($localFieldData['references']) && !$localFieldData['primary'] ) return $this; /* (2) On vérifie que la colonne a une référence vers la table de @rows */ $referencesToRows = isset($localFieldData['references']) && $localFieldData['references'][0] == $rows->schema['table']; $rowsField = null; /* (3) On vérifie que la colonne est la référence d'un champ de @rows */ $referencesFromRows = false; // On vérifie chaque champ de @rows foreach($rows->schema['columns'] as $field=>$data) // Si un champ de la table de @rows a pour référence le champ local if( isset($data['references']) && $data['references'][0] == $this->schema['table'] && $data['references'][1] == $localField ){ $referencesFromRows = true; $rowsField = $field; break; } /* (4) On vérifie que la colonne a la même référence qu'une colonne de @rows */ $referencesSameTarget = false; // On vérifie toutes les colonnes de @rows foreach($rows->schema['columns'] as $field=>$data) // Si on trouve un champ avec la même référence if( isset($data['references']) && isset($localFieldData['references']) && count(array_diff($data['references'], $localFieldData['references'])) == 0 ){ $referencesSameTarget = true; $rowsField = $field; // On enregistre le champ qui a la même cible break; } /* (4) Si aucune référence en commun, on ne fait rien */ if( !$referencesToRows && !$referencesFromRows && !$referencesSameTarget ) return $this; /* [2] On enregistre la référence =========================================================*/ $this->joined[$localField] = [ 'object' => $rows, 'field' => is_null($rowsField) ? $localFieldData['references'][1] : $rowsField // On met le nom du champ de @rows à lier ]; /* [3] On retourne l'object courant =========================================================*/ return $this; } /* PERMET DE DIRE QUE L'ON VEUT UN RESULTAT UNIQUE * * @return this Retourne l'object courant * */ public function unique(){ /* [1] On enregistre le choix =========================================================*/ $this->unique = true; /* [2] On retourne l'object courant =========================================================*/ return $this; } /* MODIFIE DES ENTREES (SANS MODIFICATION DE CLE PRIMAIRE POSSIBLE) * * @updates Tableau associatif contenant les nouvelles valeurs * * @return updated Retourne si TRUE/FALSE la modification a bien été faite * */ public function edit($updates){ /* [0] Vérification des paramètres =========================================================*/ /* (1) Si c'est pas un tableau, erreur */ if( !is_array($updates) ) return false; /* (2) On retire les champ inconnus / clés primaires */ $cleared = []; // Pour chaque entrée du tableau foreach($updates as $field=>$value) if( isset($this->schema['columns'][$field]) && !$this->schema['columns'][$field]['primary'] ) // Champ existe et n'est pas clé primaire $cleared[$field] = $value; /* (3) On vérifie les types des champs */ foreach($cleared as $field=>$value){ $type = $this->schema['columns'][$field]['type']; // {1} Si de type INT/FLOAT et pas numérique, on retire le champ // if( in_array($type, ['int', 'float']) && !is_numeric($value) ) unset($cleared[$field]); // {2} Si de type TEXT/VARCHAR et pas string, on retire le champ // if( in_array($type, ['text', 'varchar']) && !is_string($value) ) unset($cleared[$field]); } /* (4) Si on a plus de champ, on retourne l'object courant */ if( count($cleared) == 0 ) return false; /* [1] Rédaction de la clause UPDATE =========================================================*/ /* (1) On initialise la requête */ $requestS = SQLBuilder::UPDATE($this->schema['table'])."\n"; /* [2] Rédaction de la clause SET =========================================================*/ /* (0) On initialise les variables à "binder" */ $binded = []; /* (1) On met tout les champs à modifier */ $requestS .= SQLBuilder::SET($cleared, $binded)."\n"; /* [3] On rédige la clause WHERE/AND =========================================================*/ /* (1) On met les conditions locales */ $c = 0; foreach($this->where as $field=>$conditions) foreach($conditions as $cdt=>$value){ if( $value[1] == self::COND_IN ) // Si condition de type IN $requestS .= SQLBuilder::IN([$this->schema['table'], $field], $value[0], $c, $binded)."\n"; else // Sinon $requestS .= SQLBuilder::WHERE([$this->schema['table'], $field], $value, $c, $binded)."\n"; $c++; } /* (2) On ajoute les jointures */ foreach($this->joined as $localField=>$rows){ if( $c == 0 ) $requestS .= 'WHERE '; else $requestS .= 'AND '; // {1} On inclut la requête de la jointure // $requestS .= $this->schema['table'].'.'.$localField." in (\n\t"; // {2} On récupère la requête // $RowsFetched = $rows[0]->fetch(false); // {3} On ajoute la requête // $requestS .= implode("\n\t", explode("\n", $RowsFetched['request'])); // {4} On bind les params de la requête // $binded = array_merge($binded, $RowsFetched['binded']); // {5} On précise qu'on veut un seul résultat // $requestS .= ")\n"; $c++; } /* [4] Clause LIMIT =========================================================*/ if( $this->unique ) $requestS .= "LIMIT 1"; /* [5] On prépare la requête =========================================================*/ /* (0) On prépare la requête */ $request = Database::getPDO()->prepare($requestS.';'); /* [6] On exécute la requête et retourne le résultat =========================================================*/ /* (1) On exécute la requête */ $updated = $request->execute($binded); /* (2) On retourne l'état de la requête */ return $updated; } /* AJOUTE UNE ENTREE DANS LA TABLE * * @entry Tableau associatif de la forme (colonne => valeur) * OU * @entries Tableau de la forme ([entry1, entry2]) * * @return status Retourne si TRUE ou FALSE les entrées ont bien été supprimées * */ public function insert($entry){ /* [0] On vérifie les paramètres =========================================================*/ /* (1) Si c'est pas un tableau avec au moins une entrée, erreur */ if( !is_array($entry) || count($entry) == 0 ) return false; // S'il n'y a qu'une entrée, on met au même format que s'il y en avait plusieurs $firstIndex = array_keys($entry)[0]; if( !is_array($entry[$firstIndex]) ) $entry = [ $entry ]; /* (2) On retire les champ inconnus */ $cleared = []; // Pour chaque entrée du tableau foreach($entry as $i=>$set){ $cleared[$i] = []; foreach($set as $field=>$value){ if( isset($this->schema['columns'][$field]) ) // Champ existe $cleared[$i][$field] = $value; } } /* (3) On vérifie les types des champs */ foreach($cleared as $i=>$set){ foreach($set as $field=>$value){ $type = $this->schema['columns'][$field]['type']; // {1} Si de type INT/FLOAT et pas numérique, on retire le champ // if( in_array($type, ['int', 'float']) && !is_numeric($value) && $value != self::DEFAULT ) unset($cleared[$i][$field]); // {2} Si de type TEXT/VARCHAR et pas string, on retire le champ // if( in_array($type, ['text', 'varchar']) && !is_string($value) && $value != self::DEFAULT ) unset($cleared[$i][$field]); } /* (4) Si il manque des données, erreur */ if( count($cleared[$i]) != count($this->schema['columns']) ) return false; } /* [1] On crée la requête =========================================================*/ /* (1) Clause INSERT INTO table */ $requestS = 'INSERT INTO '.$this->schema['table']."("; /* (2) Clause : table(col1, col2, ...) */ $c = 0; foreach($this->schema['columns'] as $field=>$value){ if( $c > 0 ) $requestS .= ', '; $requestS .= $field; $c++; } // Fin de clause $requestS .= ")\n"; /* (3) Clause : VALUES(val1, val2, ...) */ $v = 0; foreach($cleared as $i=>$set){ if( $v == 0 ) $requestS .= 'VALUES('; else $requestS .= ",\n\t("; $c = 0; foreach($this->schema['columns'] as $field=>$column){ if( $c > 0 ) $requestS .= ', '; // Si l'entrée est donnée if( isset($set[$field]) ) if( $set[$field] == self::DEFAULT ) $requestS .= 'DEFAULT'; // On insère directement les valeurs 'DEFAULT' else $requestS .= ':insert_'.$field.'_'.$i; else $requestS .= 'DEFAULT'; $c++; } // Fin de clause $requestS .= ")"; $v++; } /* [2] On bind les paramètres et exécute la requête =========================================================*/ /* (0) On initialise la requête et les paramètres */ $request = Database::getPDO()->prepare($requestS.';'); $binded = []; /* (1) On bind les paramètres */ foreach($cleared as $i=>$set) foreach($this->schema['columns'] as $field=>$column) if( isset($set[$field]) && $set[$field] != self::DEFAULT ) $binded[':insert_'.$field.'_'.$i] = $set[$field]; /* [3] On exécute la requête et envoie le status =========================================================*/ $inserted = $request->execute($binded); // On retourne le status return $inserted; } /* SUPPRIME LES ENTREES * * @return status Retourne si TRUE ou FALSE les entrées ont bien été supprimées * */ public function delete(){ /* [0] Initialisation des paramètres =========================================================*/ /* (1) On initialise la requête */ $requestS = []; /* (2) On initialise les paramètres */ $binded = []; /* [1] Clause DELETE FROM =========================================================*/ $requestS['DELETE'] = SQLBuilder::DELETE($this->schema['table']); /* [2] On rédige la clause WHERE/AND =========================================================*/ /* (1) On met les conditions locales */ $c = 0; foreach($this->where as $field=>$conditions) foreach($conditions as $cdt=>$value){ if( $value[1] == self::COND_IN ) // Si condition de type IN $requestS['WHERE'][$c] = SQLBuilder::IN([$this->schema['table'], $field], $value[0], $c, $binded); else // Sinon $requestS['WHERE'][$c] = SQLBuilder::WHERE([$this->schema['table'], $field], $value, $c, $binded); $c++; } /* (2) On ajoute les jointures */ // Note: On ajoute les requêtes des tables de jointures dans la clause WHERE // foreach($this->joined as $field=>$data){ // {1} On récupère la requête/les params de chaque jointure // $joinedFetched = $data['object']->fetch(false); // {2} On met la clé étrangère pour la clause SELECT // $joinedFetched['request']['SELECT'] = [ $data['object']->schema['table'].'.'.$data['field'] ]; // {3} On construit la nouvelle requête // $joinedRequest = SQLBuilder::BUILD($joinedFetched['request']); // {4} On supprime les retours à la ligne // $joinedRequest = str_replace("\n", " ", $joinedRequest); // {5} On l'ajoute à la clause FROM avec comme alias le nom de la table de @data['object'] // $requestS['WHERE'][] = $this->schema['table'].".$field in ($joinedRequest)"; // {6} On ajoute les variables à la requête courante // $binded = array_merge($binded, $joinedFetched['binded']); } /* [3] Clause LIMIT =========================================================*/ $requestS['LIMIT'] = ($this->unique) ? SQLBuilder::LIMIT(1) : SQLBuilder::LIMIT([]); /* [4] On prépare et compose la requête =========================================================*/ /* (1) On compose la requête */ $requestString = SQLBuilder::BUILD($requestS).';'; /* (2) On prépare la requête */ $request = Database::getPDO()->prepare($requestString); /* [5] On exécute la requête et retourne le résultat =========================================================*/ /* (1) On exécute la requête */ $deleted = $request->execute($binded); /* (2) On retourne l'état de la requête */ return $deleted; } /* RETOURNE LES DONNEES / NULL si une erreur survient * * @execute VRAI si on veut exécuter la requête, sinon renvoie [requete, bindedParams] * * @return data Tableau contenant les champs sélectionnés * @return data Valeur du champ sélectionné (si 1 seul champ) * @return ERROR Retourne FALSE si rien n'est trouvé * */ public function fetch($execute=true){ /* [0] On initialise =========================================================*/ /* (1) On initialise la requête */ $requestS = []; /* (2) On initialise le conteneur des variables "bindés" */ $binded = []; /* [1] On rédige la clause SELECT =========================================================*/ /* (1) On formatte les données */ $selectTables = []; /* (2) On ajoute les champs locaux */ $selectTables[$this->schema['table']] = $this->select; /* (3) On ajoute les champs des jointures */ foreach($this->joined as $rows) $selectTables[$rows['object']->schema['table']] = $rows['object']->select; /* (4) On génère la clause SELECT */ $requestS['SELECT'] = SQLBuilder::SELECT($selectTables); /* [2] On rédige la clause FROM ========================================================*/ /* (0) On initialise la clause */ $requestS['FROM'] = []; /* (1) Table locale */ $requestS['FROM'][] = $this->schema['table']; /* (2) On ajoute les tables de jointures */ // Note: On ajoute les tables de jointures dans la clause FROM avec comme alias le nom de la table foreach($this->joined as $field=>$data){ // {1} On récupère la requête/les params de chaque jointure // $joinedFetched = $data['object']->fetch(false); // {2} On met '*' pour la clause SELECT // $joinedFetched['request']['SELECT'] = [ $data['object']->schema['table'].'.*' ]; // {3} On construit la nouvelle requête // $joinedRequest = SQLBuilder::BUILD($joinedFetched['request']); // {4} On supprime les retours à la ligne // $joinedRequest = str_replace("\n", " ", $joinedRequest); // {5} On l'ajoute à la clause FROM avec comme alias le nom de la table de @data['object'] // $requestS['FROM'][] = "($joinedRequest) as ".$data['object']->schema['table']; // {6} On ajoute les variables à la requête courante // $binded = array_merge($binded, $joinedFetched['binded']); } /* [5] On rédige la clause WHERE/AND =========================================================*/ /* (1) On met les conditions locales */ $c = 0; $requestS['WHERE'] = []; foreach($this->where as $field=>$conditions) foreach($conditions as $cdt=>$value){ if( $value[1] === self::COND_IN ) // Si condition IN $requestS['WHERE'][$c] = SQLBuilder::IN([$this->schema['table'], $field], $value[0], $c, $binded); else // Sinon $requestS['WHERE'][$c] = SQLBuilder::WHERE([$this->schema['table'], $field], $value, $c, $binded); $c++; } /* (2) On ajoute les jointures */ foreach($this->joined as $localField=>$data){ $requestS['WHERE'][$c] = $this->schema['table'].".$localField = ".$data['object']->schema['table'].".".$data['field']; $c++; } /* [6] Clause LIMIT =========================================================*/ $requestS['LIMIT'] = ($this->unique) ? SQLBuilder::LIMIT(1) : SQLBuilder::LIMIT([]); /* [7] On compose/prépare la requête =========================================================*/ /* (1) Si on veut pas exécuter on renvoie la requête + bindedParams */ if( !$execute ) return [ 'request' => $requestS, 'binded' => $binded]; /* (2) On compose la requête */ $requestString = SQLBuilder::BUILD($requestS).';'; // var_dump($requestString); // var_dump($binded); // exit(); /* (3) On prépare la requête */ $request = Database::getPDO()->prepare($requestString); /* [8] On exécute la requête et retourne le résultat =========================================================*/ /* (1) On exécute la requête */ $request->execute($binded); /* (2) Si unique */ if( $this->unique ) return $this->format( $request->fetch() ); /* (3) Si tout */ return $this->format( $request->fetchAll() ); } /* ON FORMATTE LES DONNEES DE SORTIE * * @data Données / Tableau de données * * @return formatted Données formattées / Tableau de données formatté * */ private function format($data){ /* [0] On initialise le processus =========================================================*/ /* (0) Initialisation du retour */ $formatted = $data; /* (1) On vérifie qu'il s'agit d'un tableau (non vide) */ if( !is_array($formatted) || count($formatted) < 1 ) return $formatted; /* (2) On regarde si c'est des données simples */ $twoDimensions = is_array($formatted[0]); /* (3) On regarde s'il s'agit d'un Tableau de données en bonne et due forme */ if( $twoDimensions ){ $sameKeys = true; // VRAI si chaque entrée a les mêmes clés $last_keys = null; // Clés de l'entrée précédente foreach($formatted as $i=>$entry){ if( !is_null($last_keys) && count(array_diff(array_keys($entry), $last_keys)) > 0 ){ // Si différent du précédent, ducoup on est pas bon $sameKeys = false; break; } $last_keys = array_keys($entry); } // Si pas les mêmes clés, on a une erreur if( !$sameKeys ) return $formatted; } /* [1] On retire les doublons à indices numériques =========================================================*/ /* (1) Si 1 dimensions, on met en 2 pour traiter tout de la même manière */ if( !$twoDimensions ) $formatted = [$formatted]; /* (2) On retire les indices numériques */ // {1} On récupère les colonnes locales // $existingColumns = $this->schema['columns']; // {2} On ajoute les colonnes des jointures // foreach($this->joined as $j) $existingColumns = array_merge( $existingColumns, $j['object']->schema['columns'] ); // {3} On vérifie chaque clé, si c'est une colonne qui existe // foreach($formatted as $i=>$entry) // Pour chaque champ foreach($entry as $index=>$value) // Si la colonne existe on applique le type if( isset($existingColumns[$index]) ){ if( $existingColumns[$index]['type'] == 'int' ) $formatted[$i][$index] = intval( $value ); else if( $existingColumns[$index]['type'] == 'float' ) $formatted[$i][$index] = floatval( $value ); }else // Si pas dans le schéma, on le retire unset($formatted[$i][$index]); /* (3) On remet 1 dimension si 1 dimension à la base */ if( !$twoDimensions ) $formatted = $formatted[0]; /* [2] On retourne le résultat =========================================================*/ return $formatted; } } ?>