Subversion Repositories Applications.framework

Rev

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

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