<?php
/**
 * Thin PHP Framework (TPF) 2011 http://thinphp.com
 *
 * Licensed under TPF License at http://bit.ly/TPFLicense
 * Redistributions of files must retain the above copyright notice.
 *
 * @copyright     Copyright 2011, Thin PHP Framework Team
 * @link          http://thinphp.com
 * @package       app.model.base
 * @license       TPF License http://bit.ly/TPFLicense
 */
defined('BASE') or exit('Direct script access is not allowed!');
require_once BASE.'/app/model/base/IBaseDAO.php';
require_once BASE.'/app/model/base/DBFactory.php';

/** 
 * This Base DAO class. Model DAO classes must extend this class.
 */

class BaseDAO implements IBaseDao
{
	protected $dbh;
	protected $table;
	protected $lastSQL;
	
	/**
	 * Constructor to create a DAO for a specific table
	 * @param table Name of the table
	 */
	public function __construct($table)
	{
		$this->table = $table;
		$this->dbh = DBFactory::getDBHandler();
	}
	
	public function getLastSQL()
	{
		return $this->lastSQL;
	}
	
	public function getDbHandler()
	{
		return $this->dbh;
	}
	
	public function execute($sql, $paramArr)
	{		
		if ($this->dbh == null) return;
		$stmt = $this->dbh->prepare($sql);		
		if ($stmt != null) {
			$stmt->execute($paramArr);
			//$stmt->debugDumpParams();
		}
	}
	
	public function getAll()
	{
		if ($this->dbh == null) return;
		$sql = 'SELECT * FROM '.$this->table;		
		$queryRes = $this->dbh->query($sql);
		if ($queryRes != null) {
			return $queryRes->fetchAll();
		}
		return null;
	}
	
	public function countAll()
	{
		if ($this->dbh == null) return;
		$sql = 'SELECT COUNT(*) FROM '.$this->table;
		$queryRes = $this->dbh->query($sql);
		if ($queryRes != null) {
			return $queryRes->fetchColumn();
		}
		return 0;
	}

	public function getById($id)
	{		
		if ($this->dbh == null) return;
		$sql = 'SELECT * FROM '.$this->table.' WHERE '.$this->table.'Id = :id';
		$stmt = $this->dbh->prepare($sql);
		$stmt->execute(array(':id'=>$id));		
		$res = $stmt->fetchAll();		
		if ($res != null && count($res) >0) {
			return $res[0];
		}
		return null;
	}
			
	public function removeById($id)
	{
		$sql = 'DELETE FROM '.$this->table.' WHERE '.$this->table.'Id = :id';
		$stmt = $this->dbh->prepare($sql);
		$stmt->execute(array(':id'=>$id));
	}
	
	public function remove($obj)
	{
		// will be implemented by extending classes
		return;
	}
	
	public function create($obj)
	{
		// will be implemented by extending classes
		return;
	}
	
	public function update($updateClause, $arr)
	{
		$sql = 'UPDATE '.$this->table.' SET '.$updateClause;
		$stmt = $this->dbh->prepare($sql);
		$stmt->execute($arr);
	}
}