|
|
| version 1.5, 2001/04/05 20:01:25 | version 1.26, 2002/02/08 08:30:17 |
|---|---|
| Line 1 | Line 1 |
| /** @file | /** @file |
| Parser: sql driver interface. | Parser: sql driver interface. |
| Copyright (c) 2001 ArtLebedev Group (http://www.artlebedev.com) | Copyright (c) 2001, 2002 ArtLebedev Group (http://www.artlebedev.com) |
| Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru) | |
| Author: Alexander Petrosyan <paf@design.ru> (http://design.ru/paf) | |
| $Id$ | $Id$ |
| Line 32 | Line 31 |
| #include <sys/types.h> | #include <sys/types.h> |
| /// service functions for SQL driver to use | /// service functions for SQL driver to use |
| class Services_for_SQL_driver { | class SQL_Driver_services { |
| public: | public: |
| /// allocates some bytes on pool | /// allocates some bytes on pool |
| virtual void *malloc(size_t size) =0; | virtual void *malloc(size_t size) =0; |
| /// allocates some bytes clearing them with zeros | /// allocates some bytes clearing them with zeros |
| virtual void *calloc(size_t size) =0; | virtual void *calloc(size_t size) =0; |
| /// throw exception | /// prepare throw exception |
| virtual void _throw(const char *comment) =0; | virtual void _throw(const char *comment) =0; |
| /// throw C++ exception from prepared | |
| virtual void propagate_exception() =0; | |
| public: | |
| /// regretrully public, because can't make stack frames: "nowhere to return to" | |
| jmp_buf mark; | |
| }; | }; |
| #define SQL_DRIVER_API_VERSION 0x0300 | #define SQL_DRIVER_API_VERSION 0x0003 |
| #define SQL_DRIVER_CREATE create /* used in driver implementation */ | |
| #define SQL_DRIVER_CREATE_NAME "create" /* could not figure out how to # it :( */ | |
| /// SQL driver API | /// events, occuring when SQL_Driver::query()-ing |
| class SQL_Driver { | class SQL_Driver_query_event_handlers { |
| public: | public: |
| virtual void add_column(void *ptr, size_t size) =0; | |
| virtual void before_rows() =0; | |
| virtual void add_row() =0; | |
| virtual void add_row_cell(void *ptr, size_t size) =0; | |
| }; | |
| struct Cell { | /// SQL driver API |
| void *ptr; | class SQL_Driver { |
| size_t size; | |
| }; | |
| public: | public: |
| /// assignes services to driver. you can not use driver until this | |
| void set_services(Services_for_SQL_driver *aservices) { services=aservices; } | |
| SQL_Driver() : | |
| services(0) { | |
| } | |
| /// get api version | /// get api version |
| virtual int api_version() =0; | virtual int api_version() =0; |
| /// connect. @returns true+'connection' on success. 'error' on failure | /// initialize driver by loading sql dynamic link library |
| virtual void connect(char *url, void **connection) =0; | virtual const char *initialize(char *dlopen_file_spec) =0; |
| /** connect to sql database using | |
| @param used_only_to_connect_url | |
| format is driver specific | |
| WARNING: must be used only to connect, for buffer doesn't live long enough | |
| @returns true+'connection' on success. 'error' on failure | |
| */ | |
| virtual void connect(char *used_only_in_connect_url_cstr, | |
| SQL_Driver_services& services, void **connection) =0; | |
| virtual void disconnect(void *connection) =0; | virtual void disconnect(void *connection) =0; |
| virtual void commit(void *connection) =0; | virtual void commit( |
| virtual void rollback(void *connection) =0; | SQL_Driver_services& services, void *connection) =0; |
| virtual void rollback( | |
| SQL_Driver_services& services, void *connection) =0; | |
| /// @returns true to indicate that connection still alive | /// @returns true to indicate that connection still alive |
| virtual bool ping(void *connection) =0; | virtual bool ping( |
| 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(void *connection, | virtual unsigned int quote( |
| SQL_Driver_services& services, void *connection, | |
| char *to, const char *from, unsigned int length) =0; | char *to, const char *from, unsigned int length) =0; |
| virtual void query(void *connection, | virtual void query( |
| SQL_Driver_services& services, void *connection, | |
| const char *statement, unsigned long offset, unsigned long limit, | const char *statement, unsigned long offset, unsigned long limit, |
| unsigned int *column_count, Cell **columns, | SQL_Driver_query_event_handlers& handlers) =0; |
| unsigned long *row_count, Cell ***rows) =0; | |
| /// log error message | |
| //static void log(Pool& pool, const char *fmt, ...); | |
| protected: | |
| Services_for_SQL_driver *services; | |
| }; | }; |
| typedef SQL_Driver *(*SQL_Driver_create_func)(); | typedef SQL_Driver *(*SQL_Driver_create_func)(); |