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 = []; } /* RETOURNE 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 getById($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 =========================================================*/ if( count($keys) == 1 ){ /* (1) Si type INT et pas numérique */ if( $this->schema['columns'][$keys[0]]['type'] == 'int' && !is_numeric($primary) ) return $this; /* (2) Si type STRING et pas string */ if( $this->schema['columns'][$keys[0]]['type'] == 'text' && !is_string($primary) ) return $this; /* (3) Si type OK, on enregistre la condition */ $this->where[$keys[0]] = $primary; /* [3] Si clé composée =========================================================*/ }else{ $defaultWhere = $this->where; /* (1) Pour chaque clé, On vérifie les TYPES */ foreach($keys as $i=>$key){ /* (2) Si type INT et pas numérique */ if( $this->schema['columns'][$key]['type'] == 'int' && !is_numeric($primary[$i]) ){ $this->where = $defaultWhere; // On réinitialise les données si au moins 1 clé est fausse return $this; } /* (3) Si type STRING et pas string */ if( $this->schema['columns'][$key]['type'] == 'text' && !is_string($primary[$i]) ){ $this->where = $defaultWhere; // On réinitialise les données si au moins 1 clé est fausse return $this; } /* (3) Si type OK, on enregistre la condition */ $this->where[$key] = $primary[$i]; } } /* [4] On renvoie l'object courant =========================================================*/ return $this; } /* GETTERS DYNAMIQUES * * @method Nom de la méthode * @parameters Tableau contenant les paramètres * * @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('/^getBy(.+)$/', $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( !array_key_exists($column_name, $this->schema['columns']) ) 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 type INT et pas numérique */ if( $this->schema['columns'][$column_name]['type'] == 'int' && !is_numeric($a[0]) ) return $this; /* (3) Si type STRING et pas string */ if( $this->schema['columns'][$column_name]['type'] == 'text' && !is_string($a[0]) ) return $this; /* [3] Si type OK, on enregistre la condition =========================================================*/ $this->where[$column_name] = $a[0]; 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( !array_key_exists($field, $this->schema['columns']) ) 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 () * * @field Nom d'une colonne * @rows Rows d'une autre table * * @return this Retourne l'object courant * */ public function join($field, $rows){ /* [0] Vérification des paramètres =========================================================*/ if( !is_string($field) || !($rows instanceof Rows) ) return $this; /* [1] On vérifie que la clé étrangère est correcte =========================================================*/ /* (1) On vérifie que la colonne existe et qu'elle est étrangère*/ if( !isset($this->schema['columns'][$field]['references']) ) return $this; /* (2) On vérifie que la table de @rows est correcte */ if( $this->schema['columns'][$field]['references'][0] != $rows->schema['table'] ) return $this; /* [2] On enregistre la référence =========================================================*/ $this->joined[$field] = $rows; /* [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 * * @updates Tableau associatif contenant les nouvelles valeurs * * @return this Retourne l'objet courant (modifié) * */ public function edit($updates){} /* SUPPRIME LES ENTREES * * @return status Retourne si TRUE ou FALSE les entrées ont bien été supprimées * */ public function delete(){} /* RETOURNE LES DONNEES / NULL si une erreur survient * * @unique VRAI si on veut un seul résultat (itérateur) * * @return data Tableau contenant les champs sélectionnés * @return data Valeur du champ sélectionné (si 1 seul champ) * */ public function fetch($unique=null){ /* [0] Initialisation des paramètres =========================================================*/ $unique = !is_bool($unique) ? $this->unique : $unique; /* [1] On rédige la clause SELECT =========================================================*/ /* (1) On initialise la requête */ $requestS = "SELECT "; /* (2) Si aucun SELECT local, on prend tout */ $c = 0; if( count($this->select) == 0 ){ $requestS .= $this->schema['table'].".*"; $c++; } /* (3) Si aucun SELECT de jointure, on prend tout */ foreach($this->joined as $rows) if( count($rows->select) == 0 ){ if( $c == 0 ) $requestS .= $rows->schema['table'].".*"; else $requestS .= ', '.$rows->schema['table'].".*"; $c++; } /* (5) Sinon, on sélectionne les champs locaux */ foreach($this->select as $field){ if( $c == 0 ) $requestS .= $this->schema['table'].'.'.$field; else $requestS .= ', '.$this->schema['table'].'.'.$field; $c++; } /* (5) Sinon, on sélectionne les champs de jointure */ foreach($this->joined as $rows) foreach($rows->select as $field){ if( $c == 0 ) $requestS .= $rows->schema['table'].'.'.$field; else $requestS .= ', '.$rows->schema['table'].'.'.$field; $c++; } /* [2] On rédige la clause FROM ========================================================*/ /* (1) Table locale */ $requestS .= "\nFROM ".$this->schema['table']; /* (2) Tables de jointure */ foreach($this->joined as $j=>$rows) $requestS .= ", ".$rows->schema['table']; /* (3) Retour à la ligne */ $requestS .= "\n"; /* [5] On rédige la clause WHERE/AND =========================================================*/ /* (1) On met les conditions locales */ $c = 0; foreach($this->where as $field=>$value){ if( $c == 0 ) $requestS .= 'WHERE '.$this->schema['table'].'.'.$field.' = :'.$this->schema['table'].'_x_'.$field."\n"; else $requestS .= 'AND '.$this->schema['table'].'.'.$field.' = :'.$this->schema['table'].'_x_'.$field."\n"; $c++; } /* (2) On ajoute les jointures */ foreach($this->joined as $localField=>$rows){ if( $c == 0 ) $requestS .= 'WHERE '.$this->schema['table'].'.'.$localField.' = '.$this->schema['columns'][$localField]['references'][0].'.'.$this->schema['columns'][$localField]['references'][1]."\n"; else $requestS .= 'AND '.$this->schema['table'].'.'.$localField.' = '.$this->schema['columns'][$localField]['references'][0].'.'.$this->schema['columns'][$localField]['references'][1]."\n"; $c++; } /* (3) On ajoute les conditions des jointures */ foreach($this->joined as $rows) foreach($rows->where as $field=>$value){ if( $c == 0 ) $requestS .= 'WHERE '.$rows->schema['table'].'.'.$field.' = :'.$rows->schema['table'].'_x_'.$field."\n"; else $requestS .= 'AND '.$rows->schema['table'].'.'.$field.' = :'.$rows->schema['table'].'_x_'.$field."\n"; $c++; } /* [6] On exécute la requête et 'bind' les paramètres =========================================================*/ /* (0) On prépare la requête */ $request = Database::getPDO()->prepare($requestS); $binded = []; /* (1) On bind tous les paramètres locaux */ foreach($this->where as $field=>$value) $binded[':'.$this->schema['table'].'_x_'.$field] = $value; /* (3) On bind tous les paramètres des jointures */ foreach($this->joined as $rows) foreach($rows->where as $field=>$value) $binded[':'.$rows->schema['table'].'_x_'.$field] = $value; /* [6] 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( $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 */ // Pour chaque entrée foreach($formatted as $i=>$entry) // Pour chaque champ foreach($entry as $index=>$value) // Si dans le schéma on applique le type if( array_key_exists($index, $this->schema['columns']) ){ if( $this->schema['columns'][$index]['type'] == 'int' ) $formatted[$i][$index] = intval( $value ); else if( $this->schema['columns'][$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; } } ?>