Subversion Repositories Applications.framework

Rev

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

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