Subversion Repositories Applications.framework

Rev

Details | 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 
*
105 aurelien 11 
* @category  Class
12 
* @package   Framework
120 aurelien 13 
* @author	aurelien <aurelien@tela-botanica.org>
105 aurelien 14 
* @copyright 2009 Tela-Botanica
120 aurelien 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
17 
* @version   SVN: $$Id: Modele.php 133 2009-11-30 12:44:11Z aurelien $$
18 
* @link	  /doc/framework/
19 
*
105 aurelien 20 
*/
5 aurelien 21 
abstract class Modele {
22 
 
23 
	/**
133 aurelien 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;
36 
	/**
5 aurelien 37 
	 * registre global
38 
	 */
39 
	private $registre;
40 
	/**
105 aurelien 41 
	 * DSN pour accéder à la base de données
5 aurelien 42 
	 */
43 
	private $dsn;
44 
	/**
105 aurelien 45 
	 * Type de base de données (mysql, mysqli, etc ...)
5 aurelien 46 
	 */
47 
	private $type;
48 
	/**
105 aurelien 49 
	 * Hote herbergeant la base de données
5 aurelien 50 
	 */
51 
	private $hote;
52 
	/**
105 aurelien 53 
	 * Nom de la base de données à laquelle le modèle doit se connecter
5 aurelien 54 
	 */
55 
	private $bdd_nom;
56 
	/**
57 
	 * Nom d'utilisateur
58 
	 */
59 
	private $utilisateur;
60 
	/**
61 
	 * Mot de passe
62 
	 */
63 
	private $pass;
120 aurelien 64 
 
5 aurelien 65 
	/**
120 aurelien 66 
	 * Encodage de la base de données
67 
	 */
68 
	 private $encodage = null;
69 
	/**
105 aurelien 70 
	 * Connexion à la base de données
5 aurelien 71 
	 */
72 
	private $connexion = null;
73 
 
74 
	/**
105 aurelien 75 
	 * Constructeur par défaut, appelé à l'initialisation.
5 aurelien 76 
	 */
120 aurelien 77 
	final public function __construct() {
78 
		// les différents paramètres nécessaires sont lus à partir du registre
79 
		$this->registre = Registre::getInstance();
133 aurelien 80 
		$this->abstraction = strtolower(Config::get('bdd_abstraction'));
120 aurelien 81 
		$this->type = Config::get('bdd_protocole');
82 
		$this->hote = Config::get('bdd_serveur');
83 
		$this->bdd_nom = Config::get('bdd_nom');
84 
		$this->utilisateur = Config::get('bdd_utilisateur');
85 
		$this->pass = Config::get('bdd_mot_de_passe');
86 
		$this->encodage = Config::get('bdd_encodage');
87 
 
88 
		$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
133 aurelien 89 
		$this->initialiserProtocole();
120 aurelien 90 
	}
91 
 
92 
	/**
133 aurelien 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."'");
138 
		}
139 
	}
140 
 
141 
	/**
120 aurelien 142 
	 * Fonction qui appelle la bonne fonction de requete suivant le type de bdd.
143 
	 *
144 
	 * @param string la requete à effectuer
145 
	 * @return PDOStatement un objet contenant le résultat de la requête
146 
	 */
147 
	final protected function requete($requete) {
148 
		// on ne se connecte que lors du premier appel à une requete (lazy connexion)
149 
		if ($this->connexion == null) {
150 
			$this->connecter();
151 
		}
133 aurelien 152 
 
153 
		$retour = null;
154 
 
155 
		switch ($this->abstraction) {
156 
			case 'pdo':
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;
120 aurelien 174 
	}
175 
 
133 aurelien 176 
	final protected function requeteUn($requete,$mode = 'ASSOC') {
120 aurelien 177 
 
133 aurelien 178 
		// on ne se connecte que lors du premier appel à une requete (lazy connexion)
179 
		if ($this->connexion == null) {
180 
			$this->connecter();
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;
202 
 
203 
			case 'sqlite3':
204 
				$retour = $this->connexion->querySingle($requete);
205 
			break;
206 
		}
207 
 
208 
		return $retour;
120 aurelien 209 
	}
210 
 
133 aurelien 211 
 
212 
	final protected function requeteTous($requete,$mode = 'ASSOC') {
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;
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 
						}
256 
						$retour [] = $ligneObjet;
257 
					}
258 
				}
259 
			break;
260 
 
261 
		}
262 
 
263 
		return $retour;
264 
	}
265 
 
120 aurelien 266 
	/**
267 
	 * protège une chaine de caractères avant l'insertion dans la base de données
268 
	 */
269 
	final protected function proteger($chaine) {
133 aurelien 270 
 
120 aurelien 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 
 
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;
120 aurelien 297 
	}
298 
 
299 
	/**
133 aurelien 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:
328 
				throw new Exception('Erreur : l\'abstraction '.$this->abstraction.' n\'est pas prise en charge');
329 
			break;
330 
		}
331 
	}
332 
 
333 
	/**
120 aurelien 334 
	 * Destructeur de classe, se contente de fermer explicitement la connexion
335 
	 */
336 
	final public function __destruct() {
133 aurelien 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':
347 
				$this->connexion->close();
348 
			break;
349 
 
350 
			case 'sqlite3':
351 
				$this->connexion->close();
352 
			break;
120 aurelien 353 
		}
354 
	}
5 aurelien 355 
}
356 
?>