--- sql/oracle/parser3oracle.C 2004/01/26 14:59:08 1.49 +++ sql/oracle/parser3oracle.C 2004/03/04 09:10:13 1.52 @@ -7,7 +7,7 @@ 2001.07.30 using Oracle 8.1.6 [@test tested with Oracle 7.x.x] */ -static const char *RCSId="$Id: parser3oracle.C,v 1.49 2004/01/26 14:59:08 paf Exp $"; +static const char *RCSId="$Id: parser3oracle.C,v 1.52 2004/03/04 09:10:13 paf Exp $"; #include "config_includes.h" @@ -173,8 +173,8 @@ static sb4 cbf_get_data(dvoid *ctxp, ub1 *piecep, dvoid **indpp, ub2 **rcodepp); -void tolower(char *out, const char *in, size_t size); -void toupper(char *out, const char *in, size_t size); +static void tolower(char *out, const char *in, size_t size); +static void toupper(char *out, const char *in, size_t size); static const char *options2env(char *s, Connection::Options* options) { while(s) { @@ -261,12 +261,12 @@ public: void connect( char *used_only_in_connect_url, SQL_Driver_services& services, - void **aconnection ///< output: Connection * + void **connection_ref ///< output: Connection * ) { - // connections are cross-request, do not use services._alloc [linked with request] - Connection& connection=*(Connection *)::calloc(sizeof(Connection), 1); + Connection& connection=*(Connection *)services.malloc(sizeof(Connection)); connection.services=&services; connection.options.bLowerCaseColumnNames = true; + *connection_ref=&connection; char *user=used_only_in_connect_url; char *service=lsplit(user, '@'); @@ -341,9 +341,6 @@ public: (dvoid *)connection.svchp, (ub4)OCI_HTYPE_SVCCTX, (dvoid *)connection.usrhp, (ub4)0, OCI_ATTR_SESSION, connection.errhp)); - - // return created connection - *(Connection **)aconnection=&connection; } void disconnect(void *aconnection) { Connection& connection=*static_cast(aconnection); @@ -669,7 +666,7 @@ private: // private funcs OCIParam *mypard; ub2 dtype; - text *col_name; + const char* col_name; struct Col { ub2 type; @@ -707,13 +704,20 @@ private: // private funcs (dvoid*) mypard, (ub4)OCI_DTYPE_PARAM, (dvoid**) &col_name, (ub4 *) &col_name_len, (ub4)OCI_ATTR_NAME, (OCIError *)connection.errhp)); - + // transcode to $request:charset from connect-string?client_charset + if(const char* cstrClientCharset=connection.options.cstrClientCharset) { + services.transcode(col_name, col_name_len, + col_name, col_name_len, + cstrClientCharset, + services.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(ptr, (char *)col_name, length); + tolower(ptr, col_name, length); else memcpy(ptr, col_name, length); ptr[length]=0; @@ -1116,11 +1120,11 @@ static sb4 cbf_get_data(dvoid *ctxp, return OCI_CONTINUE; } -void tolower(char *out, const char *in, size_t size) { +static void tolower(char *out, const char *in, size_t size) { while(size--) *out++=(char)tolower(*in++); } -void toupper(char *out, const char *in, size_t size) { +static void toupper(char *out, const char *in, size_t size) { while(size--) *out++=(char)toupper(*in++); }