--- parser3/src/include/pa_sql_driver_manager.h 2003/01/27 16:19:11 1.26.2.2 +++ parser3/src/include/pa_sql_driver_manager.h 2009/05/14 11:27:23 1.35 @@ -2,16 +2,16 @@ Parser: sql driver manager decl. global sql driver manager, must be thread-safe - Copyright (c) 2001, 2003 ArtLebedev Group (http://www.artlebedev.com) + Copyright (c) 2001-2009 ArtLebedev Group (http://www.artlebedev.com) Author: Alexandr Petrosian (http://paf.design.ru) */ #ifndef PA_SQL_DRIVER_MANAGER_H #define PA_SQL_DRIVER_MANAGER_H -static const char* IDENT_SQL_DRIVER_MANAGER_H="$Date: 2003/01/27 16:19:11 $"; +static const char * const IDENT_SQL_DRIVER_MANAGER_H="$Date: 2009/05/14 11:27:23 $"; + -#include "pa_pool.h" #include "pa_sql_driver.h" #include "pa_hash.h" #include "pa_table.h" @@ -27,11 +27,23 @@ static const char* IDENT_SQL_DRIVER_MANA // forwards class SQL_Connection; -DECLARE_OBJECT_PTR (SQL_Connection) /// sql driver manager class SQL_Driver_manager: public Cache_manager { +public: + + typedef HashString driver_cache_type; + typedef Stack connection_cache_element_base_type; + typedef HashString connection_cache_type; + +private: + friend class SQL_Connection; + + bool is_dlinited; + driver_cache_type driver_cache; + connection_cache_type connection_cache; + public: SQL_Driver_manager(); @@ -42,39 +54,38 @@ public: using driver dynamic library found in table, if not loaded yet checks driver version */ - SQL_ConnectionPtr get_connection(Pool& pool, ConstStringPtr aurl, ConstStringPtr aorigin, - Table *protocol2driver_and_client); + SQL_Connection* get_connection(const String& aurl, + Table *protocol2driver_and_client, + const char* arequest_charset, + const char* adocument_root); private: // driver cache - SQL_Driver *get_driver_from_cache(ConstStringPtr protocol); - void put_driver_to_cache(ConstStringPtr protocol, SQL_Driver& driver); + SQL_Driver *get_driver_from_cache(driver_cache_type::key_type protocol); + void put_driver_to_cache(driver_cache_type::key_type protocol, driver_cache_type::value_type driver); private: // connection cache - SQL_Connection *get_connection_from_cache(ConstStringPtr url); - void put_connection_to_cache(ConstStringPtr url, SQL_Connection& connection); + SQL_Connection* get_connection_from_cache(connection_cache_type::key_type url); + void put_connection_to_cache(connection_cache_type::key_type url, + SQL_Connection* connection); private: time_t prev_expiration_pass_time; private: // for SQL_Connection /// caches connection - void close_connection(ConstStringPtr url, SQL_Connection& connection); - -private: - - Hash driver_cache; - Hash *> connection_cache; + void close_connection(connection_cache_type::key_type url, + SQL_Connection* connection); public: // Cache_manager - override ValuePtr get_status(Pool& pool, ConstStringPtr source); + override Value* get_status(); override void maybe_expire_cache(); }; /// global -extern SQL_Driver_manager SQL_driver_manager; +extern SQL_Driver_manager* SQL_driver_manager; #endif