Subversion Repositories Applications.framework

Rev

Rev 355 | Rev 406 | Go to most recent revision | Only display areas with differences | Regard whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 355 Rev 401
1
<?php
1
<?php
2
// declare(encoding='UTF-8');
2
// declare(encoding='UTF-8');
3
/**
3
/**
4
 * Classe Bdd, d'accés au base de données.
4
 * Classe Bdd, d'accés au base de données.
5
 * Elle fait office d'abstraction légère de base de données en utilisant diverses possibilités d'accès aux 
5
 * Elle fait office d'abstraction légère de base de données en utilisant diverses possibilités d'accès aux
6
 * bases de données (PDO, mysql, mysqli, SQLite3).
6
 * bases de données (PDO, mysql, mysqli, SQLite3).
7
 * Les valeurs pour le paramètre 'bdd_abstraction' du fichier config.ini sont : pdo, mysql, mysqli, sqlite3
7
 * Les valeurs pour le paramètre 'bdd_abstraction' du fichier config.ini sont : pdo, mysql, mysqli, sqlite3
8
 * Vous pouvez aussi utiliser : "php:Bdd::ABSTRACTION_PDO","php:Bdd::ABSTRACTION_MYSQL", "php:Bdd::ABSTRACTION_MYSQLI",
8
 * Vous pouvez aussi utiliser : "php:Bdd::ABSTRACTION_PDO","php:Bdd::ABSTRACTION_MYSQL", "php:Bdd::ABSTRACTION_MYSQLI",
9
 * "php:Bdd::ABSTRACTION_SQLITE3".
9
 * "php:Bdd::ABSTRACTION_SQLITE3".
10
 * Elle peut être étendue, pour ajouter le support d'autres bases de données où prendre en compte des méthodes spécifique à
10
 * Elle peut être étendue, pour ajouter le support d'autres bases de données où prendre en compte des méthodes spécifique à
11
 * un type d'abstraction.
11
 * un type d'abstraction.
12
 *
12
 *
13
 * @category	php 5.2
13
 * @category	php 5.2
14
 * @package	Framework
14
 * @package	Framework
15
 * @author		Aurélien PERONNET <aurelien@tela-botanica.org>
15
 * @author		Aurélien PERONNET <aurelien@tela-botanica.org>
16
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
16
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
17
 * @copyright	Copyright (c) 2010, Tela Botanica (accueil@tela-botanica.org)
17
 * @copyright	Copyright (c) 2010, Tela Botanica (accueil@tela-botanica.org)
18
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
18
 * @license	http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
19
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
19
 * @license	http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
20
 * @version	$Id: Bdd.php 355 2011-08-08 13:31:31Z jpm $
20
 * @version	$Id: Bdd.php 401 2011-12-29 10:44:38Z jpm $
21
 * @link		/doc/framework/
21
 * @link		/doc/framework/
22
 */
22
 */
