--- parser3/src/main/pa_sql_driver_manager.C 2001/04/04 11:47:29 1.2 +++ parser3/src/main/pa_sql_driver_manager.C 2001/04/05 11:01:57 1.4 @@ -5,7 +5,7 @@ Author: Alexander Petrosyan (http://design.ru/paf) - $Id: pa_sql_driver_manager.C,v 1.2 2001/04/04 11:47:29 paf Exp $ + $Id: pa_sql_driver_manager.C,v 1.4 2001/04/05 11:01:57 paf Exp $ */ #include "pa_config_includes.h" @@ -24,6 +24,31 @@ SQL_Driver_manager *SQL_driver_manager; const int MAX_PROTOCOL=20; const char *LIBRARY_CREATE_FUNC_NAME="create"; + +/// Services_for_SQL_driver implementation +class Services_for_SQL_driver_impl : public Services_for_SQL_driver, public Pooled { +public: + Services_for_SQL_driver_impl(Pool& apool, const String& aurl) : Pooled(apool), + furl(aurl) { + } + + /// allocates some bytes on pool + void *malloc(size_t size) { return Pooled::malloc(size); } + /// allocates some bytes clearing them with zeros + void *calloc(size_t size) { return Pooled::calloc(size); } + /// throw exception + void _throw(const char *comment) { + THROW(0, 0, + &furl, + comment); + } + +private: + const String& furl; +}; + +// SQL_Driver_manager + // url: // protocol://user:pass@host:port/database // ^^^^^^^^^^^^^^^^^^^^^^^^^^^^ this is driver-dependent @@ -95,25 +120,32 @@ SQL_Connection& SQL_Driver_manager::get_ // validate driver api version int driver_api_version=driver->api_version(); - if(driver_api_versionpool()) SQL_Connection(url.pool(), //< associate with request - *driver, url_cstr, url); + // services associated with request + Services_for_SQL_driver_impl& services= + *new(pool) Services_for_SQL_driver_impl(pool, url); + + // allocate in global pool + // associate with services[request], deassociates at close + SQL_Connection& result= + *new(this->pool()) SQL_Connection(this->pool(), url, *driver, services, url_cstr); + + return result; } void SQL_Driver_manager::close_connection(const String& url, SQL_Connection& connection) { SYNCHRONIZED(true); - connection.set_pool(0); // deassociate from request put_connection_to_cache(url, connection); }