PHPLaravelDBDataWrapper.php

<?php
namespace Dhtmlx\Connector\DataStorage;
use Dhtmlx\Connector\DataProcessor\DataProcessor;
use \Exception;

class PHPLaravelDBDataWrapper extends ArrayDBDataWrapper {

	public function select($source) {
		$sourceData = $source->get_source();
		if(is_array($sourceData))	//result of find
			$res = $sourceData;
		else if ($sourceData){
			if (is_string($sourceData))
				$sourceData = new $sourceData();
			
			if (is_a($sourceData, "Illuminate\\Database\\Eloquent\\Collection")){
				$res = $sourceData->toArray();
			} else if (is_a($sourceData, "Illuminate\\Database\\Eloquent\\Builder")){
				$res = $sourceData->get();
			} else {
				$res = $sourceData->all();
			}
		}

		return new ArrayQueryWrapper($res);
	}

	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) {
		$obj = null;
		if(method_exists($source->get_source(), 'getModel')){
			$obj = $source->get_source()->getModel()->newInstance();
		} else {
			$className = get_class($source->get_source());
			$obj = new $className();
		}

		$this->fill_model($obj, $data)->save();

		$fieldPrimaryKey = $this->config->id["db_name"];
		$data->success($obj->$fieldPrimaryKey);
	}

	public function delete($data, $source) {
		if(method_exists($source->get_source(), 'getModel')){
			$source->get_source()->getModel()->find($data->get_id())->delete();
		} else {
			$className = get_class($source->get_source());
			$className::destroy($data->get_id());
		}
		$data->success();
	}

	public function update($data, $source) {
		$obj = null;
		if(method_exists($source->get_source(), 'getModel')){
			$obj = $source->get_source()->getModel()->find($data->get_id());
		} else {
			$className = get_class($source->get_source());
			$obj = $className::find($data->get_id());
		}

		$this->fill_model($obj, $data)->save();
		$data->success();
	}

	private function fill_model($obj, $data) {
		$dataArray = $data->get_data();
		unset($dataArray[DataProcessor::$action_param]);
		unset($dataArray[$this->config->id["db_name"]]);

		foreach($dataArray as $key => $value)
			$obj->$key = $value;

		return $obj;
	}

	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");
	}

}