Subversion Repositories Applications.gtt

Rev

Rev 118 | Go to most recent revision | Details | Compare with Previous | Last modification | View Log | RSS feed

Rev Author Line No. Line
10 jpm 1 
<?php
2 
 
3 
abstract class aGttSql {
14 jpm 4 
 
10 jpm 5 
	/*** Attributs : */
6 
	private $base_de_donnees = GTT_BDD_NOM;
7 
	protected $table_nom;
8 
	protected $correspondance;
118 jpm 9 
 
10 jpm 10 
	/*** Accesseurs : */
14 jpm 11 
 
10 jpm 12 
	// Base De Donnees
13 
	function getBaseDeDonnees()
14 
	{
15 
		return $this->base_de_donnees;
16 
	}
17 
	function setBaseDeDonnees($bdd)
18 
	{
19 
		$this->base_de_donnees = $bdd;
20 
	}
21 
	// TableNom
22 
	function getTableNom()
23 
	{
24 
		return $this->dao_table_nom;
25 
	}
26 
	function setTableNom($tn)
27 
	{
28 
		$this->dao_table_nom = $tn;
29 
	}
30 
	// Correspondance
48 jpm 31 
	function getCorrespondance($champ = null)
10 jpm 32 
	{
48 jpm 33 
		if (!is_null($champ)) {
34 
			return $this->dao_correspondance[$champ];
35 
		}
10 jpm 36 
		return $this->dao_correspondance;
37 
	}
38 
	function setCorrespondance($c)
39 
	{
40 
		$this->dao_correspondance = $c;
41 
	}
14 jpm 42 
 
104 jpm 43 
	/*** Méthodes : */
14 jpm 44 
 
104 jpm 45 
    /** Instancie un objet utilisateur à partir d'un enregistrement issu de la base de donnée ou l'inverse.
46 
	* Cette métohode permet de s'abstraire des noms des champs présent dans la base de donnée.
10 jpm 47 
	*/
48 
	protected function basculerEnregistrementObjet($donnees, $instancier = false)
14 jpm 49 
	{
10 jpm 50 
		$classe = get_class($this);
51 
		if (is_array($donnees)) {
52 
			if ($instancier) {
53 
				foreach ($this->getCorrespondance() as $champ => $attribut) {
54 
					if (isset($donnees[$champ]) && !is_null($donnees[$champ])) {
48 jpm 55 
						$methode = $this->donnerMethodeSetAvecAttribut($attribut);
10 jpm 56 
						$this->$methode($donnees[$champ]);
57 
					}
58 
				}
59 
			} else {
60 
				$Objet = new $classe;
61 
				foreach ($this->getCorrespondance() as $champ => $attribut) {
62 
					if (isset($donnees[$champ]) && !is_null($donnees[$champ])) {
48 jpm 63 
						$methode = $this->donnerMethodeSetAvecAttribut($attribut);
10 jpm 64 
						$Objet->$methode($donnees[$champ]);
65 
					}
66 
				}
67 
				return $Objet;
68 
			}
69 
		} else if ($donnees instanceof $classe) {
70 
			$enregistrement = array();
71 
			foreach ($this->getCorrespondance() as $champ => $attribut) {
48 jpm 72 
				$methode = $this->donnerMethodeGetAvecAttribut($attribut);
10 jpm 73 
				if (method_exists($donnees, $methode)) {
14 jpm 74 
					if (!is_null($donnees->$methode())) {
10 jpm 75 
				 		$enregistrement[$champ] = $donnees->$methode();
76 
					}
77 
				}
78 
			}
79 
			return $enregistrement;
80 
		}
81 
	}
48 jpm 82 
	private function donnerMethodeGetAvecAttribut($attribut)
83 
	{
84 
		return 'get'.str_replace(' ', '', ucwords(str_replace('_', ' ', $attribut)));
85 
	}
86 
	private function donnerMethodeGetAvecChamp($champ)
87 
	{
88 
		return 'get'.str_replace(' ', '', ucwords(str_replace('_', ' ', $this->getCorrespondance($champ))));
89 
	}
90 
	private function donnerMethodeSetAvecAttribut($attribut)
91 
	{
92 
		return 'set'.str_replace(' ', '', ucwords(str_replace('_', ' ', $attribut)));
93 
	}
94 
	private function donnerMethodeSetAvecChamp($champ)
95 
	{
96 
		return 'set'.str_replace(' ', '', ucwords(str_replace('_', ' ', $this->getCorrespondance($champ))));
97 
	}
14 jpm 98 
 
10 jpm 99 
	/**
104 jpm 100 
	* Consulter un ou plusieurs enregistrements dans la base de données.
101 
	* Chaque requête comportant des paramêtre doivent les inclures sous la forme "#0" pour le paramêtre 0,
102 
	* puis "#1" pour le paramêtre 1 et ainsi de suite.
75 jpm 103 
	* Exemple : SELECT * FROM gestion_projet WHERE gp_id_projet = #0
104 
	* ou		SELECT * FROM gestion_projet WHERE gp_nom_projet = "#0"
105 
	* @return mixed false, un objet, un tableau d'objet ou rien et instancie l'objet courant.
106 
	*/
173 mathias 107 
	public function consulter($requete = '', $parametres = null, $instancier = false)
75 jpm 108 
	{
104 jpm 109 
		// Formatage de la requête avec les paramêtres s'il y en a
75 jpm 110 
		if (!is_null($parametres)) {
111 
			if (!is_array($parametres)) {
112 
				$parametres = array('#0' => $parametres);
113 
			} else {
104 jpm 114 
				// Ajout d'un # devant chaque clé numérique
75 jpm 115 
				if (count($parametres) > 0) {
116 
					foreach ($parametres as $c => $v) {
117 
						$parametres['#'.$c] = $v;
118 
					}
119 
				}
120 
			}
104 jpm 121 
			// Remplacement dans la requete par les valeurs des paramêtres
75 jpm 122 
			$requete = strtr($requete, $parametres);
123 
		}
118 jpm 124 
		if (GTT_DEBOGAGE_SQL) {
89 jpm 125 
			trigger_error($requete, E_USER_NOTICE);
126 
		}
118 jpm 127 
		$tps = microtime(true);
75 jpm 128 
		$resultat = $GLOBALS['db']->query($requete);
118 jpm 129 
		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));
