Subversion Repositories Applications.gtt

<?php

abstract class aGttSql {

	/*** Attributs : */

	private $base_de_donnees = GTT_BDD_NOM;

	protected $table_nom;

	protected $correspondance;

	/*** Accesseurs : */

	// Base De Donnees

	function getBaseDeDonnees()

	{

		return $this->base_de_donnees;

	}

	function setBaseDeDonnees($bdd)

	{

		$this->base_de_donnees = $bdd;

	}

	// TableNom

	function getTableNom()

	{

		return $this->dao_table_nom;

	}

	function setTableNom($tn)

	{

		$this->dao_table_nom = $tn;

	}

	// Correspondance

	function getCorrespondance($champ = null)

	{

		if (!is_null($champ)) {

			return $this->dao_correspondance[$champ];

		}

		return $this->dao_correspondance;

	}

	function setCorrespondance($c)

	{

		$this->dao_correspondance = $c;

	}

	/*** Méthodes : */

    /** Instancie un objet utilisateur à partir d'un enregistrement issu de la base de donnée ou l'inverse.

	* Cette métohode permet de s'abstraire des noms des champs présent dans la base de donnée.

	*/

	protected function basculerEnregistrementObjet($donnees, $instancier = false)

	{

		$classe = get_class($this);

		if (is_array($donnees)) {

			if ($instancier) {

				foreach ($this->getCorrespondance() as $champ => $attribut) {

					if (isset($donnees[$champ]) && !is_null($donnees[$champ])) {

						$methode = $this->donnerMethodeSetAvecAttribut($attribut);

						$this->$methode($donnees[$champ]);

					}

				}

			} else {

				$Objet = new $classe;

				foreach ($this->getCorrespondance() as $champ => $attribut) {

					if (isset($donnees[$champ]) && !is_null($donnees[$champ])) {

						$methode = $this->donnerMethodeSetAvecAttribut($attribut);

						$Objet->$methode($donnees[$champ]);

					}

				}

				return $Objet;

			}

		} else if ($donnees instanceof $classe) {

			$enregistrement = array();

			foreach ($this->getCorrespondance() as $champ => $attribut) {

				$methode = $this->donnerMethodeGetAvecAttribut($attribut);

				if (method_exists($donnees, $methode)) {

					if (!is_null($donnees->$methode())) {

				 		$enregistrement[$champ] = $donnees->$methode();

					}

				}

			}

			return $enregistrement;

		}

	}

	private function donnerMethodeGetAvecAttribut($attribut)

	{

		return 'get'.str_replace(' ', '', ucwords(str_replace('_', ' ', $attribut)));

	}

	private function donnerMethodeGetAvecChamp($champ)

	{

		return 'get'.str_replace(' ', '', ucwords(str_replace('_', ' ', $this->getCorrespondance($champ))));

	}

	private function donnerMethodeSetAvecAttribut($attribut)

	{

		return 'set'.str_replace(' ', '', ucwords(str_replace('_', ' ', $attribut)));

	}

	private function donnerMethodeSetAvecChamp($champ)

	{

		return 'set'.str_replace(' ', '', ucwords(str_replace('_', ' ', $this->getCorrespondance($champ))));

	}

	/**

	* Consulter un ou plusieurs enregistrements dans la base de données.

	* Chaque requête comportant des paramêtre doivent les inclures sous la forme "#0" pour le paramêtre 0,

	* puis "#1" pour le paramêtre 1 et ainsi de suite.

	* Exemple : SELECT * FROM gestion_projet WHERE gp_id_projet = #0

	* ou		SELECT * FROM gestion_projet WHERE gp_nom_projet = "#0"

	* @return mixed false, un objet, un tableau d'objet ou rien et instancie l'objet courant.

	*/

	public function consulter($requete = '', $parametres = null, $instancier = false)

