Rev 143 | Blame | Last modification | View Log | RSS feed
<?php// declare(encoding='UTF-8');/*** Classe modèle, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.* Elle fait office d'abstraction légère de base de données en utilisant diveres possibilités* d'abstraction de base de données (PDO, mysql, mysqli, sqlite)* Elle est abstraite donc doit obligatoirement être étendue.** PHP Version 5** @category Class* @package Framework* @author aurelien <aurelien@tela-botanica.org>* @copyright 2009 Tela-Botanica* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL* @version SVN: $$Id: Modele.php 145 2010-03-02 17:23:09Z jpm $$* @link /doc/framework/**/abstract class Modele {/*** Mode de fetch associatif*/private $ASSOC = '';/*** Mode de fetch objet*/private $OBJECT = '';/*** abstraction de base de données utilisée*/private $abstraction;/*** registre global*/private $registre;/*** DSN pour accéder à la base de données*/private $dsn;/*** Type de base de données (mysql, mysqli, etc ...)*/private $type;/*** Hote herbergeant la base de données*/private $hote;/*** Nom de la base de données à laquelle le modèle doit se connecter*/private $bdd_nom;/*** Nom d'utilisateur*/private $utilisateur;/*** Mot de passe*/private $pass;/*** Encodage de la base de données*/private $encodage = null;/*** Connexion à la base de données*/private $connexion = null;/*** Constructeur par défaut, appelé à l'initialisation.*/public function __construct() {// les différents paramètres nécessaires sont lus à partir du registre$this->registre = Registre::getInstance();$this->abstraction = strtolower(Config::get('bdd_abstraction'));$this->type = Config::get('bdd_protocole');$this->hote = Config::get('bdd_serveur');$this->bdd_nom = Config::get('bdd_nom');$this->utilisateur = Config::get('bdd_utilisateur');$this->pass = Config::get('bdd_mot_de_passe');$this->encodage = Config::get('bdd_encodage');$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;$this->initialiserProtocole();}/*** Connection à la base de données en utilisant les informations fournies par* le fichier de configuration.* private et final car n'a pas vocation a être appelée par l'utilisateur.** @throws Exception une exception dans le cas ou là connexion échoue*/final private function connecter() {switch ($this->abstraction) {case 'pdo':$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);break;case 'mysql':$this->connexion = mysql_connect($this->hote,$this->utilisateur,$this->pass);if ($this->connexion != null) {mysql_select_db($this->bdd_nom, $this->connexion);} else {throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');}break;case 'mysqli':$this->connexion = new mysqli($this->hote,$this->utilisateur,$this->pass, $this->bdd_nom);if (!$this->connexion) {throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');return;}break;case 'sqlite3':// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir$this->connexion = new SQLite3($this->bdd_nom);if (!$this->connexion) {throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');return;}break;default:$this->connexion = null;}if ($this->encodage != null) {$this->requete("SET names '".$this->encodage."'");}}/*** Fonction qui appelle la bonne fonction pour executer une requête suivant le type de bdd.** @param string la requete à effectuer* @return PDOStatement un objet contenant le résultat de la requête*/final protected function requete($requete) {// on ne se connecte que lors du premier appel à une requete (lazy connexion)if ($this->connexion == null) {$this->connecter();}$retour = null;switch ($this->abstraction) {case 'pdo':$retour = $this->connexion->query($requete);break;case 'mysql':$retour = mysql_query($requete,$this->connexion);break;case 'mysqli':$retour = $this->connexion->query($requete);break;case 'sqlite3':$retour = $this->connexion->exec($requete);break;}return $retour;}final protected function requeteUn($requete,$mode = 'ASSOC') {// Connection seulement lors du premier appel à une requete (lazy connexion)if ($this->connexion == null) {$this->connecter();}$retour = null;switch ($this->abstraction) {case 'pdo':$res_req = $this->connexion->query($requete);$retour =$res_req->fetch($this->$mode);break;case 'mysql':$res = mysql_query($requete,$this->connexion);$fonction_fetch = $this->$mode;$retour = $fonction_fetch($res);break;case 'mysqli':$res = $this->connexion->query($requete);$fonction_fetch = $this->$mode;$retour = $res->$fonction_fetch();break;case 'sqlite3':$retour = $this->connexion->querySingle($requete);break;}return $retour;}final protected function requeteTous($requete,$mode = 'ASSOC') {// Connexion seulement lors du premier appel à une requete (lazy connexion)if ($this->connexion == null) {$this->connecter();}$retour = null;switch ($this->abstraction) {case 'pdo':try {$res_req = $this->connexion->query($requete);if ($res_req !== false) {$retour = $res_req->fetchAll($this->$mode);} else {$retour = false;}} catch (PDOException $e) {$message = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s';trigger_error(sprintf($message, $e->getFile(), $e->getLine(), $e->getMessage()), E_USER_WARNING);}break;case 'mysql':$res = mysql_query($requete, $this->connexion);$fonction_fetch = $this->$mode;while ($ligne = $fonction_fetch($res)) {$retour[] = $ligne;}break;case 'mysqli':$res = $this->connexion->query($requete);$function_fetch = $this->$mode;while ($ligne = $res->$function_fetch()) {$retour[] = $ligne;}break;case 'sqlite3':$res = $this->connexion->query($requete);while ($ligne = $res->fetch_array($this->ASSOC)) {if ($mode == $this->ASSOC) {$retour[] = $ligne;} elseif ($mode == $this->OBJECT) {// cas particulier de sqllite// qui n'a pas de fonction fetch_object$ligneObjet = new stdClass();foreach ($ligne as $colonne => $valeur) {$ligneObjet->$colonne = $valeur;}$retour[] = $ligneObjet;}}break;}return $retour;}/*** protège une chaine de caractères avant l'insertion dans la base de données*/final protected function proteger($chaine) {// on ne se connecte que lors du premier appel à une requeteif ($this->connexion == null) {$this->connecter();}$retour = $chaine;switch ($this->abstraction) {case 'pdo':$retour = $this->connexion->quote($chaine);break;case 'mysql':$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';break;case 'mysqli':$retour = '"'.$this->connexion->real_escape_string($chaine).'"';break;case 'sqlite3':$retour = $this->connexion->escapeString($chaine);break;}return $retour;}/*** initialise les constantes de classe à leur bonne valeur* et lance une exception si le protocole n'est pas bien défini* @throws Exception*/final public function initialiserProtocole() {switch ($this->abstraction) {case 'pdo':$this->ASSOC = PDO::FETCH_ASSOC;$this->OBJECT = PDO::FETCH_CLASS;break;case 'mysql':$this->ASSOC = 'mysql_fetch_assoc';$this->OBJECT = 'mysql_fetch_object';break;case 'mysqli':$this->ASSOC = 'fetch_assoc';$this->OBJECT = 'fetch_object';break;case 'sqlite3':$this->ASSOC = 'SQLITE3_ASSOC';$this->OBJECT = 'SQLITE3_OBJECT';break;default:throw new Exception('Erreur : l\'abstraction '.$this->abstraction.' n\'est pas prise en charge');break;}}/*** Destructeur de classe, se contente de fermer explicitement la connexion*/final public function __destruct() {switch ($this->abstraction) {case 'pdo':$this->connexion = null;break;case 'mysql':return mysql_close($this->connexion);break;case 'mysqli':$this->connexion->close();break;case 'sqlite3':$this->connexion->close();break;}}}?>