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
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
|
<?php
require_once('Cif_Database_Exception.inc.php');
/**
* @category Cif
* @package Cif_Database
*
* @author Jesse Morgan <jesse@jesterpm.net>
* @copyright Copyright (c) 2009, Jesse Morgan
* @version $Id: Cif_Database.inc.php 134 2011-03-08 23:35:57Z jessemorgan $
*/
/**
* Cif_Database is an object providing an
* interface to manipulate a MySQL database.
*
* @package Cif_Database
*/
class Cif_Database {
/**
* Creates a new Cif_Database_Database object and connects to the database.
*
* @param string $host MySQL Server to connect to.
* @param string $user Username to connect with.
* @param string $password Password to connect with.
* @param string $database Database to select.
* @throws Cif_Database_Exception if the database can not be opened.
*/
public function __construct($host, $user, $password, $database) {
if (!mysql_connect($host, $user, $password)) {
throw new Cif_Database_Exception("Failed to connect to database.");
}
if (!mysql_select_db($database)) {
throw new Cif_Database_Exception("Failed to select database.");
}
}
/**
* Fetch one row from the database with the given query.
*
* @param string $query The MySQL query.
* @return array Array of fields mapped to values.
* @throws Cif_Database_Exception if the query fails.
*/
public function fetchAssocRow($query) {
$result = mysql_query($query);
// A query error occured.
if (!$result) {
throw new Cif_Database_Exception("Query Failed.");
}
return $this->_cleanRow(mysql_fetch_assoc($result));
}
/**
* Fetch multiple rows from the database with the given query.
*
* @param string $query The MySQL query.
* @return array Array containing arrays of fields mapped to values for each row.
* @throws Cif_Database_Exception if the query fails.
*/
public function fetchAssocRows($query) {
$result = mysql_query($query);
// A query error occured.
if (!$result) {
throw new Cif_Database_Exception("Query Failed.");
}
$rows = array();
while ($row = mysql_fetch_assoc($result)) {
$rows[] = $this->_cleanRow($row);
}
return $rows;
}
/**
* Update a specified table in the database with the values given.
*
* @param string $table The table to update.
* @param array $values Array of fields mapped to values to update.
* @param string $append Optional string to be appended to the MySQL query.
* @throws InvalidArgumentException if the table name or values list are empty.
* @throws Cif_Database_Exception if the query fails.
*/
public function update($table, $values, $append = "") {
// If the table name is empty, or they didn't provide an array of updates,
// throw an exception.
if ($table == "" or !is_array($values)) {
throw new InvalidArgumentException();
}
// Prep the $values for the update.
foreach ($values as $field=>$value) {
if ($value === NULL) {
$updatefields[] = "`$field`=NULL";
} else {
$updatefields[] = "`$field`='$value'";
}
}
$result = mysql_query("UPDATE `$table` SET ". implode(",", $updatefields) ." $append");
if (!$result) {
throw new Cif_Database_Exception("Update Failed.");
}
}
/**
* Insert a collection of rows into the database.
*
* @param string $table The table to update.
* @param array $row Arrays of fields mapped to values for the new row.
* @return int Auto-incremented id of the new row.
* @throws InvalidArgumentException if the table name or values list are empty.
* @throws Cif_Database_Exception if the query fails.
*/
function insert($table, $row) {
if (!is_array($row)) {
throw new InvalidArgumentException();
}
foreach ($row as $field=>$value) {
$fields[] = "`$field`";
if ($value === NULL) {
$values[] = "NULL";
} else {
$values[] = "'$value'";
}
}
$result = mysql_query("INSERT INTO `$table` (". implode(', ', $fields) .") VALUES (". implode(", ", $values) .")");
if ($result) {
$id = mysql_insert_id();
return $id;
} else {
throw new Cif_Database_Exception("Insert Failed.");
}
}
/**
* Delete rows from the specified table.
*
* @param string $table The table to delete from.
* @param string $where The string to append to the end of the query.
* @throws Cif_Database_Exception if the query fails.
*/
function delete($table, $where) {
$result = mysql_query("DELETE FROM `$table` WHERE $where");
if (!$result) {
throw new Cif_Database_Exception("Delete Failed.");
}
}
/**
* Run a query against the database.
*
* @param string $query The query to run.
* @throws Cif_Database_Exception if the query fails.
*/
function raw($command) {
$result = mysql_query($command);
if (!$result) {
throw new Cif_Database_Exception("Raw Command.");
}
}
/**
* Strip the slashes from every field of the given row.
*
* @param array $row Array of fields mapped to values.
* @return array Array of fields mapped to values, without slashes.
*/
private function _cleanRow($row) {
if (!$row) return NULL;
foreach ($row as $key => $value) {
$new[$key] = stripslashes($value);
}
return $new;
}
}
?>
|
