<?php
	require_once('TipologiaRepositoryInterface.php');
	require_once(dirname(__FILE__).'/../classes/Tipologia.php');
	require_once(dirname(__FILE__)."/../constants.php");
	require_once(dirname(__FILE__)."/../utilities.php");

	class TipologiaRepository implements TipologiaRepositoryInterface {
		protected $db;

		public function __construct($db) {
			$this->db = $db;
		}

		public function getTipologiaById($id_tipologia) {
			$status = array();

			$queryTipologia = "SELECT tipologia FROM tipologie WHERE id=:id";

			$tipologia;

			try {
				$stmt = $this->db->prepare($queryTipologia);
	    		$stmt->bindParam(':id', $id_tipologia);
				$query = $stmt->execute();

				if (!$query) {
					$status = createErrorMessage(1, "Errore DB");
					$status["tipologia"] = null;
					return $status;
				}

				$row = ($stmt->rowCount()>0) ? $stmt->fetch() : null;

				if (is_null($row)) {
					$status["return"] = 0;
					$status["tipologia"] = null;
					return $status;
				}

				$tipologia = new Tipologia();

				$tipologia->id = $id_tipologia;
				$tipologia->tipologia = $row["tipologia"];

				$status["return"] = 0;
				$status["tipologia"] = $tipologia;
				return $status;

			} catch (PDOException $e) {
				echo $e->getMessage();
				$status = createErrorMessage(1, "Errore DB");
				$status["tipologia"] = null;
				return $status;
			} 
		}

		public function getTipologiaByValue($value) {
			$status = array();

			$queryTipologia = "SELECT id FROM tipologie WHERE tipologia=:tipologia";

			$tipologia;

			try {
				$stmt = $this->db->prepare($queryTipologia);
	    		$stmt->bindParam(':tipologia', $value);
				$query = $stmt->execute();

				if (!$query) {
					$status = createErrorMessage(1, "Errore DB");
					$status["tipologia"] = null;
					return $status;
				}

				$row = ($stmt->rowCount()>0) ? $stmt->fetch() : null;

				if (is_null($row)) {
					$status["return"] = 0;
					$status["tipologia"] = null;
					return $status;
				}

				$tipologia = new Tipologia();

				$tipologia->id = $row["id"];
				$tipologia->tipologia = $value;

				$status["return"] = 0;
				$status["tipologia"] = $tipologia;
				return $status;

			} catch (PDOException $e) {
				echo $e->getMessage();
				$status = createErrorMessage(1, "Errore DB");
				$status["tipologia"] = null;
				return $status;
			} 
		}

		public function getTipologiaList() {
			$status = array();

			$queryTipologia = "SELECT id,tipologia FROM tipologie";

			$tipologie = array();

			try {
				$stmt = $this->db->prepare($queryTipologia);
				$query = $stmt->execute();

				if (!$query || $stmt->rowCount()==0) {
					$status = createErrorMessage(1, "Errore DB");
					$status["tipologie"] = null;
					return $status;
				}

				$rows = $stmt->fetchAll(PDO::FETCH_ASSOC);

				foreach ($rows as $row) {
					$tipologia = new Tipologia();

					$tipologia->id = $row["id"];
					$tipologia->tipologia = $row["tipologia"];

					array_push($tipologie, $tipologia);
				}

				$status["return"] = 0;
				$status["tipologie"] = $tipologie;
				return $status;

			} catch (PDOException $e) {
				echo $e->getMessage();
				$status = createErrorMessage(1, "Errore DB");
				$status["tipologie"] = null;
				return $status;
			}
		}

	}

?>