2,8 → 2,8 |
// declare(encoding='UTF-8'); |
/** |
* Classe modèle, donc d'accés au données, elle ne devrait pas être appelée de l'extérieur. |
* Elle fait office d'abstraction légère de base de données en utilisant les objects PDO natifs |
* de PHP |
* Elle fait office d'abstraction légère de base de données en utilisant diveres possibilités |
* d'abstraction de base de données (PDO, mysql, mysqli, sqlite) |
* Elle est abstraite donc doit obligatoirement être étendue. |
* |
* PHP Version 5 |
21,6 → 21,19 |
abstract class Modele { |
|
/** |
* Mode de fetch associatif |
*/ |
private $ASSOC = ''; |
/** |
* Mode de fetch objet |
*/ |
private $OBJECT = ''; |
|
/** |
* abstraction de base de données utilisée |
*/ |
private $abstraction; |
/** |
* registre global |
*/ |
private $registre; |
64,6 → 77,7 |
final public function __construct() { |
// les différents paramètres nécessaires sont lus à partir du registre |
$this->registre = Registre::getInstance(); |
$this->abstraction = strtolower(Config::get('bdd_abstraction')); |
$this->type = Config::get('bdd_protocole'); |
$this->hote = Config::get('bdd_serveur'); |
$this->bdd_nom = Config::get('bdd_nom'); |
72,9 → 86,59 |
$this->encodage = Config::get('bdd_encodage'); |
|
$this->dsn = $this->type.':dbname='.$this->bdd_nom.';host='.$this->hote; |
$this->initialiserProtocole(); |
} |
|
/** |
* Connection à la base de données en utilisant les informations fournies par |
* le fichier de configuration. |
* private et final car n'a pas vocation a être appelée par l'utilisateur. |
* |
* @throws Exception une exception dans le cas ou là connexion échoue |
*/ |
final private function connecter() { |
|
switch ($this->abstraction) { |
case 'pdo': |
$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass); |
break; |
|
case 'mysql': |
$this->connexion = mysql_connect($this->hote,$this->utilisateur,$this->pass); |
if($this->connexion != null) { |
mysql_select_db($this->bdd_nom, $this->connexion); |
} else { |
throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration'); |
} |
break; |
|
case 'mysqli': |
$this->connexion = new mysqli($this->hote,$this->utilisateur,$this->pass, $this->bdd_nom); |
if(!$this->connexion) { |
throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration'); |
return; |
} |
break; |
|
case 'sqlite3': |
// cas particulier de sqllite, on considère que le nom de la base de données correspond au fichier à ouvrir |
$this->connexion = new SQLite3($this->bdd_nom); |
if(!$this->connexion) { |
throw new Exception('Erreur de connexion à la base de données, vérifiez les paramètres du fichier de configuration'); |
return; |
} |
break; |
|
default: |
$this->connexion = null; |
} |
|
if($this->encodage != null) { |
$this->requete("SET names '".$this->encodage."'"); |
} |
} |
|
/** |
* Fonction qui appelle la bonne fonction de requete suivant le type de bdd. |
* |
* @param string la requete à effectuer |
85,41 → 149,207 |
if ($this->connexion == null) { |
$this->connecter(); |
} |
return $this->connexion->query($requete); |
|
$retour = null; |
|
switch ($this->abstraction) { |
case 'pdo': |
$retour = $this->connexion->query($requete); |
break; |
|
case 'mysql': |
$retour = mysql_query($requete,$this->connexion); |
break; |
|
case 'mysqli': |
$retour = $this->connexion->query($requete); |
break; |
|
case 'sqlite3': |
$retour = $this->connexion->exec($requete); |
break; |
} |
|
return $retour; |
} |
|
/** |
* Connection à la base de données en utilisant les informations fournies par |
* le fichier de configuration. |
* private et final car n'a pas vocation a être appelée par l'utilisateur. |
* |
* @throws PDOException une exception dans le cas ou là connexion échoue |
*/ |
final private function connecter() { |
final protected function requeteUn($requete,$mode = 'ASSOC') { |
|
$this->connexion = new PDO($this->dsn, $this->utilisateur, $this->pass); |
if($this->encodage != null) { |
$this->requete("SET names '".$this->encodage."'"); |
} |
// on ne se connecte que lors du premier appel à une requete (lazy connexion) |
if ($this->connexion == null) { |
$this->connecter(); |
} |
|
$retour = null; |
|
switch ($this->abstraction) { |
case 'pdo': |
$res_req = $this->connexion->query($requete); |
$retour =$res_req->fetch($this->$mode); |
break; |
|
case 'mysql': |
$res = mysql_query($requete,$this->connexion); |
$fonction_fetch = $this->$mode; |
$retour = $fonction_fetch($res); |
break; |
|
case 'mysqli': |
$res = $this->connexion->query($requete); |
$fonction_fetch = $this->$mode; |
$retour = $res->$fonction_fetch(); |
break; |
|
case 'sqlite3': |
$retour = $this->connexion->querySingle($requete); |
break; |
} |
|
return $retour; |
} |
|
|
final protected function requeteTous($requete,$mode = 'ASSOC') { |
|
// on ne se connecte que lors du premier appel à une requete (lazy connexion) |
if ($this->connexion == null) { |
$this->connecter(); |
} |
|
$retour = null; |
|
switch ($this->abstraction) { |
case 'pdo': |
$res_req = $this->connexion->query($requete); |
$retour =$res_req->fetchAll($this->$mode); |
break; |
|
case 'mysql': |
$res = mysql_query($requete,$this->connexion); |
$fonction_fetch = $this->$mode; |
while($ligne = $fonction_fetch($res)) { |
$retour[] = $ligne; |
} |
break; |
|
case 'mysqli': |
$res = $this->connexion->query($requete); |
$function_fetch = $this->$mode; |
while($ligne = $res->$function_fetch()) { |
$retour[] = $ligne; |
} |
break; |
|
case 'sqlite3': |
$res = $this->connexion->query($requete); |
while($ligne = $res->fetch_array($this->ASSOC)) { |
if($mode == $this->ASSOC) { |
$retour[] = $ligne; |
} |
elseif($mode == $this->OBJECT){ |
// cas particulier de sqllite |
// qui n'a pas de fonction fetch_object |
$ligneObjet = new stdClass(); |
foreach($ligne as $colonne => $valeur) { |
$ligneObjet->$colonne = $valeur; |
} |
$retour [] = $ligneObjet; |
} |
} |
break; |
|
} |
|
return $retour; |
} |
|
/** |
* protège une chaine de caractères avant l'insertion dans la base de données |
*/ |
final protected function proteger($chaine) { |
|
// on ne se connecte que lors du premier appel à une requete |
if ($this->connexion == null) { |
$this->connecter(); |
} |
return $this->connexion->quote($chaine); |
|
$retour = $chaine; |
|
switch ($this->abstraction) { |
case 'pdo': |
$retour = $this->connexion->quote($chaine); |
break; |
|
case 'mysql': |
$retour = '"'.mysql_real_escape_string($chaine, $this->connexion).'"'; |
break; |
|
case 'mysqli': |
$retour = '"'.$this->connexion->real_escape_string($chaine).'"'; |
break; |
|
case 'sqlite3': |
$retour = $this->connexion->escapeString($chaine); |
break; |
} |
|
return $retour; |
} |
|
/** |
* initialise les constantes de classe à leur bonne valeur |
* et lance une exception si le protocole n'est pas bien défini |
* @throws Exception |
*/ |
final public function initialiserProtocole() { |
|
switch ($this->abstraction) { |
case 'pdo': |
$this->ASSOC = PDO::FETCH_ASSOC; |
$this->OBJECT = PDO::FETCH_CLASS; |
break; |
|
case 'mysql': |
$this->ASSOC = 'mysql_fetch_assoc'; |
$this->OBJECT = 'mysql_fetch_object'; |
break; |
|
case 'mysqli': |
$this->ASSOC = 'fetch_assoc'; |
$this->OBJECT = 'fetch_object'; |
break; |
|
case 'sqlite3': |
$this->ASSOC = 'SQLITE3_ASSOC'; |
$this->OBJECT = 'SQLITE3_OBJECT'; |
break; |
|
default: |
throw new Exception('Erreur : l\'abstraction '.$this->abstraction.' n\'est pas prise en charge'); |
break; |
} |
} |
|
/** |
* Destructeur de classe, se contente de fermer explicitement la connexion |
*/ |
final public function __destruct() { |
if ($this->connexion != null) { |
$this->connexion = null ; |
switch ($this->abstraction) { |
case 'pdo': |
$this->connexion = null; |
break; |
|
case 'mysql': |
return mysql_close($this->connexion); |
break; |
|
case 'mysqli': |
$this->connexion->close(); |
break; |
|
case 'sqlite3': |
$this->connexion->close(); |
break; |
} |
} |
} |