Win\DAO\DAO

Complexity

Total Complexity

34

Size/Duplication

Total Lines	242
Duplicated Lines	6.61 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes	2
Bugs	0	Features	0

20 Methods

Rating	Name	Duplication	Size	Complexity
	mapObject()	0	1	?
	mapRow()	0	1	?
A	__construct()	0	3	1
A	setPDO()	0	3	1
A	setSelectCollumns()	0	3	1
A	addSelectCollumn()	0	5	2
A	save()	0	11	3
A	insert()	0	12	2
A	update()	0	16	3
A	delete()	0	3	1
A	deleteById()	0	8	2
A	fetchById()	0	3	1
A	fetchByField()	0	3	1
A	fetch()	0	14	3
A	fetchAll()	9	18	4
A	selectSQL()	0	3	1
A	whereSQL()	0	4	2
A	numRows()	7	16	3
A	objExists()	0	3	1
A	validateObject()	0	5	2

<?php

namespace Win\DAO;

use Win\Mvc\Application;
use Win\Connection\MySQL;

/**
 * Data Access Object
 */
abstract class DAO implements DAOInterface {

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

	/** @var string[] */
	protected $selectCollumns = ['*'];

	/**
	 * Retorna um objeto a partir da linha da tabela
	 * @param array[] $row
	 */
	abstract protected function mapObject($row);

	/** Retorna a linha da tabela a partir de um objeto
	 * @param object $obj
	 */
	abstract protected function mapRow($obj);

	/** Inicia o DAO */
	public function __construct() {
		$this->pdo = MySQL::instance()->getPDO();
	}

	/**
	 * Define uma conexão manualmente
	 * @param \PDO $pdo
	 */
	public function setPDO($pdo) {
		$this->pdo = $pdo;
	}

	/**
	 * Define quais colunas serão consultadas nos comandos SELECT
	 * @param string[] $collumns
	 */
	public function setSelectCollumns(array $collumns) {
		$this->selectCollumns = $collumns;
	}

	/**
	 * Adiciona nova coluna no select
	 * @param string $collumn
	 */
	public function addSelectCollumn($collumn) {
		if (!in_array($collumn, $this->selectCollumns)) {
			$this->selectCollumns[] = $collumn;
		}
	}

	/**
	 * Salva o registro
	 * @param object $obj
	 */
	public function save($obj) {
		$this->obj = $obj;

The property obj does not exist. Did you maybe forget to declare it?

		if (!$this->objExists()) {
			$this->insert();
			if ($this->pdo) {
				$this->obj->setId($this->pdo->lastInsertId());
			}
		} else {
			$this->update();
		}
	}

	/** Insere o registro */
	protected function insert() {
		$mapRow = $this->mapRow($this->obj);
		$keys = array_keys($mapRow);
		$values = array_values($mapRow);
		$params = str_split(str_repeat('?', count($keys)));

		$sql = 'INSERT INTO ' . static::TABLE . ' (' . implode(',', $keys) . ') VALUES (' . implode(', ', $params) . ') ';
		if ($this->pdo) {
			$stmt = $this->pdo->prepare($sql);
			$stmt->execute($values);
		}
	}

	/** Atualiza o registro */
	protected function update() {
		$mapRow = $this->mapRow($this->obj);
		$keys = array_keys($mapRow);
		$values = array_values($mapRow);
		$params = [];
		foreach ($keys as $key):
			$params[] = $key . ' = ?';
		endforeach;
		$values[] = $this->obj->getId();

		$sql = 'UPDATE ' . static::TABLE . ' SET ' . implode(', ', $params) . ' WHERE id = ? ';
		if ($this->pdo) {
			$stmt = $this->pdo->prepare($sql);
			$stmt->execute($values);
		}
	}

	/**
	 * Exclui o registro
	 * @param object $obj
	 */
	public function delete($obj) {
		$this->deleteById($obj->getId());
	}

