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

Subversion Repositories Applications.framework

(root)/branches/v0.2-buhl/framework/Modele.php @ 495 – Rev 426 → 474