1 ///////////////////////////////////////////////////////////////////////////////
3 // Purpose: Declaration of the wxDbTable class.
5 // Modified by: George Tasker
10 // Copyright: (c) 1996 Remstar International, Inc.
11 // Licence: wxWindows licence
12 ///////////////////////////////////////////////////////////////////////////////
22 #include "wx/version.h"
24 #if defined(__GNUG__) && !defined(NO_GCC_PRAGMA)
25 #pragma interface "dbtable.h"
30 #include "wx/variant.h"
31 #include "wx/dbkeyg.h"
33 const int wxDB_ROWID_LEN
= 24; // 18 is the max, 24 is in case it gets larger
34 const int wxDB_DEFAULT_CURSOR
= 0;
35 const bool wxDB_QUERY_ONLY
= TRUE
;
36 const bool wxDB_DISABLE_VIEW
= TRUE
;
38 // Used to indicate end of a variable length list of
39 // column numbers passed to member functions
40 const int wxDB_NO_MORE_COLUMN_NUMBERS
= -1;
42 // The following class is used to define a column of a table.
43 // The wxDbTable constructor will dynamically allocate as many of
44 // these as there are columns in the table. The class derived
45 // from wxDbTable must initialize these column definitions in it's
46 // constructor. These column definitions provide inf. to the
47 // wxDbTable class which allows it to create a table in the data
48 // source, exchange data between the data source and the C++
50 class WXDLLIMPEXP_ODBC wxDbColDef
53 wxChar ColName
[DB_MAX_COLUMN_NAME_LEN
+1]; // Column Name
54 int DbDataType
; // Logical Data Type; e.g. DB_DATA_TYPE_INTEGER
55 SWORD SqlCtype
; // C data type; e.g. SQL_C_LONG
56 void *PtrDataObj
; // Address of the data object
57 int SzDataObj
; // Size, in bytes, of the data object
58 bool KeyField
; // TRUE if this column is part of the PRIMARY KEY to the table; Date fields should NOT be KeyFields.
59 bool Updateable
; // Specifies whether this column is updateable
60 bool InsertAllowed
; // Specifies whether this column should be included in an INSERT statement
61 bool DerivedCol
; // Specifies whether this column is a derived value
62 SDWORD CbValue
; // Internal use only!!!
63 bool Null
; // NOT FULLY IMPLEMENTED - Allows NULL values in Inserts and Updates
71 class WXDLLIMPEXP_ODBC wxDbColDataPtr
80 // This structure is used when creating secondary indexes.
81 class WXDLLIMPEXP_ODBC wxDbIdxDef
84 wxChar ColName
[DB_MAX_COLUMN_NAME_LEN
+1];
89 class WXDLLIMPEXP_ODBC wxDbTable
92 ULONG tableID
; // Used for debugging. This can help to match up mismatched constructors/destructors
94 // Private member variables
98 // Private member functions
99 bool initialize(wxDb
*pwxDb
, const wxString
&tblName
, const UWORD numColumns
,
100 const wxString
&qryTblName
, bool qryOnly
, const wxString
&tblPath
);
103 void setCbValueForColumn(int columnIndex
);
104 bool bindParams(bool forUpdate
); // called by the other 'bind' functions
105 bool bindInsertParams(void);
106 bool bindUpdateParams(void);
108 bool bindCols(HSTMT cursor
);
109 bool getRec(UWORD fetchType
);
110 bool execDelete(const wxString
&pSqlStmt
);
111 bool execUpdate(const wxString
&pSqlStmt
);
112 bool query(int queryType
, bool forUpdate
, bool distinct
, const wxString
&pSqlStmt
=wxEmptyString
);
114 #if !wxODBC_BACKWARD_COMPATABILITY
116 // Where, Order By and From clauses
117 wxString where
; // Standard SQL where clause, minus the word WHERE
118 wxString orderBy
; // Standard SQL order by clause, minus the ORDER BY
119 wxString from
; // Allows for joins in a wxDbTable::Query(). Format: ",tbl,tbl..."
122 HENV henv
; // ODBC Environment handle
123 HDBC hdbc
; // ODBC DB Connection handle
124 HSTMT hstmt
; // ODBC Statement handle
125 HSTMT
*hstmtDefault
; // Default cursor
126 HSTMT hstmtInsert
; // ODBC Statement handle used specifically for inserts
127 HSTMT hstmtDelete
; // ODBC Statement handle used specifically for deletes
128 HSTMT hstmtUpdate
; // ODBC Statement handle used specifically for updates
129 HSTMT hstmtInternal
; // ODBC Statement handle used internally only
130 HSTMT
*hstmtCount
; // ODBC Statement handle used by Count() function (No binding of columns)
133 bool selectForUpdate
;
135 // Pointer to the database object this table belongs to
139 wxString tablePath
; // needed for dBase tables
140 wxString tableName
; // Table name
141 wxString queryTableName
; // Query Table Name
142 UWORD noCols
; // # of columns in the table
143 bool queryOnly
; // Query Only, no inserts, updates or deletes
145 // Column Definitions
146 wxDbColDef
*colDefs
; // Array of wxDbColDef structures
149 #if wxODBC_BACKWARD_COMPATABILITY
150 // Where, Order By and From clauses
151 char *where
; // Standard SQL where clause, minus the word WHERE
152 char *orderBy
; // Standard SQL order by clause, minus the ORDER BY
153 char *from
; // Allows for joins in a wxDbTable::Query(). Format: ",tbl,tbl..."
156 HENV henv
; // ODBC Environment handle
157 HDBC hdbc
; // ODBC DB Connection handle
158 HSTMT hstmt
; // ODBC Statement handle
159 HSTMT
*hstmtDefault
; // Default cursor
160 HSTMT hstmtInsert
; // ODBC Statement handle used specifically for inserts
161 HSTMT hstmtDelete
; // ODBC Statement handle used specifically for deletes
162 HSTMT hstmtUpdate
; // ODBC Statement handle used specifically for updates
163 HSTMT hstmtInternal
; // ODBC Statement handle used internally only
164 HSTMT
*hstmtCount
; // ODBC Statement handle used by Count() function (No binding of columns)
167 bool selectForUpdate
;
169 // Pointer to the database object this table belongs to
173 char tablePath
[wxDB_PATH_MAX
]; // needed for dBase tables
174 char tableName
[DB_MAX_TABLE_NAME_LEN
+1]; // Table name
175 char queryTableName
[DB_MAX_TABLE_NAME_LEN
+1]; // Query Table Name
176 UWORD noCols
; // # of columns in the table
177 bool queryOnly
; // Query Only, no inserts, updates or deletes
179 // Column Definitions
180 wxDbColDef
*colDefs
; // Array of wxDbColDef structures
182 // Public member functions
183 wxDbTable(wxDb
*pwxDb
, const wxString
&tblName
, const UWORD numColumns
,
184 const wxString
&qryTblName
=wxEmptyString
, bool qryOnly
= !wxDB_QUERY_ONLY
,
185 const wxString
&tblPath
=wxEmptyString
);
188 wxDbTable(wxDb
*pwxDb
, const wxString
&tblName
, const UWORD numColumns
,
189 const wxChar
*qryTblName
=wxEmptyString
, bool qryOnly
= !wxDB_QUERY_ONLY
,
190 const wxString
&tblPath
=wxEmptyString
);
192 virtual ~wxDbTable();
194 bool Open(bool checkPrivileges
=FALSE
, bool checkTableExists
=TRUE
);
195 bool CreateTable(bool attemptDrop
=TRUE
);
196 bool DropTable(void);
197 bool CreateIndex(const wxString
&idxName
, bool unique
, UWORD noIdxCols
,
198 wxDbIdxDef
*pIdxDefs
, bool attemptDrop
=TRUE
);
199 bool DropIndex(const wxString
&idxName
);
203 // The member variables returned by these accessors are all
204 // set when the wxDbTable instance is created and cannot be
205 // changed, hence there is no corresponding SetXxxx function
206 wxDb
*GetDb() { return pDb
; }
207 const wxString
&GetTableName() { return tableName
; }
208 const wxString
&GetQueryTableName() { return queryTableName
; }
209 const wxString
&GetTablePath() { return tablePath
; }
211 UWORD
GetNumberOfColumns() { return noCols
; } // number of "defined" columns for this wxDbTable instance
213 const wxString
&GetFromClause() { return from
; }
214 const wxString
&GetOrderByClause() { return orderBy
; }
215 const wxString
&GetWhereClause() { return where
; }
217 bool IsQueryOnly() { return queryOnly
; }
218 #if wxODBC_BACKWARD_COMPATABILITY
219 void SetFromClause(const char *From
) { from
= (char *)From
; }
220 void SetOrderByClause(const char *OrderBy
) { orderBy
= (char *)OrderBy
; }
221 void SetWhereClause(const char *Where
) { where
= (char *)Where
; }
223 void SetFromClause(const wxString
&From
) { from
= From
; }
224 void SetOrderByClause(const wxString
&OrderBy
) { orderBy
= OrderBy
; }
225 bool SetOrderByColNums(UWORD first
, ...);
226 void SetWhereClause(const wxString
&Where
) { where
= Where
; }
227 void From(const wxString
&From
) { from
= From
; }
228 void OrderBy(const wxString
&OrderBy
) { orderBy
= OrderBy
; }
229 void Where(const wxString
&Where
) { where
= Where
; }
230 const wxString
&Where() { return where
; }
231 const wxString
&OrderBy() { return orderBy
; }
232 const wxString
&From() { return from
; }
236 bool Update(const wxString
&pSqlStmt
);
237 bool UpdateWhere(const wxString
&pWhereClause
);
239 bool DeleteWhere(const wxString
&pWhereClause
);
240 bool DeleteMatching(void);
241 virtual bool Query(bool forUpdate
= FALSE
, bool distinct
= FALSE
);
242 bool QueryBySqlStmt(const wxString
&pSqlStmt
);
243 bool QueryMatching(bool forUpdate
= FALSE
, bool distinct
= FALSE
);
244 bool QueryOnKeyFields(bool forUpdate
= FALSE
, bool distinct
= FALSE
);
246 bool GetNext(void) { return(getRec(SQL_FETCH_NEXT
)); }
247 bool operator++(int) { return(getRec(SQL_FETCH_NEXT
)); }
249 /***** These four functions only work with wxDb instances that are defined *****
250 ***** as not being FwdOnlyCursors *****/
252 bool operator--(int);
256 bool IsCursorClosedOnCommit(void);
257 UWORD
GetRowNum(void);
259 void BuildSelectStmt(wxString
&pSqlStmt
, int typeOfSelect
, bool distinct
);
260 void BuildSelectStmt(wxChar
*pSqlStmt
, int typeOfSelect
, bool distinct
);
262 void BuildDeleteStmt(wxString
&pSqlStmt
, int typeOfDel
, const wxString
&pWhereClause
=wxEmptyString
);
263 void BuildDeleteStmt(wxChar
*pSqlStmt
, int typeOfDel
, const wxString
&pWhereClause
=wxEmptyString
);
265 void BuildUpdateStmt(wxString
&pSqlStmt
, int typeOfUpd
, const wxString
&pWhereClause
=wxEmptyString
);
266 void BuildUpdateStmt(wxChar
*pSqlStmt
, int typeOfUpd
, const wxString
&pWhereClause
=wxEmptyString
);
268 void BuildWhereClause(wxString
&pWhereClause
, int typeOfWhere
, const wxString
&qualTableName
=wxEmptyString
, bool useLikeComparison
=FALSE
);
269 void BuildWhereClause(wxChar
*pWhereClause
, int typeOfWhere
, const wxString
&qualTableName
=wxEmptyString
, bool useLikeComparison
=FALSE
);
271 #if wxODBC_BACKWARD_COMPATABILITY
272 // The following member functions are deprecated. You should use the BuildXxxxxStmt functions (above)
273 void GetSelectStmt(char *pSqlStmt
, int typeOfSelect
, bool distinct
)
274 { BuildSelectStmt(pSqlStmt
,typeOfSelect
,distinct
); }
275 void GetDeleteStmt(char *pSqlStmt
, int typeOfDel
, const char *pWhereClause
= NULL
)
276 { BuildDeleteStmt(pSqlStmt
,typeOfDel
,pWhereClause
); }
277 void GetUpdateStmt(char *pSqlStmt
, int typeOfUpd
, const char *pWhereClause
= NULL
)
278 { BuildUpdateStmt(pSqlStmt
,typeOfUpd
,pWhereClause
); }
279 void GetWhereClause(char *pWhereClause
, int typeOfWhere
,
280 const char *qualTableName
= NULL
, bool useLikeComparison
=FALSE
)
281 { BuildWhereClause(pWhereClause
,typeOfWhere
,qualTableName
,useLikeComparison
); }
283 bool CanSelectForUpdate(void);
284 bool CanUpdByROWID(void);
285 void ClearMemberVar(UWORD colNo
, bool setToNull
=FALSE
);
286 void ClearMemberVars(bool setToNull
=FALSE
);
287 bool SetQueryTimeout(UDWORD nSeconds
);
289 wxDbColDef
*GetColDefs() { return colDefs
; }
290 void SetColDefs(UWORD index
, const wxString
&fieldName
, int dataType
,
291 void *pData
, SWORD cType
,
292 int size
, bool keyField
= FALSE
, bool upd
= TRUE
,
293 bool insAllow
= TRUE
, bool derivedCol
= FALSE
);
294 wxDbColDataPtr
*SetColDefs(wxDbColInf
*colInfs
, UWORD numCols
);
296 bool CloseCursor(HSTMT cursor
);
297 bool DeleteCursor(HSTMT
*hstmtDel
);
298 void SetCursor(HSTMT
*hstmtActivate
= (void **) wxDB_DEFAULT_CURSOR
);
299 HSTMT
GetCursor(void) { return(hstmt
); }
300 HSTMT
*GetNewCursor(bool setCursor
= FALSE
, bool bindColumns
= TRUE
);
301 #if wxODBC_BACKWARD_COMPATABILITY
302 // The following member function is deprecated. You should use the GetNewCursor
303 HSTMT
*NewCursor(bool setCursor
= FALSE
, bool bindColumns
= TRUE
) { return GetNewCursor(setCursor
,bindColumns
); }
306 ULONG
Count(const wxString
&args
=_T("*"));
307 int DB_STATUS(void) { return(pDb
->DB_STATUS
); }
309 bool IsColNull(UWORD colNo
) const;
310 bool SetColNull(UWORD colNo
, bool set
=TRUE
);
311 bool SetColNull(const wxString
&colName
, bool set
=TRUE
);
312 #if wxODBC_BACKWARD_COMPATABILITY
313 // The following member functions are deprecated. You should use the SetColNull()
314 bool SetNull(int colNo
, bool set
=TRUE
) { return (SetNull(colNo
,set
)); }
315 bool SetNull(const char *colName
, bool set
=TRUE
) { return (SetNull(colName
,set
)); }
318 ULONG
GetTableID() { return tableID
; }
321 //TODO: Need to Document
322 typedef enum { WX_ROW_MODE_QUERY
, WX_ROW_MODE_INDIVIDUAL
} rowmode_t
;
323 virtual void SetRowMode(const rowmode_t rowmode
);
324 virtual wxVariant
GetCol(const int colNo
) const ;
325 virtual void SetCol(const int colNo
, const wxVariant value
);
326 virtual GenericKey
GetKey(void);
327 virtual void SetKey(const GenericKey
&key
);
330 HSTMT
*m_hstmtGridQuery
;
334 // typedef enum {unmodified=0, UpdatePending, InsertPending } recStatus;
336 // recStatus get_ModifiedStatus() { return m_recstatus; }
339 // if (m_recstatus==unmodified)
340 // m_recstatus=UpdatePending;
343 // void insertify() {m_recstatus=InsertPending; }
344 // void unmodify() {m_recstatus=unmodified; }
345 // recStatus m_recstatus;
346 //TODO: Need to Document
350 // Change this to 0 to remove use of all deprecated functions
351 #if wxODBC_BACKWARD_COMPATABILITY
352 //#################################################################################
353 //############### DEPRECATED functions for backward compatability #################
354 //#################################################################################
356 // Backward compability. These will eventually go away
357 typedef wxDbTable wxTable
;
358 typedef wxDbIdxDef wxIdxDef
;
359 typedef wxDbIdxDef CidxDef
;
360 typedef wxDbColDef wxColDef
;
361 typedef wxDbColDef CcolDef
;
362 typedef wxDbColDataPtr wxColDataPtr
;
363 typedef wxDbColDataPtr CcolDataPtr
;
365 const int ROWID
= wxDB_ROWID_LEN
;
366 const int DEFAULT_CURSOR
= wxDB_DEFAULT_CURSOR
;
367 const bool QUERY_ONLY
= wxDB_QUERY_ONLY
;
368 const bool DISABLE_VIEW
= wxDB_DISABLE_VIEW
;