Subversion Repositories Applications.framework

Rev

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