Database::setDbType() - Code Metrics - Inspection of "manyToMany annot bug fixed + quote in SqlUtils" - phpMv/ubiquity - Measure and Improve Code Quality continuously with Scrutinizer

Completed

Push — master ( 9f7bd0...42ad31 )

by Jean-Christophe

created 2018-03-12 19:36 UTC

Database::setDbType() A

↳ Parent: Database

Complexity

Conditions	1
Paths	1

Size

Total Lines	4
Code Lines	3

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	4
rs	10
c	0
b	0
f	0
cc	1
eloc	3
nc	1
nop	1

<?php

namespace Ubiquity\db;

use Ubiquity\cache\database\DbCache;
use Ubiquity\exceptions\CacheException;

/**
 * PDO Database class
 * @author jc
 * @version 1.0.0.3
 * @package db
 *
 */
class Database {
	private $dbType;
	private $serverName;
	private $port;
	private $dbName;
	private $user;
	private $password;
	private $pdoObject;
	private $statements=[ ];
	private $cache;
	private $options;

	/**
	 * Constructor
	 * @param string $dbName
	 * @param string $serverName
	 * @param string $port
	 * @param string $user
	 * @param string $password
	 * @param array $options
	 * @param boolean|string $cache
	 */
	public function __construct($dbType,$dbName, $serverName="localhost", $port="3306", $user="root", $password="", $options=[],$cache=false) {
		$this->dbType=$dbType;
		$this->dbName=$dbName;
		$this->serverName=$serverName;
		$this->port=$port;
		$this->user=$user;
		$this->password=$password;
		if(isset($options["quote"]))
			SqlUtils::$quote=$options["quote"];
		$this->options=$options;
		if ($cache !== false) {
			if(\is_callable($cache)){
				$this->cache=$cache();
			}else{
				if(\class_exists($cache)){
					$this->cache=new $cache();
				}else{
					throw new CacheException($cache." is not a valid value for database cache");
				}
			}
		}
	}

	/**
	 * Creates the PDO instance
	 */
	public function connect() {
		$this->pdoObject=new \PDO($this->dbType.':host=' . $this->serverName . ';dbname=' . $this->dbName . ';charset=UTF8;port:' . $this->port, $this->user, $this->password,$this->options);
		$this->pdoObject->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
	}

	/**
	 * Executes an SQL statement, returning a result set as a PDOStatement object
	 * @param string $sql
	 * @return \PDOStatement
	 */
	public function query($sql) {
		return $this->pdoObject->query($sql);
	}

	/**
	 * @param string $tableName
	 * @param string $condition
	 * @param array|string $fields
	 * @param boolean|null $useCache
	 * @return boolean|array
	 */
	public function prepareAndExecute($tableName, $condition,$fields,$useCache=NULL) {
		$cache=(DbCache::$active && $useCache !== false) || (!DbCache::$active && $useCache === true);
		$result=false;
		if ($cache) {
			$result=$this->cache->fetch($tableName, $condition);
		}
		if ($result === false) {
			$fields=SqlUtils::getFieldList($fields,$tableName);
function acceptsInteger($int) { }

$x = '123'; // string "123"

// Instead of
acceptsInteger($x);

// we recommend to use
acceptsInteger((integer) $x);
			$statement=$this->getStatement("SELECT {$fields} FROM " . $tableName . $condition);
			$statement->execute();
			$result=$statement->fetchAll();
			$statement->closeCursor();
			if ($cache) {
				$this->cache->store($tableName, $condition, $result);
			}
		}
		return $result;
	}

