--- sql/oracle/parser3oracle.C	2008/07/08 08:07:49	1.72
+++ sql/oracle/parser3oracle.C	2012/06/06 14:49:01	1.76
@@ -1,21 +1,21 @@
 /** @file
 	Parser Oracle driver.
 
-	Copyright(c) 2001, 2003 ArtLebedev Group (http://www.artlebedev.com)
+	Copyright (c) 2001-2012 Art. Lebedev Studio (http://www.artlebedev.com)
 
 	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
 
 	2001.07.30 using Oracle 8.1.6 [@test tested with Oracle 7.x.x]
 */
 
-static const char *RCSId="$Id: parser3oracle.C,v 1.72 2008/07/08 08:07:49 misha Exp $"; 
-
 #include "config_includes.h"
 
 #include "pa_sql_driver.h"
 
 #include <oci.h>
 
+volatile const char * IDENT_PARSER3ORACLE_C="$Id: parser3oracle.C,v 1.76 2012/06/06 14:49:01 moko Exp $" IDENT_PA_SQL_DRIVER_H;
+
 #define MAX_COLS 500
 #define MAX_IN_LOBS 5
 #define MAX_LOB_NAME_LENGTH 100
@@ -275,8 +275,8 @@ public:
 
 			if(!error)
 				OCIInitialize((ub4)OCI_THREADED/*| OCI_OBJECT*/, (dvoid *)0, 
-					(dvoid * (*)(void *, unsigned int))0, 
-					(dvoid * (*)(void*, void*, unsigned int))0,  
+					(dvoid * (*)(void *, size_t))0, 
+					(dvoid * (*)(void*, void*, size_t))0,  
 					(void (*)(void*, void*))0 
 				);
 		}
@@ -445,20 +445,33 @@ public:
 		return true;
 	}
 
-	const char* quote(void *aconnection,
-		const char *from, unsigned int length) 
+	// charset here is services.request_charset(), not connection.client_charset
+	// thus we can't use the sql server quoting support
+	const char* quote(void *aconnection, const char *str, unsigned int length) 
 	{
-		Connection& connection=*static_cast<Connection *>(aconnection);
-		char *result=(char*)connection.services->malloc_atomic(length*2+1);
-		char *to=result;
-		while(length--) {
-			switch(*from) {
-			case '\'': // "'" -> "''"
-				*to++='\'';
-				break;
-			}
-			*to++=*from++;
+		const char* from;
+		const char* from_end=str+length;
+
+		size_t quoted=0;
+
+		for(from=str; from<from_end; from++){
+			if(*from=='\'')
+				quoted++;
 		}
+
+		if(!quoted)
+			return str;
+
+		Connection& connection=*static_cast<Connection*>(aconnection);
+		char *result=(char*)connection.services->malloc_atomic(length + quoted + 1);
+		char *to = result;
+
+		for(from=str; from<from_end; from++){
+			if(*from=='\'')
+				*to++= '\''; // ' -> ''
+			*to++=*from;
+		}
+		
 		*to=0;
 		return result;
 	}
@@ -882,17 +895,17 @@ private: // private funcs
 					(dvoid**) &col_name, (ub4 *) &col_name_len, (ub4)OCI_ATTR_NAME, 
 					(OCIError *)connection.errhp));
 
+				size_t length=(size_t)col_name_len;
 				if(transcode_needed){
 					// transcode column name from ?ClientCharset to $request:charset
 					services.transcode(col_name, col_name_len,
-						col_name, col_name_len,
+						col_name, length,
 						client_charset,
 						request_charset);
 				}
 
 				Col& col=cols[column_count-1];
 				{
-					size_t length=(size_t)col_name_len;
 					char *ptr=(char *)services.malloc_atomic(length+1);
 					if( connection.options.bLowerCaseColumnNames ) 
 						tolower_str(ptr, col_name, length);
@@ -1086,8 +1099,8 @@ cleanup: // no check call after this poi
 				strcat(statement_limited, astatement);
 
 				statement_limited+=46+statement_size;
-				statement_limited+=snprintf(statement_limited, 18+MAX_NUMBER, ") z__) WHERE r__<=%u", limit+offset);
-				statement_limited+=snprintf(statement_limited, 9+MAX_NUMBER, " AND r__>%u", offset);
+				statement_limited+=snprintf(statement_limited, 18+MAX_NUMBER, ") z__) WHERE r__<=%lu", limit+offset);
+				statement_limited+=snprintf(statement_limited, 9+MAX_NUMBER, " AND r__>%lu", offset);
 
 			} else {
 
@@ -1107,7 +1120,7 @@ cleanup: // no check call after this poi
 				strcat(statement_limited, astatement);
 
 				statement_limited+=15+statement_size;
-				statement_limited+=snprintf(statement_limited, 16+MAX_NUMBER, ") WHERE ROWNUM<=%u", limit);
+				statement_limited+=snprintf(statement_limited, 16+MAX_NUMBER, ") WHERE ROWNUM<=%lu", limit);
 
 			}
 			*statement_limited=0;