--- parser3/src/main/pa_sql_driver_manager.C 2003/12/10 14:17:45 1.76 +++ parser3/src/main/pa_sql_driver_manager.C 2004/02/11 15:33:16 1.82 @@ -1,11 +1,11 @@ /** @file Parser: sql driver manager implementation. - Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com) + Copyright (c) 2001-2004 ArtLebedev Group (http://www.artlebedev.com) Author: Alexandr Petrosian (http://paf.design.ru) */ -static const char * const IDENT_SQL_DRIVER_MANAGER_C="$Date: 2003/12/10 14:17:45 $"; +static const char * const IDENT_SQL_DRIVER_MANAGER_C="$Date: 2004/02/11 15:33:16 $"; #include "pa_sql_driver_manager.h" #include "ltdl.h" @@ -15,10 +15,11 @@ static const char * const IDENT_SQL_DRIV #include "pa_common.h" #include "pa_vhash.h" #include "pa_vtable.h" +#include "pa_charsets.h" // globals -SQL_Driver_manager SQL_driver_manager; +SQL_Driver_manager* SQL_driver_manager=0; // consts @@ -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) { @@ -55,12 +75,10 @@ static void expire_connections(SQL_Drive SQL_Driver_manager::SQL_Driver_manager(): is_dlinited(false), prev_expiration_pass_time(0) { - - cache_managers.put(String::Body("sql"), this); } SQL_Driver_manager::~SQL_Driver_manager() { - connection_cache.for_each(expire_connections, time(0)+(time_t)1/*=in future=expire all*/); + connection_cache.for_each(expire_connections, time(0)+(time_t)10/*=in future=expire all*/); if(is_dlinited) lt_dlexit(); @@ -68,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", @@ -133,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); @@ -171,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(); } @@ -260,8 +281,8 @@ static void add_connections_to_status_ca SQL_Driver_manager::connection_cache_type::key_type /*key*/, SQL_Driver_manager::connection_cache_type::value_type stack, Table* table) { - for(Array_iterator i(*stack); i.has_next(); ) - add_connection_to_status_cache_table(*i.next(), table); + for(Array_iterator i(*stack); i.has_next(); ) + add_connection_to_status_cache_table(*i.next(), table); } Value* SQL_Driver_manager::get_status() {