Subversion Repositories Applications.framework

Rev

Rev 238 | Rev 241 | Go to most recent revision | Only display areas with differences | Ignore whitespace | Details | Blame | Last modification | View Log | RSS feed

Rev 238 Rev 239
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) 2009, Tela Botanica (accueil@tela-botanica.org)
17
 * @copyright	Copyright (c) 2009, 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 238 2010-11-24 17:53:29Z jpm $
20
 * @version	$Id: Bdd.php 239 2010-11-25 18:04:00Z 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
	
86
	
87
	/** Constructeur par défaut, appelé à l'initialisation. */
87
	/** Constructeur par défaut, appelé à l'initialisation. */
88
	public function __construct() {
88
	public function __construct() {
89
		Debug::verifierParametresConfig($this->parametres_obligatoires);
89
		Debug::verifierParametresConfig($this->parametres_obligatoires);
90
		$this->abstraction = strtolower(Config::get('bdd_abstraction'));
90
		$this->abstraction = strtolower(Config::get('bdd_abstraction'));
91
		$this->type = Config::get('bdd_protocole');
91
		$this->type = Config::get('bdd_protocole');
92
		$this->hote = Config::get('bdd_serveur');
92
		$this->hote = Config::get('bdd_serveur');
93
		$this->bdd_nom = Config::get('bdd_nom');
93
		$this->bdd_nom = Config::get('bdd_nom');
94
		$this->utilisateur = Config::get('bdd_utilisateur');
94
		$this->utilisateur = Config::get('bdd_utilisateur');
95
		$this->pass = Config::get('bdd_mot_de_passe');
95
		$this->pass = Config::get('bdd_mot_de_passe');
96
		$this->encodage = Config::get('bdd_encodage');
96
		$this->encodage = Config::get('bdd_encodage');
97
 
97
 
98
		$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
98
		$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
99
		$this->initialiserProtocole();
99
		$this->initialiserProtocole();
100
	}
100
	}
101
 
101
 
102
	/** Initialise les constantes de classe à leur bonne valeur et déclenche une erreur si le protocole n'est pas bien défini. */
102
	/** Initialise les constantes de classe à leur bonne valeur et déclenche une erreur si le protocole n'est pas bien défini. */
103
	protected function initialiserProtocole() {
103
	protected function initialiserProtocole() {
104
		switch ($this->abstraction) {
104
		switch ($this->abstraction) {
105
			case self::ABSTRACTION_PDO :
105
			case self::ABSTRACTION_PDO :
106
				$this->ASSOC = PDO::FETCH_ASSOC;
106
				$this->ASSOC = PDO::FETCH_ASSOC;
107
				$this->OBJECT = PDO::FETCH_CLASS;
107
				$this->OBJECT = PDO::FETCH_CLASS;
108
				break;
108
				break;
109
			case self::ABSTRACTION_MYSQL :
109
			case self::ABSTRACTION_MYSQL :
110
				$this->ASSOC = 'mysql_fetch_assoc';
110
				$this->ASSOC = 'mysql_fetch_assoc';
111
				$this->OBJECT = 'mysql_fetch_object';
111
				$this->OBJECT = 'mysql_fetch_object';
112
				break;
112
				break;
113
			case self::ABSTRACTION_MYSQLI :
113
			case self::ABSTRACTION_MYSQLI :
114
				$this->ASSOC = 'fetch_assoc';
114
				$this->ASSOC = 'fetch_assoc';
115
				$this->OBJECT = 'fetch_object';
115
				$this->OBJECT = 'fetch_object';
116
				break;
116
				break;
117
			case self::ABSTRACTION_SQLITE3 :
117
			case self::ABSTRACTION_SQLITE3 :
118
				$this->ASSOC = 'SQLITE3_ASSOC';
118
				$this->ASSOC = 'SQLITE3_ASSOC';
119
				$this->OBJECT = 'SQLITE3_OBJECT';
119
				$this->OBJECT = 'SQLITE3_OBJECT';
120
				break;
120
				break;
121
			default:
121
			default:
122
				$m = "Erreur : l'abstraction '{$this->abstraction}' n'est pas prise en charge";
122
				$m = "Erreur : l'abstraction '{$this->abstraction}' n'est pas prise en charge";
123
				trigger_error($m, E_USER_WARNING);
123
				trigger_error($m, E_USER_WARNING);
124
		}
124
		}
125
	}
125
	}
