micro\db\Database

Complexity

Total Complexity

20

Size/Duplication

Total Lines	129
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	1

Importance

Changes	1
Bugs	0	Features	0

12 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	8	1
A	connect()	0	13	2
A	query()	0	3	1
B	prepareAndExecute()	0	16	7
A	getStatement()	0	8	2
A	execute()	0	3	1
A	getServerName()	0	3	1
A	setServerName()	0	3	1
A	prepareStatement()	0	3	1
A	bindValueFromStatement()	0	3	1
A	lastInserId()	0	3	1
A	getTablesName()	0	5	1

<?php
namespace micro\db;
use micro\cache\QueryCache;

/**
 * Classe d'accès aux Bases de données encapsulant un objet PDO
 * @author heron
 * @version 1.0.0.3
 * @package db
 *
 */
class Database {
	private $serverName;
	private $port;
	private $dbName;
	private $user;
	private $password;
	private $pdoObject;
	private $statements=[];

	/**
	 * Constructeur
	 * @param string $dbName
	 * @param string $serverName
	 * @param string $port
	 * @param string $user
	 * @param string $password
	 */
	public function __construct($dbName, $serverName = "localhost", $port = "3306",
			$user = "root", $password = "") {
		$this->dbName = $dbName;
		$this->serverName = $serverName;
		$this->port = $port;
		$this->user = $user;
		$this->password = $password;
	}

	/**
	 * Réalise la connexion à la base de données
	 */
	public function connect() {
		try {
			$this->pdoObject = new \PDO(
					'mysql:host=' . $this->serverName . ';dbname='
							. $this->dbName . ';port:' . $this->port,
					$this->user, $this->password);
			$this->pdoObject->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
			$this->pdoObject->exec("SET CHARACTER SET utf8");

		} catch (\PDOException $e) {
			print "Error!: " . $e->getMessage() . "<br/>";
		}
	}

	/**
	 * Exécute l'instruction SQL passée en paramètre et retourne un statement
	 * @param string $sql
	 * @return PDOStatement
	 */
	public function query($sql) {
		return $this->pdoObject->query($sql);
	}

	public function prepareAndExecute($sql,$useCache=NULL){
		$cache=(QueryCache::$active && $useCache!==false) || (!QueryCache::$active && $useCache===true);
		if($cache){
			$result=QueryCache::fetch($sql);
		}
		if($result===false){

The variable $result does not seem to be defined for all execution paths leading up to this point.

			$statement=$this->getStatement($sql);
			$statement->execute();
			$result= $statement->fetchAll();
			$statement->closeCursor();
			if($cache){
				QueryCache::store($sql, $result);
			}
		}
		return $result;
	}

	private function getStatement($sql){
		if(!isset($this->statements[$sql])){
			$this->statements[$sql]=$this->pdoObject->prepare($sql);
			$this->statements[$sql]->setFetchMode(\PDO::FETCH_ASSOC);

		}
		return $this->statements[$sql];
	}

	/**
	 * Exécute l'instruction sql $sql de mise à jour (INSERT, UPDATE ou DELETE)
	 * @return le nombre d'enregistrements affectés
	 */
	public function execute($sql) {
		return $this->pdoObject->exec($sql);
	}

	public function getServerName() {
		return $this->serverName;
	}

	public function setServerName($serverName) {
		$this->serverName = $serverName;
	}

	/**
	 * Prépare l'instruction $sql pour son exécution
	 * @param String $sql
	 * @return PDOStatement
	 */
	public function prepareStatement($sql){
		return $this->pdoObject->prepare($sql);
	}

	/**
	 * Affecte la valeur $value au paramétre $parameter
	 * @param PDOStatement $statement
	 * @param String $parameter
	 * @param mixed $value
	 * @return boolean
	 */
	public function bindValueFromStatement(\PDOStatement $statement,$parameter,$value){
		return $statement->bindValue(":".$parameter, $value);
	}

	/**
	 * retourne le dernier auto-increment généré
	 * @return integer
	 */
	public function lastInserId(){
		return $this->pdoObject->lastInsertId();
	}

	public function getTablesName(){
		$sql = 'SHOW TABLES';
		$query = $this->pdoObject->query($sql);
		return $query->fetchAll(\PDO::FETCH_COLUMN);
	}

}