23
class Bdd {
23
class Bdd {
24
	/** Constante stockant le squelette du message en cas d'erreur de requête sql. */
24
	/** Constante stockant le squelette du message en cas d'erreur de requête sql. */
25
	const ERREUR_REQUETE_TPL = 'Requête echec.\nFichier : %s.\nLigne : %s.\nMessage : %s.\nRequête : %s';
25
	const ERREUR_REQUETE_TPL = 'Requête echec.\nFichier : %s.\nLigne : %s.\nMessage : %s.\nRequête : %s';
26
	
26
 
27
	/** Constante stockant le squelette du message en cas d'erreur de connexion à la base de données. */
27
	/** Constante stockant le squelette du message en cas d'erreur de connexion à la base de données. */
28
	const ERREUR_CONNEXION_TPL = 'Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration.\nMessage : %S.';
28
	const ERREUR_CONNEXION_TPL = 'Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration.\nMessage : %S.';
29
	
29
 
30
	/** Constante stockant le squelette du message en cas d'erreur de sélection de la base de données. */
30
	/** Constante stockant le squelette du message en cas d'erreur de sélection de la base de données. */
31
	const ERREUR_SELECTION_BDD_TPL = 'Erreur de sélection de la base de données, vérifiez les paramètres du fichier de configuration.\nMessage : %S.';
31
	const ERREUR_SELECTION_BDD_TPL = 'Erreur de sélection de la base de données, vérifiez les paramètres du fichier de configuration.\nMessage : %S.';
32
	
32
 
33
	/** Constante stockant le code pour l'abstraction de PDO. */
33
	/** Constante stockant le code pour l'abstraction de PDO. */
34
	const ABSTRACTION_PDO = 'pdo';
34
	const ABSTRACTION_PDO = 'pdo';
35
	
35
 
36
	/** Constante stockant le code pour l'abstraction de mysql. */
36
	/** Constante stockant le code pour l'abstraction de mysql. */
37
	const ABSTRACTION_MYSQL = 'mysql';
37
	const ABSTRACTION_MYSQL = 'mysql';
38
	
38
 
39
	/** Constante stockant le code pour l'abstraction de mysqli. */
39
	/** Constante stockant le code pour l'abstraction de mysqli. */
40
	const ABSTRACTION_MYSQLI = 'mysqli';
40
	const ABSTRACTION_MYSQLI = 'mysqli';
41
	
41
 
42
	/** Constante stockant le code pour l'abstraction de SQLite3. */
42
	/** Constante stockant le code pour l'abstraction de SQLite3. */
43
	const ABSTRACTION_SQLITE3 = 'sqlite3';
43
	const ABSTRACTION_SQLITE3 = 'sqlite3';
44
	
44
 
45
	/** Constante stockant le code pour le mode tableau associatif des résultats des requêtes. */
45
	/** Constante stockant le code pour le mode tableau associatif des résultats des requêtes. */
46
	const MODE_ASSOC = 'ASSOC';
46
	const MODE_ASSOC = 'ASSOC';
47
	
47
 
48
	/** Constante stockant le code pour le mode objet des résultats des requêtes. */
48
	/** Constante stockant le code pour le mode objet des résultats des requêtes. */
49
	const MODE_OBJET = 'OBJECT';
49
	const MODE_OBJET = 'OBJECT';
50
	
50
 
51
	/** Mode de fetch associatif */
51
	/** Mode de fetch associatif */
52
	protected $ASSOC = '';
52
	protected $ASSOC = '';
53
	
53
 
54
	/** Mode de fetch objet */
54
	/** Mode de fetch objet */
55
	protected $OBJECT = '';
55
	protected $OBJECT = '';
56
 
56
 
57
	/** abstraction de base de données utilisée */
57
	/** abstraction de base de données utilisée */
58
	protected $abstraction;
58
	protected $abstraction;
59
	
59
 
60
	/** DSN pour accéder à la base de données */
60
	/** DSN pour accéder à la base de données */
61
	protected $dsn;
61
	protected $dsn;
62
	
62
 
63
	/** Type de base de données (mysql, mysqli, etc ...) */
63
	/** Type de base de données (mysql, mysqli, etc ...) */
64
	protected $type;
64
	protected $type;
65
	
65
 
66
	/** Hote herbergeant la base de données */
66
	/** Hote herbergeant la base de données */
67
	protected $hote;
67
	protected $hote;
68
	
68
 
69
	/** Nom de la base de données à laquelle le modèle doit se connecter */
69
	/** Nom de la base de données à laquelle le modèle doit se connecter */
70
	protected $bdd_nom;
70
	protected $bdd_nom;
71
	
71
 
72
	/** Nom d'utilisateur */
72
	/** Nom d'utilisateur */
73
	protected $utilisateur;
73
	protected $utilisateur;
74
	
74
 
75
	/** Mot de passe */
75
	/** Mot de passe */
76
	protected $pass;
76
	protected $pass;
77
 
77
 
78
	/** Encodage de la base de données */
78
	/** Encodage de la base de données */
79
	protected $encodage = null;
79
	protected $encodage = null;
80
	
80
 
81
	/** Connexion à la base de données */
81
	/** Connexion à la base de données */
82
	protected $connexion = null;
82
	protected $connexion = null;
83
 
83
 
84
	/** Tableau des noms des paramètres à définir dans le fichier de config car obligatoirement nécessaire à cette classe.*/
84
	/** Tableau des noms des paramètres à définir dans le fichier de config car obligatoirement nécessaire à cette classe.*/
85
	protected $parametres_obligatoires = array('bdd_abstraction', 'bdd_protocole', 'bdd_serveur', 'bdd_nom', 
85
	protected $parametres_obligatoires = array('bdd_abstraction', 'bdd_protocole', 'bdd_serveur', 'bdd_nom',
86
		'bdd_utilisateur', 'bdd_mot_de_passe', 'bdd_encodage');
86
		'bdd_utilisateur', 'bdd_mot_de_passe', 'bdd_encodage');
87
	
87
 
88
	/** Constructeur par défaut, appelé à l'initialisation. */
88
	/** Constructeur par défaut, appelé à l'initialisation. */
89
	public function __construct() {
89
	public function __construct() {
90
		Config::verifierPresenceParametres($this->parametres_obligatoires);
90
		Config::verifierPresenceParametres($this->parametres_obligatoires);
91
		$this->abstraction = strtolower(Config::get('bdd_abstraction'));
91
		$this->abstraction = strtolower(Config::get('bdd_abstraction'));
92
		$this->type = Config::get('bdd_protocole');
92
		$this->type = Config::get('bdd_protocole');
93
		$this->hote = Config::get('bdd_serveur');
93
		$this->hote = Config::get('bdd_serveur');
94
		$this->bdd_nom = Config::get('bdd_nom');
94
		$this->bdd_nom = Config::get('bdd_nom');
95
		$this->utilisateur = Config::get('bdd_utilisateur');
95
		$this->utilisateur = Config::get('bdd_utilisateur');
96
		$this->pass = Config::get('bdd_mot_de_passe');
96
		$this->pass = Config::get('bdd_mot_de_passe');
97
		$this->encodage = Config::get('bdd_encodage');
97
		$this->encodage = Config::get('bdd_encodage');
-
 
98
 
-
 
99
		if ($this->type == 'sqlite' || $this->type == 'sqlite2') {
-
 
100
			$this->dsn = $this->type.':'.$this->hote;
98
 
101
		} else {
-
 
102
			$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
99
		$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
103
		}
100
		$this->initialiserProtocole();
104
		$this->initialiserProtocole();
101
	}
105
	}
102
 
106
 
103
	/** Initialise les constantes de classe à leur bonne valeur et déclenche une erreur si le protocole n'est pas bien défini. */
107
	/** Initialise les constantes de classe à leur bonne valeur et déclenche une erreur si le protocole n'est pas bien défini. */
104
	protected function initialiserProtocole() {
108
	protected function initialiserProtocole() {
105
		switch ($this->abstraction) {
109
		switch ($this->abstraction) {
106
			case self::ABSTRACTION_PDO :
110
			case self::ABSTRACTION_PDO :
107
				$this->ASSOC = PDO::FETCH_ASSOC;
111
				$this->ASSOC = PDO::FETCH_ASSOC;
108
				$this->OBJECT = PDO::FETCH_CLASS;
112
				$this->OBJECT = PDO::FETCH_CLASS;
109
				break;
113
				break;
110
			case self::ABSTRACTION_MYSQL :
114
			case self::ABSTRACTION_MYSQL :
111
				$this->ASSOC = 'mysql_fetch_assoc';
115
				$this->ASSOC = 'mysql_fetch_assoc';
112
				$this->OBJECT = 'mysql_fetch_object';
116
				$this->OBJECT = 'mysql_fetch_object';
113
				break;
117
				break;
114
			case self::ABSTRACTION_MYSQLI :
118
			case self::ABSTRACTION_MYSQLI :
115
				$this->ASSOC = 'fetch_assoc';
119
				$this->ASSOC = 'fetch_assoc';
116
				$this->OBJECT = 'fetch_object';
120
				$this->OBJECT = 'fetch_object';
117
				break;
121
				break;
118
			case self::ABSTRACTION_SQLITE3 :
122
			case self::ABSTRACTION_SQLITE3 :
119
				$this->ASSOC = 'SQLITE3_ASSOC';
123
				$this->ASSOC = 'SQLITE3_ASSOC';
120
				$this->OBJECT = 'SQLITE3_OBJECT';
124
				$this->OBJECT = 'SQLITE3_OBJECT';
121
				break;
125
				break;
122
			default:
126
			default:
123
				$m = "Erreur : l'abstraction '{$this->abstraction}' n'est pas prise en charge";
127
				$m = "Erreur : l'abstraction '{$this->abstraction}' n'est pas prise en charge";
124
				trigger_error($m, E_USER_WARNING);
128
				trigger_error($m, E_USER_WARNING);
125
		}
129
		}
126
	}
130
	}
127
	
131
 
128
	/**
132
	/**
129
	 * Connection à la base de données en utilisant les informations fournies par
133
	 * Connection à la base de données en utilisant les informations fournies par
130
	 * le fichier de configuration.
134
	 * le fichier de configuration.
131
	 * Cette méthode est private et final car elle n'a pas vocation a être appelée par l'utilisateur.
135
	 * Cette méthode est private et final car elle n'a pas vocation a être appelée par l'utilisateur.
132
	 */
136
	 */
133
	protected function connecter() {
137
	protected function connecter() {
134
		if ($this->connexion == null) {
138
		if ($this->connexion == null) {
135
			switch ($this->abstraction) {
139
			switch ($this->abstraction) {
136
				case self::ABSTRACTION_PDO :
140
				case self::ABSTRACTION_PDO :
137
					try {
141
					try {
138
						$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
142
						$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
139
						$this->connexion->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
143
						$this->connexion->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
140
					} catch (PDOException $e) {
144
					} catch (PDOException $e) {
141
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $e->getMessage());
145
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $e->getMessage());
142
						trigger_error($e, E_USER_WARNING);
146
						trigger_error($e, E_USER_WARNING);
143
					}
147
					}
-
 
148
					if ($this->encodage != null && $this->type == 'mysql') {
-
 
149
						$this->requeter("SET names '".$this->encodage."'");
-
 
150
					} else if ($this->type == 'sqlite') {
-
 
151
						$this->requeter("PRAGMA case_sensitive_like = false");
-
 
152
					}
144
					break;
153
					break;
145
				case self::ABSTRACTION_MYSQL :
154
				case self::ABSTRACTION_MYSQL :
146
					$this->connexion = mysql_connect($this->hote, $this->utilisateur, $this->pass);
155
					$this->connexion = mysql_connect($this->hote, $this->utilisateur, $this->pass);
147
					if ($this->connexion !== false) {
156
					if ($this->connexion !== false) {
148
						$selection = mysql_select_db($this->bdd_nom, $this->connexion);
157
						$selection = mysql_select_db($this->bdd_nom, $this->connexion);
149
						if ($selection === false) {
158
						if ($selection === false) {
150
							$e = sprintf(self::ERREUR_SELECTION_BDD_TPL, mysql_error());
159
							$e = sprintf(self::ERREUR_SELECTION_BDD_TPL, mysql_error());
151
							trigger_error($e, E_USER_WARNING);
160
							trigger_error($e, E_USER_WARNING);
152
						}
161
						}
153
					} else {
162
					} else {
154
						$e = sprintf(self::ERREUR_CONNEXION_TPL, mysql_error());
163
						$e = sprintf(self::ERREUR_CONNEXION_TPL, mysql_error());
155
						trigger_error($e, E_USER_WARNING);
164
						trigger_error($e, E_USER_WARNING);
156
					}
165
					}
-
 
166
					if ($this->encodage != null) {
-
 
167
						$this->requeter("SET names '".$this->encodage."'");
-
 
168
					}
157
					break;
169
					break;
158
				case self::ABSTRACTION_MYSQLI :
170
				case self::ABSTRACTION_MYSQLI :
159
					$this->connexion = @new mysqli($this->hote, $this->utilisateur, $this->pass, $this->bdd_nom);
171
					$this->connexion = @new mysqli($this->hote, $this->utilisateur, $this->pass, $this->bdd_nom);
160
					if ($this->connexion->connect_errno) {
172
					if ($this->connexion->connect_errno) {
161
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $this->connexion->connect_error);
173
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $this->connexion->connect_error);
162
						trigger_error($e, E_USER_WARNING);
174
						trigger_error($e, E_USER_WARNING);
163
					}
175
					}
-
 
176
					if ($this->encodage != null) {
-
 
177
						$this->requeter("SET names '".$this->encodage."'");
-
 
178
					}
164
					break;
179
					break;
165
				case self::ABSTRACTION_SQLITE3 :
180
				case self::ABSTRACTION_SQLITE3 :
166
					// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir
181
					// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir
167
					$this->connexion = new SQLite3($this->bdd_nom);
182
					$this->connexion = new SQLite3($this->bdd_nom);
168
					if (!$this->connexion) {
183
					if (!$this->connexion) {
169
						$e = sprintf(self::ERREUR_CONNEXION_TPL, '');
184
						$e = sprintf(self::ERREUR_CONNEXION_TPL, '');
170
						trigger_error($e, E_USER_WARNING);
185
						trigger_error($e, E_USER_WARNING);
171
					}
186
					}
-
 
187
					$this->requeter("PRAGMA case_sensitive_like = false");
172
					break;
188
					break;
173
				default:
189
				default:
174
					$this->connexion = null;
190
					$this->connexion = null;
175
			}
191
			}
176
	
192
 
177
			if ($this->encodage != null) {
193
			if ($this->encodage != null) {
178
				$this->requete("SET names '".$this->encodage."'");
194
				$this->requete("SET names '".$this->encodage."'");
179
			}
195
			}
180
		}
196
		}
