WebSVN – Applications.framework – Diff – /trunk/framework/Bdd.php


<?php
// declare(encoding='UTF-8');
/**
* Classe modèle, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.
* Elle fait office d'abstraction légère de base de données en utilisant diveres possibilités
* d'abstraction de base de données (PDO, mysql, mysqli, sqlite)
* Elle est abstraite donc doit obligatoirement être étendue.
*
* PHP Version 5
*
* @category  Class
* @package   Framework
* @author	aurelien <aurelien@tela-botanica.org>
* @copyright 2009 Tela-Botanica
* @license   http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL
* @license   http://www.gnu.org/licenses/gpl.html Licence GNU-GPL
* @version   SVN: $$Id: Modele.php 143 2010-03-02 13:00:37Z jpm $$
* @link	  /doc/framework/
*
*/
abstract class Modele {
 
	/**
	 * Mode de fetch associatif
	 */
	private $ASSOC = '';
	/**
	 * Mode de fetch objet
	 */
	private $OBJECT = '';
 
	/**
	 * abstraction de base de données utilisée
	 */
	private $abstraction;
	/**
	 * registre global
	 */
	private $registre;
	/**
	 * DSN pour accéder à la base de données
	 */
	private $dsn;
	/**
	 * Type de base de données (mysql, mysqli, etc ...)
	 */
	private $type;
	/**
	 * Hote herbergeant la base de données
	 */
	private $hote;
	/**
	 * Nom de la base de données à laquelle le modèle doit se connecter
	 */
	private $bdd_nom;
	/**
	 * Nom d'utilisateur
	 */
	private $utilisateur;
	/**
	 * Mot de passe
	 */
	private $pass;
 
	/**
	 * Encodage de la base de données
	 */
	 private $encodage = null;
	/**
	 * Connexion à la base de données
	 */
	private $connexion = null;
 
	/**
	 * Constructeur par défaut, appelé à l'initialisation.
	 */
	final public function __construct() {
		// les différents paramètres nécessaires sont lus à partir du registre
		$this->registre = Registre::getInstance();
		$this->abstraction = strtolower(Config::get('bdd_abstraction'));
		$this->type = Config::get('bdd_protocole');
		$this->hote = Config::get('bdd_serveur');
		$this->bdd_nom = Config::get('bdd_nom');
		$this->utilisateur = Config::get('bdd_utilisateur');
		$this->pass = Config::get('bdd_mot_de_passe');
		$this->encodage = Config::get('bdd_encodage');
 
		$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;
		$this->initialiserProtocole();
	}
 
	/**
	 * Connection à la base de données en utilisant les informations fournies par
	 * le fichier de configuration.
	 * private et final car n'a pas vocation a être appelée par l'utilisateur.
	 *
	 * @throws Exception une exception dans le cas ou là connexion échoue
	 */
	final private function connecter() {
		switch ($this->abstraction) {
			case 'pdo':
				$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);
			break;
 
			case 'mysql':
				$this->connexion = mysql_connect($this->hote,$this->utilisateur,$this->pass);
				if ($this->connexion != null) {
					mysql_select_db($this->bdd_nom, $this->connexion);
				} else {
					throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');
				}
			break;
 
			case 'mysqli':
				$this->connexion = new mysqli($this->hote,$this->utilisateur,$this->pass, $this->bdd_nom);
				if (!$this->connexion) {
					throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');
					return;
				}
			break;
 
			case 'sqlite3':
				// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir
				$this->connexion = new SQLite3($this->bdd_nom);
				if (!$this->connexion) {
					throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');
					return;
				}
			break;
 
			default:
				$this->connexion = null;
		}
 
