Subversion Repositories Applications.referentiel

Rev

Rev 23 | Rev 26 | Go to most recent revision | 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';
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
				$verifier = array('NULL', "\n", "\r", "\\", "'", '"', "\x00", "\x1a", ';');
39
				$_GET[$get] = str_replace($verifier, '', $_GET[$get]);
40
				if (isset($_GET[$get]) && $_GET[$get] != '') {
41
					$this->$get = $_GET[$get];
42
				} else {
43
					$_GET[$get] = null;
44
				}
45
			}
46
		}
47
	}
48
 
49
	/**
50
	 * Méthode appelée quand aucun paramètre n'est passé dans l'url et avec une requête de type GET.
51
	 */
52
	public function getRessource() {
53
		$this->getElement(array());
54
	}
55
 
56
	protected function envoyer($donnees = null, $mime = 'text/html', $encodage = 'utf-8', $json = true) {
57
		// Traitements des messages d'erreurs et données
58
		if (count($this->messages) != 0) {
24 jpm 59
			header('HTTP/1.1 424 Method failure');
6 jpm 60
			$mime = 'text/html';
61
			$encodage = 'utf-8';
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
			if (is_null($donnees)) {
70
				$sortie = 'OK';
71
			}
72
		}
73
 
74
		// Gestion de l'envoie du déboguage
24 jpm 75
		$this->envoyerEnteteDebogage();
6 jpm 76
 
77
		// Encodage au format et JSON et envoie sur la sortie standard
78
		$contenu = $json ? json_encode($sortie) : $sortie;
79
		$this->envoyerContenu($encodage, $mime, $contenu);
80
	}
81
 
24 jpm 82
	protected function envoyerEnteteMessage() {
83
		if (!is_array($this->messages)) {
84
			$this->messages[] = $this->messages;
85
		}
86
		if (count($this->messages) != 0) {
87
			foreach ($this->messages as $cle => $val) {
88
				if (is_array($val)) {
89
					$this->messages[$cle] = print_r($val, true);
90
				}
91
			}
92
			header('X-MessageJrest-Data:'.json_encode($this->messages));
93
		}
94
	}
95
 
96
	protected function envoyerEnteteDebogage() {
6 jpm 97
		if (!is_array($this->debug)) {
98
			$this->debug[] = $this->debug;
99
		}
100
		if (count($this->debug) != 0) {
101
			foreach ($this->debug as $cle => $val) {
102
				if (is_array($val)) {
103
					$this->debug[$cle] = print_r($val, true);
104
				}
105
			}
106
			header('X-DebugJrest-Data:'.json_encode($this->debug));
107
		}
108
	}
109
 
110
	protected function envoyerContenu($encodage, $mime, $contenu) {
111
		header("Content-Type: $mime; charset=$encodage");
112
		print $contenu;
113
	}
114
 
115
	private function connecterPDO($config, $base = 'database') {
116
        $cfg = $config[$base];
117
		$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];
118
		try {
119
    		$PDO = new PDO($dsn, $cfg['username'], $cfg['password']);
120
		} catch (PDOException $e) {
121
    		echo 'La connexion à la base de donnée via PDO a échouée : ' . $e->getMessage();
122
		}
123
		// Passe en UTF-8 la connexion à la BDD
124
		$PDO->exec("SET NAMES 'utf8'");
125
		// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)
126
		$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
127
        return $PDO;
128
	}
129
 
130
	protected function getTxt($id) {
131
		$sortie = '';
132
		switch ($id) {
133
			case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;
134
			default : $sortie = $id;
135
		}
136
		return $sortie;
137
	}
138
 
139
	protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {
140
		$sortie = array();
141
		foreach ($params_attendu as $num => $nom) {
142
			if (isset($params[$num]) && $params[$num] != '*') {
143
				if ($pourBDD) {
144
					$params[$num] = $this->bdd->quote($params[$num]);
145
				}
146
				$sortie[$nom] = $params[$num];
147
			}
148
		}
149
		return $sortie;
150
	}
23 jpm 151
 
152
	protected function traiterParametresPost($params_attendu, $params, $pourBDD = true) {
153
		$sortie = array();
154
		foreach ($params_attendu as $num => $nom) {
155
			if (isset($params[$nom]) && $params[$nom] != '') {
156
				if ($pourBDD) {
157
					$params[$nom] = $this->bdd->quote($params[$nom]);
158
				}
159
				$sortie[$nom] = $params[$nom];
160
			} else {
161
				if ($pourBDD) {
162
					$sortie[$nom] = 'NULL';
163
				} else {
164
					$sortie[$nom] = '';
165
				}
166
			}
167
		}
168
		return $sortie;
169
	}
6 jpm 170
}
171
?>