75 jpm 130 
		(DB::isError($resultat)) ? trigger_error(GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete), E_USER_ERROR) : '' ;
131 
		$tab_resultat = array();
132 
		while ($donnees =& $resultat->fetchRow(DB_FETCHMODE_ASSOC)) {
133 
			$tab_resultat[] = $this->basculerEnregistrementObjet($donnees, $instancier);
134 
		}
135 
		$resultat_nbre = count($tab_resultat);
95 jpm 136 
		if ($resultat_nbre >= 1) {
75 jpm 137 
			return $tab_resultat;
138 
		} else if ($resultat_nbre == 0) {
139 
			return false;
140 
		}
141 
	}
142 
 
143 
	/**
104 jpm 144 
	* Ajouter un enregistrement dans la base de données.
145 
	* @return true si ok, false si aucun enregistrement effectué
10 jpm 146 
	*/
147 
	public function ajouter()
148 
	{
149 
		$enregistrement = $this->basculerEnregistrementObjet($this);
150 
		$sql_attributs = '';
151 
		$sql_valeurs = '';
152 
		foreach($enregistrement as $champ => $val) {
14 jpm 153 
			if (!is_numeric($val)) {
154 
				$val = '"'.$val.'"';
155 
			}
10 jpm 156 
			$sql_attributs .= $champ.', ';
157 
			$sql_valeurs .= $val.', ';
158 
		}
159 
		$sql_attributs = trim($sql_attributs, ', ');
160 
		$sql_valeurs = trim($sql_valeurs, ', ');
161 
		$requete = 	'INSERT INTO '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' '.
162 
					'( '.$sql_attributs.' ) '.
163 
					'VALUES '.
164 
					'( '.$sql_valeurs.' )';
118 jpm 165 
		if (GTT_DEBOGAGE_SQL) {
166 
			trigger_error($requete, E_USER_NOTICE);
167 
		}
168 
		$tps = microtime(true);
10 jpm 169 
		$resultat = $GLOBALS['db']->query($requete);
118 jpm 170 
		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));
10 jpm 171 
		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;
172 
		$nbre_enregistrement_ajoute = $GLOBALS['db']->affectedRows();
173 
		if ($nbre_enregistrement_ajoute == 1) {
174 
			return true;
175 
		} elseif ($nbre_enregistrement_ajoute == 0) {
176 
			return false;
177 
		}
178 
	}
14 jpm 179 
 