126
	
126
	
127
	/**
127
	/**
128
	 * Connection à la base de données en utilisant les informations fournies par
128
	 * Connection à la base de données en utilisant les informations fournies par
129
	 * le fichier de configuration.
129
	 * le fichier de configuration.
130
	 * Cette méthode est private et final car elle n'a pas vocation a être appelée par l'utilisateur.
130
	 * Cette méthode est private et final car elle n'a pas vocation a être appelée par l'utilisateur.
131
	 */
131
	 */
132
	protected function connecter() {
132
	protected function connecter() {
133
		if ($this->connexion == null) {
133
		if ($this->connexion == null) {
134
			switch ($this->abstraction) {
134
			switch ($this->abstraction) {
135
				case self::ABSTRACTION_PDO :
135
				case self::ABSTRACTION_PDO :
136
					try {
136
					try {
137
						$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
137
						$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
138
					} catch (PDOException $e) {
138
					} catch (PDOException $e) {
139
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $e->getMessage());
139
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $e->getMessage());
140
						trigger_error($e, E_USER_WARNING);
140
						trigger_error($e, E_USER_WARNING);
141
					}
141
					}
142
					break;
142
					break;
143
				case self::ABSTRACTION_MYSQL :
143
				case self::ABSTRACTION_MYSQL :
144
					$this->connexion = mysql_connect($this->hote, $this->utilisateur, $this->pass);
144
					$this->connexion = mysql_connect($this->hote, $this->utilisateur, $this->pass);
145
					if ($this->connexion !== false) {
145
					if ($this->connexion !== false) {
146
						$selection = mysql_select_db($this->bdd_nom, $this->connexion);
146
						$selection = mysql_select_db($this->bdd_nom, $this->connexion);
147
						if ($selection === false) {
147
						if ($selection === false) {
148
							$e = sprintf(self::ERREUR_SELECTION_BDD_TPL, mysql_error());
148
							$e = sprintf(self::ERREUR_SELECTION_BDD_TPL, mysql_error());
149
							trigger_error($e, E_USER_WARNING);
149
							trigger_error($e, E_USER_WARNING);
150
						}
150
						}
151
					} else {
151
					} else {
152
						$e = sprintf(self::ERREUR_CONNEXION_TPL, mysql_error());
152
						$e = sprintf(self::ERREUR_CONNEXION_TPL, mysql_error());
153
						trigger_error($e, E_USER_WARNING);
153
						trigger_error($e, E_USER_WARNING);
154
					}
154
					}
155
					break;
155
					break;
156
				case self::ABSTRACTION_MYSQLI :
156
				case self::ABSTRACTION_MYSQLI :
157
					$this->connexion = @new mysqli($this->hote, $this->utilisateur, $this->pass, $this->bdd_nom);
157
					$this->connexion = @new mysqli($this->hote, $this->utilisateur, $this->pass, $this->bdd_nom);
158
					if ($this->connexion->connect_errno) {
158
					if ($this->connexion->connect_errno) {
159
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $this->connexion->connect_error);
159
						$e = sprintf(self::ERREUR_CONNEXION_TPL, $this->connexion->connect_error);
160
						trigger_error($e, E_USER_WARNING);
160
						trigger_error($e, E_USER_WARNING);
161
					}
161
					}
162
					break;
162
					break;
163
				case self::ABSTRACTION_SQLITE3 :
163
				case self::ABSTRACTION_SQLITE3 :
164
					// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir
164
					// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir
165
					$this->connexion = new SQLite3($this->bdd_nom);
165
					$this->connexion = new SQLite3($this->bdd_nom);
166
					if (!$this->connexion) {
166
					if (!$this->connexion) {
167
						$e = sprintf(self::ERREUR_CONNEXION_TPL, '');
167
						$e = sprintf(self::ERREUR_CONNEXION_TPL, '');
168
						trigger_error($e, E_USER_WARNING);
168
						trigger_error($e, E_USER_WARNING);
169
					}
169
					}
170
					break;
170
					break;
171
				default:
171
				default:
172
					$this->connexion = null;
172
					$this->connexion = null;
173
			}
173
			}
174
	
174
	
175
			if ($this->encodage != null) {
175
			if ($this->encodage != null) {
176
				$this->requete("SET names '".$this->encodage."'");
176
				$this->requete("SET names '".$this->encodage."'");
177
			}
177
			}
178
		}
