--- parser3/src/include/pa_sql_connection.h 2001/04/05 11:01:55 1.2 +++ parser3/src/include/pa_sql_connection.h 2001/05/17 13:23:28 1.9 @@ -1,54 +1,55 @@ /** @file - Parser: sql connection decl. + Parser: sql fconnection decl. Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) Author: Alexander Petrosyan (http://design.ru/paf) - $Id: pa_sql_connection.h,v 1.2 2001/04/05 11:01:55 paf Exp $ + $Id: pa_sql_connection.h,v 1.9 2001/05/17 13:23:28 parser Exp $ */ #ifndef PA_SQL_CONNECTION_H #define PA_SQL_CONNECTION_H +#include "pa_config_includes.h" #include "pa_pool.h" #include "pa_sql_driver.h" -#include "pa_exception.h" +#include "pa_sql_driver_manager.h" -/// sql connection +/// SQL fconnection. handy wrapper around low level SQL_Driver class SQL_Connection : public Pooled { public: - void set_services(Services_for_SQL_driver *services) { - fdriver.set_services(services); - } - - SQL_Connection(Pool& pool, - const String& aurl, - SQL_Driver& adriver, Services_for_SQL_driver& services, - char *url_cstr) : Pooled(pool), + SQL_Connection(Pool& pool, const String& aurl, SQL_Driver& adriver) : Pooled(pool), furl(aurl), fdriver(adriver) { - - set_services(&services); // associate with services[request] - fdriver.connect(url_cstr, &connection); + } + void set_services(SQL_Driver_services *aservices) { + fservices=aservices; } void close() { - set_services(0); // deassociate from services[request] SQL_driver_manager->close_connection(furl, *this); } - void disconnect() { fdriver.disconnect(connection); } - void commit() { fdriver.commit(connection); } - void rollback() { fdriver.rollback(connection); } + void connect(char *used_only_in_connect_url_cstr) { + fdriver.connect(used_only_in_connect_url_cstr, *fservices, &fconnection); + } + void disconnect() { fdriver.disconnect(*fservices, fconnection); } + void commit() { fdriver.commit(*fservices, fconnection); } + void rollback() { fdriver.rollback(*fservices, fconnection); } + bool ping() { return fdriver.ping(*fservices, fconnection); } + uint quote(char *to, const char *from, unsigned int length) { + return fdriver.quote(*fservices, fconnection, to, from, length); + } + void query( - const char *statement, + const char *statement, unsigned long offset, unsigned long limit, unsigned int *column_count, SQL_Driver::Cell **columns, unsigned long *row_count, SQL_Driver::Cell ***rows) { - fdriver.query(connection, - statement, + fdriver.query(*fservices, fconnection, + statement, offset, limit, column_count, columns, row_count, rows); } @@ -56,9 +57,10 @@ public: private: - SQL_Driver& fdriver; - void *connection; const String& furl; + SQL_Driver& fdriver; + SQL_Driver_services *fservices; + void *fconnection; }; #endif