Subversion Repositories Applications.referentiel

Rev

Rev 141 | Details | Compare with Previous | 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';
191 jpm 24
	protected $start = 0;
6 jpm 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
			$sortie = $this->messages;
24 jpm 63
			// 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
64
			// avec ce type d'erreur HTTP en php..
65
			// FIXME : comment récupérer en php le contenu de la réponse portant le code HTTP 424 ou 500
66
			$this->envoyerEnteteMessage();
6 jpm 67
		} else {
68
			$sortie = $donnees;
69
		}
70
 
71
		// Gestion de l'envoie du déboguage
24 jpm 72
		$this->envoyerEnteteDebogage();
6 jpm 73
 
74
		// Encodage au format et JSON et envoie sur la sortie standard
75
		$contenu = $json ? json_encode($sortie) : $sortie;
141 jpm 76
		$mime = $json ? 'application/json' : $mime;
6 jpm 77
		$this->envoyerContenu($encodage, $mime, $contenu);
78
	}
79
 
24 jpm 80
	protected function envoyerEnteteMessage() {
81
		if (!is_array($this->messages)) {
82
			$this->messages[] = $this->messages;
83
		}
84
		if (count($this->messages) != 0) {
85
			foreach ($this->messages as $cle => $val) {
86
				if (is_array($val)) {
87
					$this->messages[$cle] = print_r($val, true);
88
				}
89
			}
26 jpm 90
			header('X-MessageJrest-Data: '.json_encode($this->messages));
24 jpm 91
		}
92
	}
93
 
94
	protected function envoyerEnteteDebogage() {
6 jpm 95
		if (!is_array($this->debug)) {
96
			$this->debug[] = $this->debug;
97
		}
98
		if (count($this->debug) != 0) {
99
			foreach ($this->debug as $cle => $val) {
100
				if (is_array($val)) {
101
					$this->debug[$cle] = print_r($val, true);
102
				}
103
			}
26 jpm 104
			header('X-DebugJrest-Data: '.json_encode($this->debug));
6 jpm 105
		}
106
	}
107
 
108
	protected function envoyerContenu($encodage, $mime, $contenu) {
109
		header("Content-Type: $mime; charset=$encodage");
110
		print $contenu;
111
	}
112
 
113
	private function connecterPDO($config, $base = 'database') {
114
        $cfg = $config[$base];
115
		$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];
116
		try {
117
    		$PDO = new PDO($dsn, $cfg['username'], $cfg['password']);
118
		} catch (PDOException $e) {
119
    		echo 'La connexion à la base de donnée via PDO a échouée : ' . $e->getMessage();
120
		}
121
		// Passe en UTF-8 la connexion à la BDD
122
		$PDO->exec("SET NAMES 'utf8'");
123
		// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)
124
		$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
125
        return $PDO;
126
	}
127
 
51 jpm 128
	protected function executerRequete($requete, $message_echec) {
129
		try {
130
			$infos = $this->bdd->query($requete)->fetchAll(PDO::FETCH_ASSOC);
131
			if ($infos === false) {
132
				$this->messages[] = $message_echec;
133
			}
134
		} catch (PDOException $e) {
135
			$this->messages[] = sprintf($this->getTxt('sql_erreur_requete'), $e->getFile(), $e->getLine(), $e->getMessage(), $requete);
136
		}
137
		return $infos;
138
	}
139
 
6 jpm 140
	protected function getTxt($id) {
141
		$sortie = '';
142
		switch ($id) {
143
			case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;
51 jpm 144
			case 'sql_erreur_requete' : $sortie = "Requête echec.\nFichier : %s.\nLigne : %s.\nMessage : %s.\nRequête : %s"; break;
6 jpm 145
			default : $sortie = $id;
146
		}
147
		return $sortie;
148
	}
149
 
150
	protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {
151
		$sortie = array();
152
		foreach ($params_attendu as $num => $nom) {
153
			if (isset($params[$num]) && $params[$num] != '*') {
154
				if ($pourBDD) {
155
					$params[$num] = $this->bdd->quote($params[$num]);
156
				}
157
				$sortie[$nom] = $params[$num];
158
			}
159
		}
160
		return $sortie;
161
	}
23 jpm 162
 
163
	protected function traiterParametresPost($params_attendu, $params, $pourBDD = true) {
164
		$sortie = array();
165
		foreach ($params_attendu as $num => $nom) {
166
			if (isset($params[$nom]) && $params[$nom] != '') {
167
				if ($pourBDD) {
168
					$params[$nom] = $this->bdd->quote($params[$nom]);
169
				}
170
				$sortie[$nom] = $params[$nom];
171
			} else {
172
				if ($pourBDD) {
173
					$sortie[$nom] = 'NULL';
174
				} else {
175
					$sortie[$nom] = '';
176
				}
177
			}
178
		}
179
		return $sortie;
180
	}
26 jpm 181
 
182
	protected function traiterBddClauseIn($chaine) {
183
		$sortie = '';
184
		$chaine = trim($chaine, " '");
185
		if ($chaine != '') {
186
			$valeurs = explode(',', $chaine);
187
			foreach ($valeurs as $id => $valeur) {
188
				$valeurs[$id] = $this->bdd->quote($valeur);
189
			}
190
			$sortie = implode(',', $valeurs);
191
		}
192
		return $sortie;
193
	}
6 jpm 194
}
195
?>