178
		}
179
	}
179
	}
180
	
180
	
181
	/**
181
	/**
-
 
182
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see requeter
-
 
183
	 */
-
 
184
	final protected function requete($requete) {
-
 
185
		return $this->requeter($requete, $mode);
-
 
186
	}
-
 
187
	
-
 
188
	/**
182
	 * Execute une requête et retourne le résultat tel que renvoyé par l'abstraction courante.
189
	 * Execute une requête et retourne le résultat tel que renvoyé par l'abstraction courante.
183
	 *
190
	 *
184
	 * @param string la requête à effectuer
191
	 * @param string la requête à effectuer
185
	 * @return mixed un objet contenant le résultat de la requête
192
	 * @return mixed un objet contenant le résultat de la requête
186
	 */
193
	 */
187
	public function requete($requete) {
194
	public function requeter($requete) {
188
		$this->connecter();
195
		$this->connecter();
189
 
196
 
190
		$retour = null;
197
		$retour = null;
191
		switch ($this->abstraction) {
198
		switch ($this->abstraction) {
192
			case self::ABSTRACTION_PDO :
199
			case self::ABSTRACTION_PDO :
193
				try {
200
				try {
194
					$retour = $this->connexion->query($requete);
201
					$retour = $this->connexion->query($requete);
195
				} catch (PDOException $e) {
202
				} catch (PDOException $e) {
196
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
203
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
197
					trigger_error($m, E_USER_WARNING);
204
					trigger_error($m, E_USER_WARNING);
198
				}
205
				}
199
				break;
206
				break;
200
			case self::ABSTRACTION_MYSQL :
207
			case self::ABSTRACTION_MYSQL :
201
				$retour = mysql_query($requete, $this->connexion);
208
				$retour = mysql_query($requete, $this->connexion);
202
				break;
209
				break;
203
			case self::ABSTRACTION_MYSQLI :
210
			case self::ABSTRACTION_MYSQLI :
204
				$retour = $this->connexion->query($requete);
211
				$retour = $this->connexion->query($requete);
205
				break;
212
				break;
206
			case self::ABSTRACTION_SQLITE3 :
213
			case self::ABSTRACTION_SQLITE3 :
207
				$retour = $this->connexion->exec($requete);
214
				$retour = $this->connexion->exec($requete);
208
				break;
215
				break;
209
		}
216
		}
210
		return $retour;
217
		return $retour;
211
	}
218
	}
212
 
219
	
-
 
220
	/**
-
 
221
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see recuperer
-
 
222
	 */
-
 
223
	final protected function requeteUn($requete, $mode = self::MODE_ASSOC) {
-
 
224
		return $this->recuperer($requete, $mode);
-
 
225
	}
-
 
226
	
213
	/**
227
	/**
214
	 * Execute une requête et retourne le premier résultat sous forme de tableau (par défaut) ou d'objet.
228
	 * Execute une requête et retourne le premier résultat sous forme de tableau (par défaut) ou d'objet.
215
	 * 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.
229
	 * 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.
216
	 *
230
	 *
217
	 * @param string la requête à effectuer
231
	 * @param string la requête à effectuer
218
	 * @param string le mode de retour ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
232
	 * @param string le mode de retour ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
219
	 * @return mixed un objet ou un tableau contenant le résultat de la requête
233
	 * @return mixed un objet ou un tableau contenant le résultat de la requête
220
	 */
234
	 */