181
	}
197
	}
182
	
198
 
183
	/**
199
	/**
184
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see requeter
200
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see requeter
185
	 */
201
	 */
186
	final protected function requete($requete) {
202
	final protected function requete($requete) {
187
		return $this->requeter($requete);
203
		return $this->requeter($requete);
188
	}
204
	}
189
	
205
 
190
	/**
206
	/**
191
	 * Execute une requête et retourne le résultat tel que renvoyé par l'abstraction courante.
207
	 * Execute une requête et retourne le résultat tel que renvoyé par l'abstraction courante.
192
	 *
208
	 *
193
	 * @param string la requête à effectuer
209
	 * @param string la requête à effectuer
194
	 * @return mixed un objet contenant le résultat de la requête
210
	 * @return mixed un objet contenant le résultat de la requête
195
	 */
211
	 */
196
	public function requeter($requete) {
212
	public function requeter($requete) {
197
		$this->connecter();
213
		$this->connecter();
198
 
214
 
199
		$retour = null;
215
		$retour = null;
200
		switch ($this->abstraction) {
216
		switch ($this->abstraction) {
201
			case self::ABSTRACTION_PDO :
217
			case self::ABSTRACTION_PDO :
202
				try {
218
				try {
203
					$retour = $this->connexion->query($requete);
219
					$retour = $this->connexion->query($requete);
204
				} catch (PDOException $e) {
220
				} catch (PDOException $e) {
205
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
221
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
206
					trigger_error($m, E_USER_WARNING);
222
					trigger_error($m, E_USER_WARNING);
207
				}
223
				}
208
				break;
224
				break;
209
			case self::ABSTRACTION_MYSQL :
225
			case self::ABSTRACTION_MYSQL :
210
				$retour = mysql_query($requete, $this->connexion);
226
				$retour = mysql_query($requete, $this->connexion);
211
				break;
227
				break;
212
			case self::ABSTRACTION_MYSQLI :
228
			case self::ABSTRACTION_MYSQLI :
213
				$retour = $this->connexion->query($requete);
229
				$retour = $this->connexion->query($requete);
214
				break;
230
				break;
215
			case self::ABSTRACTION_SQLITE3 :
231
			case self::ABSTRACTION_SQLITE3 :
216
				$retour = $this->connexion->exec($requete);
232
				$retour = $this->connexion->exec($requete);
217
				break;
233
				break;
218
		}
234
		}
219
		return $retour;
235
		return $retour;
220
	}
236
	}
