PDOWrapper::inTransaction() - Code Metrics - Inspection of "Fixed doc on setVar" - phpMv/ubiquity - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Pull Request — master (#97)

by Gildonei

created 2020-01-30 12:06 UTC

PDOWrapper::inTransaction() A

↳ Parent: PDOWrapper

Complexity

Conditions	1
Paths	1

Size

Total Lines	2
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Code Coverage

Tests	0
CRAP Score	2

Importance

Changes

Metric	Value
eloc	1
c	0
b	0
f	0
dl	0
loc	2
ccs	0
cts	2
cp	0
rs	10
cc	1
nc	1
nop	0
crap	2

<?php

namespace Ubiquity\db\providers\pdo;

use Ubiquity\db\providers\AbstractDbWrapper;

/**
 * Ubiquity\db\providers$PDOWrapper
 * This class is part of Ubiquity
 *
 * @author jcheron <[email protected]>
 * @version 1.0.0
 * @property \PDO $dbInstance
 *
 */
class PDOWrapper extends AbstractDbWrapper {
	protected static $savepointsDrivers = [ 'pgsql' => true,'mysql' => true,'sqlite' => true ];
	private static $quotes = [ 'mysql' => '`','sqlite' => '"','pgsql' => '' ];
	protected $transactionLevel = 0;
	protected $dbType;

	public function __construct($dbType = 'mysql') {
		$this->quote = self::$quotes [$dbType] ?? '';
		$this->dbType = $dbType;
	}

	public function fetchAllColumn($statement, array $values = null, string $column = null) {
		$result = false;
		if ($statement->execute ( $values )) {
			$result = $statement->fetchAll ( \PDO::FETCH_COLUMN, $column );
		}
		$statement->closeCursor ();
		return $result;
	}

	public function lastInsertId() {
		return $this->dbInstance->lastInsertId ();
	}

	public function fetchAll($statement, array $values = null, $mode = null) {
		$result = false;
		if ($statement->execute ( $values )) {
			$result = $statement->fetchAll ( $mode );
		}
		$statement->closeCursor ();
		return $result;
	}

	public function fetchOne($statement, array $values = null, $mode = null) {
		$result = false;
		if ($statement->execute ( $values )) {
			$result = $statement->fetch ( $mode );
		}
		$statement->closeCursor ();
		return $result;
	}

	public static function getAvailableDrivers() {
		return \PDO::getAvailableDrivers ();
	}

	public function prepareStatement(string $sql) {
		return $this->dbInstance->prepare ( $sql );
	}

	public function fetchColumn($statement, array $values = null, int $columnNumber = null) {
		if ($statement->execute ( $values )) {
			return $statement->fetchColumn ( $columnNumber );
		}
		return false;
	}

	public function getStatement($sql) {
		$st = $this->dbInstance->prepare ( $sql );
		$st->setFetchMode ( \PDO::FETCH_ASSOC );
		return $st;
	}

	public function execute($sql) {
		return $this->dbInstance->exec ( $sql );
	}

	public function connect(string $dbType, $dbName, $serverName, string $port, string $user, string $password, array $options) {
		$options [\PDO::ATTR_ERRMODE] = \PDO::ERRMODE_EXCEPTION;
		$this->dbInstance = new \PDO ( $this->getDSN ( $serverName, $port, $dbName, $dbType ), $user, $password, $options );
	}

	public function getDSN(string $serverName, string $port, string $dbName, string $dbType = 'mysql') {
		$charsetString = [ 'mysql' => 'charset=UTF8','pgsql' => 'options=\'--client_encoding=UTF8\'','sqlite' => '' ] [$dbType] ?? 'charset=UTF8';
		if ($dbType === 'sqlite') {
			return "sqlite:{$dbName}";
		}
		return $dbType . ":dbname={$dbName};host={$serverName};{$charsetString};port=" . $port;
	}

	public function bindValueFromStatement($statement, $parameter, $value) {
		return $statement->bindValue ( ":" . $parameter, $value );
	}

	public function query(string $sql) {
		return $this->dbInstance->query ( $sql );
	}

	public function queryAll(string $sql, int $fetchStyle = null) {
		return $this->dbInstance->query ( $sql )->fetchAll ( $fetchStyle );
	}

	public function queryColumn(string $sql, int $columnNumber = null) {
		return $this->dbInstance->query ( $sql )->fetchColumn ( $columnNumber );
	}

	public function executeStatement($statement, array $values = null) {
		return $statement->execute ( $values );
	}

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

	public function statementRowCount($statement) {
		return $statement->rowCount ();
	}

	public function inTransaction() {
		return $this->dbInstance->inTransaction ();
	}

	public function commit() {
		return $this->dbInstance->commit ();
	}

	public function rollBack() {
		return $this->dbInstance->rollBack ();
	}

	public function beginTransaction() {
		return $this->dbInstance->beginTransaction ();
	}

	public function savePoint($level) {
		$this->dbInstance->exec ( 'SAVEPOINT LEVEL' . $level );
	}

	public function releasePoint($level) {
		$this->dbInstance->exec ( 'RELEASE SAVEPOINT LEVEL' . $level );
	}

	public function rollbackPoint($level) {
		$this->dbInstance->exec ( 'ROLLBACK TO SAVEPOINT LEVEL' . $level );
	}

	public function nestable() {
		return isset ( self::$savepointsDrivers [$this->dbType] );
	}

	public function ping() {
		return ($this->dbInstance != null) && (1 === \intval ( $this->queryColumn ( 'SELECT 1', 0 ) ));
	}

	public function getPrimaryKeys($tableName) {
		$fieldkeys = array ();
		$recordset = $this->dbInstance->query ( "SHOW KEYS FROM `{$tableName}` WHERE Key_name = 'PRIMARY'" );
		$keys = $recordset->fetchAll ( \PDO::FETCH_ASSOC );
		foreach ( $keys as $key ) {
			$fieldkeys [] = $key ['Column_name'];
		}
		return $fieldkeys;
	}

	public function getForeignKeys($tableName, $pkName, $dbName = null) {
		$recordset = $this->dbInstance->query ( "SELECT *
												FROM
												 information_schema.KEY_COLUMN_USAGE
												WHERE
												 REFERENCED_TABLE_NAME = '" . $tableName . "'
												 AND REFERENCED_COLUMN_NAME = '" . $pkName . "'
												 AND TABLE_SCHEMA = '" . $dbName . "';" );
		return $recordset->fetchAll ( \PDO::FETCH_ASSOC );
	}

	public function getFieldsInfos($tableName) {
		$fieldsInfos = array ();
		$recordset = $this->dbInstance->query ( "SHOW COLUMNS FROM `{$tableName}`" );
		$fields = $recordset->fetchAll ( \PDO::FETCH_ASSOC );
		foreach ( $fields as $field ) {
			$fieldsInfos [$field ['Field']] = [ "Type" => $field ['Type'],"Nullable" => $field ["Null"] ];
		}
		return $fieldsInfos;
	}

	public function _optPrepareAndExecute($sql, array $values = null) {
		$statement = $this->_getStatement ( $sql );
		$result = false;
		if ($statement->execute ( $values )) {
			$result = $statement->fetchAll ( \PDO::FETCH_ASSOC );
		}
		$statement->closeCursor ();
		return $result;
	}
}


1		<?php
2
3		namespace Ubiquity\db\providers\pdo;
4
5		use Ubiquity\db\providers\AbstractDbWrapper;
6
7		/**
8		* Ubiquity\db\providers$PDOWrapper
9		* This class is part of Ubiquity
10		*
11		* @author jcheron <[email protected]>
12		* @version 1.0.0
13		* @property \PDO $dbInstance
14		*
15		*/
16		class PDOWrapper extends AbstractDbWrapper {
17		protected static $savepointsDrivers = [ 'pgsql' => true,'mysql' => true,'sqlite' => true ];
18		private static $quotes = [ 'mysql' => '`','sqlite' => '"','pgsql' => '' ];
19		protected $transactionLevel = 0;
20		protected $dbType;
21
22	80	public function __construct($dbType = 'mysql') {
23	80	$this->quote = self::$quotes [$dbType] ?? '';
24	80	$this->dbType = $dbType;
25	80	}
26
27		public function fetchAllColumn($statement, array $values = null, string $column = null) {
28		$result = false;
29		if ($statement->execute ( $values )) {
30		$result = $statement->fetchAll ( \PDO::FETCH_COLUMN, $column );
31		}
32		$statement->closeCursor ();
33		return $result;
34		}
35
36	10	public function lastInsertId() {
37	10	return $this->dbInstance->lastInsertId ();
38		}
39
40	23	public function fetchAll($statement, array $values = null, $mode = null) {
41	23	$result = false;
42	23	if ($statement->execute ( $values )) {
43	23	$result = $statement->fetchAll ( $mode );
44		}
45	23	$statement->closeCursor ();
46	23	return $result;
47		}
48
49		public function fetchOne($statement, array $values = null, $mode = null) {
50		$result = false;
51		if ($statement->execute ( $values )) {
52		$result = $statement->fetch ( $mode );
53		}
54		$statement->closeCursor ();
55		return $result;
56		}
57
58	2	public static function getAvailableDrivers() {
59	2	return \PDO::getAvailableDrivers ();
60		}
61
62	7	public function prepareStatement(string $sql) {
63	7	return $this->dbInstance->prepare ( $sql );
64		}
65
66		public function fetchColumn($statement, array $values = null, int $columnNumber = null) {
67		if ($statement->execute ( $values )) {
68		return $statement->fetchColumn ( $columnNumber );
69		}
70		return false;
71		}
72
73	68	public function getStatement($sql) {
74	68	$st = $this->dbInstance->prepare ( $sql );
75	68	$st->setFetchMode ( \PDO::FETCH_ASSOC );
76	68	return $st;
77		}
78
79		public function execute($sql) {
80		return $this->dbInstance->exec ( $sql );
81		}
82
83	75	public function connect(string $dbType, $dbName, $serverName, string $port, string $user, string $password, array $options) {
84	75	$options [\PDO::ATTR_ERRMODE] = \PDO::ERRMODE_EXCEPTION;
85	75	$this->dbInstance = new \PDO ( $this->getDSN ( $serverName, $port, $dbName, $dbType ), $user, $password, $options );
86	75	}
87
88	75	public function getDSN(string $serverName, string $port, string $dbName, string $dbType = 'mysql') {
89	75	$charsetString = [ 'mysql' => 'charset=UTF8','pgsql' => 'options=\'--client_encoding=UTF8\'','sqlite' => '' ] [$dbType] ?? 'charset=UTF8';
90	75	if ($dbType === 'sqlite') {
91		return "sqlite:{$dbName}";
92		}
93	75	return $dbType . ":dbname={$dbName};host={$serverName};{$charsetString};port=" . $port;
94		}
95
96		public function bindValueFromStatement($statement, $parameter, $value) {
97		return $statement->bindValue ( ":" . $parameter, $value );
98		}
99
100		public function query(string $sql) {
101		return $this->dbInstance->query ( $sql );
102		}
103
104		public function queryAll(string $sql, int $fetchStyle = null) {
105		return $this->dbInstance->query ( $sql )->fetchAll ( $fetchStyle );
106		}
107
108	7	public function queryColumn(string $sql, int $columnNumber = null) {
109	7	return $this->dbInstance->query ( $sql )->fetchColumn ( $columnNumber );
110		}
111
112		public function executeStatement($statement, array $values = null) {
113		return $statement->execute ( $values );
114		}
115
116	3	public function getTablesName() {
117	3	$query = $this->dbInstance->query ( 'SHOW TABLES' );
118	3	return $query->fetchAll ( \PDO::FETCH_COLUMN );
119		}
120
121		public function statementRowCount($statement) {
122		return $statement->rowCount ();
123		}
124
125		public function inTransaction() {
126		return $this->dbInstance->inTransaction ();
127		}
128
129	4	public function commit() {
130	4	return $this->dbInstance->commit ();
131		}
132
133	3	public function rollBack() {
134	3	return $this->dbInstance->rollBack ();
135		}
136
137	8	public function beginTransaction() {
138	8	return $this->dbInstance->beginTransaction ();
139		}
140
141	4	public function savePoint($level) {
142	4	$this->dbInstance->exec ( 'SAVEPOINT LEVEL' . $level );
143	4	}
144
145	2	public function releasePoint($level) {
146	2	$this->dbInstance->exec ( 'RELEASE SAVEPOINT LEVEL' . $level );
147	2	}
148
149	2	public function rollbackPoint($level) {
150	2	$this->dbInstance->exec ( 'ROLLBACK TO SAVEPOINT LEVEL' . $level );
151	2	}
152
153	4	public function nestable() {
154	4	return isset ( self::$savepointsDrivers [$this->dbType] );
155		}
156
157	4	public function ping() {
158	4	return ($this->dbInstance != null) && (1 === \intval ( $this->queryColumn ( 'SELECT 1', 0 ) ));
159		}
160
161	1	public function getPrimaryKeys($tableName) {
162	1	$fieldkeys = array ();
163	1	$recordset = $this->dbInstance->query ( "SHOW KEYS FROM `{$tableName}` WHERE Key_name = 'PRIMARY'" );
164	1	$keys = $recordset->fetchAll ( \PDO::FETCH_ASSOC );
165	1	foreach ( $keys as $key ) {
166	1	$fieldkeys [] = $key ['Column_name'];
167		}
168	1	return $fieldkeys;
169		}
170
171	1	public function getForeignKeys($tableName, $pkName, $dbName = null) {
172	1	$recordset = $this->dbInstance->query ( "SELECT *
173		FROM
174		information_schema.KEY_COLUMN_USAGE
175		WHERE
176	1	REFERENCED_TABLE_NAME = '" . $tableName . "'
177	1	AND REFERENCED_COLUMN_NAME = '" . $pkName . "'
178	1	AND TABLE_SCHEMA = '" . $dbName . "';" );
179	1	return $recordset->fetchAll ( \PDO::FETCH_ASSOC );
180		}
181
182	1	public function getFieldsInfos($tableName) {
183	1	$fieldsInfos = array ();
184	1	$recordset = $this->dbInstance->query ( "SHOW COLUMNS FROM `{$tableName}`" );
185	1	$fields = $recordset->fetchAll ( \PDO::FETCH_ASSOC );
186	1	foreach ( $fields as $field ) {
187	1	$fieldsInfos [$field ['Field']] = [ "Type" => $field ['Type'],"Nullable" => $field ["Null"] ];
188		}
189	1	return $fieldsInfos;
190		}
191
192	60	public function _optPrepareAndExecute($sql, array $values = null) {
193	60	$statement = $this->_getStatement ( $sql );
194	60	$result = false;
195	60	if ($statement->execute ( $values )) {
196	60	$result = $statement->fetchAll ( \PDO::FETCH_ASSOC );
197		}
198	60	$statement->closeCursor ();
199	60	return $result;
200		}
201		}
202

phpMv / ubiquity

Pull Request — master (#97)

PDOWrapper::inTransaction() A

Complexity

Size

Duplication

Code Coverage

Importance

Duplication Side-by-Side

Filter issues like