221
	public function requeteUn($requete, $mode = self::MODE_ASSOC) {
235
	public function recuperer($requete, $mode = self::MODE_ASSOC) {
222
		$this->connecter();
236
		$this->connecter();
223
 
237
 
224
		$retour = null;
238
		$retour = null;
225
		switch ($this->abstraction) {
239
		switch ($this->abstraction) {
226
			case self::ABSTRACTION_PDO :
240
			case self::ABSTRACTION_PDO :
227
				try {
241
				try {
228
					$resultat = $this->connexion->query($requete);
242
					$resultat = $this->connexion->query($requete);
229
					$retour = $resultat->fetch($this->$mode);
243
					$retour = $resultat->fetch($this->$mode);
230
				} catch (PDOException $e) {
244
				} catch (PDOException $e) {
231
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
245
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
232
					trigger_error($m, E_USER_WARNING);
246
					trigger_error($m, E_USER_WARNING);
233
				}
247
				}
234
				break;
248
				break;
235
			case self::ABSTRACTION_MYSQL :
249
			case self::ABSTRACTION_MYSQL :
236
				$res = mysql_query($requete, $this->connexion);
250
				$res = mysql_query($requete, $this->connexion);
237
				$fonction_fetch = $this->$mode;
251
				$fonction_fetch = $this->$mode;
238
				$retour = $fonction_fetch($res);
252
				$retour = $fonction_fetch($res);
239
				break;
253
				break;
240
			case self::ABSTRACTION_MYSQLI :
254
			case self::ABSTRACTION_MYSQLI :
241
				$res = $this->connexion->query($requete);
255
				$res = $this->connexion->query($requete);
242
				$fonction_fetch = $this->$mode;
256
				$fonction_fetch = $this->$mode;
243
				$retour = $res->$fonction_fetch();
257
				$retour = $res->$fonction_fetch();
244
				break;
258
				break;
245
			case self::ABSTRACTION_SQLITE3 :
259
			case self::ABSTRACTION_SQLITE3 :
246
				$retour = $this->connexion->querySingle($requete);
260
				$retour = $this->connexion->querySingle($requete);
247
				break;
261
				break;
248
		}
262
		}
249
		return $retour;
263
		return $retour;
250
	}
264
	}
251
 
265
	
-
 
266
	/**
-
 
267
	 * @deprecated changement de nom. Disparaîtra dans la version 0.4. Utiliser à la place : @see recupererTous
-
 
268
	 */
-
 
269
	final protected function requeteTous($requete, $mode = self::MODE_ASSOC) {
-
 
270
		return $this->recupererTous($requete, $mode);
-
 
271
	}
-
 
272
	
252
	/**
273
	/**
253
	 * Execute une requête et retourne un tableau de résultats. Un résultat peut être présentés sous forme 
274
	 * Execute une requête et retourne un tableau de résultats. Un résultat peut être présentés sous forme 
254
	 * de tableau (par défaut) ou d'objet.
275
	 * de tableau (par défaut) ou d'objet.
255
	 * Les noms des champs de la base de données correspondent aux noms des clés du tableau résultat ou 
276
	 * Les noms des champs de la base de données correspondent aux noms des clés du tableau résultat ou 
256
	 * aux noms des attributs de l'objet résultat.
277
	 * aux noms des attributs de l'objet résultat.
257
	 *
278
	 *
258
	 * @param string la requête à effectuer
279
	 * @param string la requête à effectuer
259
	 * @param string le mode de retour des résultats : ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
280
	 * @param string le mode de retour des résultats : ASSOC (Bdd::MODE_ASSOC) pour un tableau ou OBJECT (Bdd::MODE_OBJET) pour un objet.
260
	 * @return array un tableau contenant les résultats sous forme d'objets ou de tableau (par défaut).
281
	 * @return array un tableau contenant les résultats sous forme d'objets ou de tableau (par défaut).
261
	 */
282
	 */