221
	
237
 
222
	/**
238
	/**
223
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see recuperer
239
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see recuperer
224
	 */
240
	 */
225
	final protected function requeteUn($requete, $mode = self::MODE_ASSOC) {
241
	final protected function requeteUn($requete, $mode = self::MODE_ASSOC) {
226
		return $this->recuperer($requete, $mode);
242
		return $this->recuperer($requete, $mode);
227
	}
243
	}
228
	
244
 
229
	/**
245
	/**
230
	 * Execute une requête et retourne le premier résultat sous forme de tableau (par défaut) ou d'objet.
246
	 * Execute une requête et retourne le premier résultat sous forme de tableau (par défaut) ou d'objet.
231
	 * Les noms des champs de la base de données correspondent aux noms des clés du tableau ou aux noms des attributs de l'objet.
247
	 * Les noms des champs de la base de données correspondent aux noms des clés du tableau ou aux noms des attributs de l'objet.
232
	 *
248
	 *
233
	 * @param string la requête à effectuer
249
	 * @param string la requête à effectuer
234
	 * @param string le mode de retour ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
250
	 * @param string le mode de retour ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
235
	 * @return mixed un objet ou un tableau contenant le résultat de la requête
251
	 * @return mixed un objet ou un tableau contenant le résultat de la requête
236
	 */
