--- parser3/src/main/pa_sql_driver_manager.C	2004/03/04 12:05:16	1.83
+++ parser3/src/main/pa_sql_driver_manager.C	2013/07/05 21:09:58	1.92
@@ -1,12 +1,10 @@
 /** @file
 	Parser: sql driver manager implementation.
 
-	Copyright (c) 2001-2004 ArtLebedev Group (http://www.artlebedev.com)
+	Copyright (c) 2001-2012 Art. Lebedev Studio (http://www.artlebedev.com)
 	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
 */
 
-static const char * const IDENT_SQL_DRIVER_MANAGER_C="$Date: 2004/03/04 12:05:16 $";
-
 #include "pa_sql_driver_manager.h"
 #include "ltdl.h"
 #include "pa_threads.h"
@@ -17,6 +15,8 @@ static const char * const IDENT_SQL_DRIV
 #include "pa_vtable.h"
 #include "pa_charsets.h"
 
+volatile const char * IDENT_PA_SQL_DRIVER_MANAGER_C="$Id: pa_sql_driver_manager.C,v 1.92 2013/07/05 21:09:58 moko Exp $" IDENT_PA_SQL_DRIVER_MANAGER_H IDENT_PA_SQL_CONNECTION_H;
+
 // globals
 
 SQL_Driver_manager* SQL_driver_manager=0;
@@ -32,8 +32,11 @@ const String& SQL_Driver_services_impl::
 	String& result=*new String;
 	result << furl->mid(0, furl->pos(':')) << "://****";
 
-	size_t at_pos=furl->pos('@');
-	if(at_pos!=STRING_NOT_FOUND)
+	size_t at_pos=0;
+	size_t new_at_pos;
+	while( (new_at_pos=furl->pos('@', at_pos+1))!=STRING_NOT_FOUND)
+		at_pos=new_at_pos;
+	if(at_pos)
 		result << furl->mid(at_pos, furl->length());
 
 	return result;
@@ -98,24 +101,20 @@ static void expire_connections(SQL_Drive
 
 // SQL_Driver_manager
 
-SQL_Driver_manager::SQL_Driver_manager(): 
-	is_dlinited(false), prev_expiration_pass_time(0) {
-}
+SQL_Driver_manager::SQL_Driver_manager(): prev_expiration_pass_time(0) {}
 
 SQL_Driver_manager::~SQL_Driver_manager() {
-	connection_cache.for_each(expire_connections, time(0)+(time_t)10/*=in future=expire all*/);
-
-	if(is_dlinited)
-		lt_dlexit();
+	connection_cache.for_each<time_t>(expire_connections, time(0)+(time_t)10/*=in future=expire all*/);
 }
 
 /// @param aurl protocol://[driver-dependent]
 SQL_Connection* SQL_Driver_manager::get_connection(const String& aurl,
 						   Table *protocol2driver_and_client,
-						   const char* arequest_charset) {
+						   const char* arequest_charset,
+						   const char* adocument_root) {
 	// we have table for locating protocol's library
 	if(!protocol2driver_and_client)
-		throw Exception("parser.runtime",
+		throw Exception(PARSER_RUNTIME,
 			&aurl,
 			"$"MAIN_SQL_NAME":"MAIN_SQL_DRIVERS_NAME" table must be defined");
 
@@ -135,7 +134,7 @@ SQL_Connection* SQL_Driver_manager::get_
 	else { // no cached connection or it were unpingabe: connect/reconnect
 		url_cstr=aurl.cstrm();
 		if(!strstr(url_cstr, "://"))
-			throw Exception("parser.runtime",
+			throw Exception(PARSER_RUNTIME,
 				aurl.length()?&aurl:0,
 				"connection string must start with protocol://");
 
@@ -155,27 +154,20 @@ SQL_Connection* SQL_Driver_manager::get_
 			Table::Action_options options;
 			if(protocol2driver_and_client->locate(0, protocol, options)) {
 				if(!(library=protocol2driver_and_client->item(1)) || library->length()==0)
-					throw Exception("parser.runtime",
+					throw Exception(PARSER_RUNTIME,
 						0,
 						"driver library column for protocol '%s' is empty", 
 							protocol_cstr);
 				dlopen_file_spec=protocol2driver_and_client->item(2);
 			} else
-				throw Exception("parser.runtime",
+				throw Exception(PARSER_RUNTIME,
 					&aurl,
 					"undefined protocol '%s'", 
 						protocol_cstr);
 
-			if(!is_dlinited) {
-				if(lt_dlinit())
-					throw Exception(0,
-						library,
-						"prepare to dynamic loading failed, %s", lt_dlerror());
-
-				is_dlinited=true;
-			}
+			pa_dlinit();
 
-			const char* filename=library->cstr(String::L_FILE_SPEC);
+			const char* filename=library->taint_cstr(String::L_FILE_SPEC);
 			lt_dlhandle handle=lt_dlopen(filename);
 			if (!handle) {
 				const char* error=lt_dlerror();
@@ -184,8 +176,8 @@ SQL_Connection* SQL_Driver_manager::get_
 					error?error:"can not open the module");
 			}
 
-			SQL_Driver_create_func create=(SQL_Driver_create_func)lt_dlsym(handle, 
-				SQL_DRIVER_CREATE_NAME);
+			SQL_Driver_create_func create=(SQL_Driver_create_func)(lt_dlsym(handle, 
+				SQL_DRIVER_CREATE_NAME));
 			if(!create)
 				throw Exception(0,
 					library,
@@ -205,7 +197,7 @@ SQL_Connection* SQL_Driver_manager::get_
 			// initialise by connecting to sql client dynamic link library
 			char* dlopen_file_spec_cstr=
 				dlopen_file_spec && dlopen_file_spec->length()?
-				dlopen_file_spec->cstrm(String::L_AS_IS):0;
+				dlopen_file_spec->taint_cstrm(String::L_AS_IS):0;
 			if(const char* error=driver->initialize(dlopen_file_spec_cstr))
 				throw Exception(0,
 					library,
@@ -217,7 +209,7 @@ SQL_Connection* SQL_Driver_manager::get_
 			put_driver_to_cache(protocol, driver);
 		}
 	
-		connection=new SQL_Connection(aurl, *driver, arequest_charset);
+		connection=new SQL_Connection(aurl, *driver, arequest_charset, adocument_root);
 		// associate with pool[request]  (deassociates at close)
 		connection->set_url(); 
 	}
@@ -283,7 +275,7 @@ void SQL_Driver_manager::maybe_expire_ca
 	time_t now=time(0);
 
 	if(prev_expiration_pass_time<now-CHECK_EXPIRED_CONNECTIONS_SECONDS) {
-		connection_cache.for_each(expire_connections, time_t(now-EXPIRE_UNUSED_CONNECTION_SECONDS));
+		connection_cache.for_each<time_t>(expire_connections, time_t(now-EXPIRE_UNUSED_CONNECTION_SECONDS));
 
 		prev_expiration_pass_time=now;
 	}
@@ -320,7 +312,7 @@ Value* SQL_Driver_manager::get_status()
 		columns+=new String("time");
 		Table& table=*new Table(&columns, connection_cache.count());
 
-		connection_cache.for_each(add_connections_to_status_cache_table, &table);
+		connection_cache.for_each<Table*>(add_connections_to_status_cache_table, &table);
 
 		result->get_hash()->put(*new String("cache"), new VTable(&table));
 	}