Subversion Repositories Applications.framework

Rev

Rev 123 | Rev 140 | Go to most recent revision | Show entire file | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 123 Rev 133
Line 1... Line 1...
1 
<?php
 1 
<?php
2 
// declare(encoding='UTF-8');
 2 
// declare(encoding='UTF-8');
3 
/**
 3 
/**
4 
* Classe modèle, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.
 4 
* Classe modèle, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.
5 
* Elle fait office d'abstraction légère de base de données en utilisant les objects PDO natifs
 5 
* Elle fait office d'abstraction légère de base de données en utilisant diveres possibilités
6 
* de PHP
 6 
* d'abstraction de base de données (PDO, mysql, mysqli, sqlite)
7 
* Elle est abstraite donc doit obligatoirement être étendue.
 7 
* Elle est abstraite donc doit obligatoirement être étendue.
8 
*
 8 
*
9 
* PHP Version 5
 9 
* PHP Version 5
10 
*
 10 
*
11 
* @category  Class
 11 
* @category  Class
12 
* @package   Framework
 12 
* @package   Framework
13 
* @author	aurelien <aurelien@tela-botanica.org>
 13 
* @author	aurelien <aurelien@tela-botanica.org>
14 
* @copyright 2009 Tela-Botanica
 14 
* @copyright 2009 Tela-Botanica
15 
* @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
 15 
* @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
16 
* @license   http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
 16 
* @license   http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
17 
* @version   SVN: $$Id: Modele.php 123 2009-09-01 15:33:34Z aurelien $$
 17 
* @version   SVN: $$Id: Modele.php 133 2009-11-30 12:44:11Z aurelien $$
18 
* @link	  /doc/framework/
 18 
* @link	  /doc/framework/
19 
*
 19 
*
20 
*/
 20 
*/
21 
abstract class Modele {
 21 
abstract class Modele {
Line 22... Line 22...
22 
 
 22 
 
- 
 
 23 
	/**
- 
 
 24 
	 * Mode de fetch associatif
- 
 
 25 
	 */
- 
 
 26 
	private $ASSOC = '';
- 
 
 27 
	/**
- 
 
 28 
	 * Mode de fetch objet
- 
 
 29 
	 */
- 
 
 30 
	private $OBJECT = '';
- 
 
 31 
 
- 
 
 32 
	/**
- 
 
 33 
	 * abstraction de base de données utilisée
- 
 
 34 
	 */
- 
 
