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
|
#ifdef HAVE_CONFIG_H
#include "config.h"
#endif
#ifdef HAVE_MYSQL
#include "SQL.h"
SQLConnection::SQLConnection(String host, String user, String passwd,
String db, int port, String socket,
unsigned long cflags) throw (GeneralException) : res(0) {
mysql_init(&con);
const char * phost = ((ugly_string) host).p;
const char * puser = ((ugly_string) user).p;
const char * ppasswd = ((ugly_string) passwd).p;
const char * pdb = ((ugly_string) db).p;
const char * psocket = ((ugly_string) socket).p;
phost = *phost ? phost : 0;
psocket = *psocket ? psocket : 0;
if (!mysql_real_connect(&con, phost, puser, ppasswd, pdb, port, psocket, cflags)) {
throw GeneralException("Could not connect to MySQL host " + host);
}
}
SQLConnection::~SQLConnection() {
mysql_close(&con);
}
void SQLConnection::query(String q) throw(GeneralException) {
if (res) {
mysql_free_result(res);
}
if (mysql_real_query(&con, ((ugly_string)q).p, q.strlen())) {
throw GeneralException(String("Couldn't run query ") + q);
}
res = mysql_store_result(&con);
if (res) {
nr = mysql_num_rows(res);
nf = mysql_num_fields(res);
fields = mysql_fetch_fields(res);
} else {
nr = 0;
nf = 0;
fields = 0;
}
}
int SQLConnection::numrows() {
return nr;
}
int SQLConnection::numfields() {
return nf;
}
AssocArray SQLConnection::fetchrow() {
AssocArray r;
MYSQL_ROW row;
int i;
row = mysql_fetch_row(res);
for (i = 0; i < nf; i++) {
r[fields[i].name] = row[i];
}
return r;
}
#endif
|
