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
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
|
<?php
/*
---------------------------------------
| Flyspray database access functions, |
| utilising ADOdb |
---------------------------------------
*/
class Database {
function dbOpen($dbhost = '', $dbuser = '', $dbpass = '', $dbname = '', $dbtype = '') {
$this->dbtype = $dbtype;
$this->dblink = NewADOConnection($dbtype);
$res = $this->dblink->Connect($dbhost, $dbuser, $dbpass, $dbname);
$this->dblink->SetFetchMode(ADODB_FETCH_BOTH);
return $res;
}
function dbClose() {
$this->dblink->Close();
}
/* Replace undef values (treated as NULL in SQL database) with empty
strings.
@param arr input array or false
@return SQL safe array (without undefined values)
*/
function dbUndefToEmpty($arr)
{
if (is_array($arr))
{
$c = count($arr);
for($i=0; $i<$c; $i++)
{
if (!isset($arr[$i]))
{
$arr[$i] = '';
}
// This line safely escapes sql before it goes to the db
$this->dblink->qmagic($arr[$i]);
}
}
return $arr;
}
/** Replace empty values with 0. Useful when inserting values from
checkboxes.
*/
function emptyToZero($arg)
{
return empty($arg) ? 0 : $arg;
}
function dbExec($sql, $inputarr=false, $numrows=-1, $offset=-1)
{
// replace undef values (treated as NULL in SQL database) with empty
// strings
$inputarr = $this->dbUndefToEmpty($inputarr);
//$inputarr = $this->dbMakeSqlSafe($inputarr);
$ADODB_FETCH_MODE = ADODB_FETCH_ASSOC;
if (($numrows>=0) or ($offset>=0)) {
$result = $this->dblink->SelectLimit($sql, $numrows, $offset, $inputarr);
} else {
$result = $this->dblink->Execute($sql, $inputarr);
}
if (!$result) {
if (function_exists("debug_backtrace")) {
echo "<pre style='text-align: left;'>";
var_dump(debug_backtrace());
echo "</pre>";
}
die (sprintf("Query {%s} with params {%s} Failed! (%s)",
$sql, implode(', ', $inputarr),
$this->dblink->ErrorMsg()));
}
return $result;
}
function CountRows($result) {
$num_rows = $result->RecordCount();
return $num_rows;
}
function FetchRow(&$result) {
$row = $result->FetchRow();
return $row;
}
/* compatibility functions */
function Query($sql, $inputarr=false, $numrows=-1, $offset=-1) {
$result = $this->dbExec($sql, $inputarr, $numrows, $offset);
return $result;
}
function FetchArray(&$result) {
$row = $this->FetchRow($result);
return $row;
}
function FetchOne(&$result) {
$row = $this->FetchArray($result);
return (count($row) > 0 ? $row[0] : null);
}
// End of Database Class
}
?>
|
