Annotation of parser3/src/sql/pa_sql_driver.h, revision 1.36
1.22 paf 1: /** @file
2: Parser: sql driver interface.
3:
1.35 paf 4: Copyright (c) 2001-2003 ArtLebedev Group (http://www.artlebedev.com)
1.26 paf 5: Author: Alexandr Petrosian <paf@design.ru> (http://paf.design.ru)
1.22 paf 6:
7:
8: driver dynamic library must look like this:
9: @code
1.35 paf 10: class X_SQL_Driver: public SQL_Driver {
1.22 paf 11: public:
12:
13: X_SQL_Driver() : SQL_driver() {}
14:
15: int api_version() { return SQL_DRIVER_API_VERSION; }
16:
17: //...
18: };
19:
20: extern "C" SQL_Driver *create() {
21: return new X_SQL_Driver();
22: }
23: @endcode
24: */
25:
26: #ifndef PA_SQL_DRIVER_H
27: #define PA_SQL_DRIVER_H
1.27 paf 28:
1.36 ! paf 29: static const char * const IDENT_SQL_DRIVER_H="$Date: 2003/07/24 11:31:24 $";
1.22 paf 30:
31: #include <sys/types.h>
1.35 paf 32: #include <setjmp.h>
33: #include <stdlib.h>
1.22 paf 34:
1.35 paf 35: #define SQL_DRIVER_API_VERSION 0x0007
1.29 paf 36: #define SQL_DRIVER_CREATE create /* used in driver implementation */
37: #define SQL_DRIVER_CREATE_NAME "create" /* could not figure out how to # it :( */
38:
39: /// fields are freed elsewhere
1.32 paf 40: class SQL_Error {
1.29 paf 41: bool fdefined;
1.35 paf 42: const char* ftype;
43: const char* fcomment;
1.29 paf 44: public:
1.32 paf 45: SQL_Error():
1.29 paf 46: fdefined(false) {}
1.32 paf 47: SQL_Error(
1.35 paf 48: const char* atype,
49: const char* acomment):
1.29 paf 50: fdefined(true),
51: ftype(atype),
52: fcomment(acomment) {}
1.35 paf 53: SQL_Error(const char* acomment):
1.29 paf 54: fdefined(true),
55: ftype(0),
56: fcomment(acomment) {}
1.32 paf 57: SQL_Error& operator =(const SQL_Error& src) {
1.29 paf 58: fdefined=src.fdefined;
59: ftype=src.ftype;
60: fcomment=src.fcomment;
61: return *this;
62: }
63:
1.32 paf 64: bool defined() const { return fdefined; }
1.35 paf 65: const char* type() const { return ftype; }
66: const char* comment() const { return fcomment; }
1.29 paf 67: };
68:
1.22 paf 69: /// service functions for SQL driver to use
70: class SQL_Driver_services {
71: public:
1.35 paf 72: /// allocates some bytes
1.22 paf 73: virtual void *malloc(size_t size) =0;
1.35 paf 74: /// allocates some bytes, user promises: no pointers inside
75: virtual void *malloc_atomic(size_t size) =0;
76: /// reallocates bytes
77: virtual void *realloc(void *ptr, size_t size) =0;
1.22 paf 78: /// prepare throw exception
1.32 paf 79: virtual void _throw(const SQL_Error& e) =0;
1.22 paf 80: /// throw C++ exception from prepared
81: virtual void propagate_exception() =0;
1.29 paf 82: /// helper func
1.35 paf 83: void _throw(const char* comment) { _throw(SQL_Error("sql.connect", comment)); }
1.22 paf 84: public:
85: /// regretrully public, because can't make stack frames: "nowhere to return to"
86: jmp_buf mark;
87: };
88:
1.32 paf 89: /** events, occuring when SQL_Driver::query()-ing.
90:
91: when OK must return false.
92: must NOT throw exceptions, must store them to error & return true.
93: */
1.22 paf 94: class SQL_Driver_query_event_handlers {
95: public:
1.35 paf 96: virtual bool add_column(SQL_Error& error, const char* str, size_t length) =0;
1.32 paf 97: virtual bool before_rows(SQL_Error& error) =0;
98: virtual bool add_row(SQL_Error& error) =0;
1.35 paf 99: virtual bool add_row_cell(SQL_Error& error, const char* str, size_t length) =0;
1.22 paf 100: };
101:
102: /// SQL driver API
103: class SQL_Driver {
104: public:
105:
1.35 paf 106: /** allocated using our allocator,
107: @todo never freed
108: */
109: static void *operator new(size_t size) {
110: void *result=::malloc(size);
111: if(!result)
112: abort();
113:
114: return result;
115: }
1.22 paf 116: /// get api version
117: virtual int api_version() =0;
118: /// initialize driver by loading sql dynamic link library
1.35 paf 119: virtual const char* initialize(char *dlopen_file_spec) =0;
1.22 paf 120: /** connect to sql database using
121: @param used_only_to_connect_url
122: format is driver specific
123: WARNING: must be used only to connect, for buffer doesn't live long enough
124:
125: @returns true+'connection' on success. 'error' on failure
126: */
127: virtual void connect(char *used_only_in_connect_url_cstr,
128: SQL_Driver_services& services, void **connection) =0;
129: virtual void disconnect(void *connection) =0;
130: virtual void commit(
131: SQL_Driver_services& services, void *connection) =0;
132: virtual void rollback(
133: SQL_Driver_services& services, void *connection) =0;
134: /// @returns true to indicate that connection still alive
135: virtual bool ping(
136: SQL_Driver_services& services, void *connection) =0;
137: /// encodes the string in 'from' to an escaped SQL string
1.35 paf 138: virtual const char* quote(
1.22 paf 139: SQL_Driver_services& services, void *connection,
1.35 paf 140: const char* str, unsigned int length) =0;
1.22 paf 141: virtual void query(
142: SQL_Driver_services& services, void *connection,
1.35 paf 143: const char* statement, unsigned long offset, unsigned long limit,
1.22 paf 144: SQL_Driver_query_event_handlers& handlers) =0;
145: };
146:
147: typedef SQL_Driver *(*SQL_Driver_create_func)();
148:
149: #endif
E-mail:
![[BACK]](/cvsweb/icons/back.gif){kind=icon}
Return to pa_sql_driver.h CVS log ![[TXT]](/cvsweb/icons/text.gif){kind=icon}
![[DIR]](/cvsweb/icons/dir.gif){kind=icon}
Up to [parser3project] / parser3 / src / sql