Subversion Repositories Applications.gtt

Rev

Rev 104 | 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;
14 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
	*/
107
	public function consulter($requete, $parametres = null, $instancier = false)
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
		}
89 jpm 124
		if (GTT_DEBOGAGE) {
125
			trigger_error($requete, E_USER_NOTICE);
126
		}
75 jpm 127
		$resultat = $GLOBALS['db']->query($requete);
128
		(DB::isError($resultat)) ? trigger_error(GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete), E_USER_ERROR) : '' ;
129
		$tab_resultat = array();
130
		while ($donnees =& $resultat->fetchRow(DB_FETCHMODE_ASSOC)) {
131
			$tab_resultat[] = $this->basculerEnregistrementObjet($donnees, $instancier);
132
		}
133
		$resultat_nbre = count($tab_resultat);
95 jpm 134
		if ($resultat_nbre >= 1) {
75 jpm 135
			return $tab_resultat;
136
		} else if ($resultat_nbre == 0) {
137
			return false;
138
		}
139
	}
140
 
141
	/**
104 jpm 142
	* Ajouter un enregistrement dans la base de données.
143
	* @return true si ok, false si aucun enregistrement effectué
10 jpm 144
	*/
145
	public function ajouter()
146
	{
147
		$enregistrement = $this->basculerEnregistrementObjet($this);
148
		$sql_attributs = '';
149
		$sql_valeurs = '';
150
		foreach($enregistrement as $champ => $val) {
14 jpm 151
			if (!is_numeric($val)) {
152
				$val = '"'.$val.'"';
153
			}
10 jpm 154
			$sql_attributs .= $champ.', ';
155
			$sql_valeurs .= $val.', ';
156
		}
157
		$sql_attributs = trim($sql_attributs, ', ');
158
		$sql_valeurs = trim($sql_valeurs, ', ');
159
		$requete = 	'INSERT INTO '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' '.
160
					'( '.$sql_attributs.' ) '.
161
					'VALUES '.
162
					'( '.$sql_valeurs.' )';
14 jpm 163
		trigger_error($requete, E_USER_NOTICE);
10 jpm 164
		$resultat = $GLOBALS['db']->query($requete);
14 jpm 165
 
10 jpm 166
		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;
167
		$nbre_enregistrement_ajoute = $GLOBALS['db']->affectedRows();
168
		if ($nbre_enregistrement_ajoute == 1) {
169
			return true;
170
		} elseif ($nbre_enregistrement_ajoute == 0) {
171
			return false;
172
		}
173
	}
14 jpm 174
 
10 jpm 175
	/**
104 jpm 176
	* Modifier un enregistrement dans la base de données.
177
	* @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.
178
	* @return true si ok, false si aucun enregistrement effectué.
10 jpm 179
	*/
48 jpm 180
	public function modifier($Ancien = null)
10 jpm 181
	{
182
		$enregistrement = $this->basculerEnregistrementObjet($this);
183
		$sql_where = '';
184
		$sql_set = '';
185
		foreach($enregistrement as $champ => $val) {
14 jpm 186
			if (!is_numeric($val)) {
187
				$val = '"'.$val.'"';
188
			}
48 jpm 189
			$sql_set .= $champ.' = '.$val.', ';
190
			$classe = get_class($this);
191
			if ($Ancien instanceof $classe) {
192
				$methode = $this->donnerMethodeGetAvecChamp($champ);
193
				$val = $Ancien->$methode();
194
				if (!is_numeric($val)) {
195
					$val = '"'.$val.'"';
196
				}
197
			}
10 jpm 198
			if (preg_match('/_id_/', $champ)) {
199
				$sql_where .= $champ.' = '.$val.' AND ';
200
			}
201
		}
202
		$sql_set = trim($sql_set, ', ').' ';
203
		$sql_where = trim($sql_where, ' AND ').' ';
204
		$requete = 	'UPDATE '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' SET '.$sql_set.'WHERE '.$sql_where;
14 jpm 205
		trigger_error($requete, E_USER_NOTICE);
10 jpm 206
		$resultat = $GLOBALS['db']->query($requete);
14 jpm 207
 
10 jpm 208
		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;
209
		$nbre_enregistrement_ajoute = $GLOBALS['db']->affectedRows();
210
		if ($nbre_enregistrement_ajoute == 1) {
211
			return true;
212
		} elseif ($nbre_enregistrement_ajoute == 0) {
213
			return false;
214
		}
215
	}
14 jpm 216
 
10 jpm 217
	/**
104 jpm 218
	* Supprimer un enregistrement dans la base de données.
219
	* @return true si ok, false si aucun enregistrement effectué
10 jpm 220
	*/
221
	public function supprimer()
222
	{
223
		$enregistrement = $this->basculerEnregistrementObjet($this);
224
		$sql_where = '';
225
		foreach($enregistrement as $champ => $val) {
14 jpm 226
			if (!is_numeric($val)) {
227
				$val = '"'.$val.'"';
228
			}
10 jpm 229
			//if (preg_match('/_id_/', $champ)) {
230
				$sql_where .= $champ.' = '.$val.' AND ';
231
			//}
232
		}
233
		$sql_where = trim($sql_where, ' AND ').' ';
234
		$requete = 'DELETE FROM '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' WHERE '.$sql_where ;
14 jpm 235
		trigger_error($requete, E_USER_NOTICE);
10 jpm 236
		$resultat = $GLOBALS['db']->query($requete);
237
		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;
238
 
50 jpm 239
		$nbre_enregistrement_suppr = $GLOBALS['db']->affectedRows();
240
		if ($nbre_enregistrement_suppr == 1) {
10 jpm 241
			return true;
50 jpm 242
		} elseif ($nbre_enregistrement_suppr == 0) {
10 jpm 243
			return false;
244
		}
245
	}
92 jpm 246
 
110 jpm 247
	/** Mettre à NULL les champs de l'objet*/
248
	public function initialiser()
249
	{
250
		foreach ($this->getCorrespondance() as $champ => $attribut) {
251
			$methode = $this->donnerMethodeGetAvecAttribut($attribut);
252
			$this->$methode(null);
253
		}
254
	}
255
 
92 jpm 256
	/** Afficher l'objet courrant. */
257
	public function afficher()
258
	{
259
		echo '<pre>'.print_r($this, true).'</pre>';
260
	}
10 jpm 261
}
262
?>