	/**
	 * @param string $sql
	 * @return \PDOStatement
	 */
	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];
	}

	/**
	 * Execute an SQL statement and return the number of affected rows (INSERT, UPDATE or DELETE)
	 * @param string $sql
	 * @return int the number of rows that were modified or deleted by the SQL statement you issued
	 */
	public function execute($sql) {
		return $this->pdoObject->exec($sql);
	}

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

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

	/**
	 * Prepares a statement for execution and returns a statement object
	 * @param String $sql
	 * @return \PDOStatement
	 */
	public function prepareStatement($sql) {
		return $this->pdoObject->prepare($sql);
	}

	/**
	 * Sets $value to $parameter
	 * @param \PDOStatement $statement
	 * @param String $parameter
	 * @param mixed $value
	 * @return boolean
	 */
	public function bindValueFromStatement(\PDOStatement $statement, $parameter, $value) {
		return $statement->bindValue(":" . $parameter, $value);
	}

	/**
	 * Returns the last insert id
	 * @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);
	}

	/**
	 * Returns the number of records in $tableName that respects the condition passed as a parameter
	 * @param string $tableName
	 * @param string $condition Partie suivant le WHERE d'une instruction SQL
	 */
	public function count($tableName, $condition='') {
		if ($condition != '')
			$condition=" WHERE " . $condition;
			return $this->query("SELECT COUNT(*) FROM " . $tableName . $condition)->fetchColumn();
	}

	public function isConnected(){
		return ($this->pdoObject!==null && $this->pdoObject instanceof \PDO);
	}

	public function setDbType($dbType) {
		$this->dbType=$dbType;
		return $this;
	}

	public function getPort() {
		return $this->port;
	}

	public function getDbName() {
		return $this->dbName;
	}

	public function getUser() {
		return $this->user;
	}

	public function getPdoObject() {
		return $this->pdoObject;
	}

}


