class-databases
Uitleg
------
Code (php)
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
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
<?php
//Voorbeeld om zelf een child class te maken:
class mysqliDatabase extends databaseCore {
//Declare alle abstracte functies (ev. meer)
}
//Je kan type veranderen (bij getConnection) in mysqli en het script zoekt het verder uit.
############################################################################
//class opzetten (port & socket worden in de MySQL variant niet gebruikt.
$db = databaseCore::getConnection(array(
'type' => 'mysql', //Hier de prefix van de child class.
'host' => '',
'port' => '', //Wordt niet gebruikt bij mysql, voeg toe bij host.
'socket' => '', //Wordt niet gebruikt bij mysql, gebruik host.
'user' => '',
'password' => '',
'dbname' => ''
), [$debug=false[, $connect=true]]);
//Query uitvoeren (retourneert het result)
$db->query($sqlCode);
//Meerdere query's uitvoeren (kunnen zoveel query's in als je wilt)
$db->multiQuery($sqlCode[, $... ]);
//Rijen ophalen (zonder een argument wordt de laatste query gebruikt)
$db->fetch([$result]);
//Aantal rijen tellen (zonder een argument wordt de laatste query gebruikt)
$db->numRows([$result]);
//Geeft het aantal results van de laatste UPDATE, INSERT etc. query terug.
$db->affectedRows();
//Escaped zodat het veilig is in te voegen (zoals mysql_real_escape_string)
$db->escape($str);
//Geeft laatste insert id terug (zoals mysql_insert_id)
$db->insertId();
//Retourneert de SQL code of het RESULT van een query die is uitgevoerd
$db->getQuery($id); //id begint altijd met een q of een r, q staat voor de sql code, r staat voor het result. Daarna wordt een integer verwacht (het echte id)
//Aantal query's dat is uitgevoerd.
$db->getQueryTime();
//Retourneert de waarde van $this->debug
$db->getDebug();
//Veranderd het debug variabel
$db->setDebug($str); //Str kan zij: true, false of switch
//Verbinding maken
$db->connect(); //Gebruik deze alleen als je het standaard verbinden hebt uitgeschakeld. Anders wordt dit automatisch gedaan!
?>
//Voorbeeld om zelf een child class te maken:
class mysqliDatabase extends databaseCore {
//Declare alle abstracte functies (ev. meer)
}
//Je kan type veranderen (bij getConnection) in mysqli en het script zoekt het verder uit.
############################################################################
//class opzetten (port & socket worden in de MySQL variant niet gebruikt.
$db = databaseCore::getConnection(array(
'type' => 'mysql', //Hier de prefix van de child class.
'host' => '',
'port' => '', //Wordt niet gebruikt bij mysql, voeg toe bij host.
'socket' => '', //Wordt niet gebruikt bij mysql, gebruik host.
'user' => '',
'password' => '',
'dbname' => ''
), [$debug=false[, $connect=true]]);
//Query uitvoeren (retourneert het result)
$db->query($sqlCode);
//Meerdere query's uitvoeren (kunnen zoveel query's in als je wilt)
$db->multiQuery($sqlCode[, $... ]);
//Rijen ophalen (zonder een argument wordt de laatste query gebruikt)
$db->fetch([$result]);
//Aantal rijen tellen (zonder een argument wordt de laatste query gebruikt)
$db->numRows([$result]);
//Geeft het aantal results van de laatste UPDATE, INSERT etc. query terug.
$db->affectedRows();
//Escaped zodat het veilig is in te voegen (zoals mysql_real_escape_string)
$db->escape($str);
//Geeft laatste insert id terug (zoals mysql_insert_id)
$db->insertId();
//Retourneert de SQL code of het RESULT van een query die is uitgevoerd
$db->getQuery($id); //id begint altijd met een q of een r, q staat voor de sql code, r staat voor het result. Daarna wordt een integer verwacht (het echte id)
//Aantal query's dat is uitgevoerd.
$db->getQueryTime();
//Retourneert de waarde van $this->debug
$db->getDebug();
//Veranderd het debug variabel
$db->setDebug($str); //Str kan zij: true, false of switch
//Verbinding maken
$db->connect(); //Gebruik deze alleen als je het standaard verbinden hebt uitgeschakeld. Anders wordt dit automatisch gedaan!
?>
Voorbeeld.php
-------------
Code (php)
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
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
<?php
require_once('databasecore.class.php');
require_once('mysqldatabase.class.php');
try {
$db = databaseCore::getConnection(array(
'type' => 'mysql',
'host' => 'HOST',
'user' => 'USER',
'password' => 'PASSWORD',
'dbname' => 'DATABASE_NAME'
), true, false);
$db->query("SELECT * FROM test");
while($row = $db->fetch()) {
echo $row['name'].' zegt: '.$row['message'].'<br />';
}
echo 'Total messages: '.$db->numRows().'<br />';
} catch(Exception $e) {
echo $e->getMessage().'<br />Code: '.$e->getCode().'<br />Line: '.$e->getLine().'<br />File: '.$e->getFile();
if($e->getCode() > 100) {
exit;
}
}
try {
$db->multiQuery( "UPDATE status SET sitestatus = 'offline' WHERE id = 1",
"INSERT INTO users(name, pass, email) VALUES ('Pietje', '".md5('Dit_is_een_slecht_wachtwoord')."', '".$db->escape('[email protected]')."')",
"UPDATE users SET ip = '".$_SERVER['REMOTE_ADDR']."' WHERE name = 'Pietje'",
"SELECT * FROM test"
);
while($row = $db->fetch()) {
echo $row['name'].' zegt: '.$row['message'].'<br />';
}
} catch(Exception $e) {
echo $e->getMessage().'<br />Code: '.$e->getCode().'<br />Line: '.$e->getLine().'<br />File: '.$e->getFile();
if($e->getCode() > 100) {
exit;
}
}
?>
require_once('databasecore.class.php');
require_once('mysqldatabase.class.php');
try {
$db = databaseCore::getConnection(array(
'type' => 'mysql',
'host' => 'HOST',
'user' => 'USER',
'password' => 'PASSWORD',
'dbname' => 'DATABASE_NAME'
), true, false);
$db->query("SELECT * FROM test");
while($row = $db->fetch()) {
echo $row['name'].' zegt: '.$row['message'].'<br />';
}
echo 'Total messages: '.$db->numRows().'<br />';
} catch(Exception $e) {
echo $e->getMessage().'<br />Code: '.$e->getCode().'<br />Line: '.$e->getLine().'<br />File: '.$e->getFile();
if($e->getCode() > 100) {
exit;
}
}
try {
$db->multiQuery( "UPDATE status SET sitestatus = 'offline' WHERE id = 1",
"INSERT INTO users(name, pass, email) VALUES ('Pietje', '".md5('Dit_is_een_slecht_wachtwoord')."', '".$db->escape('[email protected]')."')",
"UPDATE users SET ip = '".$_SERVER['REMOTE_ADDR']."' WHERE name = 'Pietje'",
"SELECT * FROM test"
);
while($row = $db->fetch()) {
echo $row['name'].' zegt: '.$row['message'].'<br />';
}
} catch(Exception $e) {
echo $e->getMessage().'<br />Code: '.$e->getCode().'<br />Line: '.$e->getLine().'<br />File: '.$e->getFile();
if($e->getCode() > 100) {
exit;
}
}
?>
databasecore.class.php
-----------------------
Code (php)
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
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
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
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
<?php
/**
* databaseCore
* @package databaseConnector
* @author Tom Janssen
* @copyright Copyright (c) 2009, Tom Janssen
* @license Free to use under GNU General Public License {@link http://www.gnu.org/licenses/gpl.html}
* @version 1.1.3
*/
abstract class databaseCore {
/**
* General error level, generated by among other querys
*/
const GEN_ERROR = 100;
/**
* General error level, generated by among other connection failure
*/
const CON_ERROR = 200;
/**
* General error level, generated by among other setup failure
*/
const FAT_ERROR = 250;
/**
* Holds the link identifier
* @access protected
* @var mixed
*/
protected $_dblink;
/**
* Holds all the host settings before connecting
* @static
* @access protected
* @var array
*/
static protected $_data = array (
'type' => '',
'host' => '',
'port' => '',
'socket' => '',
'user' => '',
'password' => '',
'dbname' => ''
);
/**
* Holds all the host settings that the user has given.
* @access protected
* @var array
*/
protected $_userdata = array ();
/**
* Debug true or false. Default false.
* @access protected
* @var bool
*/
protected $debug = false;
/**
* Holds all query's in order of executing
* @access protected
* @var array
*/
protected $queryCache = array();
/**
* Holds the 'id' of the last query.
* @access protected
* @var int
*/
protected $queryTime = 0; //Dit is het aantal querys dat is uitgevoerd.
/**
* Constructor, sets the connecting vars and connects. Also set debug to true.
* @access public
* @param bool $debug holds the debug choise
*/
public function __construct($debug=false) {
if($debug === true) {
$this->debug = true;
}
}
/**#@+
* @abstract
*/
/**
* connect, called by functions who connect to MySQL.
* @access protected
*/
abstract public function connect();
/**
* checkConnection, checks if there is a connection.
* @access protected
* @return bool
*/
abstract protected function checkConnection();
/**
* escape, alias of mysql_real_escape_string
* @access public
* @param string $toEcape string to escape with mysql_real_escape_string.
* @return string
*/
abstract public function escape($toEscape);
/**
* query, tries to execute a query.
* @access public
* @param string $sql SQL code to execute.
* @return string
*/
abstract public function query($sql);
/**
* multiQuery, excecutes so many query's if you want. Just add more SQL codes.
* @access public
* @param string $sql,.. you can add this parameter many times as you want.
*/
abstract public function multiQuery();
/**
* fetch, if no parameter is given, use last query.
* @access public
* @param [string $query] contains a query resource or an query ID starting with a 'r'. Not required to be given.
* @return array
*/
abstract public function fetch();
/**
* numRows, if no parameter is given, use last query.
* @access public
* @param [string $query] contains a query resource or an query ID starting with a 'r'
* @return int
*/
abstract public function numRows();
/**
* affectedRows, gives affected rows from last UPDATE, INSERT etc. query.
* @access public
* @return int
*/
abstract public function affectedRows();
/**
* insertId, gives last insert id.
* @access public
* @return int
*/
abstract public function insertId();
/**#@-*/
/**
* setDebug, change debug setting
* @access public
* @param bool $newValue sets debug on true or false.
* @return bool
*/
public function setDebug($newValue) {
if($newValue === true || $newValue === false) {
$this->debug = $newValue;
return true;
} elseif($newValue === 'switch') {
if($this->debug === true) {
$this->debug = false;
return true;
} elseif($this->debug === false) {
$this->debug = true;
return true;
}
}
return false;
}
/**
* getDebug, get the debug setting
* @access public
* @return bool
*/
public function getDebug() {
return $this->debug;
}
/**
* getQueryTime, returns the $queryTime variable.
* @access public
* @return int
*/
public function getQueryTime() {
return $this->queryTime;
}
/**
* getDebug, get the debug setting
* @access public
* @param string $id hold the ID starting with a 'q' or a 'r'.
* @return array
*/
public function getQuery($id) {
$type = substr($id, 0, 1);
if(ctype_digit(substr($id, 1)) && $id >= 0 && $type === 'q' || $type === 'r') {
if($id <= $this->queryTime) {
return $this->queryCache[$type][$id];
}
}
//Return false in alle andere gevallen.
return false;
}
/**
* Hiermee selecteer je een database type.
* @static
* @since version 1.1
* @param array $data contains all data wich are importent to connect.
*/
static public function getConnection(array $data = null, $debug=false, $connect=true) {
if(!!!($keys = array_diff_key($data, self::$_data))) {
$data = array_merge(self::$_data, $data);
} else {
$_s = (count($keys) > 1) ? 's' : '';
throw new Exception('Geen valid parameter '.$_s.': '.implode(', ', $keys), self::FAT_ERROR);
}
$class = $data['type'].'Database';
if(class_exists($class, false) === true) {
return new $class($data, $debug, $connect);
}
throw new Exception('Het type dat is opgegeven klopt niet. Gebruik een ander type aan of definieer deze class.', self::FAT_ERROR);
}
}
?>
/**
* databaseCore
* @package databaseConnector
* @author Tom Janssen
* @copyright Copyright (c) 2009, Tom Janssen
* @license Free to use under GNU General Public License {@link http://www.gnu.org/licenses/gpl.html}
* @version 1.1.3
*/
abstract class databaseCore {
/**
* General error level, generated by among other querys
*/
const GEN_ERROR = 100;
/**
* General error level, generated by among other connection failure
*/
const CON_ERROR = 200;
/**
* General error level, generated by among other setup failure
*/
const FAT_ERROR = 250;
/**
* Holds the link identifier
* @access protected
* @var mixed
*/
protected $_dblink;
/**
* Holds all the host settings before connecting
* @static
* @access protected
* @var array
*/
static protected $_data = array (
'type' => '',
'host' => '',
'port' => '',
'socket' => '',
'user' => '',
'password' => '',
'dbname' => ''
);
/**
* Holds all the host settings that the user has given.
* @access protected
* @var array
*/
protected $_userdata = array ();
/**
* Debug true or false. Default false.
* @access protected
* @var bool
*/
protected $debug = false;
/**
* Holds all query's in order of executing
* @access protected
* @var array
*/
protected $queryCache = array();
/**
* Holds the 'id' of the last query.
* @access protected
* @var int
*/
protected $queryTime = 0; //Dit is het aantal querys dat is uitgevoerd.
/**
* Constructor, sets the connecting vars and connects. Also set debug to true.
* @access public
* @param bool $debug holds the debug choise
*/
public function __construct($debug=false) {
if($debug === true) {
$this->debug = true;
}
}
/**#@+
* @abstract
*/
/**
* connect, called by functions who connect to MySQL.
* @access protected
*/
abstract public function connect();
/**
* checkConnection, checks if there is a connection.
* @access protected
* @return bool
*/
abstract protected function checkConnection();
/**
* escape, alias of mysql_real_escape_string
* @access public
* @param string $toEcape string to escape with mysql_real_escape_string.
* @return string
*/
abstract public function escape($toEscape);
/**
* query, tries to execute a query.
* @access public
* @param string $sql SQL code to execute.
* @return string
*/
abstract public function query($sql);
/**
* multiQuery, excecutes so many query's if you want. Just add more SQL codes.
* @access public
* @param string $sql,.. you can add this parameter many times as you want.
*/
abstract public function multiQuery();
/**
* fetch, if no parameter is given, use last query.
* @access public
* @param [string $query] contains a query resource or an query ID starting with a 'r'. Not required to be given.
* @return array
*/
abstract public function fetch();
/**
* numRows, if no parameter is given, use last query.
* @access public
* @param [string $query] contains a query resource or an query ID starting with a 'r'
* @return int
*/
abstract public function numRows();
/**
* affectedRows, gives affected rows from last UPDATE, INSERT etc. query.
* @access public
* @return int
*/
abstract public function affectedRows();
/**
* insertId, gives last insert id.
* @access public
* @return int
*/
abstract public function insertId();
/**#@-*/
/**
* setDebug, change debug setting
* @access public
* @param bool $newValue sets debug on true or false.
* @return bool
*/
public function setDebug($newValue) {
if($newValue === true || $newValue === false) {
$this->debug = $newValue;
return true;
} elseif($newValue === 'switch') {
if($this->debug === true) {
$this->debug = false;
return true;
} elseif($this->debug === false) {
$this->debug = true;
return true;
}
}
return false;
}
/**
* getDebug, get the debug setting
* @access public
* @return bool
*/
public function getDebug() {
return $this->debug;
}
/**
* getQueryTime, returns the $queryTime variable.
* @access public
* @return int
*/
public function getQueryTime() {
return $this->queryTime;
}
/**
* getDebug, get the debug setting
* @access public
* @param string $id hold the ID starting with a 'q' or a 'r'.
* @return array
*/
public function getQuery($id) {
$type = substr($id, 0, 1);
if(ctype_digit(substr($id, 1)) && $id >= 0 && $type === 'q' || $type === 'r') {
if($id <= $this->queryTime) {
return $this->queryCache[$type][$id];
}
}
//Return false in alle andere gevallen.
return false;
}
/**
* Hiermee selecteer je een database type.
* @static
* @since version 1.1
* @param array $data contains all data wich are importent to connect.
*/
static public function getConnection(array $data = null, $debug=false, $connect=true) {
if(!!!($keys = array_diff_key($data, self::$_data))) {
$data = array_merge(self::$_data, $data);
} else {
$_s = (count($keys) > 1) ? 's' : '';
throw new Exception('Geen valid parameter '.$_s.': '.implode(', ', $keys), self::FAT_ERROR);
}
$class = $data['type'].'Database';
if(class_exists($class, false) === true) {
return new $class($data, $debug, $connect);
}
throw new Exception('Het type dat is opgegeven klopt niet. Gebruik een ander type aan of definieer deze class.', self::FAT_ERROR);
}
}
?>
mysqldatabase.class.php
-----------------------
Code (php)
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
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
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
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
<?php
/**
* mysqlDatabase
* @package databaseConnector
* @author Tom Janssen
* @copyright Copyright (c) 2009, Tom Janssen
* @license Free to use under GNU General Public License {@link http://www.gnu.org/licenses/gpl.html}
* @version 1.1.3
*/
class mysqlDatabase extends databaseCore {
/**
* Constructor
* @access public
* @param array $data contains all needed data to set up a connection
*/
public function __construct(array $data, $debug=false, $connect=true) {
parent::__construct($debug);
if(isset($data['host'], $data['user'], $data['password'], $data['dbname'])) {
$this->_userdata = $data;
if($connect === true) {
try {
$this->connect();
} catch(Exception $e) {
//Errors doorsturen.
throw $e;
}
}
} else {
throw new Exception('Niet genoeg gegevens meegestuurd.', self::FAT_ERROR);
}
}
/**
* Connector, hiermee zet het script een connectie op met de eerder ingevoerde gegevens.
* @access public
*/
public function connect() {
$this->_dblink = mysql_connect($this->_userdata['host'], $this->_userdata['user'], $this->_userdata['password']);
if($this->_dblink === false) {
$errorMessage = "Kon geen verbinding maken met de database maken.";
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno().": ".mysql_error();
}
} else {
//Probeer nu de database te selecteren
$dbbase = mysql_select_db($this->_userdata['dbname'], $this->_dblink);
//Database select error handler
if($dbbase === false) {
$errorMessage = "Kon geen database selecteren.";
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno().": ".mysql_error();
}
}
}
if(isset($errorMessage)) {
throw new Exception($errorMessage, self::FAT_ERROR);
}
}
/**
* checkConnection, checks if there is a connection, alias from mysql_ping.
* @access protected
* @return bool
*/
protected function checkConnection() {
//Doe dit omdat als er nog geen connectie is er een lelijke error komt.
if($this->_dblink !== NULL) {
return mysql_ping($this->_dblink);
}
return false;
}
/**
* escape, alias of mysql_real_escape_string
* @access public
* @param string $toEcape string to escape with mysql_real_escape_string.
* @return string
*/
public function escape($toEscape) {
//Doe dit omdat als er nog geen connectie is er een lelijke error komt.
if($this->_dblink !== NULL) {
return mysql_real_escape_string($toEscape, $this->_dblink);
}
return mysql_real_escape_string($toEscape);
}
/**
* query, tries to execute a query.
* @access public
* @param string $sql SQL code to execute.
* @return string
*/
public function query($sql) {
if($this->checkConnection() === true) {
$this->queryTime++;
$this->queryCache['q'][$this->queryTime] = $sql;
$query = mysql_query($sql, $this->_dblink);
if($query !== false) {
$this->queryCache['r'][$this->queryTime] = $query;
return $query;
}
$errorMessage = "Kon geen query verzenden.";
$eC = self::GEN_ERROR;
$this->queryCache['r'][$this->queryTime] = mysql_error($this->_dblink);
} else {
$errorMessage = "Kon geen verbinding vinden.";
$eC = self::CON_ERROR;
}
if($this->debug === true && $eC != self::CON_ERROR) {
$errorMessage .= "<br />".mysql_errno($this->_dblink).": ".mysql_error($this->_dblink);
}
throw new Exception($errorMessage, $eC);
}
/**
* multiQuery, excecutes so many query's if you want. Just add more SQL codes.
* @access public
* @param string $sql,.. you can add this parameter many times as you want.
*/
public function multiQuery() {
if($this->checkConnection() === true) {
$numArgs = func_num_args();
if($numArgs === 1) {
return $this->query(func_get_arg(0));
}
for($i = 0; $i < $numArgs; $i++) {
$this->queryTime++;
$this->queryCache['q'][$this->queryTime] = func_get_arg($i);
$query = mysql_query($this->queryCache['q'][$this->queryTime], $this->_dblink);
if($query !== false) {
$this->queryCache['r'][$this->queryTime] = $query;
} else {
$errorMessage = "Kon de query met id #".$this->queryTime." niet verzenden!";
$this->queryCache['r'][$this->queryTime] = mysql_error($this->_dblink);
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno($this->_dblink).": ".mysql_error($this->_dblink);
}
throw new Exception($errorMessage, self::GEN_ERROR);
}
$query = NULL;
}
} else {
//Errors onmogelijk omdat er geen verbinding is.
$errorMessage = "Kon geen verbinding vinden.";
throw new Exception($errorMessage, self::CON_ERROR);
}
}
/**
* fetch, if no parameter is given, use last query.
* @access public
* @param string $query contains a query resource or an query ID starting with a 'r'. Not required to be given.
* @return array
*/
public function fetch() {
if(func_num_args() == 0) {
$query = 'r'.$this->queryTime;
} else {
$query = func_get_arg(0);
}
if(preg_match('/r[0-9]/i', $query)) {
$rQuery = $this->queryCache[substr($query, 0, 1)][substr($query, 1)];
} else {
$rQuery = $query;
}
$fQuery = mysql_fetch_assoc($rQuery);
if($fQuery === false && trim(mysql_error($this->_dblink)) != '') {
$errorMessage = "Kon de query niet fetchen.";
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno($this->_dblink).": ".mysql_error($this->_dblink);
}
throw new Exception($errorMessage, self::GEN_ERROR); //Function stops here.
}
return $fQuery; //Else return the fetched rows.
}
/**
* numRows, if no parameter is given, use last query.
* @access public
* @param string $query contains a query resource or an query ID starting with a 'r'
* @return int
*/
public function numRows() {
if(func_num_args() == 0) {
$query = 'r'.$this->queryTime;
} else {
$query = func_get_arg(0);
}
if(preg_match('/r[0-9]/i', $query)) {
$rQuery = $this->queryCache['r'][substr($query, 1)];
} else {
$rQuery = $query;
}
return mysql_num_rows($rQuery);
}
/**
* affectedRows, alias of mysql_affected_rows
* @access public
* @return int
*/
public function affectedRows() {
$affectedRows = mysql_affected_rows($this->_dblink);
//Als de laatste query heeft gefaald returnt hij -1. Gewenste waarde is dan 0.
if($affectedRows === -1) {
return 0;
}
return $affectedRows;
}
/**
* insertId, alias of mysql_insert_id
* @access public
* @param mixed $tabel this will give the last auto_increment, if you specefy a tabel, this will be send with. Default: false.
* @return int
* @since version 1.1.2
*/
public function insertId($tabel=false) {
if($this->checkConnection()) {
$idQuery = "SELECT LAST_INSERT_ID() AS last_id";
if($tabel !== false) {
$idQuery .= " FROM ".$tabel;
}
try {
$this->query($idQuery);
$row = $this->fetch();
return $row['last_id'];
} catch(Exception $e) {
throw $e;
}
} else {
throw new Exception('Er is geen verbinding gevonden.', self::CON_ERROR);
}
}
}
?>
/**
* mysqlDatabase
* @package databaseConnector
* @author Tom Janssen
* @copyright Copyright (c) 2009, Tom Janssen
* @license Free to use under GNU General Public License {@link http://www.gnu.org/licenses/gpl.html}
* @version 1.1.3
*/
class mysqlDatabase extends databaseCore {
/**
* Constructor
* @access public
* @param array $data contains all needed data to set up a connection
*/
public function __construct(array $data, $debug=false, $connect=true) {
parent::__construct($debug);
if(isset($data['host'], $data['user'], $data['password'], $data['dbname'])) {
$this->_userdata = $data;
if($connect === true) {
try {
$this->connect();
} catch(Exception $e) {
//Errors doorsturen.
throw $e;
}
}
} else {
throw new Exception('Niet genoeg gegevens meegestuurd.', self::FAT_ERROR);
}
}
/**
* Connector, hiermee zet het script een connectie op met de eerder ingevoerde gegevens.
* @access public
*/
public function connect() {
$this->_dblink = mysql_connect($this->_userdata['host'], $this->_userdata['user'], $this->_userdata['password']);
if($this->_dblink === false) {
$errorMessage = "Kon geen verbinding maken met de database maken.";
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno().": ".mysql_error();
}
} else {
//Probeer nu de database te selecteren
$dbbase = mysql_select_db($this->_userdata['dbname'], $this->_dblink);
//Database select error handler
if($dbbase === false) {
$errorMessage = "Kon geen database selecteren.";
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno().": ".mysql_error();
}
}
}
if(isset($errorMessage)) {
throw new Exception($errorMessage, self::FAT_ERROR);
}
}
/**
* checkConnection, checks if there is a connection, alias from mysql_ping.
* @access protected
* @return bool
*/
protected function checkConnection() {
//Doe dit omdat als er nog geen connectie is er een lelijke error komt.
if($this->_dblink !== NULL) {
return mysql_ping($this->_dblink);
}
return false;
}
/**
* escape, alias of mysql_real_escape_string
* @access public
* @param string $toEcape string to escape with mysql_real_escape_string.
* @return string
*/
public function escape($toEscape) {
//Doe dit omdat als er nog geen connectie is er een lelijke error komt.
if($this->_dblink !== NULL) {
return mysql_real_escape_string($toEscape, $this->_dblink);
}
return mysql_real_escape_string($toEscape);
}
/**
* query, tries to execute a query.
* @access public
* @param string $sql SQL code to execute.
* @return string
*/
public function query($sql) {
if($this->checkConnection() === true) {
$this->queryTime++;
$this->queryCache['q'][$this->queryTime] = $sql;
$query = mysql_query($sql, $this->_dblink);
if($query !== false) {
$this->queryCache['r'][$this->queryTime] = $query;
return $query;
}
$errorMessage = "Kon geen query verzenden.";
$eC = self::GEN_ERROR;
$this->queryCache['r'][$this->queryTime] = mysql_error($this->_dblink);
} else {
$errorMessage = "Kon geen verbinding vinden.";
$eC = self::CON_ERROR;
}
if($this->debug === true && $eC != self::CON_ERROR) {
$errorMessage .= "<br />".mysql_errno($this->_dblink).": ".mysql_error($this->_dblink);
}
throw new Exception($errorMessage, $eC);
}
/**
* multiQuery, excecutes so many query's if you want. Just add more SQL codes.
* @access public
* @param string $sql,.. you can add this parameter many times as you want.
*/
public function multiQuery() {
if($this->checkConnection() === true) {
$numArgs = func_num_args();
if($numArgs === 1) {
return $this->query(func_get_arg(0));
}
for($i = 0; $i < $numArgs; $i++) {
$this->queryTime++;
$this->queryCache['q'][$this->queryTime] = func_get_arg($i);
$query = mysql_query($this->queryCache['q'][$this->queryTime], $this->_dblink);
if($query !== false) {
$this->queryCache['r'][$this->queryTime] = $query;
} else {
$errorMessage = "Kon de query met id #".$this->queryTime." niet verzenden!";
$this->queryCache['r'][$this->queryTime] = mysql_error($this->_dblink);
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno($this->_dblink).": ".mysql_error($this->_dblink);
}
throw new Exception($errorMessage, self::GEN_ERROR);
}
$query = NULL;
}
} else {
//Errors onmogelijk omdat er geen verbinding is.
$errorMessage = "Kon geen verbinding vinden.";
throw new Exception($errorMessage, self::CON_ERROR);
}
}
/**
* fetch, if no parameter is given, use last query.
* @access public
* @param string $query contains a query resource or an query ID starting with a 'r'. Not required to be given.
* @return array
*/
public function fetch() {
if(func_num_args() == 0) {
$query = 'r'.$this->queryTime;
} else {
$query = func_get_arg(0);
}
if(preg_match('/r[0-9]/i', $query)) {
$rQuery = $this->queryCache[substr($query, 0, 1)][substr($query, 1)];
} else {
$rQuery = $query;
}
$fQuery = mysql_fetch_assoc($rQuery);
if($fQuery === false && trim(mysql_error($this->_dblink)) != '') {
$errorMessage = "Kon de query niet fetchen.";
if($this->debug === true) {
$errorMessage .= "<br />".mysql_errno($this->_dblink).": ".mysql_error($this->_dblink);
}
throw new Exception($errorMessage, self::GEN_ERROR); //Function stops here.
}
return $fQuery; //Else return the fetched rows.
}
/**
* numRows, if no parameter is given, use last query.
* @access public
* @param string $query contains a query resource or an query ID starting with a 'r'
* @return int
*/
public function numRows() {
if(func_num_args() == 0) {
$query = 'r'.$this->queryTime;
} else {
$query = func_get_arg(0);
}
if(preg_match('/r[0-9]/i', $query)) {
$rQuery = $this->queryCache['r'][substr($query, 1)];
} else {
$rQuery = $query;
}
return mysql_num_rows($rQuery);
}
/**
* affectedRows, alias of mysql_affected_rows
* @access public
* @return int
*/
public function affectedRows() {
$affectedRows = mysql_affected_rows($this->_dblink);
//Als de laatste query heeft gefaald returnt hij -1. Gewenste waarde is dan 0.
if($affectedRows === -1) {
return 0;
}
return $affectedRows;
}
/**
* insertId, alias of mysql_insert_id
* @access public
* @param mixed $tabel this will give the last auto_increment, if you specefy a tabel, this will be send with. Default: false.
* @return int
* @since version 1.1.2
*/
public function insertId($tabel=false) {
if($this->checkConnection()) {
$idQuery = "SELECT LAST_INSERT_ID() AS last_id";
if($tabel !== false) {
$idQuery .= " FROM ".$tabel;
}
try {
$this->query($idQuery);
$row = $this->fetch();
return $row['last_id'];
} catch(Exception $e) {
throw $e;
}
} else {
throw new Exception('Er is geen verbinding gevonden.', self::CON_ERROR);
}
}
}
?>