252
	 */
237
	public function recuperer($requete, $mode = self::MODE_ASSOC) {
253
	public function recuperer($requete, $mode = self::MODE_ASSOC) {
238
		$this->connecter();
254
		$this->connecter();
239
 
255
 
240
		$retour = null;
256
		$retour = null;
241
		switch ($this->abstraction) {
257
		switch ($this->abstraction) {
242
			case self::ABSTRACTION_PDO :
258
			case self::ABSTRACTION_PDO :
243
				try {
259
				try {
244
					$resultat = $this->connexion->query($requete);
260
					$resultat = $this->connexion->query($requete);
245
					$retour = ($resultat !== false) ? $resultat->fetch($this->$mode) : $resultat;
261
					$retour = ($resultat !== false) ? $resultat->fetch($this->$mode) : $resultat;
246
				} catch (PDOException $e) {
262
				} catch (PDOException $e) {
247
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
263
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
248
					trigger_error($m, E_USER_WARNING);
264
					trigger_error($m, E_USER_WARNING);
249
				}
265
				}
250
				break;
266
				break;
251
			case self::ABSTRACTION_MYSQL :
267
			case self::ABSTRACTION_MYSQL :
252
				$res = mysql_query($requete, $this->connexion);
268
				$res = mysql_query($requete, $this->connexion);
253
				$fonction_fetch = $this->$mode;
269
				$fonction_fetch = $this->$mode;
254
				$retour = $fonction_fetch($res);
270
				$retour = $fonction_fetch($res);
255
				break;
271
				break;
256
			case self::ABSTRACTION_MYSQLI :
272
			case self::ABSTRACTION_MYSQLI :
257
				$res = $this->connexion->query($requete);
273
				$res = $this->connexion->query($requete);
258
				$fonction_fetch = $this->$mode;
274
				$fonction_fetch = $this->$mode;
259
				$retour = $res->$fonction_fetch();
275
				$retour = $res->$fonction_fetch();
260
				break;
276
				break;
261
			case self::ABSTRACTION_SQLITE3 :
277
			case self::ABSTRACTION_SQLITE3 :
262
				$retour = $this->connexion->querySingle($requete);
278
				$retour = $this->connexion->querySingle($requete);
263
				break;
279
				break;
264
		}
280
		}
265
		return $retour;
281
		return $retour;
266
	}
282
	}