10 jpm 180 
	/**
104 jpm 181 
	* Modifier un enregistrement dans la base de données.
182 
	* @param object l'ancien objet contenant les valeurs de clés primaires non modifiées. Laissé vide si on ne modifie pas les clés.
183 
	* @return true si ok, false si aucun enregistrement effectué.
10 jpm 184 
	*/
48 jpm 185 
	public function modifier($Ancien = null)
10 jpm 186 
	{
187 
		$enregistrement = $this->basculerEnregistrementObjet($this);
188 
		$sql_where = '';
189 
		$sql_set = '';
190 
		foreach($enregistrement as $champ => $val) {
14 jpm 191 
			if (!is_numeric($val)) {
192 
				$val = '"'.$val.'"';
193 
			}
48 jpm 194 
			$sql_set .= $champ.' = '.$val.', ';
195 
			$classe = get_class($this);
196 
			if ($Ancien instanceof $classe) {
197 
				$methode = $this->donnerMethodeGetAvecChamp($champ);
198 
				$val = $Ancien->$methode();
199 
				if (!is_numeric($val)) {
200 
					$val = '"'.$val.'"';
201 
				}
202 
			}
10 jpm 203 
			if (preg_match('/_id_/', $champ)) {
204 
				$sql_where .= $champ.' = '.$val.' AND ';
205 
			}
206 
		}
207 
		$sql_set = trim($sql_set, ', ').' ';
208 
		$sql_where = trim($sql_where, ' AND ').' ';
209 
		$requete = 	'UPDATE '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' SET '.$sql_set.'WHERE '.$sql_where;
118 jpm 210 
		if (GTT_DEBOGAGE_SQL) {
211 
			trigger_error($requete, E_USER_NOTICE);
212 
		}
213 
		$tps = microtime(true);
10 jpm 214 
		$resultat = $GLOBALS['db']->query($requete);
118 jpm 215 
		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));
10 jpm 216 
		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;
217 
		$nbre_enregistrement_ajoute = $GLOBALS['db']->affectedRows();
218 
		if ($nbre_enregistrement_ajoute == 1) {
219 
			return true;
220 
		} elseif ($nbre_enregistrement_ajoute == 0) {
221 
			return false;
222 
		}
223 
	}
14 jpm 224 
 
10 jpm 225 
	/**
104 jpm 226 
	* Supprimer un enregistrement dans la base de données.
227 
	* @return true si ok, false si aucun enregistrement effectué
10 jpm 228 
	*/
229 
	public function supprimer()
230 
	{
231 
		$enregistrement = $this->basculerEnregistrementObjet($this);
232 
		$sql_where = '';
233 
		foreach($enregistrement as $champ => $val) {
14 jpm 234 
			if (!is_numeric($val)) {
235 
				$val = '"'.$val.'"';
236 
			}
10 jpm 237 
			//if (preg_match('/_id_/', $champ)) {
238 
				$sql_where .= $champ.' = '.$val.' AND ';
239 
			//}
240 
		}
241 
		$sql_where = trim($sql_where, ' AND ').' ';
242 
		$requete = 'DELETE FROM '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' WHERE '.$sql_where ;
118 jpm 243 
		if (GTT_DEBOGAGE_SQL) {
244 
			trigger_error($requete, E_USER_NOTICE);
245 
		}
246 
		$tps = microtime(true);
10 jpm 247 
		$resultat = $GLOBALS['db']->query($requete);
118 jpm 248 
		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));
10 jpm 249 
		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;
250 
 
50 jpm 251 
		$nbre_enregistrement_suppr = $GLOBALS['db']->affectedRows();
252 
		if ($nbre_enregistrement_suppr == 1) {
10 jpm 253 
			return true;
50 jpm 254 
		} elseif ($nbre_enregistrement_suppr == 0) {
10 jpm 255 
			return false;
256 
		}
257 
	}
92 jpm 258 
 
110 jpm 259 
	/** Mettre à NULL les champs de l'objet*/
260 
	public function initialiser()
261 
	{
262 
		foreach ($this->getCorrespondance() as $champ => $attribut) {
118 jpm 263 
			$methode = $this->donnerMethodeSetAvecAttribut($attribut);
110 jpm 264 
			$this->$methode(null);
265 
		}
266 
	}
267 
 
92 jpm 268 
	/** Afficher l'objet courrant. */
269 
	public function afficher()
270 
	{
271 
		echo '<pre>'.print_r($this, true).'</pre>';
272 
	}
10 jpm 273 
}
274 
?>