 35 
	private $abstraction;
23 
	/**
 36 
	/**
24 
	 * registre global
 37 
	 * registre global
25 
	 */
 38 
	 */
26 
	private $registre;
 39 
	private $registre;
27 
	/**
 40 
	/**
Line 62... Line 75...
62 
	 * Constructeur par défaut, appelé à l'initialisation.
 75 
	 * Constructeur par défaut, appelé à l'initialisation.
63 
	 */
 76 
	 */
64 
	final public function __construct() {
 77 
	final public function __construct() {
65 
		// les différents paramètres nécessaires sont lus à partir du registre
 78 
		// les différents paramètres nécessaires sont lus à partir du registre
66 
		$this->registre = Registre::getInstance();
 79 
		$this->registre = Registre::getInstance();
- 
 
 80 
		$this->abstraction = strtolower(Config::get('bdd_abstraction'));
67 
		$this->type = Config::get('bdd_protocole');
 81 
		$this->type = Config::get('bdd_protocole');
68 
		$this->hote = Config::get('bdd_serveur');
 82 
		$this->hote = Config::get('bdd_serveur');
69 
		$this->bdd_nom = Config::get('bdd_nom');
 83 
		$this->bdd_nom = Config::get('bdd_nom');
70 
		$this->utilisateur = Config::get('bdd_utilisateur');
 84 
		$this->utilisateur = Config::get('bdd_utilisateur');
71 
		$this->pass = Config::get('bdd_mot_de_passe');
 85 
		$this->pass = Config::get('bdd_mot_de_passe');
72 
		$this->encodage = Config::get('bdd_encodage');
 86 
		$this->encodage = Config::get('bdd_encodage');
Line 73... Line 87...
73 
 
 87 
 
- 
 
 88 
		$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
- 
 
 89 
		$this->initialiserProtocole();
- 
 
 90 
	}
- 
 
 91 
 
- 
 
 92 
	/**
- 
 
 93 
	 * Connection à la base de données en utilisant les informations fournies par
- 
 
 94 
	 * le fichier de configuration.
- 
 
 95 
	 * private et final car n'a pas vocation a être appelée par l'utilisateur.
- 
 
 96 
	 *
- 
 
 97 
	 * @throws Exception une exception dans le cas ou là connexion échoue
- 
 
 98 
	 */
- 
 
 99 
	final private function connecter() {
- 
 
 100 
 
- 
 
 101 
		switch ($this->abstraction) {
- 
 
 102 
			case 'pdo':
- 
 
 103 
				$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
- 
 
 104 
			break;
- 
 
 105 
 
- 
 
 106 
			case 'mysql':
- 
 
 107 
				$this->connexion = mysql_connect($this->hote,$this->utilisateur,$this->pass);
- 
 
 108 
				if($this->connexion != null) {
- 
 
 109 
					mysql_select_db($this->bdd_nom, $this->connexion);
- 
 
 110 
				} else {
- 
 
 111 
					throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');
- 
 
 112 
				}
- 
 
 113 
			break;
- 
 
 114 
 
- 
 
 115 
			case 'mysqli':
- 
 
 116 
				$this->connexion = new mysqli($this->hote,$this->utilisateur,$this->pass, $this->bdd_nom);
- 
 
 117 
				if(!$this->connexion) {
- 
 
 118 
					throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');
- 
 
 119 
					return;
- 
 
 120 
				}
- 
 
 121 
			break;
- 
 
 122 
 
- 
 
 123 
			case 'sqlite3':
- 
 
 124 
				// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir
- 
 
 125 
				$this->connexion = new SQLite3($this->bdd_nom);
- 
 
 126 
				if(!$this->connexion) {
- 
 
 127 
					throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');
- 
 
 128 
					return;
- 
 
 129 
				}
- 
 
 130 
			break;
- 
 
 131 
 
- 
 
 132 
			default:
- 
 
 133 
				$this->connexion = null;
- 
 
 134 
		}
- 
 
 135 
 
- 
 
 136 
		if($this->encodage != null) {
- 
 
 137 
			$this->requete("SET names '".$this->encodage."'");
74 
		$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
 138 
		}
Line 75... Line 139...
75 
	}
 139 
	}
76 
 
 140 
 
77 
	/**
 141 
	/**
Line 83... Line 147...
83 
	final protected function requete($requete) {
 147 
	final protected function requete($requete) {
84 
		// on ne se connecte que lors du premier appel à une requete (lazy connexion)
 148 
		// on ne se connecte que lors du premier appel à une requete (lazy connexion)
85 
		if ($this->connexion == null) {
 149 
		if ($this->connexion == null) {
86 
			$this->connecter();
 150 
			$this->connecter();
87 
		}
 151 
		}
- 
 
 152 
 
- 
 
 153 
		$retour = null;
- 
 
 154 
 
- 
 
 155 
		switch ($this->abstraction) {
- 
 
 156 
			case 'pdo':
88 
		return $this->connexion->query($requete);
 157 
				$retour = $this->connexion->query($requete);
- 
 
 158 
			break;
- 
 
 159 
 
- 
 
 160 
			case 'mysql':
- 
 
 161 
				$retour = mysql_query($requete,$this->connexion);
- 
 
 162 
			break;
- 
 
 163 
 
- 
 
 164 
			case 'mysqli':
- 
 
 165 
				$retour = $this->connexion->query($requete);
- 
 
 166 
			break;
- 
 
 167 
 
- 
 
 168 
			case 'sqlite3':
- 
 
 169 
				$retour = $this->connexion->exec($requete);
- 
 
 170 
			break;
- 
 
 171 
		}
- 
 
 172 
 
- 
 
 173 
		return $retour;
89 
	}
 174 
	}
Line -... Line 175...
- 
 
 175 
 
90 
 
 176 
	final protected function requeteUn($requete,$mode = 'ASSOC') {
91 
	/**
 177 
 
92 
	 * Connection à la base de données en utilisant les informations fournies par
 178 
		// on ne se connecte que lors du premier appel à une requete (lazy connexion)
93 
	 * le fichier de configuration.
 179 
		if ($this->connexion == null) {
94 
	 * private et final car n'a pas vocation a être appelée par l'utilisateur.
 180 
			$this->connecter();
95 
	 *
 - 
 
96 
	 * @throws PDOException une exception dans le cas ou là connexion échoue
 - 
 
97 
	 */
 - 
 
Line -... Line 181...
- 
 
