/********************************************************************** * Copyright (c) 2002, Leo Seib, Hannover * * Project:SQLiteDataset C++ Dynamic Library * Module: SQLiteDataset class header file * Author: Leo Seib E-Mail: lev@almaty.pointstrike.net * Begin: 5/04/2002 * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal * in the Software without restriction, including without limitation the rights * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell * copies of the Software, and to permit persons to whom the Software is * furnished to do so, subject to the following conditions: * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. * * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN * THE SOFTWARE. * **********************************************************************/ #ifndef _SQLITEDATASET_H #define _SQLITEDATASET_H #include #include "dataset.h" #include "sqlite.h" extern "C" { #include "gambas.h" #include "gb_common.h" #include "../gb.db.h" extern GB_INTERFACE GB; extern DB_INTERFACE DB; } /* NG */ using namespace std; #include #include typedef vector Tables; //#define DEFAULT_STRING_LENGTH 65535 #define DEFAULT_STRING_LENGTH 0 /* */ /* Return Field Type from Database */ void SetFieldType( result_set *r, Tables tables ); fType GetFieldType( char *Type, unsigned int *len ); /***************** Class SqliteDatabase definition ****************** class 'SqliteDatabase' connects with Sqlite-server ******************************************************************/ class SqliteDatabase: public Database { protected: /* connect descriptor */ sqlite *conn; bool _in_transaction; int last_err; public: /* default constructor */ SqliteDatabase(); /* destructor */ virtual ~SqliteDatabase(); Dataset *CreateDataset() const; /* func. returns connection handle with SQLite-server */ sqlite *getHandle() { return conn; } /* func. returns current status about SQLite-server connection */ virtual int status(); virtual int setErr(int err_code); /* func. returns error message if error occurs */ virtual const char *getErrorMsg(); /* func. connects to database-server */ virtual int connect(); /* func. disconnects from database-server */ virtual void disconnect(); /* func. creates new database */ virtual int create(); /* func. deletes database */ virtual int drop(); virtual long nextid(const char* seq_name); /* virtual methods for transaction */ virtual void start_transaction(); virtual void commit_transaction(); virtual void rollback_transaction(); bool in_transaction() {return _in_transaction;} int lastError() { return last_err; } }; /***************** Class SqliteDataset definition ******************* class 'SqliteDataset' does a query to SQLite-server ******************************************************************/ class SqliteDataset : public Dataset { protected: /* query results*/ result_set result; result_set exec_res; char* errmsg; sqlite* handle(); /* Makes direct queries to database */ virtual void make_query(StringList &_sql); /* Makes direct inserts into database */ virtual void make_insert(); /* Edit SQL */ virtual void make_edit(); /* Delete SQL */ virtual void make_deletion(); //static int sqlite_callback(void* res_ptr,int ncol, char** reslt, char** cols); /* This function works only with MySQL database Filling the fields information from select statement */ virtual void fill_fields(); /* Changing field values during dataset navigation */ public: /* constructor */ SqliteDataset(); SqliteDataset(SqliteDatabase *newDb); /* destructor */ virtual ~SqliteDataset(); /* opens a query & then sets a query results */ virtual void open(); virtual void open(const string &sql); /* func. executes a query without results to return */ virtual int exec (); virtual int exec (const string &sql); virtual const void* getExecRes(); /* as open, but with our query exept Sql */ virtual bool query(const char *query); virtual bool query(const string &query); /* func. closes a query */ virtual void close(void); /* Cancel changes, made in insert or edit states of dataset */ virtual void cancel(); /* sequence numbers */ virtual long nextid(const char *seq_name); /* sequence numbers */ virtual int num_rows(); virtual bool bof(); virtual bool eof(); virtual void first(); virtual void last(); virtual void prev(); virtual void next(); /* Go to record No (starting with 0) */ virtual bool seek(int pos=0); }; #endif