Win\Database\Connection

Complexity

Total Complexity

12

Size/Duplication

Total Lines	112
Duplicated Lines	0 %

Importance

Changes

0

9 Methods

Rating	Name	Duplication	Size	Complexity
A	getPdo()	0	3	1
A	fetchCount()	0	5	1
A	query()	0	5	1
A	fetchAll()	0	5	1
A	connect()	0	9	2
A	validate()	0	4	2
A	stmt()	0	6	1
A	isValid()	0	3	2
A	getLastInsertId()	0	3	1

<?php

namespace Win\Database;

use PDO;
use PDOException;
use PDOStatement;
use Win\Mvc\Application;
use Win\Singleton\SingletonTrait;

/**
 * Conexão com banco de dados
 */
abstract class Connection
{
	use SingletonTrait;

	/** @var PDO */
	protected $pdo;

	/** @var PDOException|null */
	protected $pdoException;

	/**
	 * Cria e retorna conexão PDO
	 * @param string[] $dbConfig
	 * @throws PDOException
	 * @return PDO
	 */
	abstract protected function createPdo(&$dbConfig);

	/** @return PDO */
	public function getPdo()
	{
		return $this->pdo;
	}

	/**
	 * Cria uma conexão com um banco de dados
	 * @param string[] $dbConfig
	 */
	public function connect($dbConfig)
	{
		try {
			$this->pdo = $this->createPdo($dbConfig);
			$this->pdo->exec('set names utf8');
			$this->pdoException = null;
			Orm::setConnection($this);
		} catch (PDOException $ex) {
			$this->pdoException = $ex;
		}
	}

	/**
	 * Retorna TRUE caso a conexão tenha sido bem sucedida
	 * @return bool
	 */
	public function isValid()
	{
		return is_null($this->pdoException) && $this->pdo instanceof \PDO;
	}

	/**
	 * Redireciona para 503 caso a conexão tenha falhado
	 */
	public function validate()
	{
		if (!is_null($this->pdoException)) {
			Application::app()->errorPage(503, $this->pdoException->getMessage());
		}
	}

	/**
	 * @param string $query
	 * @param string $values
	 * @return bool
	 */
	public function query($query, $values = [])
	{
		$stmt = $this->pdo->prepare($query);

		return $stmt->execute($values);

It seems like $values can also be of type string; however, parameter $input_parameters of PDOStatement::execute() does only seem to accept array, maybe add an additional type check?

	}

	/**
	 * @param string $query
	 * @param string $values
	 * @return PDOStatement|null
	 */
	public function stmt($query, $values = [])
	{
		$stmt = $this->pdo->prepare($query);
		$stmt->execute($values);

It seems like $values can also be of type string; however, parameter $input_parameters of PDOStatement::execute() does only seem to accept array, maybe add an additional type check?

		return $stmt;

The expression return $stmt also could return the type boolean which is incompatible with the documented return type PDOStatement|null.

	}

	/**
	 * @param string $query
	 * @param string $values
	 * @return mixed[]
	 */
	public function fetchAll($query, $values = [])
	{
		$stmt = $this->stmt($query, $values);

It seems like $values can also be of type array; however, parameter $values of Win\Database\Connection::stmt() does only seem to accept string, maybe add an additional type check?

		return $stmt->fetchAll(PDO::FETCH_ASSOC);
	}

	/**
	 * @param string $query
	 * @param mixed[] $values
	 * @return int
	 */
	public function fetchCount($query, $values)
	{
		$stmt = $this->stmt($query, $values);

$values of type array<mixed,mixed> is incompatible with the type string expected by parameter $values of Win\Database\Connection::stmt().

		return $stmt->fetchColumn();
	}

	/** @return string */
	public function getLastInsertId()
	{
		return $this->pdo->lastInsertId();
	}
}