		if ($this->encodage != null) {
			$this->requete("SET names '".$this->encodage."'");
		}
	}
 
	/**
	 * Fonction qui appelle la bonne fonction pour executer une requête suivant le type de bdd.
	 *
	 * @param string la requete à effectuer
	 * @return PDOStatement un objet contenant le résultat de la requête
	 */
	final protected function requete($requete) {
		// on ne se connecte que lors du premier appel à une requete (lazy connexion)
		if ($this->connexion == null) {
			$this->connecter();
		}
 
		$retour = null;
 
		switch ($this->abstraction) {
			case 'pdo':
				$retour = $this->connexion->query($requete);
				break;
			case 'mysql':
				$retour = mysql_query($requete,$this->connexion);
				break;
			case 'mysqli':
				$retour = $this->connexion->query($requete);
				break;
			case 'sqlite3':
				$retour = $this->connexion->exec($requete);
				break;
		}
 
		return $retour;
	}
 
	final protected function requeteUn($requete,$mode = 'ASSOC') {
		// Connection seulement lors du premier appel à une requete (lazy connexion)
		if ($this->connexion == null) {
			$this->connecter();
		}
 
		$retour = null;
		switch ($this->abstraction) {
			case 'pdo':
				$res_req = $this->connexion->query($requete);
				$retour =$res_req->fetch($this->$mode);
				break;
			case 'mysql':
				$res = mysql_query($requete,$this->connexion);
				$fonction_fetch = $this->$mode;
				$retour = $fonction_fetch($res);
				break;
			case 'mysqli':
				$res = $this->connexion->query($requete);
				$fonction_fetch = $this->$mode;
				$retour = $res->$fonction_fetch();
				break;
			case 'sqlite3':
				$retour = $this->connexion->querySingle($requete);
				break;
		}
 
		return $retour;
	}
 
 
	final protected function requeteTous($requete,$mode = 'ASSOC') {
		// Connexion seulement lors du premier appel à une requete (lazy connexion)
		if ($this->connexion == null) {
			$this->connecter();
		}
 
		$retour = null;
 
		switch ($this->abstraction) {
			case 'pdo':
				try {
					$res_req = $this->connexion->query($requete);
					if ($res_req !== false) {
						$retour = $res_req->fetchAll($this->$mode);
					} else {
						$retour = false;
					}
				} catch (PDOException $e) {
					$message = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s';
					trigger_error(sprintf($message, $e->getFile(), $e->getLine(), $e->getMessage()), E_USER_WARNING);
				}
				break;
			case 'mysql':
				$res = mysql_query($requete, $this->connexion);
				$fonction_fetch = $this->$mode;
				while ($ligne = $fonction_fetch($res)) {
					$retour[] = $ligne;
				}
				break;
			case 'mysqli':
				$res = $this->connexion->query($requete);
				$function_fetch = $this->$mode;
				while ($ligne = $res->$function_fetch()) {
					$retour[] = $ligne;
				}
				break;
			case 'sqlite3':
				$res = $this->connexion->query($requete);
				while ($ligne = $res->fetch_array($this->ASSOC)) {
					if ($mode == $this->ASSOC) {
						$retour[] = $ligne;
					} elseif ($mode == $this->OBJECT) {
						// cas particulier de sqllite
						// qui n'a pas de fonction fetch_object
						$ligneObjet = new stdClass();
						foreach ($ligne as $colonne => $valeur) {
							$ligneObjet->$colonne = $valeur;
						}
						$retour[] = $ligneObjet;
					}
				}
				break;
		}
 
		return $retour;
	}
 
	/**
	 * protège une chaine de caractères avant l'insertion dans la base de données
	 */
	final protected function proteger($chaine) {
 
		// on ne se connecte que lors du premier appel à une requete
		if ($this->connexion == null) {
			$this->connecter();
		}
 
		$retour = $chaine;
 
		switch ($this->abstraction) {
			case 'pdo':
				$retour = $this->connexion->quote($chaine);
				break;
			case 'mysql':
				$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';
				break;
			case 'mysqli':
				$retour = '"'.$this->connexion->real_escape_string($chaine).'"';
				break;
			case 'sqlite3':
				$retour = $this->connexion->escapeString($chaine);
				break;
		}
 
		return $retour;
	}
 
	/**
	 * initialise les constantes de classe à leur bonne valeur
	 * et lance une exception si le protocole n'est pas bien défini
	 * @throws Exception
	 */
	final public function initialiserProtocole() {
 
		switch ($this->abstraction) {
			case 'pdo':
				$this->ASSOC = PDO::FETCH_ASSOC;
				$this->OBJECT = PDO::FETCH_CLASS;
				break;
			case 'mysql':
				$this->ASSOC = 'mysql_fetch_assoc';
				$this->OBJECT = 'mysql_fetch_object';
				break;
			case 'mysqli':
				$this->ASSOC = 'fetch_assoc';
				$this->OBJECT = 'fetch_object';
				break;
			case 'sqlite3':
				$this->ASSOC = 'SQLITE3_ASSOC';
				$this->OBJECT = 'SQLITE3_OBJECT';
				break;
			default:
				throw new Exception('Erreur : l\'abstraction '.$this->abstraction.' n\'est pas prise en charge');
				break;
		}
	}
 
	/**
	 * Destructeur de classe, se contente de fermer explicitement la connexion
	 */
	final public function __destruct() {
		switch ($this->abstraction) {
			case 'pdo':
				$this->connexion = null;
				break;
			case 'mysql':
				return mysql_close($this->connexion);
				break;
			case 'mysqli':
				$this->connexion->close();
				break;
			case 'sqlite3':
				$this->connexion->close();
				break;
		}
	}
}
?>

