--- parser3/src/main/pa_sql_driver_manager.C 2003/12/11 09:22:09 1.78 +++ parser3/src/main/pa_sql_driver_manager.C 2003/12/22 11:44:35 1.80 @@ -5,7 +5,7 @@ Author: Alexandr Petrosian (http://paf.design.ru) */ -static const char * const IDENT_SQL_DRIVER_MANAGER_C="$Date: 2003/12/11 09:22:09 $"; +static const char * const IDENT_SQL_DRIVER_MANAGER_C="$Date: 2003/12/22 11:44:35 $"; #include "pa_sql_driver_manager.h" #include "ltdl.h" @@ -15,6 +15,7 @@ static const char * const IDENT_SQL_DRIV #include "pa_common.h" #include "pa_vhash.h" #include "pa_vtable.h" +#include "pa_charsets.h" // globals @@ -38,6 +39,25 @@ const String& SQL_Driver_services_impl:: return result; } +void SQL_Driver_services_impl::transcode(const char* src, size_t src_length, + const char*& dst, size_t& dst_length, + const char* charset_from_name, + const char* charset_to_name + ) +{ + try { + String::C result=Charset::transcode(String::C(src, src_length), + charsets.get(charset_from_name), + charsets.get(charset_to_name)); + dst=result.str; + dst_length=result.length; + } catch(const Exception& e) { + _throw(SQL_Error(e.type(), e.comment())); + } catch(...) { + _throw(SQL_Error(0, "unknown error while transcoding in sql driver")); + } +} + // helpers static void expire_connection(SQL_Connection& connection, time_t older_dies) { @@ -66,7 +86,8 @@ SQL_Driver_manager::~SQL_Driver_manager( /// @param aurl protocol://[driver-dependent] SQL_Connection* SQL_Driver_manager::get_connection(const String& aurl, - Table *protocol2driver_and_client) { + Table *protocol2driver_and_client, + const char* arequest_charset) { // we have table for locating protocol's library if(!protocol2driver_and_client) throw Exception("parser.runtime", @@ -131,10 +152,12 @@ SQL_Connection* SQL_Driver_manager::get_ const char* filename=library->cstr(String::L_FILE_SPEC); lt_dlhandle handle=lt_dlopen(filename); - if (!handle) + if (!handle) { + const char* error=lt_dlerror(); throw Exception(0, library, - "can not open the module, %s", lt_dlerror()); + error?error:"can not open the module"); + } SQL_Driver_create_func create=(SQL_Driver_create_func)lt_dlsym(handle, SQL_DRIVER_CREATE_NAME); @@ -169,7 +192,7 @@ SQL_Connection* SQL_Driver_manager::get_ put_driver_to_cache(protocol, driver); } - connection=new SQL_Connection(aurl, *driver); + connection=new SQL_Connection(aurl, *driver, arequest_charset); // associate with pool[request] (deassociates at close) connection->set_url(); }