Subversion Repositories Applications.framework

Rev

Rev 426 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

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