 181 
		}
- 
 
 182 
 
- 
 
 183 
		$retour = null;
- 
 
 184 
 
- 
 
 185 
		switch ($this->abstraction) {
- 
 
 186 
			case 'pdo':
- 
 
 187 
				$res_req = $this->connexion->query($requete);
- 
 
 188 
				$retour =$res_req->fetch($this->$mode);
- 
 
 189 
			break;
- 
 
 190 
 
- 
 
 191 
			case 'mysql':
- 
 
 192 
				$res = mysql_query($requete,$this->connexion);
- 
 
 193 
				$fonction_fetch = $this->$mode;
- 
 
 194 
				$retour = $fonction_fetch($res);
- 
 
 195 
			break;
- 
 
 196 
 
- 
 
 197 
			case 'mysqli':
- 
 
 198 
				$res = $this->connexion->query($requete);
- 
 
 199 
				$fonction_fetch = $this->$mode;
- 
 
 200 
				$retour = $res->$fonction_fetch();
- 
 
 201 
			break;
98 
	final private function connecter() {
 202 
 
- 
 
 203 
			case 'sqlite3':
- 
 
 204 
				$retour = $this->connexion->querySingle($requete);
- 
 
 205 
			break;
- 
 
 206 
		}
- 
 
 207 
 
- 
 
 208 
		return $retour;
- 
 
 209 
	}
- 
 
 210 
 
- 
 
 211 
 
- 
 
 212 
	final protected function requeteTous($requete,$mode = 'ASSOC') {
99 
 
 213 
 
- 
 
 214 
		// on ne se connecte que lors du premier appel à une requete (lazy connexion)
- 
 
 215 
		if ($this->connexion == null) {
- 
 
 216 
			$this->connecter();
- 
 
 217 
		}
- 
 
 218 
 
- 
 
 219 
		$retour = null;
- 
 
 220 
 
- 
 
 221 
		switch ($this->abstraction) {
- 
 
 222 
			case 'pdo':
- 
 
 223 
				$res_req = $this->connexion->query($requete);
- 
 
 224 
				$retour =$res_req->fetchAll($this->$mode);
- 
 
 225 
			break;
100 
			$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
 226 
 
- 
 
 227 
			case 'mysql':
- 
 
 228 
				$res = mysql_query($requete,$this->connexion);
- 
 
 229 
				$fonction_fetch = $this->$mode;
- 
 
 230 
				while($ligne = $fonction_fetch($res)) {
- 
 
 231 
					$retour[] = $ligne;
- 
 
 232 
				}
- 
 
 233 
			break;
- 
 
 234 
 
- 
 
 235 
			case 'mysqli':
- 
 
 236 
				$res = $this->connexion->query($requete);
- 
 
 237 
				$function_fetch = $this->$mode;
- 
 
 238 
				while($ligne = $res->$function_fetch()) {
- 
 
 239 
					$retour[] = $ligne;
- 
 
 240 
				}
- 
 
 241 
			break;
- 
 
 242 
 
- 
 
 243 
			case 'sqlite3':
- 
 
 244 
				$res = $this->connexion->query($requete);
- 
 
 245 
				while($ligne = $res->fetch_array($this->ASSOC)) {
- 
 
 246 
					if($mode == $this->ASSOC) {
- 
 
 247 
						$retour[] = $ligne;
- 
 
 248 
					}
- 
 
 249 
					elseif($mode == $this->OBJECT){
- 
 
 250 
						// cas particulier de sqllite
- 
 
 251 
						// qui n'a pas de fonction fetch_object
- 
 
 252 
						$ligneObjet = new stdClass();
- 
 
 253 
						foreach($ligne as $colonne => $valeur) {
- 
 
 254 
							$ligneObjet->$colonne = $valeur;
- 
 
 255 
						}
101 
			if($this->encodage != null) {
 256 
						$retour [] = $ligneObjet;
- 
 
 257 
					}
- 
 
 258 
				}
- 
 
 259 
			break;
- 
 
 260 
 
- 
 
 261 
		}
102 
				$this->requete("SET names '".$this->encodage."'");
 262 
 
Line 103... Line 263...
103 
			}
 263 
		return $retour;
104 
	}
 264 
	}
105 
 
 265 
 
106 
	/**
 266 
	/**
- 
 
 267 
	 * protège une chaine de caractères avant l'insertion dans la base de données
107 
	 * protège une chaine de caractères avant l'insertion dans la base de données
 268 
	 */
