Annotation of sql/mysql/parser3mysql.C, revision 1.15
1.1 parser 1: /** @file
2: Parser MySQL driver.
3:
1.11 paf 4: Copyright(c) 2001, 2003 ArtLebedev Group (http://www.artlebedev.com)
1.1 parser 5:
1.7 paf 6: Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
1.1 parser 7:
8: 2001.07.30 using MySQL 3.23.22b
1.3 paf 9:
10: 2001.11.06 numrows on "HP-UX istok1 B.11.00 A 9000/869 448594332 two-user license"
11: 3.23.42 & 4.0.0.alfa never worked, both subst & .sl version returned 0
1.1 parser 12: */
1.15 ! paf 13: static const char *RCSId="$Id: parser3mysql.C,v 1.14 2003/11/10 08:43:18 paf Exp $";
1.1 parser 14:
15: #include "config_includes.h"
16:
17: #include "pa_sql_driver.h"
18:
19: #define NO_CLIENT_LONG_LONG
20: #include "mysql.h"
21: #include "ltdl.h"
22:
23: #define MAX_STRING 0x400
24: #define MAX_NUMBER 20
25:
26: #if _MSC_VER
27: # define snprintf _snprintf
1.2 parser 28: # define strcasecmp _stricmp
1.1 parser 29: #endif
30:
31: static char *lsplit(char *string, char delim) {
32: if(string) {
33: char *v=strchr(string, delim);
34: if(v) {
35: *v=0;
36: return v+1;
37: }
38: }
39: return 0;
40: }
41:
1.2 parser 42: static char *lsplit(char **string_ref, char delim) {
43: char *result=*string_ref;
44: char *next=lsplit(*string_ref, delim);
45: *string_ref=next;
46: return result;
47: }
48:
1.14 paf 49: struct Connection {
1.15 ! paf 50: SQL_Driver_services *services;
! 51:
1.14 paf 52: MYSQL* handle;
53: bool autocommit;
54: };
55:
1.1 parser 56: /**
57: MySQL server driver
58: */
59: class MySQL_Driver : public SQL_Driver {
60: public:
61:
62: MySQL_Driver() : SQL_Driver() {
63: }
64:
65: /// get api version
66: int api_version() { return SQL_DRIVER_API_VERSION; }
67: /// initialize driver by loading sql dynamic link library
1.4 paf 68: const char *initialize(char *dlopen_file_spec) {
1.1 parser 69: return dlopen_file_spec?
70: dlink(dlopen_file_spec):"client library column is empty";
71: }
72: /** connect
73: @param used_only_in_connect_url
1.2 parser 74: format: @b user:pass@host[:port]|[/unix/socket]/database?
75: charset=cp1251_koi8&
76: timeout=3&
77: compress=1&
78: named_pipe=1
1.1 parser 79: 3.23.22b
80: Currently the only option for @b character_set_name is cp1251_koi8.
81: WARNING: must be used only to connect, for buffer doesn't live long
82: */
83: void connect(
84: char *used_only_in_connect_url,
85: SQL_Driver_services& services,
1.14 paf 86: void **connection_ref ///< output: Connection*
1.1 parser 87: ) {
88: char *user=used_only_in_connect_url;
89: char *s=lsplit(user, '@');
90: char *host=0;
91: char *unix_socket=0;
92: if(s && s[0]=='[') { // unix socket
93: unix_socket=1+s;
94: s=lsplit(unix_socket, ']');
95: } else { // IP
96: host=s;
97: }
98: char *db=lsplit(s, '/');
99: char *pwd=lsplit(user, ':');
100: char *error_pos=0;
101: char *port_cstr=lsplit(host, ':');
102: int port=port_cstr?strtol(port_cstr, &error_pos, 0):0;
1.2 parser 103: char *options=lsplit(db, '?');
104:
105: char *charset=0;
1.1 parser 106:
1.15 ! paf 107: Connection& connection=*(Connection *)::calloc(sizeof(Connection), 1);
! 108: *connection_ref=&connection;
! 109: connection.services=&services;
1.14 paf 110: connection.handle=mysql_init(NULL);
111: connection.autocommit=true;
1.2 parser 112:
113: while(options) {
114: if(char *key=lsplit(&options, '&')) {
115: if(*key) {
116: if(char *value=lsplit(key, '=')) {
117: if(strcasecmp(key, "charset")==0) {
118: charset=value;
119: } else if(strcasecmp(key, "timeout")==0) {
120: unsigned int timeout=(unsigned int)atoi(value);
1.14 paf 121: if(mysql_options(connection.handle, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&timeout)!=0)
122: services._throw(mysql_error(connection.handle));
1.2 parser 123: } else if(strcasecmp(key, "compress")==0) {
124: if(atoi(value))
1.14 paf 125: if(mysql_options(connection.handle, MYSQL_OPT_COMPRESS, 0)!=0)
126: services._throw(mysql_error(connection.handle));
1.2 parser 127: } else if(strcasecmp(key, "named_pipe")==0) {
128: if(atoi(value))
1.14 paf 129: if(mysql_options(connection.handle, MYSQL_OPT_NAMED_PIPE , 0)!=0)
130: services._throw(mysql_error(connection.handle));
131: } else if(strcasecmp(key, "autocommit")==0) {
132: if(atoi(value)==0) {
133: connection.autocommit=false;
134: }
1.2 parser 135: } else
136: services._throw("unknown connect option" /*key*/);
137: } else
138: services._throw("connect option without =value" /*key*/);
139: }
140: }
141: }
142:
1.14 paf 143: if(!mysql_real_connect(connection.handle,
1.1 parser 144: host, user, pwd, db, port?port:MYSQL_PORT, unix_socket, 0))
1.14 paf 145: services._throw(mysql_error(connection.handle));
1.1 parser 146:
1.2 parser 147: if(charset) {
1.1 parser 148: // set charset
149: char statement[MAX_STRING]="set CHARACTER SET "; // cp1251_koi8
150: strncat(statement, charset, MAX_STRING);
151:
1.15 ! paf 152: exec(connection, statement);
1.1 parser 153: }
154:
1.14 paf 155: if(!connection.autocommit)
1.15 ! paf 156: exec(connection, "set autocommit=0");
1.14 paf 157: }
158:
1.15 ! paf 159: void exec(Connection& connection, const char* statement) {
1.14 paf 160: if(mysql_query(connection.handle, statement))
1.15 ! paf 161: connection.services->_throw(mysql_error(connection.handle));
1.14 paf 162: (*mysql_store_result)(connection.handle); // throw out the result [don't need but must call]
1.1 parser 163: }
1.14 paf 164:
165: void disconnect(void *aconnection) {
166: Connection& connection=*static_cast<Connection*>(aconnection);
167:
168: mysql_close(connection.handle);
1.1 parser 169: }
1.15 ! paf 170: void commit(void *aconnection) {
1.14 paf 171: Connection& connection=*static_cast<Connection*>(aconnection);
1.1 parser 172:
1.14 paf 173: if(!connection.autocommit)
1.15 ! paf 174: exec(connection, "commit");
1.14 paf 175: }
1.15 ! paf 176: void rollback(void *aconnection) {
1.14 paf 177: Connection& connection=*static_cast<Connection*>(aconnection);
178:
179: if(!connection.autocommit)
1.15 ! paf 180: exec(connection, "rollback");
1.14 paf 181: }
182:
1.15 ! paf 183: bool ping(void *aconnection) {
1.14 paf 184: Connection& connection=*static_cast<Connection*>(aconnection);
185:
186: return mysql_ping(connection.handle)==0;
1.1 parser 187: }
188:
1.15 ! paf 189: const char* quote(void *aconnection, const char *from, unsigned int length) {
! 190: Connection& connection=*static_cast<Connection*>(aconnection);
1.1 parser 191: /*
192: 3.23.22b
193: You must allocate the to buffer to be at least length*2+1 bytes long.
194: (In the worse case, each character may need to be encoded as using two bytes,
195: and you need room for the terminating null byte.)
196: */
1.15 ! paf 197: char *result=(char*)connection.services->malloc_atomic(length*2+1);
1.13 paf 198: mysql_escape_string(result, from, length);
199: return result;
1.1 parser 200: }
201: void query(
1.15 ! paf 202: void *aconnection,
1.1 parser 203: const char *astatement, unsigned long offset, unsigned long limit,
204: SQL_Driver_query_event_handlers& handlers) {
1.14 paf 205: Connection& connection=*static_cast<Connection*>(aconnection);
1.15 ! paf 206: SQL_Driver_services& services=*connection.services;
1.1 parser 207: MYSQL_RES *res=NULL;
208:
209: const char *statement;
210: if(offset || limit) {
211: size_t statement_size=strlen(astatement);
1.13 paf 212: char *statement_limited=(char *)services.malloc_atomic(
1.1 parser 213: statement_size+MAX_NUMBER*2+8/* limit #,#*/+1);
214: char *cur=statement_limited;
215: memcpy(cur, astatement, statement_size); cur+=statement_size;
216: cur+=sprintf(cur, " limit ");
217: if(offset)
218: cur+=snprintf(cur, MAX_NUMBER+1, "%u,", offset);
219: if(limit)
220: cur+=snprintf(cur, MAX_NUMBER, "%u", limit);
221: statement=statement_limited;
222: } else
223: statement=astatement;
224:
1.14 paf 225: if(mysql_query(connection.handle, statement))
226: services._throw(mysql_error(connection.handle));
227: if(!(res=mysql_store_result(connection.handle)) && mysql_field_count(connection.handle))
228: services._throw(mysql_error(connection.handle));
1.1 parser 229: if(!res) // empty result: insert|delete|update|...
230: return;
231:
232: int column_count=mysql_num_fields(res);
233: if(!column_count) // old client
1.14 paf 234: column_count=mysql_field_count(connection.handle);
1.1 parser 235:
236: if(!column_count) {
237: mysql_free_result(res);
238: services._throw("result contains no columns");
239: }
1.8 paf 240:
1.9 paf 241: bool failed=false;
242: SQL_Error sql_error;
243: #define CHECK(afailed) \
244: if(afailed) { \
245: failed=true; \
246: goto cleanup; \
247: }
248:
249: for(int i=0; i<column_count; i++){
1.12 paf 250: if(MYSQL_FIELD *field=mysql_fetch_field(res)) {
1.13 paf 251: size_t length=strlen(field->name);
252: char* str=(char*)services.malloc_atomic(length+1);
253: memcpy(str, field->name, length+1);
254: CHECK(handlers.add_column(sql_error, str, length));
1.12 paf 255: } else {
256: // seen some broken client,
257: // which reported "44" for column count of response to "select 2+2"
258: column_count=i;
259: break;
260: }
1.9 paf 261: }
1.1 parser 262:
1.9 paf 263: CHECK(handlers.before_rows(sql_error));
264:
265: while(MYSQL_ROW mysql_row=mysql_fetch_row(res)) {
266: CHECK(handlers.add_row(sql_error));
267: unsigned long *lengths=mysql_fetch_lengths(res);
268: for(int i=0; i<column_count; i++){
1.13 paf 269: size_t length=(size_t)lengths[i];
270: char* str;
271: if(length) {
272: str=(char*)services.malloc_atomic(length+1);
273: memcpy(str, mysql_row[i], length);
274: str[length]=0;
1.9 paf 275: } else
1.13 paf 276: str=0;
277: CHECK(handlers.add_row_cell(sql_error, str, length));
1.3 paf 278: }
1.9 paf 279: }
280: cleanup:
1.1 parser 281: mysql_free_result(res);
1.9 paf 282: if(failed)
283: services._throw(sql_error);
1.1 parser 284: }
285:
286: private: // mysql client library funcs
287:
288: typedef MYSQL* (STDCALL *t_mysql_init)(MYSQL *); t_mysql_init mysql_init;
289:
1.2 parser 290: typedef int (STDCALL *t_mysql_options)(MYSQL *mysql, enum mysql_option option, const char *arg); t_mysql_options mysql_options;
291:
1.1 parser 292: typedef MYSQL_RES* (STDCALL *t_mysql_store_result)(MYSQL *); t_mysql_store_result mysql_store_result;
293:
294: typedef int (STDCALL *t_mysql_query)(MYSQL *, const char *q); t_mysql_query mysql_query;
295:
296: typedef char * (STDCALL *t_mysql_error)(MYSQL *); t_mysql_error mysql_error;
297: static char* STDCALL subst_mysql_error(MYSQL *mysql) { return (mysql)->net.last_error; }
298:
299: typedef MYSQL* (STDCALL *t_mysql_real_connect)(MYSQL *, const char *host,
300: const char *user,
301: const char *passwd,
302: const char *db,
303: unsigned int port,
304: const char *unix_socket,
305: unsigned int clientflag); t_mysql_real_connect mysql_real_connect;
306:
307: typedef void (STDCALL *t_mysql_close)(MYSQL *); t_mysql_close mysql_close;
308:
309: typedef int (STDCALL *t_mysql_ping)(MYSQL *); t_mysql_ping mysql_ping;
310:
311: typedef unsigned long (STDCALL *t_mysql_escape_string)(char *to,const char *from,
312: unsigned long from_length); t_mysql_escape_string mysql_escape_string;
313:
314: typedef void (STDCALL *t_mysql_free_result)(MYSQL_RES *result); t_mysql_free_result mysql_free_result;
315:
316: typedef unsigned long* (STDCALL *t_mysql_fetch_lengths)(MYSQL_RES *result); t_mysql_fetch_lengths mysql_fetch_lengths;
317:
318: typedef MYSQL_ROW (STDCALL *t_mysql_fetch_row)(MYSQL_RES *result); t_mysql_fetch_row mysql_fetch_row;
319:
320: typedef MYSQL_FIELD* (STDCALL *t_mysql_fetch_field)(MYSQL_RES *result); t_mysql_fetch_field mysql_fetch_field;
321:
322: typedef unsigned int (STDCALL *t_mysql_num_fields)(MYSQL_RES *); t_mysql_num_fields mysql_num_fields;
323: static unsigned int STDCALL subst_mysql_num_fields(MYSQL_RES *res) { return res->field_count; }
324:
325: typedef unsigned int (STDCALL *t_mysql_field_count)(MYSQL *); t_mysql_field_count mysql_field_count;
326: static unsigned int STDCALL subst_mysql_field_count(MYSQL *mysql) { return mysql->field_count; }
327:
328: private: // mysql client library funcs linking
329:
330: const char *dlink(const char *dlopen_file_spec) {
1.10 paf 331: if(lt_dlinit())
332: return lt_dlerror();
1.1 parser 333: lt_dlhandle handle=lt_dlopen(dlopen_file_spec);
334: if (!handle)
335: return "can not open the dynamic link module";
336:
337: #define DSLINK(name, action) \
338: name=(t_##name)lt_dlsym(handle, #name); \
339: if(!name) \
340: action;
341:
342: #define DLINK(name) DSLINK(name, return "function " #name " was not found")
343: #define SLINK(name) DSLINK(name, name=subst_##name)
344:
345: DLINK(mysql_init);
1.2 parser 346: DLINK(mysql_options);
1.1 parser 347: DLINK(mysql_store_result);
348: DLINK(mysql_query);
349: SLINK(mysql_error);
350: DLINK(mysql_real_connect);
351: DLINK(mysql_close);
352: DLINK(mysql_ping);
353: DLINK(mysql_escape_string);
354: DLINK(mysql_free_result);
355: DLINK(mysql_fetch_lengths);
356: DLINK(mysql_fetch_row);
357: DLINK(mysql_fetch_field);
358: SLINK(mysql_num_fields);
359: SLINK(mysql_field_count);
360: return 0;
361: }
362:
363: };
364:
365: extern "C" SQL_Driver *SQL_DRIVER_CREATE() {
366: return new MySQL_Driver();
367: }
E-mail:
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to parser3mysql.C CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [parser3project] / sql / mysql