diff options
author | pixel <pixel> | 2004-11-27 21:46:02 +0000 |
---|---|---|
committer | pixel <pixel> | 2004-11-27 21:46:02 +0000 |
commit | ae2779e504ca5ae11a87e047b4536a5f428cce4d (patch) | |
tree | 19604ce1873e9cc98be9b840b894cb7eae341532 /lib/SQL.cc | |
parent | 583964f9f8e954eb57b31663065c5b9e833d045e (diff) |
Large dos2unix commit...
Diffstat (limited to 'lib/SQL.cc')
-rw-r--r-- | lib/SQL.cc | 152 |
1 files changed, 76 insertions, 76 deletions
@@ -1,76 +1,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
+#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 |