parser3/src/main/pa_sql_driver_manager.C - diff

Return to pa_sql_driver_manager.C CVS log

Up to [parser3project] / parser3 / src / main

Diff for /parser3/src/main/pa_sql_driver_manager.C between versions 1.79 and 1.86

version 1.79, 2003/12/19 14:30:52	version 1.86, 2006/04/09 13:38:47
Line 1	Line 1
/** @file	/** @file
Parser: sql driver manager implementation.	Parser: sql driver manager implementation.

Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com)	Copyright (c) 2001-2005 ArtLebedev Group (http://www.artlebedev.com)
Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)	Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
*/	*/

Line 15 static const char * const IDENT_SQL_DRIV	Line 15 static const char * const IDENT_SQL_DRIV
#include "pa_common.h"	#include "pa_common.h"
#include "pa_vhash.h"	#include "pa_vhash.h"
#include "pa_vtable.h"	#include "pa_vtable.h"
	#include "pa_charsets.h"

// globals	// globals

Line 31 const String& SQL_Driver_services_impl::	Line 32 const String& SQL_Driver_services_impl::
String& result=*new String;	String& result=*new String;
result << furl->mid(0, furl->pos(':')) << "://****";	result << furl->mid(0, furl->pos(':')) << "://****";

size_t at_pos=furl->pos('@');	size_t at_pos=0;
if(at_pos!=STRING_NOT_FOUND)	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());	result << furl->mid(at_pos, furl->length());

return result;	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 {
	// to speed up sql transcode [lots of charsets::get-s -- twice for each cell]
	// without complicating sql driver API
	// we need to cache couple of name->charset pairs
	// assuming pointers to names are are NOT to local vars

	struct cache_record {
	const char* name;
	Charset* object;
	} cache[2]={{0,0}, {0,0}};

	Charset* charset_from_object;
	Charset* charset_to_object;
	if(charset_from_name==cache[0].name) {
	charset_from_object=cache[0].object;
	} else {
	cache[0].name=charset_from_name;
	cache[0].object=charset_from_object=&charsets.get(charset_from_name);
	}
	if(charset_to_name==cache[1].name) {
	charset_to_object=cache[1].object;
	} else {
	cache[1].name=charset_to_name;
	cache[1].object=charset_to_object=&charsets.get(charset_to_name);
	}

	String::C result=Charset::transcode(String::C(src, src_length),
	*charset_from_object,
	*charset_to_object);
	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	// helpers

static void expire_connection(SQL_Connection& connection, time_t older_dies) {	static void expire_connection(SQL_Connection& connection, time_t older_dies) {
Line 58 SQL_Driver_manager::SQL_Driver_manager()	Line 106 SQL_Driver_manager::SQL_Driver_manager()
}	}

SQL_Driver_manager::~SQL_Driver_manager() {	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<time_t>(expire_connections, time(0)+(time_t)10/=in future=expire all/);

if(is_dlinited)	if(is_dlinited)
lt_dlexit();	lt_dlexit();
Line 66 SQL_Driver_manager::~SQL_Driver_manager(	Line 114 SQL_Driver_manager::~SQL_Driver_manager(

/// @param aurl protocol://[driver-dependent]	/// @param aurl protocol://[driver-dependent]
SQL_Connection* SQL_Driver_manager::get_connection(const String& aurl,	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	// we have table for locating protocol's library
if(!protocol2driver_and_client)	if(!protocol2driver_and_client)
throw Exception("parser.runtime",	throw Exception("parser.runtime",
Line 138 SQL_Connection* SQL_Driver_manager::get_	Line 187 SQL_Connection* SQL_Driver_manager::get_
error?error:"can not open the module");	error?error:"can not open the module");
}	}

SQL_Driver_create_func create=(SQL_Driver_create_func)lt_dlsym(handle,	SQL_Driver_create_func create=(SQL_Driver_create_func)(lt_dlsym(handle,
SQL_DRIVER_CREATE_NAME);	SQL_DRIVER_CREATE_NAME));
if(!create)	if(!create)
throw Exception(0,	throw Exception(0,
library,	library,
Line 171 SQL_Connection* SQL_Driver_manager::get_	Line 220 SQL_Connection* SQL_Driver_manager::get_
put_driver_to_cache(protocol, driver);	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)	// associate with pool[request] (deassociates at close)
connection->set_url();	connection->set_url();
}	}
Line 237 void SQL_Driver_manager::maybe_expire_ca	Line 286 void SQL_Driver_manager::maybe_expire_ca
time_t now=time(0);	time_t now=time(0);

if(prev_expiration_pass_time<now-CHECK_EXPIRED_CONNECTIONS_SECONDS) {	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;	prev_expiration_pass_time=now;
}	}
Line 274 Value* SQL_Driver_manager::get_status()	Line 323 Value* SQL_Driver_manager::get_status()
columns+=new String("time");	columns+=new String("time");
Table& table=*new Table(&columns, connection_cache.count());	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));	result->get_hash()->put(*new String("cache"), new VTable(&table));
}	}

E-mail:

Removed from v.1.79
changed lines
	Added in v.1.86