Rev 140	Rev 143
1	`<?php`	1	`<?php`
2	`// declare(encoding='UTF-8');`	2	`// declare(encoding='UTF-8');`
3	`/**`	3	`/**`
4	`* Classe modèle, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.`	4	`* Classe modèle, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur.`
5	`* Elle fait office d'abstraction légère de base de données en utilisant diveres possibilités`	5	`* Elle fait office d'abstraction légère de base de données en utilisant diveres possibilités`
6	`* d'abstraction de base de données (PDO, mysql, mysqli, sqlite)`	6	`* d'abstraction de base de données (PDO, mysql, mysqli, sqlite)`
7	`* Elle est abstraite donc doit obligatoirement être étendue.`	7	`* Elle est abstraite donc doit obligatoirement être étendue.`
8	`*`	8	`*`
9	`* PHP Version 5`	9	`* PHP Version 5`
10	`*`	10	`*`
11	`* @category Class`	11	`* @category Class`
12	`* @package Framework`	12	`* @package Framework`
13	`* @author aurelien <aurelien@tela-botanica.org>`	13	`* @author aurelien <aurelien@tela-botanica.org>`
14	`* @copyright 2009 Tela-Botanica`	14	`* @copyright 2009 Tela-Botanica`
15	`* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL`	15	`* @license http://www.cecill.info/licences/Licence_CeCILL_V2-fr.txt Licence CECILL`
16	`* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL`	16	`* @license http://www.gnu.org/licenses/gpl.html Licence GNU-GPL`
17	`* @version SVN: $$Id: Modele.php 140 2010-02-22 16:23:29Z jpm $$`	17	`* @version SVN: $$Id: Modele.php 143 2010-03-02 13:00:37Z jpm $$`
18	`* @link /doc/framework/`	18	`* @link /doc/framework/`
19	`*`	19	`*`
20	`*/`	20	`*/`
21	`abstract class Modele {`	21	`abstract class Modele {`
22		22
23	`/**`	23	`/**`
24	`* Mode de fetch associatif`	24	`* Mode de fetch associatif`
25	`*/`	25	`*/`
26	`private $ASSOC = '';`	26	`private $ASSOC = '';`
27	`/**`	27	`/**`
28	`* Mode de fetch objet`	28	`* Mode de fetch objet`
29	`*/`	29	`*/`
30	`private $OBJECT = '';`	30	`private $OBJECT = '';`
31		31
32	`/**`	32	`/**`
33	`* abstraction de base de données utilisée`	33	`* abstraction de base de données utilisée`
34	`*/`	34	`*/`
35	`private $abstraction;`	35	`private $abstraction;`
36	`/**`	36	`/**`
37	`* registre global`	37	`* registre global`
38	`*/`	38	`*/`
39	`private $registre;`	39	`private $registre;`
40	`/**`	40	`/**`
41	`* DSN pour accéder à la base de données`	41	`* DSN pour accéder à la base de données`
42	`*/`	42	`*/`
43	`private $dsn;`	43	`private $dsn;`
44	`/**`	44	`/**`
45	`* Type de base de données (mysql, mysqli, etc ...)`	45	`* Type de base de données (mysql, mysqli, etc ...)`
46	`*/`	46	`*/`
47	`private $type;`	47	`private $type;`
48	`/**`	48	`/**`
49	`* Hote herbergeant la base de données`	49	`* Hote herbergeant la base de données`
50	`*/`	50	`*/`
51	`private $hote;`	51	`private $hote;`
52	`/**`	52	`/**`
53	`* Nom de la base de données à laquelle le modèle doit se connecter`	53	`* Nom de la base de données à laquelle le modèle doit se connecter`
54	`*/`	54	`*/`
55	`private $bdd_nom;`	55	`private $bdd_nom;`
56	`/**`	56	`/**`
57	`* Nom d'utilisateur`	57	`* Nom d'utilisateur`
58	`*/`	58	`*/`
59	`private $utilisateur;`	59	`private $utilisateur;`
60	`/**`	60	`/**`
61	`* Mot de passe`	61	`* Mot de passe`
62	`*/`	62	`*/`
63	`private $pass;`	63	`private $pass;`
64		64
65	`/**`	65	`/**`
66	`* Encodage de la base de données`	66	`* Encodage de la base de données`
67	`*/`	67	`*/`
68	`private $encodage = null;`	68	`private $encodage = null;`
69	`/**`	69	`/**`
70	`* Connexion à la base de données`	70	`* Connexion à la base de données`
71	`*/`	71	`*/`
72	`private $connexion = null;`	72	`private $connexion = null;`
73		73
74	`/**`	74	`/**`
75	`* Constructeur par défaut, appelé à l'initialisation.`	75	`* Constructeur par défaut, appelé à l'initialisation.`
76	`*/`	76	`*/`
77	`final public function __construct() {`	77	`final public function __construct() {`
78	`// les différents paramètres nécessaires sont lus à partir du registre`	78	`// les différents paramètres nécessaires sont lus à partir du registre`
79	`$this->registre = Registre::getInstance();`	79	`$this->registre = Registre::getInstance();`
80	`$this->abstraction = strtolower(Config::get('bdd_abstraction'));`	80	`$this->abstraction = strtolower(Config::get('bdd_abstraction'));`
81	`$this->type = Config::get('bdd_protocole');`	81	`$this->type = Config::get('bdd_protocole');`
82	`$this->hote = Config::get('bdd_serveur');`	82	`$this->hote = Config::get('bdd_serveur');`
83	`$this->bdd_nom = Config::get('bdd_nom');`	83	`$this->bdd_nom = Config::get('bdd_nom');`
84	`$this->utilisateur = Config::get('bdd_utilisateur');`	84	`$this->utilisateur = Config::get('bdd_utilisateur');`
85	`$this->pass = Config::get('bdd_mot_de_passe');`	85	`$this->pass = Config::get('bdd_mot_de_passe');`
86	`$this->encodage = Config::get('bdd_encodage');`	86	`$this->encodage = Config::get('bdd_encodage');`
87		87
88	`$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;`	88	`$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote;`
89	`$this->initialiserProtocole();`	89	`$this->initialiserProtocole();`
90	`}`	90	`}`
91		91
92	`/**`	92	`/**`
93	`* Connection à la base de données en utilisant les informations fournies par`	93	`* Connection à la base de données en utilisant les informations fournies par`
94	`* le fichier de configuration.`	94	`* le fichier de configuration.`
95	`* private et final car n'a pas vocation a être appelée par l'utilisateur.`	95	`* private et final car n'a pas vocation a être appelée par l'utilisateur.`
96	`*`	96	`*`
97	`* @throws Exception une exception dans le cas ou là connexion échoue`	97	`* @throws Exception une exception dans le cas ou là connexion échoue`
98	`*/`	98	`*/`
99	`final private function connecter() {`	99	`final private function connecter() {`
100	`switch ($this->abstraction) {`	100	`switch ($this->abstraction) {`
101	`case 'pdo':`	101	`case 'pdo':`
102	`$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);`	102	`$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass);`
103	`break;`	103	`break;`
104		104
105	`case 'mysql':`	105	`case 'mysql':`
106	`$this->connexion = mysql_connect($this->hote,$this->utilisateur,$this->pass);`	106	`$this->connexion = mysql_connect($this->hote,$this->utilisateur,$this->pass);`
107	`if ($this->connexion != null) {`	107	`if ($this->connexion != null) {`
108	`mysql_select_db($this->bdd_nom, $this->connexion);`	108	`mysql_select_db($this->bdd_nom, $this->connexion);`
109	`} else {`	109	`} else {`
110	`throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');`	110	`throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');`
111	`}`	111	`}`
112	`break;`	112	`break;`
113		113
114	`case 'mysqli':`	114	`case 'mysqli':`
115	`$this->connexion = new mysqli($this->hote,$this->utilisateur,$this->pass, $this->bdd_nom);`	115	`$this->connexion = new mysqli($this->hote,$this->utilisateur,$this->pass, $this->bdd_nom);`
116	`if (!$this->connexion) {`	116	`if (!$this->connexion) {`
117	`throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');`	117	`throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');`
118	`return;`	118	`return;`
119	`}`	119	`}`
120	`break;`	120	`break;`
121		121
122	`case 'sqlite3':`	122	`case 'sqlite3':`
123	`// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir`	123	`// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir`
124	`$this->connexion = new SQLite3($this->bdd_nom);`	124	`$this->connexion = new SQLite3($this->bdd_nom);`
125	`if (!$this->connexion) {`	125	`if (!$this->connexion) {`
126	`throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');`	126	`throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration');`
127	`return;`	127	`return;`
128	`}`	128	`}`
129	`break;`	129	`break;`
130		130
131	`default:`	131	`default:`
132	`$this->connexion = null;`	132	`$this->connexion = null;`
133	`}`	133	`}`
134		134
135	`if ($this->encodage != null) {`	135	`if ($this->encodage != null) {`
136	`$this->requete("SET names '".$this->encodage."'");`	136	`$this->requete("SET names '".$this->encodage."'");`
137	`}`	137	`}`
138	`}`	138	`}`
139		139
140	`/**`	140	`/**`
141	`* Fonction qui appelle la bonne fonction pour executer une requête suivant le type de bdd.`	141	`* Fonction qui appelle la bonne fonction pour executer une requête suivant le type de bdd.`
142	`*`	142	`*`
143	`* @param string la requete à effectuer`	143	`* @param string la requete à effectuer`
144	`* @return PDOStatement un objet contenant le résultat de la requête`	144	`* @return PDOStatement un objet contenant le résultat de la requête`
145	`*/`	145	`*/`
146	`final protected function requete($requete) {`	146	`final protected function requete($requete) {`
147	`// on ne se connecte que lors du premier appel à une requete (lazy connexion)`	147	`// on ne se connecte que lors du premier appel à une requete (lazy connexion)`
148	`if ($this->connexion == null) {`	148	`if ($this->connexion == null) {`
149	`$this->connecter();`	149	`$this->connecter();`
150	`}`	150	`}`
151		151
152	`$retour = null;`	152	`$retour = null;`
153		153
154	`switch ($this->abstraction) {`	154	`switch ($this->abstraction) {`
155	`case 'pdo':`	155	`case 'pdo':`
156	`$retour = $this->connexion->query($requete);`	156	`$retour = $this->connexion->query($requete);`
157	`break;`	157	`break;`
158	`case 'mysql':`	158	`case 'mysql':`
159	`$retour = mysql_query($requete,$this->connexion);`	159	`$retour = mysql_query($requete,$this->connexion);`
160	`break;`	160	`break;`
161	`case 'mysqli':`	161	`case 'mysqli':`
162	`$retour = $this->connexion->query($requete);`	162	`$retour = $this->connexion->query($requete);`
163	`break;`	163	`break;`
164	`case 'sqlite3':`	164	`case 'sqlite3':`
165	`$retour = $this->connexion->exec($requete);`	165	`$retour = $this->connexion->exec($requete);`
166	`break;`	166	`break;`
167	`}`	167	`}`
168		168
169	`return $retour;`	169	`return $retour;`
170	`}`	170	`}`
171		171
172	`final protected function requeteUn($requete,$mode = 'ASSOC') {`	172	`final protected function requeteUn($requete,$mode = 'ASSOC') {`
173	`// Connection seulement lors du premier appel à une requete (lazy connexion)`	173	`// Connection seulement lors du premier appel à une requete (lazy connexion)`
174	`if ($this->connexion == null) {`	174	`if ($this->connexion == null) {`
175	`$this->connecter();`	175	`$this->connecter();`
176	`}`	176	`}`
177		177
178	`$retour = null;`	178	`$retour = null;`
179	`switch ($this->abstraction) {`	179	`switch ($this->abstraction) {`
180	`case 'pdo':`	180	`case 'pdo':`
181	`$res_req = $this->connexion->query($requete);`	181	`$res_req = $this->connexion->query($requete);`
182	`$retour =$res_req->fetch($this->$mode);`	182	`$retour =$res_req->fetch($this->$mode);`
183	`break;`	183	`break;`
184	`case 'mysql':`	184	`case 'mysql':`
185	`$res = mysql_query($requete,$this->connexion);`	185	`$res = mysql_query($requete,$this->connexion);`
186	`$fonction_fetch = $this->$mode;`	186	`$fonction_fetch = $this->$mode;`
187	`$retour = $fonction_fetch($res);`	187	`$retour = $fonction_fetch($res);`
188	`break;`	188	`break;`
189	`case 'mysqli':`	189	`case 'mysqli':`
190	`$res = $this->connexion->query($requete);`	190	`$res = $this->connexion->query($requete);`
191	`$fonction_fetch = $this->$mode;`	191	`$fonction_fetch = $this->$mode;`
192	`$retour = $res->$fonction_fetch();`	192	`$retour = $res->$fonction_fetch();`
193	`break;`	193	`break;`
194	`case 'sqlite3':`	194	`case 'sqlite3':`
195	`$retour = $this->connexion->querySingle($requete);`	195	`$retour = $this->connexion->querySingle($requete);`
196	`break;`	196	`break;`
197	`}`	197	`}`
198		198
199	`return $retour;`	199	`return $retour;`
200	`}`	200	`}`
201		201
202		202
203	`final protected function requeteTous($requete,$mode = 'ASSOC') {`	203	`final protected function requeteTous($requete,$mode = 'ASSOC') {`
204	`// Connexion seulement lors du premier appel à une requete (lazy connexion)`	204	`// Connexion seulement lors du premier appel à une requete (lazy connexion)`
205	`if ($this->connexion == null) {`	205	`if ($this->connexion == null) {`
206	`$this->connecter();`	206	`$this->connecter();`
207	`}`	207	`}`
208		208
209	`$retour = null;`	209	`$retour = null;`
210		210
211	`switch ($this->abstraction) {`	211	`switch ($this->abstraction) {`
212	`case 'pdo':`	212	`case 'pdo':`
-		213	`try {`
213	`$res_req = $this->connexion->query($requete);`	214	`$res_req = $this->connexion->query($requete);`
214	`if ($res_req !== false) {`	215	`if ($res_req !== false) {`
215	`$retour = $res_req->fetchAll($this->$mode);`	216	`$retour = $res_req->fetchAll($this->$mode);`
216	`} else {`	217	`} else {`
217	`$retour = false;`	218	`$retour = false;`
-		219	`}`
-		220	`} catch (PDOException $e) {`
-		221	`$message = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s';`
-		222	`trigger_error(sprintf($message, $e->getFile(), $e->getLine(), $e->getMessage()), E_USER_WARNING);`
218	`}`	223	`}`
219	`break;`	224	`break;`
220	`case 'mysql':`	225	`case 'mysql':`
221	`$res = mysql_query($requete, $this->connexion);`	226	`$res = mysql_query($requete, $this->connexion);`
222	`$fonction_fetch = $this->$mode;`	227	`$fonction_fetch = $this->$mode;`
223	`while ($ligne = $fonction_fetch($res)) {`	228	`while ($ligne = $fonction_fetch($res)) {`
224	`$retour[] = $ligne;`	229	`$retour[] = $ligne;`
225	`}`	230	`}`
226	`break;`	231	`break;`
227	`case 'mysqli':`	232	`case 'mysqli':`
228	`$res = $this->connexion->query($requete);`	233	`$res = $this->connexion->query($requete);`
229	`$function_fetch = $this->$mode;`	234	`$function_fetch = $this->$mode;`
230	`while ($ligne = $res->$function_fetch()) {`	235	`while ($ligne = $res->$function_fetch()) {`
231	`$retour[] = $ligne;`	236	`$retour[] = $ligne;`
232	`}`	237	`}`
233	`break;`	238	`break;`
234	`case 'sqlite3':`	239	`case 'sqlite3':`
235	`$res = $this->connexion->query($requete);`	240	`$res = $this->connexion->query($requete);`
236	`while ($ligne = $res->fetch_array($this->ASSOC)) {`	241	`while ($ligne = $res->fetch_array($this->ASSOC)) {`
237	`if ($mode == $this->ASSOC) {`	242	`if ($mode == $this->ASSOC) {`
238	`$retour[] = $ligne;`	243	`$retour[] = $ligne;`
239	`} elseif ($mode == $this->OBJECT) {`	244	`} elseif ($mode == $this->OBJECT) {`
240	`// cas particulier de sqllite`	245	`// cas particulier de sqllite`
241	`// qui n'a pas de fonction fetch_object`	246	`// qui n'a pas de fonction fetch_object`
242	`$ligneObjet = new stdClass();`	247	`$ligneObjet = new stdClass();`
243	`foreach ($ligne as $colonne => $valeur) {`	248	`foreach ($ligne as $colonne => $valeur) {`
244	`$ligneObjet->$colonne = $valeur;`	249	`$ligneObjet->$colonne = $valeur;`
245	`}`	250	`}`
246	`$retour[] = $ligneObjet;`	251	`$retour[] = $ligneObjet;`
247	`}`	252	`}`
248	`}`	253	`}`
249	`break;`	254	`break;`
250	`}`	255	`}`
251		256
252	`return $retour;`	257	`return $retour;`
253	`}`	258	`}`
254		259
255	`/**`	260	`/**`
256	`* protège une chaine de caractères avant l'insertion dans la base de données`	261	`* protège une chaine de caractères avant l'insertion dans la base de données`
257	`*/`	262	`*/`
258	`final protected function proteger($chaine) {`	263	`final protected function proteger($chaine) {`
259		264
260	`// on ne se connecte que lors du premier appel à une requete`	265	`// on ne se connecte que lors du premier appel à une requete`
261	`if ($this->connexion == null) {`	266	`if ($this->connexion == null) {`
262	`$this->connecter();`	267	`$this->connecter();`
263	`}`	268	`}`
264		269
265	`$retour = $chaine;`	270	`$retour = $chaine;`
266		271
267	`switch ($this->abstraction) {`	272	`switch ($this->abstraction) {`
268	`case 'pdo':`	273	`case 'pdo':`
269	`$retour = $this->connexion->quote($chaine);`	274	`$retour = $this->connexion->quote($chaine);`
270	`break;`	275	`break;`
271	`case 'mysql':`	276	`case 'mysql':`
272	`$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';`	277	`$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"';`
273	`break;`	278	`break;`
274	`case 'mysqli':`	279	`case 'mysqli':`
275	`$retour = '"'.$this->connexion->real_escape_string($chaine).'"';`	280	`$retour = '"'.$this->connexion->real_escape_string($chaine).'"';`
276	`break;`	281	`break;`
277	`case 'sqlite3':`	282	`case 'sqlite3':`
278	`$retour = $this->connexion->escapeString($chaine);`	283	`$retour = $this->connexion->escapeString($chaine);`
279	`break;`	284	`break;`
280	`}`	285	`}`
281		286
282	`return $retour;`	287	`return $retour;`
283	`}`	288	`}`
284		289
285	`/**`	290	`/**`
286	`* initialise les constantes de classe à leur bonne valeur`	291	`* initialise les constantes de classe à leur bonne valeur`
287	`* et lance une exception si le protocole n'est pas bien défini`	292	`* et lance une exception si le protocole n'est pas bien défini`
288	`* @throws Exception`	293	`* @throws Exception`
289	`*/`	294	`*/`
290	`final public function initialiserProtocole() {`	295	`final public function initialiserProtocole() {`
291		296
292	`switch ($this->abstraction) {`	297	`switch ($this->abstraction) {`
293	`case 'pdo':`	298	`case 'pdo':`
294	`$this->ASSOC = PDO::FETCH_ASSOC;`	299	`$this->ASSOC = PDO::FETCH_ASSOC;`
295	`$this->OBJECT = PDO::FETCH_CLASS;`	300	`$this->OBJECT = PDO::FETCH_CLASS;`
296	`break;`	301	`break;`
297	`case 'mysql':`	302	`case 'mysql':`
298	`$this->ASSOC = 'mysql_fetch_assoc';`	303	`$this->ASSOC = 'mysql_fetch_assoc';`
299	`$this->OBJECT = 'mysql_fetch_object';`	304	`$this->OBJECT = 'mysql_fetch_object';`
300	`break;`	305	`break;`
301	`case 'mysqli':`	306	`case 'mysqli':`
302	`$this->ASSOC = 'fetch_assoc';`	307	`$this->ASSOC = 'fetch_assoc';`
303	`$this->OBJECT = 'fetch_object';`	308	`$this->OBJECT = 'fetch_object';`
304	`break;`	309	`break;`
305	`case 'sqlite3':`	310	`case 'sqlite3':`
306	`$this->ASSOC = 'SQLITE3_ASSOC';`	311	`$this->ASSOC = 'SQLITE3_ASSOC';`
307	`$this->OBJECT = 'SQLITE3_OBJECT';`	312	`$this->OBJECT = 'SQLITE3_OBJECT';`
308	`break;`	313	`break;`
309	`default:`	314	`default:`
310	`throw new Exception('Erreur : l\'abstraction '.$this->abstraction.' n\'est pas prise en charge');`	315	`throw new Exception('Erreur : l\'abstraction '.$this->abstraction.' n\'est pas prise en charge');`
311	`break;`	316	`break;`
312	`}`	317	`}`
313	`}`	318	`}`
314		319
315	`/**`	320	`/**`
316	`* Destructeur de classe, se contente de fermer explicitement la connexion`	321	`* Destructeur de classe, se contente de fermer explicitement la connexion`
317	`*/`	322	`*/`
318	`final public function __destruct() {`	323	`final public function __destruct() {`
319	`switch ($this->abstraction) {`	324	`switch ($this->abstraction) {`
320	`case 'pdo':`	325	`case 'pdo':`
321	`$this->connexion = null;`	326	`$this->connexion = null;`
322	`break;`	327	`break;`
323	`case 'mysql':`	328	`case 'mysql':`
324	`return mysql_close($this->connexion);`	329	`return mysql_close($this->connexion);`
325	`break;`	330	`break;`
326	`case 'mysqli':`	331	`case 'mysqli':`
327	`$this->connexion->close();`	332	`$this->connexion->close();`
328	`break;`	333	`break;`
329	`case 'sqlite3':`	334	`case 'sqlite3':`
330	`$this->connexion->close();`	335	`$this->connexion->close();`
331	`break;`	336	`break;`
332	`}`	337	`}`
333	`}`	338	`}`
334	`}`	339	`}`
335	`?>`	340	`?>`

Subversion Repositories Applications.framework

(root)/trunk/framework/Bdd.php @ 500 – Rev 140 → 143