Subversion Repositories Applications.referentiel

Rev

Go to most recent revision | Details | Last modification | View Log | RSS feed

Rev Author Line No. Line
6 jpm 1
<?php
2
/**
3
 * Classe mère abstraite contenant les méthodes génériques des services des Référentiels.
4
 * Encodage en entrée : utf8
5
 * Encodage en sortie : utf8
6
 *
7
 * @category	Php 5.2
8
 * @package		Referentiel
9
 * @author		Jean-Pascal MILCENT <jpm@tela-botanica.org>
10
 * @license		GPL v3 <http://www.gnu.org/licenses/gpl.txt>
11
 * @license		CECILL v2 <http://www.cecill.info/licences/Licence_CeCILL_V2-en.txt>
12
 * @copyright	2010 Tela-Botanica
13
 * @version		$Id$
14
 */
15
abstract class Ref {
16
 
17
	public $config;
18
	protected $bdd;
19
	protected $messages = array();
20
	protected $debug = array();
21
	protected $distinct = false;
22
	protected $orderby = null;
23
	protected $formatRetour = 'objet';
24
	protected $start = 0;
25
	protected $limit = 150;
26
 
27
	public function __construct($config, $demarrer_session = true) {
28
		// Tableau contenant la config de Jrest
29
		$this->config = $config;
30
 
31
		// Connection à la base de données
32
		$this->bdd = $this->connecterPDO($this->config, 'database');
33
 
34
		// Nettoyage du $_GET (sécurité)
35
		if (isset($_GET)) {
36
			$get_params = array('orderby', 'distinct', 'start', 'limit', 'formatRetour');
37
			foreach ($get_params as $get) {
38 jpm 38
				if (isset($_GET[$get])) {
39
					$verifier = array('NULL', "\n", "\r", "\\", "'", '"', "\x00", "\x1a", ';');
40
					$_GET[$get] = strip_tags(str_replace($verifier, '', $_GET[$get]));
41
					if ($_GET[$get] != '') {
42
						$this->$get = $_GET[$get];
43
					} else {
44
						$_GET[$get] = null;
45
					}
6 jpm 46
				}
47
			}
48
		}
49
	}
50
 
51
	/**
52
	 * Méthode appelée quand aucun paramètre n'est passé dans l'url et avec une requête de type GET.
53
	 */
54
	public function getRessource() {
55
		$this->getElement(array());
56
	}
57
 
58
	protected function envoyer($donnees = null, $mime = 'text/html', $encodage = 'utf-8', $json = true) {
59
		// Traitements des messages d'erreurs et données
60
		if (count($this->messages) != 0) {
24 jpm 61
			header('HTTP/1.1 424 Method failure');
6 jpm 62
			$mime = 'text/html';
63
			$encodage = 'utf-8';
64
			$sortie = $this->messages;
24 jpm 65
			// En plus de la réponse, nous passons les messages dans l'entete car la réponse ne peut pas être récupérée
66
			// avec ce type d'erreur HTTP en php..
67
			// FIXME : comment récupérer en php le contenu de la réponse portant le code HTTP 424 ou 500
68
			$this->envoyerEnteteMessage();
6 jpm 69
		} else {
70
			$sortie = $donnees;
71
		}
72
 
73
		// Gestion de l'envoie du déboguage
24 jpm 74
		$this->envoyerEnteteDebogage();
6 jpm 75
 
76
		// Encodage au format et JSON et envoie sur la sortie standard
77
		$contenu = $json ? json_encode($sortie) : $sortie;
78
		$this->envoyerContenu($encodage, $mime, $contenu);
79
	}
80
 
24 jpm 81
	protected function envoyerEnteteMessage() {
82
		if (!is_array($this->messages)) {
83
			$this->messages[] = $this->messages;
84
		}
85
		if (count($this->messages) != 0) {
86
			foreach ($this->messages as $cle => $val) {
87
				if (is_array($val)) {
88
					$this->messages[$cle] = print_r($val, true);
89
				}
90
			}
26 jpm 91
			header('X-MessageJrest-Data: '.json_encode($this->messages));
24 jpm 92
		}
93
	}
94
 
95
	protected function envoyerEnteteDebogage() {
6 jpm 96
		if (!is_array($this->debug)) {
97
			$this->debug[] = $this->debug;
98
		}
99
		if (count($this->debug) != 0) {
100
			foreach ($this->debug as $cle => $val) {
101
				if (is_array($val)) {
102
					$this->debug[$cle] = print_r($val, true);
103
				}
104
			}
26 jpm 105
			header('X-DebugJrest-Data: '.json_encode($this->debug));
6 jpm 106
		}
107
	}
108
 
109
	protected function envoyerContenu($encodage, $mime, $contenu) {
110
		header("Content-Type: $mime; charset=$encodage");
111
		print $contenu;
112
	}
113
 
114
	private function connecterPDO($config, $base = 'database') {
115
        $cfg = $config[$base];
116
		$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];
117
		try {
118
    		$PDO = new PDO($dsn, $cfg['username'], $cfg['password']);
119
		} catch (PDOException $e) {
120
    		echo 'La connexion à la base de donnée via PDO a échouée : ' . $e->getMessage();
121
		}
122
		// Passe en UTF-8 la connexion à la BDD
123
		$PDO->exec("SET NAMES 'utf8'");
124
		// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)
125
		$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
126
        return $PDO;
127
	}
