Subversion Repositories Applications.framework

Compare Revisions

Ignore whitespace Rev 218 → Rev 219

/trunk/framework/Modele.php
1,74 → 1,81
<?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.
* Classe modèle, 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 diverses possibilités
* d'abstraction de base de données (PDO, mysql, mysqli, SQLite3).
* Les valeurs pour le paramètre 'bdd_abstraction' du fichier config.ini sont : pdo, mysql, mysqli, sqlite3
* Elle est abstraite et doit donc obligatoirement être étendue.
*
* PHP Version 5
* @category php 5.2
* @package Framework
* @author Aurélien PERONNET <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$
* @link /doc/framework/
*
* @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$$
* @link /doc/framework/
*
*/
abstract class Modele {
 
/**
* Mode de fetch associatif
*/
/** Constante stockant le squelette du message en cas d'erreur de requête sql. */
const ERREUR_REQUETE_TPL = 'Requête echec.\nFichier : %s.\nLigne : %s.\nMessage : %s.\nRequête : %s';
/** Constante stockant le squelette du message en cas d'erreur de connexion à la base de données. */
const ERREUR_CONNEXION_TPL = 'Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration.\nMessage : %S.';
/** Constante stockant le squelette du message en cas d'erreur de sélection de la base de données. */
const ERREUR_CONNEXION_TPL = 'Erreur de sélection de la base de données, vérifiez les paramètres du fichier de configuration.\nMessage : %S.';
/** Constante stockant le code pour l'abstraction de PDO. */
const ABSTRACTION_PDO = 'pdo';
/** Constante stockant le code pour l'abstraction de mysql. */
const ABSTRACTION_MYSQL = 'mysql';
/** Constante stockant le code pour l'abstraction de mysqli. */
const ABSTRACTION_MYSQLI = 'mysqli';
/** Constante stockant le code pour l'abstraction de SQLite3. */
const ABSTRACTION_SQLITE3 = 'sqlite3';
/** Constante stockant le code pour le mode tableau associatif des résultats des requêtes. */
const MODE_ASSOC = 'ASSOC';
/** Constante stockant le code pour le mode objet des résultats des requêtes. */
const MODE_OBJET = 'OBJECT';
/** Mode de fetch associatif */
private $ASSOC = '';
/**
* Mode de fetch objet
*/
/** Mode de fetch objet */
private $OBJECT = '';
 
/**
* abstraction de base de données utilisée
*/
/** abstraction de base de données utilisée */
private $abstraction;
/**
* registre global
*/
private $registre;
/**
* DSN pour accéder à la base de données
*/
/** DSN pour accéder à la base de données */
private $dsn;
/**
* Type de base de données (mysql, mysqli, etc ...)
*/
/** Type de base de données (mysql, mysqli, etc ...) */
private $type;
/**
* Hote herbergeant la base de données
*/
/** Hote herbergeant la base de données */
private $hote;
/**
* Nom de la base de données à laquelle le modèle doit se connecter
*/
/** Nom de la base de données à laquelle le modèle doit se connecter */
private $bdd_nom;
/**
* Nom d'utilisateur
*/
/** Nom d'utilisateur */
private $utilisateur;
/**
* Mot de passe
*/
/** Mot de passe */
private $pass;
 
/**
* Encodage de la base de données
*/
/** Encodage de la base de données */
private $encodage = null;
/**
* Connexion à la base de données
*/
/** Connexion à la base de données */
private $connexion = null;
 
/**
75,8 → 82,6
* 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');
98,36 → 103,42
*/
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);
case self::ABSTRACTION_PDO :
try {
$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
} catch (PDOException $e) {
$e = sprintf(self::ERREUR_CONNEXION_TPL, $e->getMessage());
trigger_error($e, E_USER_WARNING);
}
break;
case self::ABSTRACTION_MYSQL :
$this->connexion = mysql_connect($this->hote, $this->utilisateur, $this->pass);
if ($this->connexion !== false) {
$selection = mysql_select_db($this->bdd_nom, $this->connexion);
if ($selection === false) {
$e = sprintf(self::ERREUR_SELECTION_BDD_TPL, mysql_error());
trigger_error($e, E_USER_WARNING);
}
} else {
throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');
$e = sprintf(self::ERREUR_CONNEXION_TPL, mysql_error());
trigger_error($e, E_USER_WARNING);
}
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 self::ABSTRACTION_MYSQLI :
$this->connexion = @new mysqli($this->hote, $this->utilisateur, $this->pass, $this->bdd_nom);
if ($this->connexion->connect_errno) {
$e = sprintf(self::ERREUR_CONNEXION_TPL, $this->connexion->connect_error);
trigger_error($e, E_USER_WARNING);
}
break;
 
case 'sqlite3':
break;
case self::ABSTRACTION_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;
$e = sprintf(self::ERREUR_CONNEXION_TPL, '');
trigger_error($e, E_USER_WARNING);
}
break;
 
