PDOWrapper::inTransaction() - Code Metrics - Inspection of "Fix unit test bug on uGetAll + ping pb" - phpMv/ubiquity - Measure and Improve Code Quality continuously with Scrutinizer

Test Failed

Push — master ( d214bc...a9a104 )

by Jean-Christophe

created 2019-09-06 00:33 UTC

PDOWrapper::inTransaction() A

↳ Parent: PDOWrapper

Complexity

Conditions	1
Paths	1

Size

Total Lines	2
Code Lines	1

Duplication

Lines	0
Ratio	0 %

Importance

Changes

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

<?php

namespace Ubiquity\db\providers\pdo;

use Ubiquity\db\providers\AbstractDbWrapper;
use Ubiquity\exceptions\DBException;

/**
 * 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;

	public function __construct($dbType = 'mysql') {
		$this->quote = self::$quotes [$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') {
		return $dbType . ':dbname=' . $dbName . ';host=' . $serverName . ';charset=UTF8;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->dbInstance->getAttribute ( \PDO::ATTR_DRIVER_NAME )] );
	}

	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 pool() {
		throw new DBException ( 'PDO does not accept connection pooling' );
	}

	public function freePool($db) {
		throw new DBException ( 'PDO does not accept connection pooling' );
	}

	public function setPool($pool) {
		throw new DBException ( 'PDO does not accept connection pooling' );
	}

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

phpMv / ubiquity

Push — master ( d214bc...a9a104 )

PDOWrapper::inTransaction() A

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like