Subversion Repositories Applications.referentiel

Rev

Rev 19 | 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
				$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) {
59
			header('HTTP/1.1 500 Internal Server Error');
60
			$mime = 'text/html';
61
			$encodage = 'utf-8';
62
			$sortie = $this->messages;
63
		} else {
64
			$sortie = $donnees;
65
			if (is_null($donnees)) {
66
				$sortie = 'OK';
67
			}
68
		}
69
 
70
		// Gestion de l'envoie du déboguage
71
		$this->envoyerDebogage();
72
 
73
		// Encodage au format et JSON et envoie sur la sortie standard
74
		$contenu = $json ? json_encode($sortie) : $sortie;
75
		$this->envoyerContenu($encodage, $mime, $contenu);
76
	}
77
 
78
	protected function envoyerDebogage() {
79
		if (!is_array($this->debug)) {
80
			$this->debug[] = $this->debug;
81
		}
82
		if (count($this->debug) != 0) {
83
			foreach ($this->debug as $cle => $val) {
84
				if (is_array($val)) {
85
					$this->debug[$cle] = print_r($val, true);
86
				}
87
			}
88
			header('X-DebugJrest-Data:'.json_encode($this->debug));
89
		}
90
	}
91
 
92
	protected function envoyerContenu($encodage, $mime, $contenu) {
93
		header("Content-Type: $mime; charset=$encodage");
94
		print $contenu;
95
	}
96
 
97
	private function connecterPDO($config, $base = 'database') {
98
        $cfg = $config[$base];
99
		$dsn = $cfg['phptype'].':dbname='.$cfg['database'].';host='.$cfg['hostspec'];
100
		try {
101
    		$PDO = new PDO($dsn, $cfg['username'], $cfg['password']);
102
		} catch (PDOException $e) {
103
    		echo 'La connexion à la base de donnée via PDO a échouée : ' . $e->getMessage();
104
		}
105
		// Passe en UTF-8 la connexion à la BDD
106
		$PDO->exec("SET NAMES 'utf8'");
107
		// Affiche les erreurs détectées par PDO (sinon mode silencieux => aucune erreur affiché)
108
		$PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
109
        return $PDO;
110
	}
111
 
112
	protected function getTxt($id) {
113
		$sortie = '';
114
		switch ($id) {
115
			case 'sql_erreur' : $sortie = 'Requête echec. Fichier : "%s". Ligne : "%s". Message : %s'; break;
116
			default : $sortie = $id;
117
		}
118
		return $sortie;
119
	}
120
 
121
	protected function traiterParametresUrl($params_attendu, $params, $pourBDD = true) {
122
		$sortie = array();
123
		foreach ($params_attendu as $num => $nom) {
124
			if (isset($params[$num]) && $params[$num] != '*') {
125
				if ($pourBDD) {
126
					$params[$num] = $this->bdd->quote($params[$num]);
127
				}
128
				$sortie[$nom] = $params[$num];
129
			}
130
		}
131
		return $sortie;
132
	}
133
}
134
?>