	/**
	 * Exclui o registro por id
	 * @param int $id
	 */
	public function deleteById($id) {
		$sql = 'DELETE FROM ' . static::TABLE . ' WHERE id = :id';
		if ($this->pdo) {
			$stmt = $this->pdo->prepare($sql);
			$stmt->bindValue(':id', $id);
			$stmt->execute();
		}
	}

	/**
	 * Busca o objeto pelo id
	 * @param int $id
	 */
	public function fetchById($id) {
		return $this->fetchByField('id', $id);
	}

	/**
	 * Busca o objeto por um campo/atributo específico
	 * @param string $name Nome do atributo
	 * @param mixed $value Valor do atributo
	 */
	public function fetchByField($name, $value) {
		return $this->fetch([$name . ' = ?' => $value]);
	}

	/**
	 * Busca o objeto
	 * @param string[] $filter Array de filtros
	 * @param string $option [Order by, Limit, etc]
	 */
	public function fetch($filter, $option = '') {
		if (!is_array($filter)):
			throw new \Exception("Filter: '{$filter}' must be a array");
		endif;
		$sql = $sql = $this->selectSQL() . ' ' . $this->whereSQL($filter) . ' ' . $option;
		$result = [];
		if ($this->pdo) {
			$stmt = $this->pdo->prepare($sql);
			$stmt->execute(array_values($filter));

			$result = $stmt->fetch();
		}
		return $this->mapObject($result);
	}

	/**
	 * Retorna todos os registros
	 *
	 * <code>
	 * $dao->fetchAll( ['id = ?' => 10]);
	 * </code>
	 * @param string[] $filter Array de filtros
	 * @param string $option [Order by, Limit, etc]
	 */
	public function fetchAll($filter = [], $option = '') {
		$array = [];
		if (!is_array($filter)):
			throw new \Exception("Filter: '{$filter}' must be a array");
		endif;

		$sql = $this->selectSQL($this->selectCollumns) . ' ' . $this->whereSQL($filter) . ' ' . $option;
		if ($this->pdo) {

This code seems to be duplicated across your project.

			$stmt = $this->pdo->prepare($sql);
			$stmt->execute(array_values($filter));

			$results = $stmt->fetchAll();
			foreach ($results as $result):
				$array[] = $this->mapObject($result);
			endforeach;
		}
		return $array;
	}

	/**
	 * Retorna comando SELECT
	 * @param string $selectCollumns
	 * @return string
	 * @example "SELECT * FROM user"
	 */
	protected function selectSQL($selectCollumns = ['*']) {
		return 'SELECT ' . implode(', ', $selectCollumns) . ' FROM ' . static::TABLE;
	}

	/**
	 * Retorna comando WHERE
	 * @param string[] $filter
	 * @return string
	 */
	private function whereSQL(&$filter) {
		$keys = array_keys($filter);
		return ($keys) ? 'WHERE ' . implode(' AND ', $keys) : '';
	}

	/**
	 * Retorna o total de registros
	 * @param string[] $filter Array de filtros
	 * @return int
	 */
	public function numRows($filter = []) {
		$total = 0;
		if (!is_array($filter)):
			throw new \Exception("Filter: '{$filter}' must be a array");
		endif;

		$sql = 'SELECT count(*) as total FROM ' . static::TABLE . ' ' . $this->whereSQL($filter);
		if ($this->pdo) {

This code seems to be duplicated across your project.

			$stmt = $this->pdo->prepare($sql);
			$stmt->execute(array_values($filter));

			$result = $stmt->fetch();
			$total = $result['total'];
		}
		return $total;
	}

	/**
	 * Retorna True se objeto existir
	 * @return boolean
	 */
	protected function objExists() {
		return ($this->obj->getId() > 0);
	}

	/** Define como Página 404 se o objeto não existir */
	public function validateObject() {
		if (!$this->objExists()) {
			Application::app()->pageNotFound();
		}
	}

}