267
	
283
 
268
	/**
284
	/**
269
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see recupererTous
285
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see recupererTous
270
	 */
286
	 */
271
	final protected function requeteTous($requete, $mode = self::MODE_ASSOC) {
287
	final protected function requeteTous($requete, $mode = self::MODE_ASSOC) {
272
		return $this->recupererTous($requete, $mode);
288
		return $this->recupererTous($requete, $mode);
273
	}
289
	}
274
	
290
 
275
	/**
291
	/**
276
	 * Execute une requête et retourne un tableau de résultats. Un résultat peut être présentés sous forme 
292
	 * Execute une requête et retourne un tableau de résultats. Un résultat peut être présentés sous forme
277
	 * de tableau (par défaut) ou d'objet.
293
	 * de tableau (par défaut) ou d'objet.
278
	 * Les noms des champs de la base de données correspondent aux noms des clés du tableau résultat ou 
294
	 * Les noms des champs de la base de données correspondent aux noms des clés du tableau résultat ou
279
	 * aux noms des attributs de l'objet résultat.
295
	 * aux noms des attributs de l'objet résultat.
280
	 *
296
	 *
281
	 * @param string la requête à effectuer
297
	 * @param string la requête à effectuer
282
	 * @param string le mode de retour des résultats : ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
298
	 * @param string le mode de retour des résultats : ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
283
	 * @return array un tableau contenant les résultats sous forme d'objets ou de tableau (par défaut).
299
	 * @return array un tableau contenant les résultats sous forme d'objets ou de tableau (par défaut).
284
	 */
300
	 */