108 
	 */
 269 
	final protected function proteger($chaine) {
109 
	final protected function proteger($chaine) {
 270 
 
110 
		// on ne se connecte que lors du premier appel à une requete
 271 
		// on ne se connecte que lors du premier appel à une requete
- 
 
 272 
		if ($this->connexion == null) {
- 
 
 273 
			$this->connecter();
- 
 
 274 
		}
- 
 
 275 
 
- 
 
 276 
		$retour = $chaine;
111 
		if ($this->connexion == null) {
 277 
 
- 
 
 278 
		switch ($this->abstraction) {
- 
 
 279 
			case 'pdo':
- 
 
 280 
				$retour = $this->connexion->quote($chaine);
- 
 
 281 
			break;
- 
 
 282 
 
- 
 
 283 
			case 'mysql':
- 
 
 284 
				$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';
- 
 
 285 
			break;
- 
 
 286 
 
- 
 
 287 
			case 'mysqli':
- 
 
 288 
				$retour = '"'.$this->connexion->real_escape_string($chaine).'"';
- 
 
 289 
			break;
- 
 
 290 
 
- 
 
 291 
			case 'sqlite3':
- 
 
 292 
				$retour = $this->connexion->escapeString($chaine);
- 
 
 293 
			break;
- 
 
 294 
		}
- 
 
 295 
 
- 
 
 296 
		return $retour;
- 
 
 297 
	}
- 
 
 298 
 
- 
 
 299 
	/**
- 
 
 300 
	 * initialise les constantes de classe à leur bonne valeur
- 
 
 301 
	 * et lance une exception si le protocole n'est pas bien défini
- 
 
 302 
	 * @throws Exception
- 
 
 303 
	 */
- 
 
 304 
	final public function initialiserProtocole() {
- 
 
 305 
 
- 
 
 306 
		switch ($this->abstraction) {
- 
 
 307 
			case 'pdo':
- 
 
 308 
				$this->ASSOC = PDO::FETCH_ASSOC;
- 
 
 309 
				$this->OBJECT = PDO::FETCH_CLASS;
- 
 
 310 
			break;
- 
 
 311 
 
- 
 
 312 
			case 'mysql':
- 
 
 313 
				$this->ASSOC = 'mysql_fetch_assoc';
- 
 
 314 
				$this->OBJECT = 'mysql_fetch_object';
- 
 
 315 
			break;
- 
 
 316 
 
- 
 
 317 
			case 'mysqli':
- 
 
 318 
				$this->ASSOC = 'fetch_assoc';
- 
 
 319 
				$this->OBJECT = 'fetch_object';
- 
 
 320 
			break;
- 
 
 321 
 
- 
 
 322 
			case 'sqlite3':
- 
 
 323 
				$this->ASSOC = 'SQLITE3_ASSOC';
- 
 
 324 
				$this->OBJECT = 'SQLITE3_OBJECT';
- 
 
 325 
			break;
- 
 
 326 
 
- 
 
 327 
			default:
112 
			$this->connecter();
 328 
				throw new Exception('Erreur : l\'abstraction '.$this->abstraction.' n\'est pas prise en charge');
Line 113... Line 329...
113 
		}
 329 
			break;
114 
		return $this->connexion->quote($chaine);
 330 
		}
115 
	}
 331 
	}
116 
 
 332 
 
- 
 
 333 
	/**
- 
 
 334 
	 * Destructeur de classe, se contente de fermer explicitement la connexion
117 
	/**
 335 
	 */
- 
 
 336 
	final public function __destruct() {
- 
 
 337 
		switch ($this->abstraction) {
- 
 
 338 
			case 'pdo':
- 
 
 339 
				$this->connexion = null;
- 
 
 340 
			break;
- 
 
 341 
 
- 
 
 342 
			case 'mysql':
- 
 
 343 
				return mysql_close($this->connexion);
- 
 
 344 
			break;
- 
 
 345 
 
- 
 
 346 
			case 'mysqli':
118 
	 * Destructeur de classe, se contente de fermer explicitement la connexion
 347 
				$this->connexion->close();
- 
 
 348 
			break;
119 
	 */
 349 
 
120 
	final public function __destruct() {
 350 
			case 'sqlite3':
121 
		if ($this->connexion != null) {
 351 
				$this->connexion->close();
122 
			$this->connexion = null ;
 352 
			break;
123 
		}
 353 
		}