blob: 1d245b215dbb8c681313f319218024c4040dc886 (
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
|
<?php
namespace DHTMLX\Connector\DataStorage;
use DHTMLX\Connector\Tools\LogMaster;
class MsSQLDBDataWrapper extends DBDataWrapper
{
private $last_id = ""; //!< ID of previously inserted record
private $insert_operation = false; //!< flag of insert operation
private $start_from = false; //!< index of start position
public function query($sql)
{
LogMaster::log($sql);
$res = mssql_query($sql, $this->connection);
if ($this->insert_operation) {
$last = mssql_fetch_assoc($res);
$this->last_id = $last["dhx_id"];
mssql_free_result($res);
}
if ($this->start_from)
mssql_data_seek($res, $this->start_from);
return $res;
}
public function get_next($res)
{
return mssql_fetch_assoc($res);
}
public function get_new_id()
{
/*
MSSQL doesn't support identity or auto-increment fields
Insert SQL returns new ID value, which stored in last_id field
*/
return $this->last_id;
}
protected function insert_query($data, $request)
{
$sql = parent::insert_query($data, $request);
$this->insert_operation = true;
return $sql . ";SELECT @@IDENTITY AS dhx_id";
}
protected function select_query($select, $from, $where, $sort, $start, $count)
{
if (!$from)
return $select;
$sql = "SELECT ";
if ($count)
$sql .= " TOP " . ($count + $start);
$sql .= " " . $select . " FROM " . $from;
if ($where) $sql .= " WHERE " . $where;
if ($sort) $sql .= " ORDER BY " . $sort;
if ($start && $count)
$this->start_from = $start;
else
$this->start_from = false;
return $sql;
}
public function escape($data)
{
/*
there is no special escaping method for mssql - use common logic
*/
return str_replace("'", "''", $data);
}
public function begin_transaction()
{
$this->query("BEGIN TRAN");
}
}
|
