--- parser3/src/sql/mysql/Attic/parser3mysql.C	2001/05/17 17:10:12	1.20
+++ parser3/src/sql/mysql/Attic/parser3mysql.C	2001/07/23 13:59:52	1.26
@@ -4,9 +4,8 @@
 	Copyright(c) 2001 ArtLebedev Group(http://www.artlebedev.com)
 
 	Author: Alexander Petrosyan <paf@design.ru>(http://design.ru/paf)
-
-	$Id: parser3mysql.C,v 1.20 2001/05/17 17:10:12 parser Exp $
 */
+static const char *RCSId="$Id: parser3mysql.C,v 1.26 2001/07/23 13:59:52 parser Exp $"; 
 
 #include "config_includes.h"
 
@@ -47,11 +46,12 @@ public:
 	int api_version() { return SQL_DRIVER_API_VERSION; }
 	/// initialize driver by loading sql dynamic link library
 	const char *initialize(const char *dlopen_file_spec) {
-		return dlink(dlopen_file_spec);
+		return dlopen_file_spec?
+			dlink(dlopen_file_spec):"client library column is empty";
 	}
 	/**	connect
 		@param used_only_in_connect_url
-			format: @b user:pass@{host[:port]|[/unix/socket]}/database/charset 
+			format: @b user:pass@host[:port]|[/unix/socket]/database/charset 
 			3.23.22b
 			Currently the only option for @b character_set_name is cp1251_koi8.
 			WARNING: must be used only to connect, for buffer doesn't live long
@@ -121,8 +121,7 @@ public:
 	void query(
 		SQL_Driver_services& services, void *connection, 
 		const char *astatement, unsigned long offset, unsigned long limit,
-		unsigned int *column_count, Cell **columns, 
-		unsigned long *row_count, Cell ***rows) {
+		SQL_Driver_query_event_handlers& handlers) {
 
 		MYSQL *mysql=(MYSQL *)connection;
 		MYSQL_RES *res=NULL;
@@ -147,46 +146,42 @@ public:
 			services._throw(mysql_error(mysql));
 		if(!(res=mysql_store_result(mysql)) && mysql_field_count(mysql)) 
 			services._throw(mysql_error(mysql));
-		if(!res) {
-			// empty result
-			*row_count=0;
-			*column_count=0;
+		if(!res) // empty result: insert|delete|update|...
 			return;
-		}
 		
-		*column_count=mysql_num_fields(res);
-		if(!*column_count) // old client
-			*column_count=mysql_field_count(mysql);
+		int column_count=mysql_num_fields(res);
+		if(!column_count) // old client
+			column_count=mysql_field_count(mysql);
 
-		if(!*column_count)
+		if(!column_count)
 			services._throw("result contains no columns");
 
-		*columns=(Cell *)services.malloc(sizeof(Cell)*(*column_count));
-		for(unsigned int i=0; i<(*column_count); i++){
+		for(int i=0; i<column_count; i++){
 			MYSQL_FIELD *field=mysql_fetch_field(res);
 			size_t size=strlen(field->name);
-			(*columns)[i].size=size;
-			(*columns)[i].ptr=services.malloc(size);
-			memcpy((*columns)[i].ptr, field->name, size);
+			void *ptr=services.malloc(size);
+			memcpy(ptr, field->name, size);
+			handlers.add_column(ptr, size);
 		}
+
+		handlers.before_rows();
 		
-		if(*row_count=(unsigned long)mysql_num_rows(res)) {
-			*rows=(Cell **)services.malloc(sizeof(Cell *)*(*row_count));
-			
-			for(unsigned long r=0; r<(*row_count); r++) 
+		if(unsigned long row_count=(unsigned long)mysql_num_rows(res))
+			for(unsigned long r=0; r<row_count; r++) 
 				if(MYSQL_ROW mysql_row=mysql_fetch_row(res)) { // never false..
+					handlers.add_row();
 					unsigned long *lengths=mysql_fetch_lengths(res);
-					Cell *row=(Cell *)malloc(sizeof(Cell)*(*column_count));
-					(*rows)[r]=row;
-					for(unsigned int i=0; i<(*column_count); i++){
+					for(int i=0; i<column_count; i++){
 						size_t size=(size_t)lengths[i];
-						row[i].size=size;
-						row[i].ptr=services.malloc(size);
-						memcpy(row[i].ptr, mysql_row[i], size);
+						void *ptr;
+						if(size) {
+							ptr=services.malloc(size);
+							memcpy(ptr, mysql_row[i], size);
+						} else
+							ptr=0;
+						handlers.add_row_cell(ptr, size);
 					}
 				}
-		} else
-			*rows=0;
 
 		mysql_free_result(res);
 	}