|
|
| version 1.26, 2002/02/08 08:30:17 | version 1.35, 2003/07/24 11:31:24 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: sql driver interface. | Parser: sql driver interface. |
| Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001-2003 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) |
| $Id$ | |
| driver dynamic library must look like this: | driver dynamic library must look like this: |
| @code | @code |
| class X_SQL_Driver : public SQL_Driver { | class X_SQL_Driver: public SQL_Driver { |
| public: | public: |
| X_SQL_Driver() : SQL_driver() {} | X_SQL_Driver() : SQL_driver() {} |
| Line 28 | Line 26 |
| #ifndef PA_SQL_DRIVER_H | #ifndef PA_SQL_DRIVER_H |
| #define PA_SQL_DRIVER_H | #define PA_SQL_DRIVER_H |
| static const char* IDENT_SQL_DRIVER_H="$Date$"; | |
| #include <sys/types.h> | #include <sys/types.h> |
| #include <setjmp.h> | |
| #include <stdlib.h> | |
| #define SQL_DRIVER_API_VERSION 0x0007 | |
| #define SQL_DRIVER_CREATE create /* used in driver implementation */ | |
| #define SQL_DRIVER_CREATE_NAME "create" /* could not figure out how to # it :( */ | |
| /// fields are freed elsewhere | |
| class SQL_Error { | |
| bool fdefined; | |
| const char* ftype; | |
| const char* fcomment; | |
| public: | |
| SQL_Error(): | |
| fdefined(false) {} | |
| SQL_Error( | |
| const char* atype, | |
| const char* acomment): | |
| fdefined(true), | |
| ftype(atype), | |
| fcomment(acomment) {} | |
| SQL_Error(const char* acomment): | |
| fdefined(true), | |
| ftype(0), | |
| fcomment(acomment) {} | |
| SQL_Error& operator =(const SQL_Error& src) { | |
| fdefined=src.fdefined; | |
| ftype=src.ftype; | |
| fcomment=src.fcomment; | |
| return *this; | |
| } | |
| bool defined() const { return fdefined; } | |
| const char* type() const { return ftype; } | |
| const char* comment() const { return fcomment; } | |
| }; | |
| /// service functions for SQL driver to use | /// service functions for SQL driver to use |
| class SQL_Driver_services { | class SQL_Driver_services { |
| public: | public: |
| /// allocates some bytes on pool | /// allocates some bytes |
| virtual void *malloc(size_t size) =0; | virtual void *malloc(size_t size) =0; |
| /// allocates some bytes clearing them with zeros | /// allocates some bytes, user promises: no pointers inside |
| virtual void *calloc(size_t size) =0; | virtual void *malloc_atomic(size_t size) =0; |
| /// reallocates bytes | |
| virtual void *realloc(void *ptr, size_t size) =0; | |
| /// prepare throw exception | /// prepare throw exception |
| virtual void _throw(const char *comment) =0; | virtual void _throw(const SQL_Error& e) =0; |
| /// throw C++ exception from prepared | /// throw C++ exception from prepared |
| virtual void propagate_exception() =0; | virtual void propagate_exception() =0; |
| /// helper func | |
| void _throw(const char* comment) { _throw(SQL_Error("sql.connect", comment)); } | |
| public: | public: |
| /// regretrully public, because can't make stack frames: "nowhere to return to" | /// regretrully public, because can't make stack frames: "nowhere to return to" |
| jmp_buf mark; | jmp_buf mark; |
| }; | }; |
| #define SQL_DRIVER_API_VERSION 0x0003 | /** events, occuring when SQL_Driver::query()-ing. |
| #define SQL_DRIVER_CREATE create /* used in driver implementation */ | |
| #define SQL_DRIVER_CREATE_NAME "create" /* could not figure out how to # it :( */ | |
| /// events, occuring when SQL_Driver::query()-ing | when OK must return false. |
| must NOT throw exceptions, must store them to error & return true. | |
| */ | |
| class SQL_Driver_query_event_handlers { | class SQL_Driver_query_event_handlers { |
| public: | public: |
| virtual void add_column(void *ptr, size_t size) =0; | virtual bool add_column(SQL_Error& error, const char* str, size_t length) =0; |
| virtual void before_rows() =0; | virtual bool before_rows(SQL_Error& error) =0; |
| virtual void add_row() =0; | virtual bool add_row(SQL_Error& error) =0; |
| virtual void add_row_cell(void *ptr, size_t size) =0; | virtual bool add_row_cell(SQL_Error& error, const char* str, size_t length) =0; |
| }; | }; |
| /// SQL driver API | /// SQL driver API |
| class SQL_Driver { | class SQL_Driver { |
| public: | public: |
| /** allocated using our allocator, | |
| @todo never freed | |
| */ | |
| static void *operator new(size_t size) { | |
| void *result=::malloc(size); | |
| if(!result) | |
| abort(); | |
| return result; | |
| } | |
| /// get api version | /// get api version |
| virtual int api_version() =0; | virtual int api_version() =0; |
| /// initialize driver by loading sql dynamic link library | /// initialize driver by loading sql dynamic link library |
| virtual const char *initialize(char *dlopen_file_spec) =0; | virtual const char* initialize(char *dlopen_file_spec) =0; |
| /** connect to sql database using | /** connect to sql database using |
| @param used_only_to_connect_url | @param used_only_to_connect_url |
| format is driver specific | format is driver specific |
| Line 85 public: | Line 135 public: |
| virtual bool ping( | virtual bool ping( |
| SQL_Driver_services& services, void *connection) =0; | SQL_Driver_services& services, void *connection) =0; |
| /// encodes the string in 'from' to an escaped SQL string | /// encodes the string in 'from' to an escaped SQL string |
| virtual unsigned int quote( | virtual const char* quote( |
| SQL_Driver_services& services, void *connection, | SQL_Driver_services& services, void *connection, |
| char *to, const char *from, unsigned int length) =0; | const char* str, unsigned int length) =0; |
| virtual void query( | virtual void query( |
| SQL_Driver_services& services, void *connection, | SQL_Driver_services& services, void *connection, |
| const char *statement, unsigned long offset, unsigned long limit, | const char* statement, unsigned long offset, unsigned long limit, |
| SQL_Driver_query_event_handlers& handlers) =0; | SQL_Driver_query_event_handlers& handlers) =0; |
| }; | }; |