128
 
51 jpm 129
	protected function executerRequete($requete, $message_echec) {
130
		try {
131
			$infos = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
132
			if ($infos === false) {
133
				$this->messages[] = $message_echec;
134
			}
135
		} catch (PDOException $e) {
136
			$this->messages[] = sprintf($this->getTxt('sql_erreur_requete'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
137
		}
138
		return $infos;
139
	}
140
 
6 jpm 141
	protected function getTxt($id) {
142
		$sortie = '';
143
		switch ($id) {
144
			case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;
51 jpm 145
			case 'sql_erreur_requete' : $sortie = "Requête echec.\nFichier : %s.\nLigne : %s.\nMessage : %s.\nRequête : %s"; break;
6 jpm 146
			default : $sortie = $id;
147
		}
148
		return $sortie;
149
	}
150
 
151
	protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {
152
		$sortie = array();
153
		foreach ($params_attendu as $num => $nom) {
154
			if (isset($params[$num]) && $params[$num] != '*') {
155
				if ($pourBDD) {
156
					$params[$num] = $this->bdd->quote($params[$num]);
157
				}
158
				$sortie[$nom] = $params[$num];
159
			}
160
		}
161
		return $sortie;
162
	}
23 jpm 163
 
164
	protected function traiterParametresPost($params_attendu, $params, $pourBDD = true) {
165
		$sortie = array();
166
		foreach ($params_attendu as $num => $nom) {
167
			if (isset($params[$nom]) && $params[$nom] != '') {
168
				if ($pourBDD) {
169
					$params[$nom] = $this->bdd->quote($params[$nom]);
170
				}
171
				$sortie[$nom] = $params[$nom];
172
			} else {
173
				if ($pourBDD) {
174
					$sortie[$nom] = 'NULL';
175
				} else {
176
					$sortie[$nom] = '';
177
				}
178
			}
179
		}
180
		return $sortie;
181
	}
26 jpm 182
 
183
	protected function traiterBddClauseIn($chaine) {
184
		$sortie = '';
185
		$chaine = trim($chaine, " '");
186
		if ($chaine != '') {
187
			$valeurs = explode(',', $chaine);
188
			foreach ($valeurs as $id => $valeur) {
189
				$valeurs[$id] = $this->bdd->quote($valeur);
190
			}
191
			$sortie = implode(',', $valeurs);
192
		}
193
		return $sortie;
194
	}
6 jpm 195
}
196
?>