<?php
/*
	@author dhtmlx.com
	@license GPL, see license.txt
*/

require_once("db_common.php");

class PHPYii1DBDataWrapper extends ArrayDBDataWrapper{
	public function select($sql){
		if (is_array($this->connection))	//result of findAll
			$res = $this->connection;
		else
			$res = $this->connection->findAll();

		$temp = array();
		if (sizeof($res)){
			foreach ($res as $obj)
				$temp[]=$obj->getAttributes();
		}
		return new ArrayQueryWrapper($temp);
	}

	protected function getErrorMessage(){
		$errors = $this->connection->invalidFields();
		$text = array();
		foreach ($errors as $key => $value){
			$text[] = $key." - ".$value[0];
		}
		return implode("\n", $text);
	}
	public function insert($data,$source){
		$name = get_class($this->connection);
		$obj = new $name();

		$this->fill_model_and_save($obj, $data);
	}
	public function delete($data,$source){
		$obj = $this->connection->findByPk($data->get_id());
		if ($obj->delete()){
			$data->success();
			$data->set_new_id($obj->getPrimaryKey());
		} else {
			$data->set_response_attribute("details", $this->errors_to_string($obj->getErrors()));
			$data->invalid();
		}
	}
	public function update($data,$source){
		$obj = $this->connection->findByPk($data->get_id());
		$this->fill_model_and_save($obj, $data);
	}	

	protected function fill_model_and_save($obj, $data){
		$values = $data->get_data();

		//map data to model object
		for ($i=0; $i < sizeof($this->config->text); $i++){
			$step=$this->config->text[$i];
			$obj->setAttribute($step["name"], $data->get_value($step["name"]));
		}
		if ($relation = $this->config->relation_id["db_name"])
			$obj->setAttribute($relation, $data->get_value($relation));

		//save model
		if ($obj->save()){
			$data->success();
			$data->set_new_id($obj->getPrimaryKey());
		} else {
			$data->set_response_attribute("details", $this->errors_to_string($obj->getErrors()));
			$data->invalid();
		}
	}

	protected function errors_to_string($errors){
		$text = array();
		foreach($errors as $value)
			$text[]=implode("\n", $value);
		return implode("\n",$text);
	}
	public function escape($str){
		throw new Exception("Not implemented");
	}
	public function query($str){
		throw new Exception("Not implemented");
	}
	public function get_new_id(){
		throw new Exception("Not implemented");
	}
}

?>