PHP 5 - CLASSE MYSQL (STYLE MYSQLI)

<?php
/**
 * Interface de liaison avec le SGBD
 *
 */
interface iFab {
	public function Query($sql);
	public function AffectedRows();
	public function Close();
	public function Ping();
	public function Prepare($sql);
	public function ConnectTo();
}
/**
 * Interface de préparation des commandes SQL
 *
 */
interface iStatement {
	public function __construct($sql, $link);
	public function BindResult($format);
	public function Execute();
}
/**
 * Interface de dialogue des resultats SQL
 *
 */
interface iResult {
	public function __construct($query, $sql);
	public function FetchAll();
	public function FetchRow();
	public function FetchArray();
	public function FetchAssoc();
	public function FetchObject($classname=NULL, $args=NULL);
	public function NumRows();
	public function Seek($offset);
	public function Free();
}


/**
 * Classe d'abstraction des résultats SQL
 *
 */
abstract class DatabaseResult {
	/**
	 * Contient la ressource de la requète
	 *
	 * @var resource
	 */
	protected $query;
	/**
	 * Contient la requète SQL
	 *
	 * @var string
	 */
	protected $sql;
}
/**
 * Classe d'abstraction de la préparation des requètes SQL
 *
 */
abstract class DatabaseStatement {
	/**
	 * Requète SQL
	 *
	 * @var string
	 */
	protected $sql;
	/**
	 * Lien de communication avec le SGBD
	 *
	 * @var resource
	 */
	protected $link;
}
/**
 * Classe d'abstraction de toutes les bases de données.
 *
 */
abstract class DatabaseFactory {
	/**
	 * Nom de l'hôte
	 *
	 * @var string
	 */
	protected $host;
	/**
	 * Nom d'utilisateur
	 *
	 * @var string
	 */
	protected $user;
	/**
	 * Mot de passe
	 *
	 * @var string
	 */
	protected $passwd;
	/**
	 * Nom de la base de donnée
	 *
	 * @var string
	 */
	protected $dbname;	
	
	/**
	 * Identifiant de connection unique
	 *
	 * @var mixed
	 */
	protected $link;
	
	/**
	 * Instancie une classe utilisant une connection avec un SGBD
	 *
	 * @param string $host
	 * @param string $user
	 * @param string $passwd
	 * @param string $dbname
	 */
	public function __construct($host, $user, $passwd, $dbname) {
		$this->host = $host;
		$this->user = $user;
		$this->passwd = $passwd;
		$this->dbname = $dbname;
	}
	/**
	 * Méthode de connection au serveur de SGBD
	 *
	 */
	abstract protected function ConnectTo();	
}
/**
 * Classe d'abstraction pour le SGBD MySQL
 *
 */
abstract class MySQLFab extends DatabaseFactory implements iFab {

	/**
	 * Récupère l'encodage du serveur
	 *
	 * @var int
	 */
	public $encoding;
	/**
	 * Récupère les infos du client
	 *
	 * @var string
	 */
	public $client_info;
	/**
	 * Récupère les infos de l'hôte
	 *
	 * @var string
	 */
	public $host_info;
	/**
	 * Récupère les infos du protocole utilisé
	 *
	 * @var int
	 */
	public $proto_info;
	/**
	 * Récupère les infos du serveur
	 *
	 * @var string
	 */
	public $server_info;
	/**
	 * Récupère le numéro d'ID du thread
	 *
	 * @var int
	 */
	public $thread_id;
	
	/**
	 * Méthode de connection au SGBD MySQL
	 *
	 */
	protected function ConnectTo() {
		
	 $this->link = mysql_connect($this->host, $this->user, $this->passwd);
			if ( $this->link === FALSE )
			     throw new MySQLException(1, $this->host, $this->user);
			if ( !mysql_select_db($this->dbname, $this->link) ) 
			     throw new MySQLException(mysql_error(), $this->dbname);			
	       
  $this->encoding = mysql_client_encoding($this->link);
		$this->client_info = mysql_get_client_info();
		$this->host_info = mysql_get_host_info($this->link);
		$this->proto_info = mysql_get_proto_info($this->link);
		$this->server_info = mysql_get_server_info($this->link);
		$this->thread_id = mysql_thread_id($this->link);
		
	}	
	/**
	 * Méthode pour envoyer une requète MySQL
	 *
	 * @param string $sql
	 * @return MySQLResult Object / int
	 */
	public function Query($sql) {
		
		try {
			 if ( ! isset($this->link) ) $this->ConnectTo();
			$query = @mysql_query($sql, $this->link);
		  if ( $query === FALSE )
		       throw new MySQLException(10, $sql);
		} catch ( MySQLException $e ) {
			 die ( $e->GetMessage() );
		}
		
		 if ( strtolower(substr($sql, 0, 6)) === 'select' )
		      return new MySQLResult($query, $sql);
		 else 
		      return $this->AffectedRows();
		
	}
	/**
	 * Retourne le nombre de champs modifiés ou insérés
	 *
	 * @return int
	 */
	public function AffectedRows() {
		return mysql_affected_rows($this->link);
	}	
	/**
	 * Ferme la connection avec le SGBD MySQL
	 *
	 */
	public function Close() {
		
		try {
		  if ( !mysql_close($this->link) )
		       throw new MySQLException(3, $this->host, $this->user);
		 unset($this->link);
 	} catch ( MySQLException $e ) {
	 	 die( $e->GetMessage() );
	 }
	
	}
	/**
	 * Effectue un ping sur le SGBD
	 *
	 * @return bool
	 */
	public function Ping() {
		return mysql_ping($this->link);
	}	
	/**
	 * Renvoit un objet pour la préparation des requètes SQL
	 *
	 * @param string $sql
	 * @return MySQLStatement Object
	 */
	public function Prepare($sql) {
		return new MySQLStatement($sql, $this->link);		
	}
}