285
	public function recupererTous($requete, $mode = self::MODE_ASSOC) {
301
	public function recupererTous($requete, $mode = self::MODE_ASSOC) {
286
		$this->connecter();
302
		$this->connecter();
287
		
303
 
288
		$retour = null;
304
		$retour = null;
289
		switch ($this->abstraction) {
305
		switch ($this->abstraction) {
290
			case self::ABSTRACTION_PDO :
306
			case self::ABSTRACTION_PDO :
291
				try {
307
				try {
292
					$resultat = $this->connexion->query($requete);
308
					$resultat = $this->connexion->query($requete);
293
					$retour = ($resultat !== false) ? $resultat->fetchAll($this->$mode) : $resultat;
309
					$retour = ($resultat !== false) ? $resultat->fetchAll($this->$mode) : $resultat;
294
				} catch (PDOException $e) {
310
				} catch (PDOException $e) {
295
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
311
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
296
					trigger_error($m, E_USER_WARNING);
312
					trigger_error($m, E_USER_WARNING);
297
				}
313
				}
298
				break;
314
				break;
299
			case self::ABSTRACTION_MYSQL :
315
			case self::ABSTRACTION_MYSQL :
300
				$resultat = mysql_query($requete, $this->connexion);
316
				$resultat = mysql_query($requete, $this->connexion);
301
				$fonction_fetch = $this->$mode;
317
				$fonction_fetch = $this->$mode;
302
				while ($ligne = $fonction_fetch($resultat)) {
318
				while ($ligne = $fonction_fetch($resultat)) {
303
					$retour[] = $ligne;
319
					$retour[] = $ligne;
304
				}
320
				}
305
				break;
321
				break;
306
			case self::ABSTRACTION_MYSQLI :
322
			case self::ABSTRACTION_MYSQLI :
307
				$resultat = $this->connexion->query($requete);
323
				$resultat = $this->connexion->query($requete);
308
				$function_fetch = $this->$mode;
324
				$function_fetch = $this->$mode;
309
				while ($ligne = $resultat->$function_fetch()) {
325
				while ($ligne = $resultat->$function_fetch()) {
310
					$retour[] = $ligne;
326
					$retour[] = $ligne;
311
				}
327
				}
312
				break;
328
				break;
313
			case self::ABSTRACTION_SQLITE3 :
329
			case self::ABSTRACTION_SQLITE3 :
314
				$resultat = $this->connexion->query($requete);
330
				$resultat = $this->connexion->query($requete);
315
				while ($ligne = $resultat->fetch_array($this->ASSOC)) {
331
				while ($ligne = $resultat->fetch_array($this->ASSOC)) {
316
					if ($mode == self::MODE_OBJET) {
332
					if ($mode == self::MODE_OBJET) {
317
						// Cas particulier de sqllite qui n'a pas de fonction fetch_object
333
						// Cas particulier de sqllite qui n'a pas de fonction fetch_object
318
						$ligneObjet = new stdClass();
334
						$ligneObjet = new stdClass();
319
						foreach ($ligne as $colonne => $valeur) {
335
						foreach ($ligne as $colonne => $valeur) {
320
							$ligneObjet->$colonne = $valeur;
336
							$ligneObjet->$colonne = $valeur;
321
						}
337
						}
322
						$ligne = $ligneObjet;
338
						$ligne = $ligneObjet;
323
					}
339
					}
324
					$retour[] = $ligne;
340
					$retour[] = $ligne;
325
				}
341
				}
326
				break;
342
				break;
327
		}
343
		}
328
		return $retour;
344
		return $retour;
329
	}
345
	}
330
 
346
 
331
	/**
347
	/**
332
	 * Protège une chaine de caractères avant l'insertion dans la base de données (ajout de quotes ou guillemets).
348
	 * Protège une chaine de caractères avant l'insertion dans la base de données (ajout de quotes ou guillemets).
333
	 * @param string la chaine à protéger
349
	 * @param string la chaine à protéger
334
	 * @return string la chaine protégée
350
	 * @return string la chaine protégée
335
	 */
351
	 */
336
	public function proteger($chaine) {
352
	public function proteger($chaine) {
337
		$this->connecter();
353
		$this->connecter();
338
 
354
 
339
		$retour = $chaine;
355
		$retour = $chaine;
340
		switch ($this->abstraction) {
356
		switch ($this->abstraction) {
341
			case self::ABSTRACTION_PDO :
357
			case self::ABSTRACTION_PDO :
342
				$retour = $this->connexion->quote($chaine);
358
				$retour = $this->connexion->quote($chaine);
343
				break;
359
				break;
344
			case self::ABSTRACTION_MYSQL :
360
			case self::ABSTRACTION_MYSQL :
345
				$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';
361
				$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';
346
				break;
362
				break;
347
			case self::ABSTRACTION_MYSQLI :
363
			case self::ABSTRACTION_MYSQLI :
348
				$retour = '"'.$this->connexion->real_escape_string($chaine).'"';
364
				$retour = '"'.$this->connexion->real_escape_string($chaine).'"';
349
				break;
365
				break;
350
			case self::ABSTRACTION_SQLITE3 :
366
			case self::ABSTRACTION_SQLITE3 :
351
				$retour = $this->connexion->escapeString($chaine);
367
				$retour = $this->connexion->escapeString($chaine);
352
				break;
368
				break;
353
		}
369
		}
354
		return $retour;
370
		return $retour;
355
	}
371
	}
356
 
372
 
