chillerlan\Database\Drivers\PostgreSQLDriver

Complexity

Total Complexity

23

Size/Duplication

Total Lines	201
Duplicated Lines	8.96 %

Coupling/Cohesion

Components	1
Dependencies	4

Importance

Changes

0

11 Methods

Rating	Name	Duplication	Size	Complexity
B	connect()	0	31	3
A	disconnect()	0	3	1
A	getClientInfo()	0	5	1
A	getServerInfo()	0	5	1
A	escape()	0	3	1
D	__getResult()	0	36	9
A	__raw()	0	3	1
A	__prepared()	0	5	1
A	__multi()	9	9	2
A	__multi_callback()	9	9	2
A	replaceParams()	0	7	1

<?php
/**
 * Class PostgreSQLDriver
 *
 * @filesource   PostgreSQLDriver.php
 * @created      21.02.2016
 * @package      chillerlan\Database\Drivers\PostgreSQL
 * @author       Smiley <smiley@chillerlan.net>
 * @copyright    2016 Smiley
 * @license      MIT
 */

namespace chillerlan\Database\Drivers;

use chillerlan\Database\DBResult;

class PostgreSQLDriver extends DBDriverAbstract{

	protected $dialect = 'pgsql';
	protected $quotes = ['"', '"'];

	/**
	 * Holds the database resource object
	 *
	 * @var resource
	 */
	protected $db;

	/**
	 * Establishes a database connection and returns the connection object
	 *
	 * @return \chillerlan\Database\Drivers\DBDriverInterface
	 * @throws \chillerlan\Database\Drivers\DBDriverException
	 */
	public function connect():DBDriverInterface{

		if(gettype($this->db) === 'resource'){
			return $this;
		}

		// i am an ugly duckling. fix me please.

		$options = [
			'--client_encoding='.$this->options->pgsql_charset,
		];

		$conn_str = [
			'host=\''.$this->options->host.'\'',
			'port=\''.(int)$this->options->port.'\'',
			'dbname=\''.$this->options->database.'\'',
			'user=\''.$this->options->username.'\'',
			'password=\''.$this->options->password.'\'',
			'options=\''.implode(' ', $options).'\'',
		];

		try{
			$this->db = pg_connect(implode(' ', $conn_str));

			return $this;
		}
		catch(\Exception $e){
			throw new DBDriverException('db error: [PostgreSQLDriver]: '.$e->getMessage());
		}

	}

	/**
	 * Closes a database connection
	 *
	 * @return bool
	 */
	public function disconnect():bool{
		return pg_close($this->db);
	}

	/**
	 * Returns info about the used php client
	 *
	 * @return string php's database client string
	 */
	public function getClientInfo():string{
		$ver = pg_version($this->db);

		return 'PostgreSQL '.$ver['client'].' ('.$ver['client_encoding'].')';
	}

	/**
	 * Returns info about the database server
	 *
	 * @return string database's serverinfo string
	 */
	public function getServerInfo():string{
		$ver = pg_version($this->db);

		return 'PostgreSQL '.$ver['server'].' ('.$ver['server_encoding'].', date style: '.$ver['DateStyle'].', time zone: '.$ver['TimeZone'].')';
	}

	/**
	 * @param $data
	 *
	 * @return string
	 */
	public function escape($data){
		return pg_escape_string($this->db, $data);
	}

	/**
	 * @param             $result
	 * @param string|null $index
	 * @param bool        $assoc
	 *
	 * @return bool|\chillerlan\Database\DBResult
	 */
	protected function __getResult($result, string $index = null, bool $assoc = true){

		if(is_bool($result)){
			return $result; // @codeCoverageIgnore
		}

		$out = new DBResult(null, $this->source_encoding, $this->dest_encoding);
		$i   = 0;

		while($row = call_user_func_array($assoc ? 'pg_fetch_assoc' : 'pg_fetch_row', [$result])){
			$key = $i;

			$j = 0;
			foreach($row as $k => $item){
				// https://gitter.im/arenanet/api-cdi?at=594326ba31f589c64fafe554
				if(pg_field_type($result, $j) === 'boolean'){
					$row[$k] = $item === 't';
				}

				$j++;
			}

			if($assoc && !empty($index)){
				$key = $row[$index];
			}

			$out[$key] = $row;
			$i++;
		}

		$r = $i === 0 ? true : $out;

		pg_free_result($result);

		return $r;
	}

	/**
	 * @param string      $sql
	 * @param string|null $index
	 * @param bool        $assoc
	 *
	 * @return bool|\chillerlan\Database\DBResult
	 */
	protected function __raw(string $sql, string $index = null, bool $assoc = true){
		return $this->__getResult(pg_query($sql), $index, $assoc);
	}

	/**
	 * @param string      $sql
	 * @param array       $values
	 * @param string|null $index
	 * @param bool        $assoc
	 *
	 * @return bool|\chillerlan\Database\DBResult
	 */
	protected function __prepared(string $sql, array $values = [], string $index = null, bool $assoc = true){
		pg_prepare($this->db, '', $this->replaceParams($sql));

		return $this->__getResult(pg_execute($this->db, '', $values), $index, $assoc);
	}

	/**
	 * @param string $sql
	 * @param array  $values
	 *
	 * @return bool
	 */
	protected function __multi(string $sql, array $values){

This method seems to be duplicated in your project.

		pg_prepare($this->db, '', $this->replaceParams($sql));

		foreach($values as $row){
			pg_execute($this->db, '', $row);
		}

		return true;
	}

	/**
	 * @param string $sql
	 * @param array  $data
	 * @param        $callback
	 *
	 * @return bool
	 */
	protected function __multi_callback(string $sql, array $data, $callback){

This method seems to be duplicated in your project.

		pg_prepare($this->db, '', $this->replaceParams($sql));

		foreach($data as $row){
			pg_execute($this->db, '', call_user_func_array($callback, [$row]));
		}

		return true;
	}

	protected function replaceParams(string $sql):string{
		$i = 0;

		return preg_replace_callback('/(\?)/', function() use (&$i){
			return '$'.++$i;
		}, $sql);
	}

}