[BACK]Return to pa_sql_driver.h CVS log [TXT] [DIR] Up to [parser3project] / parser3 / src / sql

Diff for /parser3/src/sql/pa_sql_driver.h between versions 1.9 and 1.44

version 1.9, 2001/05/17 08:42:22 version 1.44, 2008/06/26 09:42:35
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-2005 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$  
   
   
         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 26
 #ifndef PA_SQL_DRIVER_H  #ifndef PA_SQL_DRIVER_H
 #define PA_SQL_DRIVER_H  #define PA_SQL_DRIVER_H
   
   static const char * const IDENT_SQL_DRIVER_H="$Date$";
   
 #include <sys/types.h>  #include <sys/types.h>
   #include <setjmp.h>
   #include <stdlib.h>
   #include <limits.h>
   
   /*
       1..8 not logged
           9 introducing placeholders
           10 limit fixed (default: SQL_NO_LIMIT [ULONG_MAX]), path to document_root added
   */
   //#define SQL_DRIVER_API_VERSION 10
   #define SQL_DRIVER_API_VERSION 9
   #define SQL_DRIVER_CREATE create /* used in driver implementation */
   #define SQL_DRIVER_CREATE_NAME "create" /* could not figure out how to # it :( */
   
   //#define SQL_NO_LIMIT ULONG_MAX
   #define SQL_NO_LIMIT 0
   
   /// 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;
         /// throw exception          /// reallocates bytes 
         virtual void _throw(const char *comment) =0;          virtual void *realloc(void *ptr, size_t size) =0;
           /// $request:charset
           virtual const char* request_charset() =0;
           /// $request:document-root
           virtual const char* request_document_root() =0;
           /// transcoder. 
           /// WARNING: can store pointers to charset names to speedup name-to-instance resolving
           /// so do NOT pass pointers to local vars and change those vars after that
           virtual void transcode(const char* src, size_t src_length,
                   const char*& dst, size_t& dst_length,
                   const char* charset_from_name,
                   const char* charset_to_name
                   ) =0;
           /// prepare throw exception
           virtual void _throw(const SQL_Error& e) =0;
           /// throw C++ exception from prepared
           virtual void propagate_exception() =0;
           /// helper func
           void _throw(const char* comment) { _throw(SQL_Error("sql.connect", comment)); }
   public:
           /// regretrully public, because can't make stack frames: "nowhere to return to"
           jmp_buf mark;
 };  };
   
 #define SQL_DRIVER_API_VERSION 0x0301  /** 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 {
   public:
           virtual bool add_column(SQL_Error& error, const char* str, size_t length) =0;
           virtual bool before_rows(SQL_Error& error) =0;
           virtual bool add_row(SQL_Error& error) =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:
   
         /// row cell & column title  storage          /// @todo can be optimized to contain type information, 
         struct Cell {          /// to pass IN and OUT int/double NOT in string format
                 void *ptr;          struct Placeholder {
                 size_t size;                  const char* name;
                   const char* value;
                   bool is_null;
                   bool were_updated;
         };          };
   
 public:          /** allocated using our allocator,
                   @todo never freed
         /// assignes services to driver. you can not use driver until this          */
         void set_services(SQL_Driver_services *aservices) { services=aservices; }          static void *operator new(size_t size) { 
                   void *result=::malloc(size);
                   if(!result)
                           abort();
   
         SQL_Driver() :                  return result;
                 services(0) {  
         }          }
         /// 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(const 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 url_cstr
                         format is driver specific                          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                  @returns true+'connection' on success. 'error' on failure
         */          */
         virtual void connect(char *used_only_to_connect_url, void **connection) =0;          virtual void connect(char *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(void *connection) =0;
         virtual void rollback(void *connection) =0;          virtual void rollback(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(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 const char* quote(void *connection,
                 char *to, const char *from, unsigned int length) =0;                  const char* str, unsigned int length) =0;
         virtual void query(void *connection,          virtual void query(void *connection,
                 const char *statement, unsigned long offset, unsigned long limit,                  const char* statement, 
                 unsigned int *column_count, Cell **columns,                  size_t placeholders_count, Placeholder* placeholders,
                 unsigned long *row_count, Cell ***rows) =0;                  unsigned long offset, unsigned long limit,
         /// log error message                  SQL_Driver_query_event_handlers& handlers) =0;
         //static void log(Pool& pool, const char *fmt, ...);  
   
 protected:  
   
         SQL_Driver_services *services;  
 };  };
   
 typedef SQL_Driver *(*SQL_Driver_create_func)();  typedef SQL_Driver *(*SQL_Driver_create_func)();
Removed from v.1.9  
changed lines
  Added in v.1.44

E-mail: