blob: 76a941dbf396fac9133f2060ebc3f1018a4ee509 (
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
|
<?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 PHPCake2DBDataWrapper extends ArrayDBDataWrapper{
public function select($sql){
$source = $sql->get_source();
if (is_array($source)) //result of find
$res = $source;
else
$res = $this->connection->find("all");
$temp = array();
if (sizeof($res)){
$name = get_class($this->connection);
for ($i=sizeof($res)-1; $i>=0; $i--)
$temp[]=&$res[$i][$name];
}
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);
$save = array();
$temp_data = $data->get_data();
unset($temp_data[$this->config->id['db_name']]);
unset($temp_data["!nativeeditor_status"]);
$save[$name] = $temp_data;
if ($this->connection->save($save)){
$data->success($this->connection->getLastInsertID());
} else {
$data->set_response_attribute("details", $this->getErrorMessage());
$data->invalid();
}
}
public function delete($data,$source){
$id = $data->get_id();
$this->connection->delete($id);
$data->success();
}
public function update($data,$source){
$name = get_class($this->connection);
$save = array();
$save[$name] = &$data->get_data();
if ($this->connection->save($save)){
$data->success();
} else {
$data->set_response_attribute("details", $this->getErrorMessage());
$data->invalid();
}
}
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");
}
}
?>
|