/**
 * Classe de gestion MySQL en type Singleton
 *
 */
class MySQLSingle extends MySQLFab {
 
	/**
	 * Gestion de la connection unique
	 *
	 * @var MySQL resource
	 */
 static protected $_link;
 
 /**
  * Instancie la classe et vérifie si une connection existe déja
  *
  * @param string $host
  * @param string $user
  * @param string $passwd
  * @param string $dbname
  */
	public function __construct($host='localhost', $user='root', $passwd='', $dbname='blog') {
		parent::__construct($host, $user, $passwd, $dbname);
		 if ( isset(self::$_link) ) $this->link = self::$_link;
	}
	/**
	 * Overloading de la connection à la base de donnée
	 *
	 */
	protected function ConnectTo() {
		parent::ConnectTo();
		self::$_link = $this->link;	       		
	}	
}
/**
 * Classe de gestion MySQL en type Multiton
 *
 */
class MySQLMulti extends MySQLFab {
	
	/**
	 * Défini les liens de connections existantes
	 *
	 * @var array
	 */
	static protected $_links = array();
	
	/**
	 * Instancie le multiton
	 *
	 * @param string $host
	 * @param string $user
	 * @param string $passwd
	 * @param string $dbname
	 */
	public function __construct($host='localhost', $user='root', $passwd='', $dbname='blog') {
  parent::__construct($host, $user, $passwd, $dbname);
		 if ( isset(self::$_links[$host.$user]) )
   	    $this->link = self::$_links[$host.$user];	
	}
	/**
	 * Overloading de la connection MySQL
	 *
	 */
	protected function ConnectTo() {
		parent::ConnectTo();
		self::$_links[$this->host.$this->user] = $this->link;		
	}
}


/**
 * Classe de résultat MySQL
 *
 */
class MySQLResult extends DatabaseResult implements iResult {
	public function __construct($query, $sql) {
		$this->query = $query;
		$this->sql = $sql;
	}
	public function FetchAll() {
		$a = array();
  	while ( $data = mysql_fetch_array($this->query) )
			        $a[] = $data;
	 return $a;
	}
	public function FetchRow() {
		return mysql_fetch_row($this->query);
	}
	public function FetchArray() {
		return mysql_fetch_array($this->query);
	}
	public function FetchAssoc() {
		return mysql_fetch_assoc($this->query);
	}
	public function FetchObject($classname=NULL, $args=NULL) {
		return mysql_fetch_object($this->link, $classname, $args);
	}
	public function NumRows() {
		return mysql_num_rows($this->query);
	}
	public function Seek($offset) {
		
		try {
			 if ( !mysql_data_seek($this->query, (int) $offset) )
			      throw new MySQLException(11, $this->sql);
		} catch ( MySQLException $e ) {
			 die ( $e->GetMessage() );
		}
		
	}
	public function Free() {
		
		try {
			 if ( !mysql_free_result($this->query) ) 
			      throw new MySQLException(12, $this->sql);
			unset($this);
		} catch ( MySQLException $e ) {
			 die ( $e->GetMessage() );
		}
		
	}
}
/**
 * Classe de traitement pour MySQL
 *
 */
class MySQLStatement extends DatabaseStatement implements iStatement {
	public function __construct($sql, $link) {
		$this->sql = $sql;
		$this->link = $link;
	}
	public function BindResult($format) {
		
		 for ($i=1, $n=strlen($format); $i<=$n; $i++) {
		      switch (strtolower($format[$i-1])) {
		      	case 'i': 
		      	         $a = func_get_arg($i);
		      	         $this->sql = str_replace('{'.$i.'}', (int) $a, $this->sql);
		      	         break;
		      	case 's':
		      		        $a = func_get_arg($i);
		      		        $this->sql = str_replace('{'.$i.'}', mysql_real_escape_string($a, $this->link), $this->sql);
		      		        break;		      	
		      }
	  } 

	}
	public function Execute() {
		
		try {
			 if ( ! isset($this->link) ) $this->ConnectTo();
			$query = @mysql_query($this->sql, $this->link);
		  if ( $query === FALSE )
		       throw new MySQLException(10, $this->sql);
		} catch ( MySQLException $e ) {
			 die ( $e->GetMessage() );
		}
		
		 if ( strtolower(substr($this->sql, 0, 6)) === 'select' )
		      return new MySQLResult($query, $this->sql);
		 else 
		      return $this->AffectedRows();
	}
}


class MySQLException extends Exception {
	
	static $xmlfile;
	static $lang = 'fr';
	
	public function __construct($errno) {
	 
	//	if ( !isset(self::$xmlfile) ) self::$xmlfile = simplexml_load_file('./xml/db/'.self::$lang.'.php');
		
		// Manque le parsing !
		
		parent::__construct($errno);	
		
		
	}
	
	
}
?>

<?php
// En utilisation, cela donne :
$db = new MySQLSingle('host', 'user', 'passwd', 'dbname');
$query = $db->query('SELECT montruc FROM machin WHERE x = 1);
$data = $query->FetchArray();
$query->Free();

echo $data['montruc']; 
// Bref, ca marche comme avant :p
// Autre facon de faire :

$sql = $db->prepare('SELECT machin, chose FROM truc WHERE untruc = {1} AND autretruc = "{2}"');
$sql->BindResult('is', $une_variable, $une_autre_variable);
$query = $sql->Execute();

$data = $query->FetchRow();
echo $data[0];

// Ca marche aussi :)
?>