357
	/**
373
	/**
358
	 * Retourne l'identifiant de la dernière ligne insérée, ou la dernière valeur d'une séquence d'objets, dépendamment, dans
374
	 * Retourne l'identifiant de la dernière ligne insérée, ou la dernière valeur d'une séquence d'objets, dépendamment, dans
359
	 * le cas de PDO, du driver utilisé. Les méthodes utilisées pour retourner l'identifiant peuvent avoir des comportements
375
	 * le cas de PDO, du driver utilisé. Les méthodes utilisées pour retourner l'identifiant peuvent avoir des comportements
360
	 * différent. Consulter la documentation PHP correspondant à l'abstraction choisie avant de l'utiliser :
376
	 * différent. Consulter la documentation PHP correspondant à l'abstraction choisie avant de l'utiliser :
361
	 * @link(http://fr.php.net/manual/fr/pdo.lastinsertid.php, PDO::lastInsertId([ string $name = NULL ]))
377
	 * @link(http://fr.php.net/manual/fr/pdo.lastinsertid.php, PDO::lastInsertId([ string $name = NULL ]))
362
	 * @link(http://php.net/manual/en/mysqli.insert-id.php, mysqli->insert_id()) 
378
	 * @link(http://php.net/manual/en/mysqli.insert-id.php, mysqli->insert_id())
363
	 * @link(http://fr.php.net/manual/fr/function.mysql-insert-id.php, mysql_insert_id())
379
	 * @link(http://fr.php.net/manual/fr/function.mysql-insert-id.php, mysql_insert_id())
364
	 * @link(http://fr.php.net/manual/fr/sqlite3.lastinsertrowid.php, SQLite3::lastInsertRowID()) 
380
	 * @link(http://fr.php.net/manual/fr/sqlite3.lastinsertrowid.php, SQLite3::lastInsertRowID())
365
	 * @param mixed un paramètre éventuel à transmettre (en fonction de l'abstraction de BDD utilisée).
381
	 * @param mixed un paramètre éventuel à transmettre (en fonction de l'abstraction de BDD utilisée).
366
	 * @return mixed le dernier identifiant de clé primaire ajouté dans la base de données (string ou int).
382
	 * @return mixed le dernier identifiant de clé primaire ajouté dans la base de données (string ou int).
367
	 */
383
	 */
368
	public function recupererIdDernierAjout($parametres = null) {
384
	public function recupererIdDernierAjout($parametres = null) {
369
		$this->connecter();
385
		$this->connecter();
370
 
386
 
371
		$retour = $chaine;
387
		$retour = $chaine;
372
		switch ($this->abstraction) {
388
		switch ($this->abstraction) {
373
			case self::ABSTRACTION_PDO :
389
			case self::ABSTRACTION_PDO :
374
				$retour = $this->connexion->lastInsertId($parametres);
390
				$retour = $this->connexion->lastInsertId($parametres);
375
				break;
391
				break;
376
			case self::ABSTRACTION_MYSQL :
392
			case self::ABSTRACTION_MYSQL :
377
				$retour = mysql_insert_id($this->connexion);
393
				$retour = mysql_insert_id($this->connexion);
378
				break;
394
				break;
379
			case self::ABSTRACTION_MYSQLI :
395
			case self::ABSTRACTION_MYSQLI :
380
				$retour = $this->connexion->insert_id();
396
				$retour = $this->connexion->insert_id();
381
				break;
397
				break;
382
			case self::ABSTRACTION_SQLITE3 :
398
			case self::ABSTRACTION_SQLITE3 :
383
				$retour = $this->connexion->lastInsertRowID();
399
				$retour = $this->connexion->lastInsertRowID();
384
				break;
400
				break;
385
		}
401
		}
386
		return $retour;
402
		return $retour;
387
	}
403
	}
388
	
404
 
389
	/**
405
	/**
390
	 * Destructeur de classe, se contente de fermer explicitement la connexion à la base de donnée.
406
	 * Destructeur de classe, se contente de fermer explicitement la connexion à la base de donnée.
391
	 */
407
	 */
392
	public function __destruct() {
408
	public function __destruct() {
393
		if (isset($this->connexion)) {
409
		if (isset($this->connexion)) {
394
			switch ($this->abstraction) {
410
			switch ($this->abstraction) {
395
				case self::ABSTRACTION_PDO :
411
				case self::ABSTRACTION_PDO :
396
					$this->connexion = null;
412
					$this->connexion = null;
397
					break;
413
					break;
398
				case self::ABSTRACTION_MYSQL :
414
				case self::ABSTRACTION_MYSQL :
399
					if (isset($this->connexion)) {
415
					if (isset($this->connexion)) {
400
						return mysql_close($this->connexion);
416
						return mysql_close($this->connexion);
401
					}	
417
					}
402
					break;
418
					break;
403
				case self::ABSTRACTION_MYSQLI :
419
				case self::ABSTRACTION_MYSQLI :
404
					$this->connexion->close();
420
					$this->connexion->close();
405
					break;
421
					break;
406
				case self::ABSTRACTION_SQLITE3 :
422
				case self::ABSTRACTION_SQLITE3 :
407
					$this->connexion->close();
423
					$this->connexion->close();
408
					break;
424
					break;
409
			}
425
			}
410
		}
426
		}
411
	}
427
	}
412
}
428
}
413
?>
429
?>