|
|
| version 1.69.2.6, 2003/01/28 11:57:04 | version 1.69.2.8, 2003/01/31 12:10:47 |
|---|---|
| Line 9 static const char* IDENT_SQL_DRIVER_MANA | Line 9 static const char* IDENT_SQL_DRIVER_MANA |
| #include "pa_sql_driver_manager.h" | #include "pa_sql_driver_manager.h" |
| #include "ltdl.h" | #include "ltdl.h" |
| #include "pa_threads.h" | |
| #include "pa_sql_connection.h" | #include "pa_sql_connection.h" |
| #include "pa_exception.h" | #include "pa_exception.h" |
| #include "pa_common.h" | #include "pa_common.h" |
| #include "pa_threads.h" | #include "pa_value_includes.h" |
| #include "pa_vhash.h" | #include "pa_vhash.h" |
| #include "pa_vtable.h" | #include "pa_vtable.h" |
| Line 27 const time_t CHECK_EXPIRED_CONNECTIONS_S | Line 28 const time_t CHECK_EXPIRED_CONNECTIONS_S |
| // helpers | // helpers |
| ConstStringPtr SQL_Driver_services_impl::url_without_login() const { | StringPtr SQL_Driver_services_impl::url_without_login() const { |
| StringPtr result(new String); | StringPtr result(new String); |
| *result << furl->mid(0, furl->pos(":")) << "://****"; | *result << furl->mid(0, furl->pos(":")) << "://****"; |
| Line 57 static void expire_connections( | Line 58 static void expire_connections( |
| SQL_Driver_manager::SQL_Driver_manager(): | SQL_Driver_manager::SQL_Driver_manager(): |
| prev_expiration_pass_time(0) { | prev_expiration_pass_time(0) { |
| cache_managers.put(ConstStringPtr(new String("sql")), this); | cache_managers.put(StringPtr(new String("sql")), this); |
| } | } |
| SQL_Driver_manager::~SQL_Driver_manager() { | SQL_Driver_manager::~SQL_Driver_manager() { |
| Line 65 SQL_Driver_manager::~SQL_Driver_manager( | Line 66 SQL_Driver_manager::~SQL_Driver_manager( |
| } | } |
| /// @param aurl protocol://[driver-dependent] | /// @param aurl protocol://[driver-dependent] |
| SQL_ConnectionPtr SQL_Driver_manager::get_connection(Pool& apool, ConstStringPtr arequest_url, | SQL_ConnectionPtr SQL_Driver_manager::get_connection(Pool& apool, StringPtr arequest_url, |
| ConstStringPtr aorigin, | StringPtr aorigin, |
| Table *protocol2driver_and_client) { | Table *protocol2driver_and_client) { |
| // we have table for locating protocol's library | // we have table for locating protocol's library |
| if(!protocol2driver_and_client) | if(!protocol2driver_and_client) |
| Line 108 SQL_ConnectionPtr SQL_Driver_manager::ge | Line 109 SQL_ConnectionPtr SQL_Driver_manager::ge |
| // first trying to get cached driver | // first trying to get cached driver |
| if(!(driver=get_driver_from_cache(global_protocol))) { | if(!(driver=get_driver_from_cache(global_protocol))) { |
| // no cached | // no cached |
| ConstStringPtr library(0); | StringPtr library(0); |
| ConstStringPtr dlopen_file_spec(0); | StringPtr dlopen_file_spec(0); |
| if(protocol2driver_and_client->locate(0, global_protocol)) { | if(protocol2driver_and_client->locate(0, global_protocol)) { |
| if(!(library=protocol2driver_and_client->item(1)) || library->size()==0) | if(!(library=protocol2driver_and_client->item(1)) || library->size()==0) |
| throw Exception("parser.runtime", | throw Exception("parser.runtime", |
| Line 271 static void add_connections_to_status_ca | Line 272 static void add_connections_to_status_ca |
| add_connection_to_status_cache_table(iter.next(), info); | add_connection_to_status_cache_table(iter.next(), info); |
| }*/ | }*/ |
| /// @todo convert to object_ptr | /// @todo convert to object_ptr |
| ValuePtr SQL_Driver_manager::get_status(Pool& pool, ConstStringPtr source) { | ValuePtr SQL_Driver_manager::get_status(Pool& pool, StringPtr source) { |
| ValuePtr result(new VHash); | ValuePtr result(new VHash); |
| /* | /* |
| // cache | // cache |