262
	public function requeteTous($requete, $mode = self::MODE_ASSOC) {
283
	public function recupererTous($requete, $mode = self::MODE_ASSOC) {
263
		$this->connecter();
284
		$this->connecter();
264
 
285
		
265
		$retour = null;
286
		$retour = null;
266
		switch ($this->abstraction) {
287
		switch ($this->abstraction) {
267
			case self::ABSTRACTION_PDO :
288
			case self::ABSTRACTION_PDO :
268
				try {
289
				try {
269
					$resultat = $this->connexion->query($requete);
290
					$resultat = $this->connexion->query($requete);
270
					if ($resultat !== false) {
291
					if ($resultat !== false) {
271
						$retour = $resultat->fetchAll($this->$mode);
292
						$retour = $resultat->fetchAll($this->$mode);
272
					} else {
293
					} else {
273
						$retour = false;
294
						$retour = false;
274
					}
295
					}
275
				} catch (PDOException $e) {
296
				} catch (PDOException $e) {
276
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
297
					$m = sprintf(self::ERREUR_REQUETE_TPL, $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
277
					trigger_error($m, E_USER_WARNING);
298
					trigger_error($m, E_USER_WARNING);
278
				}
299
				}
279
				break;
300
				break;
280
			case self::ABSTRACTION_MYSQL :
301
			case self::ABSTRACTION_MYSQL :
281
				$resultat = mysql_query($requete, $this->connexion);
302
				$resultat = mysql_query($requete, $this->connexion);
282
				$fonction_fetch = $this->$mode;
303
				$fonction_fetch = $this->$mode;
283
				while ($ligne = $fonction_fetch($resultat)) {
304
				while ($ligne = $fonction_fetch($resultat)) {
284
					$retour[] = $ligne;
305
					$retour[] = $ligne;
285
				}
306
				}
286
				break;
307
				break;
287
			case self::ABSTRACTION_MYSQLI :
308
			case self::ABSTRACTION_MYSQLI :
288
				$resultat = $this->connexion->query($requete);
309
				$resultat = $this->connexion->query($requete);
289
				$function_fetch = $this->$mode;
310
				$function_fetch = $this->$mode;
290
				while ($ligne = $resultat->$function_fetch()) {
311
				while ($ligne = $resultat->$function_fetch()) {
291
					$retour[] = $ligne;
312
					$retour[] = $ligne;
292
				}
313
				}
293
				break;
314
				break;
294
			case self::ABSTRACTION_SQLITE3 :
315
			case self::ABSTRACTION_SQLITE3 :
295
				$resultat = $this->connexion->query($requete);
316
				$resultat = $this->connexion->query($requete);
296
				while ($ligne = $resultat->fetch_array($this->ASSOC)) {
317
				while ($ligne = $resultat->fetch_array($this->ASSOC)) {
297
					if ($mode == self::MODE_OBJET) {
318
					if ($mode == self::MODE_OBJET) {
298
						// Cas particulier de sqllite qui n'a pas de fonction fetch_object
319
						// Cas particulier de sqllite qui n'a pas de fonction fetch_object
299
						$ligneObjet = new stdClass();
320
						$ligneObjet = new stdClass();
300
						foreach ($ligne as $colonne => $valeur) {
321
						foreach ($ligne as $colonne => $valeur) {
301
							$ligneObjet->$colonne = $valeur;
322
							$ligneObjet->$colonne = $valeur;
302
						}
323
						}
303
						$ligne = $ligneObjet;
324
						$ligne = $ligneObjet;
304
					}
325
					}
305
					$retour[] = $ligne;
326
					$retour[] = $ligne;
306
				}
327
				}
307
				break;
328
				break;
308
		}
329
		}
309
		return $retour;
330
		return $retour;
310
	}
331
	}
311
 
332
 
312
	/**
333
	/**
313
	 * Protège une chaine de caractères avant l'insertion dans la base de données (ajout de quotes ou guillemets).
334
	 * Protège une chaine de caractères avant l'insertion dans la base de données (ajout de quotes ou guillemets).
314
	 * @param string la chaine à protéger
335
	 * @param string la chaine à protéger
315
	 * @return string la chaine protégée
336
	 * @return string la chaine protégée
316
	 */
337
	 */
317
	public function proteger($chaine) {
338
	public function proteger($chaine) {
318
		$this->connecter();
339
		$this->connecter();
319
 
340
 
320
		$retour = $chaine;
341
		$retour = $chaine;
321
		switch ($this->abstraction) {
342
		switch ($this->abstraction) {
322
			case self::ABSTRACTION_PDO :
343
			case self::ABSTRACTION_PDO :
323
				$retour = $this->connexion->quote($chaine);
344
				$retour = $this->connexion->quote($chaine);
324
				break;
345
				break;
325
			case self::ABSTRACTION_MYSQL :
346
			case self::ABSTRACTION_MYSQL :
326
				$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';
347
				$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';
327
				break;
348
				break;
328
			case self::ABSTRACTION_MYSQLI :
349
			case self::ABSTRACTION_MYSQLI :
329
				$retour = '"'.$this->connexion->real_escape_string($chaine).'"';
350
				$retour = '"'.$this->connexion->real_escape_string($chaine).'"';
330
				break;
351
				break;
331
			case self::ABSTRACTION_SQLITE3 :
352
			case self::ABSTRACTION_SQLITE3 :
332
				$retour = $this->connexion->escapeString($chaine);
353
				$retour = $this->connexion->escapeString($chaine);
333
				break;
354
				break;
334
		}
355
		}
335
		return $retour;
356
		return $retour;
336
	}
357
	}
337
 
358
 
338
	/**
359
	/**
-
 
360
	 * 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
-
 
361
	 * le cas de PDO, du driver utilisé. Les méthodes utilisées pour retourner l'identifiant peuvent avoir des comportements
-
 
362
	 * différent. Consulter la documentation PHP correspondant à l'abstraction choisie avant de l'utiliser :
-
 
363
	 * @link(http://fr.php.net/manual/fr/pdo.lastinsertid.php, PDO::lastInsertId([ string $name = NULL ]))
-
 
364
	 * @link(http://php.net/manual/en/mysqli.insert-id.php, mysqli->insert_id()) 
-
 
365
	 * @link(http://fr.php.net/manual/fr/function.mysql-insert-id.php, mysql_insert_id())
-
 
366
	 * @link(http://fr.php.net/manual/fr/sqlite3.lastinsertrowid.php, SQLite3::lastInsertRowID()) 
-
 
367
	 * @param mixed un paramètre éventuel à transmettre (en fonction de l'abstraction de BDD utilisée).
-
 
368
	 * @return mixed le dernier identifiant de clé primaire ajouté dans la base de données (string ou int).
-
 
369
	 */
-
 
370
	public function recupererIdDernierAjout($parametres = null) {
-
 
371
		$this->connecter();
-
 
372
 
-
 
373
		$retour = $chaine;
-
 
374
		switch ($this->abstraction) {
-
 
375
			case self::ABSTRACTION_PDO :
-
 
376
				$retour = $this->connexion->lastInsertId($parametres);
-
 
377
				break;
-
 
378
			case self::ABSTRACTION_MYSQL :
-
 
379
				$retour = mysql_insert_id($this->connexion);
-
 
380
				break;
-
 
381
			case self::ABSTRACTION_MYSQLI :
-
 
382
				$retour = $this->connexion->insert_id();
-
 
383
				break;
-
 
384
			case self::ABSTRACTION_SQLITE3 :
-
 
385
				$retour = $this->connexion->lastInsertRowID();
-
 
386
				break;
-
 
387
		}
-
 
388
		return $retour;
-
 
389
	}
-
 
390
	
-
 
391
	/**
339
	 * Destructeur de classe, se contente de fermer explicitement la connexion à la base de donnée.
392
	 * Destructeur de classe, se contente de fermer explicitement la connexion à la base de donnée.
340
	 */
393
	 */
341
	protected function __destruct() {
394
	protected function __destruct() {
342
		switch ($this->abstraction) {
395
		switch ($this->abstraction) {
343
			case self::ABSTRACTION_PDO :
396
			case self::ABSTRACTION_PDO :
344
				$this->connexion = null;
397
				$this->connexion = null;
345
				break;
398
				break;
346
			case self::ABSTRACTION_MYSQL :
399
			case self::ABSTRACTION_MYSQL :
347
				return mysql_close($this->connexion);
400
				return mysql_close($this->connexion);
348
				break;
401
				break;
349
			case self::ABSTRACTION_MYSQLI :
402
			case self::ABSTRACTION_MYSQLI :
350
				$this->connexion->close();
403
				$this->connexion->close();
351
				break;
404
				break;
352
			case self::ABSTRACTION_SQLITE3 :
405
			case self::ABSTRACTION_SQLITE3 :
353
				$this->connexion->close();
406
				$this->connexion->close();
354
				break;
407
				break;
355
		}
408
		}
356
	}
409
	}
357
}
410
}
358
?>
411
?>