<?php
/*
	@author dhtmlx.com
	@license GPL, see license.txt
*/

require_once("db_common.php");

class PHPYiiDBDataWrapper extends ArrayDBDataWrapper {

    public function select($source) {
        $sourceData = $source->get_source();
        if(is_array($sourceData))	//result of find
            $res = $sourceData;
        else
            $res = $sourceData->find()->all();

        $temp = array();
        if(sizeof($res)) {
            foreach($res as $obj)
                $temp[] = $obj->getAttributes();
        }
        return new ArrayQueryWrapper($temp);
    }

    protected function getErrorMessage() {
        $errors = $this->connection->getErrors();
        $text = array();
        foreach($errors as $key => $value)
            $text[] = $key." - ".$value[0];

        return implode("\n", $text);
    }
    public function insert($data, $source) {
        $name = get_class($source->get_source());
        $obj = new $name();
        $this->fill_model_and_save($obj, $data);
    }

    public function delete($data, $source) {
        $obj = $source->get_source()->findOne($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 = $source->get_source()->findOne($data->get_id());
        $this->fill_model_and_save($obj, $data);
    }

    protected function fill_model_and_save($obj, $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");
    }
}

?>