1			<?php
2
3			namespace Ubiquity\db;
4
5			use Ubiquity\cache\database\DbCache;
6			use Ubiquity\exceptions\CacheException;
7
8			/**
9			* PDO Database class
10			* @author jc
11			* @version 1.0.0.3
12			* @package db
13			*
14			*/
15			class Database {
16			private $dbType;
17			private $serverName;
18			private $port;
19			private $dbName;
20			private $user;
21			private $password;
22			private $pdoObject;
23			private $statements=[ ];
24			private $cache;
25			private $options;
26
27			/**
28			* Constructor
29			* @param string $dbName
30			* @param string $serverName
31			* @param string $port
32			* @param string $user
33			* @param string $password
34			* @param array $options
35			* @param boolean\|string $cache
36			*/
37			public function __construct($dbType,$dbName, $serverName="localhost", $port="3306", $user="root", $password="", $options=[],$cache=false) {
38			$this->dbType=$dbType;
39			$this->dbName=$dbName;
40			$this->serverName=$serverName;
41			$this->port=$port;
42			$this->user=$user;
43			$this->password=$password;
44			if(isset($options["quote"]))
45			SqlUtils::$quote=$options["quote"];
46			$this->options=$options;
47			if ($cache !== false) {
48			if(\is_callable($cache)){
49			$this->cache=$cache();
50			}else{
51			if(\class_exists($cache)){
52			$this->cache=new $cache();
53			}else{
54			throw new CacheException($cache." is not a valid value for database cache");
55			}
56			}
57			}
58			}
59
60			/**
61			* Creates the PDO instance
62			*/
63			public function connect() {
64			$this->pdoObject=new \PDO($this->dbType.':host=' . $this->serverName . ';dbname=' . $this->dbName . ';charset=UTF8;port:' . $this->port, $this->user, $this->password,$this->options);
65			$this->pdoObject->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
66			}
67
68			/**
69			* Executes an SQL statement, returning a result set as a PDOStatement object
70			* @param string $sql
71			* @return \PDOStatement
72			*/
73			public function query($sql) {
74			return $this->pdoObject->query($sql);
75			}
76
77			/**
78			* @param string $tableName
79			* @param string $condition
80			* @param array\|string $fields
81			* @param boolean\|null $useCache
82			* @return boolean\|array
83			*/
84			public function prepareAndExecute($tableName, $condition,$fields,$useCache=NULL) {
85			$cache=(DbCache::$active && $useCache !== false) \|\| (!DbCache::$active && $useCache === true);
86			$result=false;
87			if ($cache) {
88			$result=$this->cache->fetch($tableName, $condition);
89			}
90			if ($result === false) {
91			$fields=SqlUtils::getFieldList($fields,$tableName);
			0 ignored issues – show Documentation introduced 2018-03-12 19:37 UTC by Report Bug Copy Issue Report `$tableName` is of type `string`, but the function expects a `boolean`. It seems like the type of the argument is not accepted by the function/method which you are calling. In some cases, in particular if PHP’s automatic type-juggling kicks in this might be fine. In other cases, however this might be a bug. We suggest to add an explicit type cast like in the following example: function acceptsInteger($int) { } $x = '123'; // string "123" // Instead of acceptsInteger($x); // we recommend to use acceptsInteger((integer) $x); Loading history...
92			$statement=$this->getStatement("SELECT {$fields} FROM " . $tableName . $condition);
93			$statement->execute();
94			$result=$statement->fetchAll();
95			$statement->closeCursor();
96			if ($cache) {
97			$this->cache->store($tableName, $condition, $result);
98			}
99			}
100			return $result;
101			}
102
103			/**
104			* @param string $sql
105			* @return \PDOStatement
106			*/
107			private function getStatement($sql) {
108			if (!isset($this->statements[$sql])) {
109			$this->statements[$sql]=$this->pdoObject->prepare($sql);
110			$this->statements[$sql]->setFetchMode(\PDO::FETCH_ASSOC);
111			}
112			return $this->statements[$sql];
113			}
114
115			/**
116			* Execute an SQL statement and return the number of affected rows (INSERT, UPDATE or DELETE)
117			* @param string $sql
118			* @return int the number of rows that were modified or deleted by the SQL statement you issued
119			*/
120			public function execute($sql) {
121			return $this->pdoObject->exec($sql);
122			}
123
124			public function getServerName() {
125			return $this->serverName;
126			}
127
128			public function setServerName($serverName) {
129			$this->serverName=$serverName;
130			}
131
132			/**
133			* Prepares a statement for execution and returns a statement object
134			* @param String $sql
135			* @return \PDOStatement
136			*/
137			public function prepareStatement($sql) {
138			return $this->pdoObject->prepare($sql);
139			}
140
141			/**
142			* Sets $value to $parameter
143			* @param \PDOStatement $statement
144			* @param String $parameter
145			* @param mixed $value
146			* @return boolean
147			*/
148			public function bindValueFromStatement(\PDOStatement $statement, $parameter, $value) {
149			return $statement->bindValue(":" . $parameter, $value);
150			}
151
152			/**
153			* Returns the last insert id
154			* @return integer
155			*/
156			public function lastInserId() {
157			return $this->pdoObject->lastInsertId();
158			}
159
160			public function getTablesName() {
161			$sql='SHOW TABLES';
162			$query=$this->pdoObject->query($sql);
163			return $query->fetchAll(\PDO::FETCH_COLUMN);
164			}
165
166			/**
167			* Returns the number of records in $tableName that respects the condition passed as a parameter
168			* @param string $tableName
169			* @param string $condition Partie suivant le WHERE d'une instruction SQL
170			*/
171			public function count($tableName, $condition='') {
172			if ($condition != '')
173			$condition=" WHERE " . $condition;
174			return $this->query("SELECT COUNT(*) FROM " . $tableName . $condition)->fetchColumn();
175			}
176
177			public function isConnected(){
178			return ($this->pdoObject!==null && $this->pdoObject instanceof \PDO);
179			}
180
181			public function setDbType($dbType) {
182			$this->dbType=$dbType;
183			return $this;
184			}
185
186			public function getPort() {
187			return $this->port;
188			}
189
190			public function getDbName() {
191			return $this->dbName;
192			}
193
194			public function getUser() {
195			return $this->user;
196			}
197
198			public function getPdoObject() {
199			return $this->pdoObject;
200			}
201
202			}
203

phpMv / ubiquity

Push — master ( 9f7bd0...42ad31 )

Database::setDbType() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like