	{

		// Formatage de la requête avec les paramêtres s'il y en a

		if (!is_null($parametres)) {

			if (!is_array($parametres)) {

				$parametres = array('#0' => $parametres);

			} else {

				// Ajout d'un # devant chaque clé numérique

				if (count($parametres) > 0) {

					foreach ($parametres as $c => $v) {

						$parametres['#'.$c] = $v;

					}

				}

			}

			// les indices numériques contiennent des copies des valeurs présentes

			// dans les indices [#0], [#1]... => wtf ? si le préfixe de table

			// contient un chiffre, celui-ci sera remplacé et tout va péter

			// => bricolage cracra, on enlève tous les indices numériques

			foreach ($parametres as $k => &$v) {

				if (is_numeric($k)) {

					unset($parametres[$k]);

				}

			}

			// Remplacement dans la requete par les valeurs des paramêtres

			$requete = strtr($requete, $parametres);

		}

		if (GTT_DEBOGAGE_SQL) {

			trigger_error($requete, E_USER_NOTICE);

		}

		$tps = microtime(true);

		$resultat = $GLOBALS['db']->query($requete);

		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));

		(DB::isError($resultat)) ? trigger_error(GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete), E_USER_ERROR) : '' ;

		$tab_resultat = array();

		while ($donnees =& $resultat->fetchRow(DB_FETCHMODE_ASSOC)) {

			$tab_resultat[] = $this->basculerEnregistrementObjet($donnees, $instancier);

		}

		$resultat_nbre = count($tab_resultat);

		if ($resultat_nbre >= 1) {

			return $tab_resultat;

		} else if ($resultat_nbre == 0) {

			return false;

		}

	}

	/**

	* Ajouter un enregistrement dans la base de données.

	* @return true si ok, false si aucun enregistrement effectué

	*/

	public function ajouter()

	{

		$enregistrement = $this->basculerEnregistrementObjet($this);

		$sql_attributs = '';

		$sql_valeurs = '';

		foreach($enregistrement as $champ => $val) {

			if (!is_numeric($val)) {

				$val = '"'.$val.'"';

			}

			$sql_attributs .= $champ.', ';

			$sql_valeurs .= $val.', ';

		}

		$sql_attributs = trim($sql_attributs, ', ');

		$sql_valeurs = trim($sql_valeurs, ', ');

		$requete = 	'INSERT INTO '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' '.

					'( '.$sql_attributs.' ) '.

					'VALUES '.

					'( '.$sql_valeurs.' )';

		if (GTT_DEBOGAGE_SQL) {

			trigger_error($requete, E_USER_NOTICE);

		}

		$tps = microtime(true);

		$resultat = $GLOBALS['db']->query($requete);

		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));

		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;

		$nbre_enregistrement_ajoute = $GLOBALS['db']->affectedRows();

		if ($nbre_enregistrement_ajoute == 1) {

			return true;

		} elseif ($nbre_enregistrement_ajoute == 0) {

			return false;

		}

	}

	/**

	* Modifier un enregistrement dans la base de données.

	* @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.

	* @return true si ok, false si aucun enregistrement effectué.

	*/

	public function modifier($Ancien = null)

	{

		$enregistrement = $this->basculerEnregistrementObjet($this);

		$sql_where = '';

		$sql_set = '';

		foreach($enregistrement as $champ => $val) {

			if (!is_numeric($val)) {

				$val = '"'.$val.'"';

			}

			$sql_set .= $champ.' = '.$val.', ';

			$classe = get_class($this);

			if ($Ancien instanceof $classe) {

				$methode = $this->donnerMethodeGetAvecChamp($champ);

				$val = $Ancien->$methode();

				if (!is_numeric($val)) {

					$val = '"'.$val.'"';

				}

			}

			if (preg_match('/_id_/', $champ)) {

				$sql_where .= $champ.' = '.$val.' AND ';

			}

		}

		$sql_set = trim($sql_set, ', ').' ';

		$sql_where = trim($sql_where, ' AND ').' ';

		$requete = 	'UPDATE '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' SET '.$sql_set.'WHERE '.$sql_where;

		if (GTT_DEBOGAGE_SQL) {

			trigger_error($requete, E_USER_NOTICE);

		}

		$tps = microtime(true);

		$resultat = $GLOBALS['db']->query($requete);

		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));

		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;

		$nbre_enregistrement_ajoute = $GLOBALS['db']->affectedRows();

		if ($nbre_enregistrement_ajoute == 1) {

			return true;

		} elseif ($nbre_enregistrement_ajoute == 0) {

			return false;

		}

	}

	/**

	* Supprimer un enregistrement dans la base de données.

	* @return true si ok, false si aucun enregistrement effectué

	*/

	public function supprimer()

	{

		$enregistrement = $this->basculerEnregistrementObjet($this);

		$sql_where = '';

		foreach($enregistrement as $champ => $val) {

			if (!is_numeric($val)) {

				$val = '"'.$val.'"';

			}

			//if (preg_match('/_id_/', $champ)) {

				$sql_where .= $champ.' = '.$val.' AND ';

			//}

		}

		$sql_where = trim($sql_where, ' AND ').' ';

		$requete = 'DELETE FROM '.$this->getBaseDeDonnees().'.'.$this->getTableNom().' WHERE '.$sql_where ;

		if (GTT_DEBOGAGE_SQL) {

			trigger_error($requete, E_USER_NOTICE);

		}

		$tps = microtime(true);

		$resultat = $GLOBALS['db']->query($requete);

		$GLOBALS['_GTT_']['chrono']->setTempsSql($tps, microtime(true));

		(DB::isError($resultat)) ? die (GestionnaireErreur::retournerErreurSql(__FILE__, __LINE__, $resultat->getMessage(), $requete)) : '' ;

		$nbre_enregistrement_suppr = $GLOBALS['db']->affectedRows();

		if ($nbre_enregistrement_suppr == 1) {

			return true;

		} elseif ($nbre_enregistrement_suppr == 0) {

			return false;

		}

	}

	/** Mettre à NULL les champs de l'objet*/

	public function initialiser()

	{

		foreach ($this->getCorrespondance() as $champ => $attribut) {

			$methode = $this->donnerMethodeSetAvecAttribut($attribut);

			$this->$methode(null);

		}

	}

	/** Afficher l'objet courrant. */

	public function afficher()

	{

		echo '<pre>'.print_r($this, true).'</pre>';

	}

}

?>