blob: 92b5134bd40fa85a124011cd8c06b41f72cbcfde (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
|
<?php
/*
@author dhtmlx.com
@license GPL, see license.txt
*/
require_once("db_common.php");
//DataProcessor::$action_param ="dhx_editor_status";
/*! Implementation of DataWrapper for PDO
if you plan to use it for Oracle - use Oracle connection type instead
**/
class PHPCakeDBDataWrapper extends ArrayDBDataWrapper {
public function select($source) {
$sourceData = $source->get_source();
if(is_array($sourceData)) //result of find
$query = $sourceData;
else
$query = $sourceData->find("all");
$temp = array();
foreach($query as $row)
$temp[] = $row->toArray();
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) {
$sourceData = $source->get_source();
$obj = $sourceData->newEntity();
$obj = $this->fillModel($obj, $data);
$savedResult = $source->get_source()->save($obj);
$data->success($savedResult->get($this->config->id["db_name"]));
}
public function delete($data, $source) {
$sourceData = $source->get_source();
$obj = $sourceData->get($data->get_id());
$source->get_source()->delete($obj);
}
public function update($data, $source) {
$sourceData = $source->get_source();
$obj = $sourceData->get($data->get_id());
$obj = $this->fillModel($obj, $data);
$sourceData->save($obj);
}
private function fillModel($obj, $data) {
//Map data to model object.
for($i = 0; $i < count($this->config->text); $i++) {
$step=$this->config->text[$i];
$obj->set($step["name"], $data->get_value($step["name"]));
}
if($relation = $this->config->relation_id["db_name"])
$obj->set($relation, $data->get_value($relation));
return $obj;
}
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");
}
}
?>
|