break;
default:
$this->connexion = null;
}
144,33 → 155,34
* @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);
case self::ABSTRACTION_PDO :
try {
$retour = $this->connexion->query($requete);
} catch (PDOException $e) {
$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
trigger_error($m, E_USER_WARNING);
}
break;
case 'mysql':
$retour = mysql_query($requete,$this->connexion);
case self::ABSTRACTION_MYSQL :
$retour = mysql_query($requete, $this->connexion);
break;
case 'mysqli':
case self::ABSTRACTION_MYSQLI :
$retour = $this->connexion->query($requete);
break;
case 'sqlite3':
case self::ABSTRACTION_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)
final protected function requeteUn($requete, $mode = self::MODE_ASSOC) {
if ($this->connexion == null) {
$this->connecter();
}
177,26 → 189,26
 
$retour = null;
switch ($this->abstraction) {
case 'pdo':
case self::ABSTRACTION_PDO :
try {
$res_req = $this->connexion->query($requete);
$retour =$res_req->fetch($this->$mode);
} 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);
$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
trigger_error($m, E_USER_WARNING);
}
break;
case 'mysql':
case self::ABSTRACTION_MYSQL :
$res = mysql_query($requete,$this->connexion);
$fonction_fetch = $this->$mode;
$retour = $fonction_fetch($res);
break;
case 'mysqli':
case self::ABSTRACTION_MYSQLI :
$res = $this->connexion->query($requete);
$fonction_fetch = $this->$mode;
$retour = $res->$fonction_fetch();
break;
case 'sqlite3':
case self::ABSTRACTION_SQLITE3 :
$retour = $this->connexion->querySingle($requete);
break;
}
205,8 → 217,7
}
 
 
final protected function requeteTous($requete,$mode = 'ASSOC') {
// Connexion seulement lors du premier appel à une requete (lazy connexion)
final protected function requeteTous($requete, $mode = self::MODE_ASSOC) {
if ($this->connexion == null) {
$this->connecter();
}
214,7 → 225,7
$retour = null;
 
switch ($this->abstraction) {
case 'pdo':
case self::ABSTRACTION_PDO :
try {
$res_req = $this->connexion->query($requete);
if ($res_req !== false) {
223,11 → 234,11
$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);
$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
trigger_error($m, E_USER_WARNING);
}
break;
case 'mysql':
case self::ABSTRACTION_MYSQL :
$res = mysql_query($requete, $this->connexion);
$fonction_fetch = $this->$mode;
while ($ligne = $fonction_fetch($res)) {
234,7 → 245,7
$retour[] = $ligne;
}
break;
case 'mysqli':
case self::ABSTRACTION_MYSQLI :
$res = $this->connexion->query($requete);
$function_fetch = $this->$mode;
while ($ligne = $res->$function_fetch()) {
241,20 → 252,18
$retour[] = $ligne;
}
break;
case 'sqlite3':
case self::ABSTRACTION_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
if ($mode == self::MODE_OBJET) {
// 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;
$ligne = $ligneObjet;
}
$retour[] = $ligne;
}
break;
}
263,11 → 272,9
}
 
/**
* protège une chaine de caractères avant l'insertion dans la base de données
* 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 requete
if ($this->connexion == null) {
$this->connecter();
}
275,16 → 282,16
$retour = $chaine;
 
switch ($this->abstraction) {
case 'pdo':
case self::ABSTRACTION_PDO :
$retour = $this->connexion->quote($chaine);
break;
case 'mysql':
case self::ABSTRACTION_MYSQL :
$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';
break;
case 'mysqli':
case self::ABSTRACTION_MYSQLI :
$retour = '"'.$this->connexion->real_escape_string($chaine).'"';
break;
case 'sqlite3':
case self::ABSTRACTION_SQLITE3 :
$retour = $this->connexion->escapeString($chaine);
break;
}
293,50 → 300,47
}
 
/**
* initialise les constantes de classe à leur bonne valeur
* et lance une exception si le protocole n'est pas bien défini
* @throws Exception
* Initialise les constantes de classe à leur bonne valeur et déclenche une erreur si le protocole n'est pas bien défini.
*/
final public function initialiserProtocole() {
 
switch ($this->abstraction) {
case 'pdo':
case self::ABSTRACTION_PDO :
$this->ASSOC = PDO::FETCH_ASSOC;
$this->OBJECT = PDO::FETCH_CLASS;
break;
case 'mysql':
case self::ABSTRACTION_MYSQL :
$this->ASSOC = 'mysql_fetch_assoc';
$this->OBJECT = 'mysql_fetch_object';
break;
case 'mysqli':
case self::ABSTRACTION_MYSQLI :
$this->ASSOC = 'fetch_assoc';
$this->OBJECT = 'fetch_object';
break;
case 'sqlite3':
case self::ABSTRACTION_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;
$m = "Erreur : l'abstraction '{$this->abstraction}' n'est pas prise en charge";
trigger_error($m, E_USER_WARNING);
}
}
 
/**
* Destructeur de classe, se contente de fermer explicitement la connexion
* Destructeur de classe, se contente de fermer explicitement la connexion à la base de donnée.
*/
final public function __destruct() {
switch ($this->abstraction) {
case 'pdo':
case self::ABSTRACTION_PDO :
$this->connexion = null;
break;
case 'mysql':
case self::ABSTRACTION_MYSQL :
return mysql_close($this->connexion);
break;
case 'mysqli':
case self::ABSTRACTION_MYSQLI :
$this->connexion->close();
break;
case 'sqlite3':
case self::ABSTRACTION_SQLITE3 :
$this->connexion->close();
break;
}