|
|
| version 1.34, 2003/01/21 15:51:16 | 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, 2003 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) |
| 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 29 | Line 29 |
| static const char* IDENT_SQL_DRIVER_H="$Date$"; | 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 0x0005 | #define SQL_DRIVER_API_VERSION 0x0007 |
| #define SQL_DRIVER_CREATE create /* used in driver implementation */ | #define SQL_DRIVER_CREATE create /* used in driver implementation */ |
| #define SQL_DRIVER_CREATE_NAME "create" /* could not figure out how to # it :( */ | #define SQL_DRIVER_CREATE_NAME "create" /* could not figure out how to # it :( */ |
| /// fields are freed elsewhere | /// fields are freed elsewhere |
| class SQL_Error { | class SQL_Error { |
| bool fdefined; | bool fdefined; |
| const char *ftype; | const char* ftype; |
| const void *fproblem_source; | const char* fcomment; |
| const char *fcomment; | |
| public: | public: |
| SQL_Error(): | SQL_Error(): |
| fdefined(false) {} | fdefined(false) {} |
| SQL_Error( | SQL_Error( |
| const char *atype, | const char* atype, |
| const void *aproblem_source, | const char* acomment): |
| const char *acomment): | |
| fdefined(true), | fdefined(true), |
| ftype(atype), | ftype(atype), |
| fproblem_source(aproblem_source), | |
| fcomment(acomment) {} | fcomment(acomment) {} |
| SQL_Error(const char *acomment): | SQL_Error(const char* acomment): |
| fdefined(true), | fdefined(true), |
| ftype(0), | ftype(0), |
| fproblem_source(0), | |
| fcomment(acomment) {} | fcomment(acomment) {} |
| SQL_Error& operator =(const SQL_Error& src) { | SQL_Error& operator =(const SQL_Error& src) { |
| fdefined=src.fdefined; | fdefined=src.fdefined; |
| ftype=src.ftype; | ftype=src.ftype; |
| fproblem_source=src.fproblem_source; | |
| fcomment=src.fcomment; | fcomment=src.fcomment; |
| return *this; | return *this; |
| } | } |
| bool defined() const { return fdefined; } | bool defined() const { return fdefined; } |
| const char *type() const { return ftype; } | const char* type() const { return ftype; } |
| const void *problem_source() const { return fproblem_source; } | const char* comment() const { return fcomment; } |
| 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 SQL_Error& e) =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 | /// helper func |
| void _throw(const char *comment) { _throw(SQL_Error("sql.connect", 0, comment)); } | 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; |
| Line 95 public: | Line 93 public: |
| */ | */ |
| class SQL_Driver_query_event_handlers { | class SQL_Driver_query_event_handlers { |
| public: | public: |
| virtual bool add_column(SQL_Error& error, void *ptr, size_t size) =0; | virtual bool add_column(SQL_Error& error, const char* str, size_t length) =0; |
| virtual bool before_rows(SQL_Error& error) =0; | virtual bool before_rows(SQL_Error& error) =0; |
| virtual bool add_row(SQL_Error& error) =0; | virtual bool add_row(SQL_Error& error) =0; |
| virtual bool add_row_cell(SQL_Error& error, 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 127 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; |
| }; | }; |