]> git.saurik.com Git - wxWidgets.git/blame - src/common/db.cpp
projects / wxWidgets.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
fixed wxConfig bug I've introduced yesterday
[wxWidgets.git] / src / common / db.cpp
CommitLineData
108106cf
JS		 1///////////////////////////////////////////////////////////////////////////////
2// Name: db.cpp
f6bcfd97
BP		 3// Purpose: Implementation of the wxDb class. The wxDb class represents a connection
4// to an ODBC data source. The wxDb class allows operations on the data
108106cf
JS		 5// source such as opening and closing the data source.
6// Author: Doug Card
67e9aaa3 7// Modified by: George Tasker
3ca6a5f0 8// Bart Jourquin
0cd121f9 9// Mark Johnson, wxWindows@mj10777.de
23f681ec 10// Mods: Dec, 1998:
a2115c88
GT		 11// -Added support for SQL statement logging and database cataloging
12// Mods: April, 1999
1e92909e
GT		 13// -Added QUERY_ONLY mode support to reduce default number of cursors
14// -Added additional SQL logging code
a2115c88 15// -Added DEBUG-ONLY tracking of wxTable objects to detect orphaned DB connections
1e92909e 16// -Set ODBC option to only read committed writes to the DB so all
a2115c88 17// databases operate the same in that respect
108106cf
JS		 18// Created: 9.96
19// RCS-ID: $Id$
20// Copyright: (c) 1996 Remstar International, Inc.
21// Licence: wxWindows licence, plus:
1e92909e 22// Notice: This class library and its intellectual design are free of charge for use,
108106cf
JS		 23// modification, enhancement, debugging under the following conditions:
24// 1) These classes may only be used as part of the implementation of a
25// wxWindows-based application
26// 2) All enhancements and bug fixes are to be submitted back to the wxWindows
27// user groups free of all charges for use with the wxWindows library.
28// 3) These classes may not be distributed as part of any other class library,
29// DLL, text (written or electronic), other than a complete distribution of
30// the wxWindows GUI development toolkit.
31///////////////////////////////////////////////////////////////////////////////
32
33/*
34// SYNOPSIS START
35// SYNOPSIS STOP
36*/
37
01dba85a
JS		 38#include "wx/wxprec.h"
39
f6bcfd97 40
a2115c88
GT		 41// Use this line for wxWindows v1.x
42//#include "wx_ver.h"
43// Use this line for wxWindows v2.x
44#include "wx/version.h"
a2115c88
GT		 45
46#if wxMAJOR_VERSION == 2
1e92909e 47 #ifdef __GNUG__
3ca6a5f0 48 #pragma implementation "db.h"
1e92909e 49 #endif
a2115c88
GT		 50#endif
51
1fc5dd6f 52#ifdef DBDEBUG_CONSOLE
52a17fe5 53 #include "wx/ioswrap.h"
108106cf 54#endif
108106cf
JS		 55
56#ifdef __BORLANDC__
1e92909e 57 #pragma hdrstop
108106cf
JS		 58#endif //__BORLANDC__
59
a2115c88 60#if wxMAJOR_VERSION == 2
1e92909e
GT		 61 #ifndef WX_PRECOMP
62 #include "wx/string.h"
63 #include "wx/object.h"
64 #include "wx/list.h"
65 #include "wx/utils.h"
66 #include "wx/msgdlg.h"
0efe4a98 67 #include "wx/log.h"
1e92909e
GT		 68 #endif
69 #include "wx/filefn.h"
70 #include "wx/wxchar.h"
a2115c88
GT		 71#endif
72
f6bcfd97 73
a2115c88 74#if wxMAJOR_VERSION == 1
1e92909e
GT		 75# if defined(wx_msw) || defined(wx_x)
76# ifdef WX_PRECOMP
77# include "wx_prec.h"
78# else
79# include "wx.h"
80# endif
81# endif
82# define wxUSE_ODBC 1
a2115c88 83#endif
108106cf 84
47d67540 85#if wxUSE_ODBC
108106cf 86
108106cf
JS		 87#include <stdio.h>
88#include <string.h>
89#include <assert.h>
7e616b10
RR		 90#include <stdlib.h>
91#include <ctype.h>
67e9aaa3 92
a2115c88 93#if wxMAJOR_VERSION == 1
1e92909e 94 #include "db.h"
a2115c88 95#elif wxMAJOR_VERSION == 2
1e92909e 96 #include "wx/db.h"
a2115c88 97#endif
108106cf 98
d50af714 99WXDLLEXPORT_DATA(wxDbList*) PtrBegDbList = 0;
108106cf 100
f6bcfd97 101
4fdae997
GT		 102wxChar const *SQL_LOG_FILENAME = wxT("sqllog.txt");
103wxChar const *SQL_CATALOG_FILENAME = wxT("catalog.txt");
9453a61b 104
e041ce57 105#ifdef __WXDEBUG__
1e92909e 106 extern wxList TablesInUse;
a2115c88
GT		 107#endif
108
109// SQL Log defaults to be used by GetDbConnection
f6bcfd97 110wxDbSqlLogState SQLLOGstate = sqlLogOFF;
a2115c88 111
3ca6a5f0 112static wxString SQLLOGfn = SQL_LOG_FILENAME;
a2115c88 113
f6bcfd97 114// The wxDb::errorList is copied to this variable when the wxDb object
a2115c88 115// is closed. This way, the error list is still available after the
9453a61b 116// database object is closed. This is necessary if the database
a2115c88 117// connection fails so the calling application can show the operator
f6bcfd97
BP		 118// why the connection failed. Note: as each wxDb object is closed, it
119// will overwrite the errors of the previously destroyed wxDb object in
3ca6a5f0
BP		 120// this variable. NOTE: This occurs during a CLOSE, not a FREEing of the
121// connection
4fdae997 122wxChar DBerrorList[DB_MAX_ERROR_HISTORY][DB_MAX_ERROR_MSG_LEN];
a2115c88 123
eedb1543 124// This type defines the return row-struct form
3ca6a5f0 125// SQLTablePrivileges, and is used by wxDB::TablePrivileges.
eedb1543 126typedef struct
3ca6a5f0 127{
a8aa2258
GT		 128 wxChar tableQual[128+1];
129 wxChar tableOwner[128+1];
130 wxChar tableName[128+1];
131 wxChar grantor[128+1];
132 wxChar grantee[128+1];
133 wxChar privilege[128+1];
134 wxChar grantable[3+1];
3ca6a5f0 135} wxDbTablePrivilegeInfo;
3ca6a5f0 136
67e9aaa3 137
942e67c3
GT		 138/********** wxDbConnectInf Constructor - form 1 **********/
139wxDbConnectInf::wxDbConnectInf()
67e9aaa3 140{
da99271d
GT		 141 Henv = 0;
142 freeHenvOnDestroy = FALSE;
143
942e67c3
GT		 144 Initialize();
145} // Constructor
146
147
148/********** wxDbConnectInf Constructor - form 2 **********/
5600884a 149wxDbConnectInf::wxDbConnectInf(HENV henv, const wxString &dsn, const wxString &userID,
da99271d
GT		 150 const wxString &password, const wxString &defaultDir,
151 const wxString &fileType, const wxString &description)
942e67c3 152{
da99271d
GT		 153 Henv = 0;
154 freeHenvOnDestroy = FALSE;
942e67c3
GT		 155
156 Initialize();
157
da99271d
GT		 158 if (henv)
159 SetHenv(henv);
942e67c3
GT		 160 else
161 AllocHenv();
162
da99271d
GT		 163 SetDsn(dsn);
164 SetUserID(userID);
165 SetPassword(password);
166 SetDescription(description);
167 SetFileType(fileType);
168 SetDefaultDir(defaultDir);
942e67c3
GT		 169} // wxDbConnectInf Constructor
170
171
172wxDbConnectInf::~wxDbConnectInf()
173{
174 if (freeHenvOnDestroy)
67e9aaa3 175 {
942e67c3 176 FreeHenv();
67e9aaa3 177 }
942e67c3 178} // wxDbConnectInf Destructor
67e9aaa3
GT		 179
180
942e67c3
GT		 181
182/********** wxDbConnectInf::Initialize() **********/
183bool wxDbConnectInf::Initialize()
67e9aaa3 184{
942e67c3 185 freeHenvOnDestroy = FALSE;
67e9aaa3 186
da99271d
GT		 187 if (freeHenvOnDestroy && Henv)
188 FreeHenv();
189
942e67c3
GT		 190 Henv = 0;
191 Dsn[0] = 0;
192 Uid[0] = 0;
193 AuthStr[0] = 0;
194 Description.Empty();
195 FileType.Empty();
196 DefaultDir.Empty();
67e9aaa3 197
942e67c3
GT		 198 return TRUE;
199} // wxDbConnectInf::Initialize()
200
201
202/********** wxDbConnectInf::AllocHenv() **********/
203bool wxDbConnectInf::AllocHenv()
3ca6a5f0 204{
942e67c3
GT		 205 // This is here to help trap if you are getting a new henv
206 // without releasing an existing henv
207 wxASSERT(!Henv);
208
209 // Initialize the ODBC Environment for Database Operations
210 if (SQLAllocEnv(&Henv) != SQL_SUCCESS)
211 {
212 wxLogDebug(wxT("A problem occured while trying to get a connection to the data source"));
213 return FALSE;
214 }
3ca6a5f0 215
942e67c3 216 freeHenvOnDestroy = TRUE;
3ca6a5f0 217
942e67c3
GT		 218 return TRUE;
219} // wxDbConnectInf::AllocHenv()
220
221
222void wxDbConnectInf::FreeHenv()
3ca6a5f0 223{
942e67c3 224 wxASSERT(Henv);
3ca6a5f0 225
942e67c3
GT		 226 if (Henv)
227 SQLFreeEnv(Henv);
3ca6a5f0 228
942e67c3
GT		 229 Henv = 0;
230 freeHenvOnDestroy = FALSE;
231
232} // wxDbConnectInf::FreeHenv()
233
234
235void wxDbConnectInf::SetDsn(const wxString &dsn)
3ca6a5f0 236{
942e67c3 237 wxASSERT(dsn.Length() < sizeof(Dsn));
3ca6a5f0 238
942e67c3
GT		 239 wxStrcpy(Dsn,dsn);
240} // wxDbConnectInf::SetDsn()
3ca6a5f0 241
942e67c3
GT		 242
243void wxDbConnectInf::SetUserID(const wxString &uid)
3ca6a5f0 244{
942e67c3
GT		 245 wxASSERT(uid.Length() < sizeof(Uid));
246 wxStrcpy(Uid,uid);
247} // wxDbConnectInf::SetUserID()
3ca6a5f0
BP		 248
249
942e67c3 250void wxDbConnectInf::SetPassword(const wxString &password)
3ca6a5f0 251{
942e67c3 252 wxASSERT(password.Length() < sizeof(AuthStr));
5600884a 253
942e67c3
GT		 254 wxStrcpy(AuthStr,password);
255} // wxDbConnectInf::SetPassword()
3ca6a5f0
BP		 256
257
942e67c3
GT		 258
259/********** wxDbColFor Constructor **********/
260wxDbColFor::wxDbColFor()
9556da13
GT		 261{
262 Initialize();
263} // wxDbColFor::wxDbColFor()
264
265
266wxDbColFor::~wxDbColFor()
267{
268} // wxDbColFor::~wxDbColFor()
269
270
271/********** wxDbColFor::Initialize() **********/
272void wxDbColFor::Initialize()
3ca6a5f0 273{
942e67c3
GT		 274 s_Field.Empty();
275 int i;
276 for (i=0; i<7; i++)
277 {
278 s_Format[i].Empty();
279 s_Amount[i].Empty();
280 i_Amount[i] = 0;
281 }
282 i_Nation = 0; // 0=EU, 1=UK, 2=International, 3=US
283 i_dbDataType = 0;
284 i_sqlDataType = 0;
285 Format(1,DB_DATA_TYPE_VARCHAR,0,0,0); // the Function that does the work
9556da13 286} // wxDbColFor::Initialize()
942e67c3
GT		 287
288
289/********** wxDbColFor::Format() **********/
4fdae997
GT		 290int wxDbColFor::Format(int Nation, int dbDataType, SWORD sqlDataType,
291 short columnSize, short decimalDigits)
67e9aaa3
GT		 292{
293 // ----------------------------------------------------------------------------------------
0cd121f9 294 // -- 19991224 : mj10777 : Create
67e9aaa3
GT		 295 // There is still a lot of work to do here, but it is a start
296 // It handles all the basic data-types that I have run into up to now
eedb1543 297 // The main work will have be with Dates and float Formatting
3ca6a5f0
BP		 298 // (US 1,000.00 ; EU 1.000,00)
299 // There are wxWindow plans for locale support and the new wxDateTime. If
300 // they define some constants (wxEUROPEAN) that can be gloably used,
67e9aaa3
GT		 301 // they should be used here.
302 // ----------------------------------------------------------------------------------------
3ca6a5f0 303 // There should also be a function to scan in a string to fill the variable
67e9aaa3 304 // ----------------------------------------------------------------------------------------
4fdae997 305 wxString tempStr;
3ca6a5f0 306 i_Nation = Nation; // 0 = timestamp , 1=EU, 2=UK, 3=International, 4=US
1e92909e 307 i_dbDataType = dbDataType;
67e9aaa3 308 i_sqlDataType = sqlDataType;
3ca6a5f0 309 s_Field.Printf(wxT("%s%d"),s_Amount[1].c_str(),i_Amount[1]); // OK for VARCHAR, INTEGER and FLOAT
4fdae997 310
3ca6a5f0 311 if (i_dbDataType == 0) // Filter unsupported dbDataTypes
67e9aaa3
GT		 312 {
313 if ((i_sqlDataType == SQL_VARCHAR) || (i_sqlDataType == SQL_LONGVARCHAR))
314 i_dbDataType = DB_DATA_TYPE_VARCHAR;
ebf776c5 315 if ((i_sqlDataType == SQL_C_DATE) || (i_sqlDataType == SQL_C_TIMESTAMP))
67e9aaa3
GT		 316 i_dbDataType = DB_DATA_TYPE_DATE;
317 if (i_sqlDataType == SQL_C_BIT)
318 i_dbDataType = DB_DATA_TYPE_INTEGER;
319 if (i_sqlDataType == SQL_NUMERIC)
320 i_dbDataType = DB_DATA_TYPE_VARCHAR;
321 if (i_sqlDataType == SQL_REAL)
322 i_dbDataType = DB_DATA_TYPE_FLOAT;
bf5423ea
GT		 323 if (i_sqlDataType == SQL_C_BINARY)
324 i_dbDataType = DB_DATA_TYPE_BLOB;
67e9aaa3 325 }
4fdae997 326
67e9aaa3
GT		 327 if ((i_dbDataType == DB_DATA_TYPE_INTEGER) && (i_sqlDataType == SQL_C_DOUBLE))
328 { // DBASE Numeric
329 i_dbDataType = DB_DATA_TYPE_FLOAT;
330 }
4fdae997
GT		 331
332 switch(i_dbDataType) // TBD: Still a lot of proper formatting to do
67e9aaa3
GT		 333 {
334 case DB_DATA_TYPE_VARCHAR:
4fdae997 335 s_Field = wxT("%s");
67e9aaa3
GT		 336 break;
337 case DB_DATA_TYPE_INTEGER:
4fdae997 338 s_Field = wxT("%d");
67e9aaa3
GT		 339 break;
340 case DB_DATA_TYPE_FLOAT:
341 if (decimalDigits == 0)
342 decimalDigits = 2;
4fdae997
GT		 343 tempStr = wxT("%");
344 tempStr.Printf(wxT("%s%d.%d"),tempStr.c_str(),columnSize,decimalDigits);
345 s_Field.Printf(wxT("%sf"),tempStr.c_str());
67e9aaa3
GT		 346 break;
347 case DB_DATA_TYPE_DATE:
348 if (i_Nation == 0) // timestamp YYYY-MM-DD HH:MM:SS.SSS (tested for SYBASE)
349 {
4fdae997 350 s_Field = wxT("%04d-%02d-%02d %02d:%02d:%02d.%03d");
67e9aaa3
GT		 351 }
352 if (i_Nation == 1) // European DD.MM.YYYY HH:MM:SS.SSS
353 {
4fdae997 354 s_Field = wxT("%02d.%02d.%04d %02d:%02d:%02d.%03d");
67e9aaa3
GT		 355 }
356 if (i_Nation == 2) // UK DD/MM/YYYY HH:MM:SS.SSS
357 {
4fdae997 358 s_Field = wxT("%02d/%02d/%04d %02d:%02d:%02d.%03d");
67e9aaa3
GT		 359 }
360 if (i_Nation == 3) // International YYYY-MM-DD HH:MM:SS.SSS
361 {
4fdae997 362 s_Field = wxT("%04d-%02d-%02d %02d:%02d:%02d.%03d");
67e9aaa3
GT		 363 }
364 if (i_Nation == 4) // US MM/DD/YYYY HH:MM:SS.SSS
365 {
4fdae997 366 s_Field = wxT("%02d/%02d/%04d %02d:%02d:%02d.%03d");
67e9aaa3
GT		 367 }
368 break;
081eb1b1 369 case DB_DATA_TYPE_BLOB:
bf5423ea 370 s_Field.Printf(wxT("Unable to format(%d)-SQL(%d)"),dbDataType,sqlDataType); //
081eb1b1 371 break;
67e9aaa3 372 default:
3ca6a5f0 373 s_Field.Printf(wxT("Unknown Format(%d)-SQL(%d)"),dbDataType,sqlDataType); //
67e9aaa3
GT		 374 break;
375 };
376 return TRUE;
f6bcfd97 377} // wxDbColFor::Format()
67e9aaa3
GT		 378
379
9556da13 380
942e67c3
GT		 381/********** wxDbColInf Constructor **********/
382wxDbColInf::wxDbColInf()
da99271d
GT		 383{
384 Initialize();
385} // wxDbColInf::wxDbColInf()
386
387
388/********** wxDbColInf Destructor ********/
389wxDbColInf::~wxDbColInf()
390{
391 if (pColFor)
392 delete pColFor;
393 pColFor = NULL;
394} // wxDbColInf::~wxDbColInf()
395
396
397bool wxDbColInf::Initialize()
942e67c3
GT		 398{
399 catalog[0] = 0;
400 schema[0] = 0;
401 tableName[0] = 0;
402 colName[0] = 0;
403 sqlDataType = 0;
404 typeName[0] = 0;
405 columnSize = 0;
406 bufferLength = 0;
407 decimalDigits = 0;
408 numPrecRadix = 0;
409 nullable = 0;
410 remarks[0] = 0;
411 dbDataType = 0;
412 PkCol = 0;
413 PkTableName[0] = 0;
414 FkCol = 0;
415 FkTableName[0] = 0;
416 pColFor = NULL;
942e67c3 417
da99271d
GT		 418 return TRUE;
419} // wxDbColInf::Initialize()
942e67c3
GT		 420
421
422/********** wxDbTableInf Constructor ********/
423wxDbTableInf::wxDbTableInf()
424{
da99271d 425 Initialize();
942e67c3
GT		 426} // wxDbTableInf::wxDbTableInf()
427
428
429/********** wxDbTableInf Constructor ********/
430wxDbTableInf::~wxDbTableInf()
431{
432 if (pColInf)
433 delete [] pColInf;
434 pColInf = NULL;
435} // wxDbTableInf::~wxDbTableInf()
436
437
da99271d
GT		 438bool wxDbTableInf::Initialize()
439{
440 tableName[0] = 0;
441 tableType[0] = 0;
442 tableRemarks[0] = 0;
443 numCols = 0;
444 pColInf = NULL;
445
446 return TRUE;
447} // wxDbTableInf::Initialize()
448
449
942e67c3
GT		 450/********** wxDbInf Constructor *************/
451wxDbInf::wxDbInf()
452{
9556da13
GT		 453 Initialize();
454} // wxDbInf::wxDbInf()
942e67c3
GT		 455
456
457/********** wxDbInf Destructor *************/
458wxDbInf::~wxDbInf()
459{
460 if (pTableInf)
461 delete [] pTableInf;
462 pTableInf = NULL;
463} // wxDbInf::~wxDbInf()
464
465
9556da13 466/********** wxDbInf::Initialize() *************/
da99271d 467bool wxDbInf::Initialize()
9556da13
GT		 468{
469 catalog[0] = 0;
470 schema[0] = 0;
471 numTables = 0;
472 pTableInf = NULL;
da99271d
GT		 473
474 return TRUE;
9556da13
GT		 475} // wxDbInf::Initialize()
476
477
a8aa2258 478/********** wxDb Constructors **********/
9556da13 479wxDb::wxDb(const HENV &aHenv, bool FwdOnlyCursors)
a8aa2258
GT		 480{
481 // Copy the HENV into the db class
482 henv = aHenv;
483 fwdOnlyCursors = FwdOnlyCursors;
da99271d
GT		 484
485 initialize();
a8aa2258
GT		 486} // wxDb::wxDb()
487
488
da99271d
GT		 489/********** PRIVATE! wxDb::initialize PRIVATE! **********/
490/********** wxDb::initialize() **********/
491void wxDb::initialize()
a8aa2258 492/*
eedb1543 493 * Private member function that sets all wxDb member variables to
a8aa2258
GT		 494 * known values at creation of the wxDb
495 */
108106cf 496{
1e92909e
GT		 497 int i;
498
499 fpSqlLog = 0; // Sql Log file pointer
500 sqlLogState = sqlLogOFF; // By default, logging is turned off
501 nTables = 0;
a8aa2258 502 dbmsType = dbmsUNIDENTIFIED;
23f681ec 503
da99271d
GT		 504 wxStrcpy(sqlState,wxEmptyString);
505 wxStrcpy(errorMsg,wxEmptyString);
1e92909e
GT		 506 nativeError = cbErrorMsg = 0;
507 for (i = 0; i < DB_MAX_ERROR_HISTORY; i++)
da99271d 508 wxStrcpy(errorList[i], wxEmptyString);
1e92909e
GT		 509
510 // Init typeInf structures
4fdae997 511 typeInfVarchar.TypeName.Empty();
1e92909e
GT		 512 typeInfVarchar.FsqlType = 0;
513 typeInfVarchar.Precision = 0;
514 typeInfVarchar.CaseSensitive = 0;
515 typeInfVarchar.MaximumScale = 0;
516
4fdae997 517 typeInfInteger.TypeName.Empty();
1e92909e
GT		 518 typeInfInteger.FsqlType = 0;
519 typeInfInteger.Precision = 0;
520 typeInfInteger.CaseSensitive = 0;
521 typeInfInteger.MaximumScale = 0;
522
4fdae997 523 typeInfFloat.TypeName.Empty();
1e92909e
GT		 524 typeInfFloat.FsqlType = 0;
525 typeInfFloat.Precision = 0;
526 typeInfFloat.CaseSensitive = 0;
527 typeInfFloat.MaximumScale = 0;
528
4fdae997 529 typeInfDate.TypeName.Empty();
1e92909e
GT		 530 typeInfDate.FsqlType = 0;
531 typeInfDate.Precision = 0;
532 typeInfDate.CaseSensitive = 0;
533 typeInfDate.MaximumScale = 0;
23f681ec 534
bf5423ea
GT		 535 typeInfBlob.TypeName.Empty();
536 typeInfBlob.FsqlType = 0;
537 typeInfBlob.Precision = 0;
538 typeInfBlob.CaseSensitive = 0;
539 typeInfBlob.MaximumScale = 0;
540
1e92909e
GT		 541 // Error reporting is turned OFF by default
542 silent = TRUE;
23f681ec 543
1e92909e
GT		 544 // Allocate a data source connection handle
545 if (SQLAllocConnect(henv, &hdbc) != SQL_SUCCESS)
546 DispAllErrors(henv);
547
548 // Initialize the db status flag
549 DB_STATUS = 0;
550
551 // Mark database as not open as of yet
552 dbIsOpen = FALSE;
da99271d 553} // wxDb::initialize()
108106cf 554
67e9aaa3 555
942e67c3 556/********** PRIVATE! wxDb::convertUserID PRIVATE! **********/
4fdae997
GT		 557//
558// NOTE: Return value from this function MUST be copied
559// immediately, as the value is not good after
560// this function has left scope.
561//
562const wxChar *wxDb::convertUserID(const wxChar *userID, wxString &UserID)
563{
564 if (userID)
565 {
566 if (!wxStrlen(userID))
567 UserID = uid;
568 else
569 UserID = userID;
570 }
571 else
572 UserID.Empty();
573
574 // dBase does not use user names, and some drivers fail if you try to pass one
575 if (Dbms() == dbmsDBASE)
576 UserID.Empty();
577
578 // Oracle user names may only be in uppercase, so force
579 // the name to uppercase
580 if (Dbms() == dbmsORACLE)
581 UserID = UserID.Upper();
582
583 return UserID.c_str();
584} // wxDb::convertUserID()
585
586
f6bcfd97 587/********** wxDb::Open() **********/
4fdae997 588bool wxDb::Open(const wxString &Dsn, const wxString &Uid, const wxString &AuthStr)
108106cf 589{
4fdae997 590 wxASSERT(Dsn.Length());
1e92909e
GT		 591 dsn = Dsn;
592 uid = Uid;
593 authStr = AuthStr;
108106cf 594
1e92909e 595 RETCODE retcode;
108106cf 596
1e92909e
GT		 597 if (!FwdOnlyCursors())
598 {
599 // Specify that the ODBC cursor library be used, if needed. This must be
600 // specified before the connection is made.
601 retcode = SQLSetConnectOption(hdbc, SQL_ODBC_CURSORS, SQL_CUR_USE_IF_NEEDED);
108106cf 602
6919c53f 603#ifdef DBDEBUG_CONSOLE
1e92909e 604 if (retcode == SQL_SUCCESS)
4fdae997 605 cout << wxT("SQLSetConnectOption(CURSOR_LIB) successful") << endl;
1e92909e 606 else
4fdae997 607 cout << wxT("SQLSetConnectOption(CURSOR_LIB) failed") << endl;
6919c53f 608#endif
1e92909e 609 }
108106cf 610
1e92909e 611 // Connect to the data source
4fdae997
GT		 612 retcode = SQLConnect(hdbc, (UCHAR FAR *) dsn.c_str(), SQL_NTS,
613 (UCHAR FAR *) uid.c_str(), SQL_NTS,
614 (UCHAR FAR *) authStr.c_str(), SQL_NTS);
f6bcfd97 615
a8aa2258 616/*
1e92909e
GT		 617 if (retcode == SQL_SUCCESS_WITH_INFO)
618 DispAllErrors(henv, hdbc);
619 else if (retcode != SQL_SUCCESS)
620 return(DispAllErrors(henv, hdbc));
108106cf 621
081eb1b1
GT		 622 if (retcode == SQL_ERROR)
623 return(DispAllErrors(henv, hdbc));
a8aa2258 624*/
081eb1b1 625 if ((retcode != SQL_SUCCESS) &&
a8aa2258 626 (retcode != SQL_SUCCESS_WITH_INFO))
081eb1b1 627 return(DispAllErrors(henv, hdbc));
a8aa2258 628
a2115c88 629/*
1e92909e
GT		 630 If using Intersolv branded ODBC drivers, this is the place where you would substitute
631 your branded driver license information
a2115c88 632
da99271d
GT		 633 SQLSetConnectOption(hdbc, 1041, (UDWORD) wxEmptyString);
634 SQLSetConnectOption(hdbc, 1042, (UDWORD) wxEmptyString);
a2115c88 635*/
67e9aaa3 636
1e92909e
GT		 637 // Mark database as open
638 dbIsOpen = TRUE;
639
640 // Allocate a statement handle for the database connection
641 if (SQLAllocStmt(hdbc, &hstmt) != SQL_SUCCESS)
642 return(DispAllErrors(henv, hdbc));
643
644 // Set Connection Options
a8aa2258 645 if (!setConnectionOptions())
1e92909e
GT		 646 return(FALSE);
647
648 // Query the data source for inf. about itself
a8aa2258 649 if (!getDbInfo())
1e92909e
GT		 650 return(FALSE);
651
652 // Query the data source regarding data type information
653
654 //
bf5423ea 655 // The way it was determined which SQL data types to use was by calling SQLGetInfo
1e92909e
GT		 656 // for all of the possible SQL data types to see which ones were supported. If
657 // a type is not supported, the SQLFetch() that's called from getDataTypeInfo()
658 // fails with SQL_NO_DATA_FOUND. This is ugly because I'm sure the three SQL data
659 // types I've selected below will not alway's be what we want. These are just
660 // what happened to work against an Oracle 7/Intersolv combination. The following is
661 // a complete list of the results I got back against the Oracle 7 database:
662 //
663 // SQL_BIGINT SQL_NO_DATA_FOUND
664 // SQL_BINARY SQL_NO_DATA_FOUND
665 // SQL_BIT SQL_NO_DATA_FOUND
666 // SQL_CHAR type name = 'CHAR', Precision = 255
667 // SQL_DATE SQL_NO_DATA_FOUND
668 // SQL_DECIMAL type name = 'NUMBER', Precision = 38
669 // SQL_DOUBLE type name = 'NUMBER', Precision = 15
670 // SQL_FLOAT SQL_NO_DATA_FOUND
671 // SQL_INTEGER SQL_NO_DATA_FOUND
672 // SQL_LONGVARBINARY type name = 'LONG RAW', Precision = 2 billion
673 // SQL_LONGVARCHAR type name = 'LONG', Precision = 2 billion
674 // SQL_NUMERIC SQL_NO_DATA_FOUND
675 // SQL_REAL SQL_NO_DATA_FOUND
676 // SQL_SMALLINT SQL_NO_DATA_FOUND
677 // SQL_TIME SQL_NO_DATA_FOUND
678 // SQL_TIMESTAMP type name = 'DATE', Precision = 19
679 // SQL_VARBINARY type name = 'RAW', Precision = 255
680 // SQL_VARCHAR type name = 'VARCHAR2', Precision = 2000
681 // =====================================================================
682 // Results from a Microsoft Access 7.0 db, using a driver from Microsoft
683 //
684 // SQL_VARCHAR type name = 'TEXT', Precision = 255
685 // SQL_TIMESTAMP type name = 'DATETIME'
686 // SQL_DECIMAL SQL_NO_DATA_FOUND
687 // SQL_NUMERIC type name = 'CURRENCY', Precision = 19
688 // SQL_FLOAT SQL_NO_DATA_FOUND
689 // SQL_REAL type name = 'SINGLE', Precision = 7
690 // SQL_DOUBLE type name = 'DOUBLE', Precision = 15
691 // SQL_INTEGER type name = 'LONG', Precision = 10
692
693 // VARCHAR = Variable length character string
3ca6a5f0
BP		 694 if (!getDataTypeInfo(SQL_VARCHAR, typeInfVarchar))
695 if (!getDataTypeInfo(SQL_CHAR, typeInfVarchar))
1e92909e
GT		 696 return(FALSE);
697 else
698 typeInfVarchar.FsqlType = SQL_CHAR;
699 else
700 typeInfVarchar.FsqlType = SQL_VARCHAR;
701
702 // Float
3ca6a5f0 703 if (!getDataTypeInfo(SQL_DOUBLE,typeInfFloat))
3ca6a5f0
BP		 704 if (!getDataTypeInfo(SQL_REAL,typeInfFloat))
705 if (!getDataTypeInfo(SQL_FLOAT,typeInfFloat))
706 if (!getDataTypeInfo(SQL_DECIMAL,typeInfFloat))
707 if (!getDataTypeInfo(SQL_NUMERIC,typeInfFloat))
1e92909e
GT		 708 return(FALSE);
709 else
710 typeInfFloat.FsqlType = SQL_NUMERIC;
711 else
712 typeInfFloat.FsqlType = SQL_DECIMAL;
713 else
714 typeInfFloat.FsqlType = SQL_FLOAT;
715 else
716 typeInfFloat.FsqlType = SQL_REAL;
717 else
718 typeInfFloat.FsqlType = SQL_DOUBLE;
719
720 // Integer
eedb1543 721 if (!getDataTypeInfo(SQL_INTEGER, typeInfInteger))
3ca6a5f0
BP		 722 {
723 // If SQL_INTEGER is not supported, use the floating point
724 // data type to store integers as well as floats
725 if (!getDataTypeInfo(typeInfFloat.FsqlType, typeInfInteger))
1e92909e
GT		 726 return(FALSE);
727 else
728 typeInfInteger.FsqlType = typeInfFloat.FsqlType;
3ca6a5f0 729 }
1e92909e
GT		 730 else
731 typeInfInteger.FsqlType = SQL_INTEGER;
732
733 // Date/Time
734 if (Dbms() != dbmsDBASE)
3ca6a5f0
BP		 735 {
736 if (! getDataTypeInfo(SQL_TIMESTAMP,typeInfDate))
1e92909e
GT		 737 return(FALSE);
738 else
739 typeInfDate.FsqlType = SQL_TIMESTAMP;
740 }
741 else
742 {
3ca6a5f0 743 if (!getDataTypeInfo(SQL_DATE,typeInfDate))
1e92909e
GT		 744 return(FALSE);
745 else
746 typeInfDate.FsqlType = SQL_DATE;
747 }
108106cf 748
bf5423ea
GT		 749 if (!getDataTypeInfo(SQL_LONGVARBINARY, typeInfBlob))
750 {
751 if (!getDataTypeInfo(SQL_VARBINARY,typeInfBlob))
752 return(FALSE);
753 else
4a45223c 754 typeInfBlob.FsqlType = SQL_VARBINARY;
bf5423ea
GT		 755 }
756 else
4a45223c 757 typeInfBlob.FsqlType = SQL_LONGVARBINARY;
bf5423ea
GT		 758
759//typeInfBlob.TypeName = "BLOB";
760
1fc5dd6f 761#ifdef DBDEBUG_CONSOLE
4fdae997
GT		 762 cout << wxT("VARCHAR DATA TYPE: ") << typeInfVarchar.TypeName << endl;
763 cout << wxT("INTEGER DATA TYPE: ") << typeInfInteger.TypeName << endl;
764 cout << wxT("FLOAT DATA TYPE: ") << typeInfFloat.TypeName << endl;
765 cout << wxT("DATE DATA TYPE: ") << typeInfDate.TypeName << endl;
bf5423ea 766 cout << wxT("BLOB DATA TYPE: ") << typeInfBlob.TypeName << endl;
1e92909e 767 cout << endl;
108106cf
JS		 768#endif
769
1e92909e
GT		 770 // Completed Successfully
771 return(TRUE);
108106cf 772
f6bcfd97 773} // wxDb::Open()
108106cf 774
108106cf 775
9556da13
GT		 776bool wxDb::Open(wxDbConnectInf *dbConnectInf)
777{
778 return Open(dbConnectInf->GetDsn(), dbConnectInf->GetUserID(),
779 dbConnectInf->GetPassword());
780} // wxDb::Open()
781
782
a8aa2258
GT		 783bool wxDb::Open(wxDb *copyDb)
784{
4fdae997
GT		 785 dsn = copyDb->GetDatasourceName();
786 uid = copyDb->GetUsername();
787 authStr = copyDb->GetPassword();
a8aa2258
GT		 788
789 RETCODE retcode;
790
791 if (!FwdOnlyCursors())
792 {
793 // Specify that the ODBC cursor library be used, if needed. This must be
794 // specified before the connection is made.
795 retcode = SQLSetConnectOption(hdbc, SQL_ODBC_CURSORS, SQL_CUR_USE_IF_NEEDED);
796
797#ifdef DBDEBUG_CONSOLE
798 if (retcode == SQL_SUCCESS)
4fdae997 799 cout << wxT("SQLSetConnectOption(CURSOR_LIB) successful") << endl;
a8aa2258 800 else
4fdae997 801 cout << wxT("SQLSetConnectOption(CURSOR_LIB) failed") << endl;
a8aa2258
GT		 802#endif
803 }
804
805 // Connect to the data source
4fdae997
GT		 806 retcode = SQLConnect(hdbc, (UCHAR FAR *) dsn.c_str(), SQL_NTS,
807 (UCHAR FAR *) uid.c_str(), SQL_NTS,
808 (UCHAR FAR *) authStr.c_str(), SQL_NTS);
a8aa2258 809
081eb1b1
GT		 810 if (retcode == SQL_ERROR)
811 return(DispAllErrors(henv, hdbc));
a8aa2258
GT		 812
813/*
814 If using Intersolv branded ODBC drivers, this is the place where you would substitute
815 your branded driver license information
816
da99271d
GT		 817 SQLSetConnectOption(hdbc, 1041, (UDWORD) wxEmptyString);
818 SQLSetConnectOption(hdbc, 1042, (UDWORD) wxEmptyString);
a8aa2258
GT		 819*/
820
821 // Mark database as open
822 dbIsOpen = TRUE;
823
824 // Allocate a statement handle for the database connection
825 if (SQLAllocStmt(hdbc, &hstmt) != SQL_SUCCESS)
826 return(DispAllErrors(henv, hdbc));
827
828 // Set Connection Options
829 if (!setConnectionOptions())
830 return(FALSE);
831
832 // Instead of Querying the data source for info about itself, it can just be copied
833 // from the wxDb instance that was passed in (copyDb).
834 wxStrcpy(dbInf.serverName,copyDb->dbInf.serverName);
835 wxStrcpy(dbInf.databaseName,copyDb->dbInf.databaseName);
836 wxStrcpy(dbInf.dbmsName,copyDb->dbInf.dbmsName);
837 wxStrcpy(dbInf.dbmsVer,copyDb->dbInf.dbmsVer);
838 dbInf.maxConnections = copyDb->dbInf.maxConnections;
839 dbInf.maxStmts = copyDb->dbInf.maxStmts;
840 wxStrcpy(dbInf.driverName,copyDb->dbInf.driverName);
841 wxStrcpy(dbInf.odbcVer,copyDb->dbInf.odbcVer);
842 wxStrcpy(dbInf.drvMgrOdbcVer,copyDb->dbInf.drvMgrOdbcVer);
843 wxStrcpy(dbInf.driverVer,copyDb->dbInf.driverVer);
844 dbInf.apiConfLvl = copyDb->dbInf.apiConfLvl;
845 dbInf.cliConfLvl = copyDb->dbInf.cliConfLvl;
846 dbInf.sqlConfLvl = copyDb->dbInf.sqlConfLvl;
847 wxStrcpy(dbInf.outerJoins,copyDb->dbInf.outerJoins);
848 wxStrcpy(dbInf.procedureSupport,copyDb->dbInf.procedureSupport);
849 wxStrcpy(dbInf.accessibleTables,copyDb->dbInf.accessibleTables);
850 dbInf.cursorCommitBehavior = copyDb->dbInf.cursorCommitBehavior;
851 dbInf.cursorRollbackBehavior = copyDb->dbInf.cursorRollbackBehavior;
852 dbInf.supportNotNullClause = copyDb->dbInf.supportNotNullClause;
853 wxStrcpy(dbInf.supportIEF,copyDb->dbInf.supportIEF);
854 dbInf.txnIsolation = copyDb->dbInf.txnIsolation;
855 dbInf.txnIsolationOptions = copyDb->dbInf.txnIsolationOptions;
856 dbInf.fetchDirections = copyDb->dbInf.fetchDirections;
857 dbInf.lockTypes = copyDb->dbInf.lockTypes;
858 dbInf.posOperations = copyDb->dbInf.posOperations;
859 dbInf.posStmts = copyDb->dbInf.posStmts;
860 dbInf.scrollConcurrency = copyDb->dbInf.scrollConcurrency;
861 dbInf.scrollOptions = copyDb->dbInf.scrollOptions;
862 dbInf.staticSensitivity = copyDb->dbInf.staticSensitivity;
863 dbInf.txnCapable = copyDb->dbInf.txnCapable;
864 dbInf.loginTimeout = copyDb->dbInf.loginTimeout;
865
866 // VARCHAR = Variable length character string
4fdae997
GT		 867 typeInfVarchar.FsqlType = copyDb->typeInfVarchar.FsqlType;
868 typeInfVarchar.TypeName = copyDb->typeInfVarchar.TypeName;
d8a0a1c9
GT		 869 typeInfVarchar.Precision = copyDb->typeInfVarchar.Precision;
870 typeInfVarchar.CaseSensitive = copyDb->typeInfVarchar.CaseSensitive;
871 typeInfVarchar.MaximumScale = copyDb->typeInfVarchar.MaximumScale;
a8aa2258
GT		 872
873 // Float
4fdae997
GT		 874 typeInfFloat.FsqlType = copyDb->typeInfFloat.FsqlType;
875 typeInfFloat.TypeName = copyDb->typeInfFloat.TypeName;
d8a0a1c9
GT		 876 typeInfFloat.Precision = copyDb->typeInfFloat.Precision;
877 typeInfFloat.CaseSensitive = copyDb->typeInfFloat.CaseSensitive;
878 typeInfFloat.MaximumScale = copyDb->typeInfFloat.MaximumScale;
a8aa2258
GT		 879
880 // Integer
4fdae997
GT		 881 typeInfInteger.FsqlType = copyDb->typeInfInteger.FsqlType;
882 typeInfInteger.TypeName = copyDb->typeInfInteger.TypeName;
d8a0a1c9
GT		 883 typeInfInteger.Precision = copyDb->typeInfInteger.Precision;
884 typeInfInteger.CaseSensitive = copyDb->typeInfInteger.CaseSensitive;
885 typeInfInteger.MaximumScale = copyDb->typeInfInteger.MaximumScale;
a8aa2258
GT		 886
887 // Date/Time
4fdae997
GT		 888 typeInfDate.FsqlType = copyDb->typeInfDate.FsqlType;
889 typeInfDate.TypeName = copyDb->typeInfDate.TypeName;
d8a0a1c9
GT		 890 typeInfDate.Precision = copyDb->typeInfDate.Precision;
891 typeInfDate.CaseSensitive = copyDb->typeInfDate.CaseSensitive;
892 typeInfDate.MaximumScale = copyDb->typeInfDate.MaximumScale;
a8aa2258 893
bf5423ea
GT		 894 // Blob
895 typeInfBlob.FsqlType = copyDb->typeInfBlob.FsqlType;
896 typeInfBlob.TypeName = copyDb->typeInfBlob.TypeName;
897 typeInfBlob.Precision = copyDb->typeInfBlob.Precision;
898 typeInfBlob.CaseSensitive = copyDb->typeInfBlob.CaseSensitive;
899 typeInfBlob.MaximumScale = copyDb->typeInfBlob.MaximumScale;
900
a8aa2258 901#ifdef DBDEBUG_CONSOLE
4fdae997
GT		 902 cout << wxT("VARCHAR DATA TYPE: ") << typeInfVarchar.TypeName << endl;
903 cout << wxT("INTEGER DATA TYPE: ") << typeInfInteger.TypeName << endl;
904 cout << wxT("FLOAT DATA TYPE: ") << typeInfFloat.TypeName << endl;
905 cout << wxT("DATE DATA TYPE: ") << typeInfDate.TypeName << endl;
bf5423ea 906 cout << wxT("BLOB DATA TYPE: ") << typeInfBlob.TypeName << endl;
a8aa2258
GT		 907 cout << endl;
908#endif
909
910 // Completed Successfully
911 return(TRUE);
912} // wxDb::Open() 2
913
914
f6bcfd97
BP		 915/********** wxDb::setConnectionOptions() **********/
916bool wxDb::setConnectionOptions(void)
67e9aaa3
GT		 917/*
918 * NOTE: The Intersolv/Oracle 7 driver was "Not Capable" of setting the login timeout.
919 */
108106cf 920{
a8aa2258
GT		 921 SWORD cb;
922
923 // I need to get the DBMS name here, because some of the connection options
924 // are database specific and need to call the Dbms() function.
925 if (SQLGetInfo(hdbc, SQL_DBMS_NAME, (UCHAR*) dbInf.dbmsName, 40, &cb) != SQL_SUCCESS)
926 return(DispAllErrors(henv, hdbc));
927
1e92909e
GT		 928 SQLSetConnectOption(hdbc, SQL_AUTOCOMMIT, SQL_AUTOCOMMIT_OFF);
929 SQLSetConnectOption(hdbc, SQL_OPT_TRACE, SQL_OPT_TRACE_OFF);
081eb1b1 930// SQLSetConnectOption(hdbc, SQL_TXN_ISOLATION, SQL_TXN_READ_COMMITTED); // No dirty reads
a8aa2258
GT		 931
932 // By default, MS Sql Server closes cursors on commit and rollback. The following
933 // call to SQLSetConnectOption() is needed to force SQL Server to preserve cursors
934 // after a transaction. This is a driver specific option and is not part of the
935 // ODBC standard. Note: this behavior is specific to the ODBC interface to SQL Server.
936 // The database settings don't have any effect one way or the other.
937 if (Dbms() == dbmsMS_SQL_SERVER)
938 {
939 const long SQL_PRESERVE_CURSORS = 1204L;
940 const long SQL_PC_ON = 1L;
941 SQLSetConnectOption(hdbc, SQL_PRESERVE_CURSORS, SQL_PC_ON);
942 }
108106cf 943
1e92909e 944 // Display the connection options to verify them
1fc5dd6f 945#ifdef DBDEBUG_CONSOLE
1e92909e 946 long l;
4fdae997 947 cout << wxT("****** CONNECTION OPTIONS ******") << endl;
23f681ec 948
1e92909e
GT		 949 if (SQLGetConnectOption(hdbc, SQL_AUTOCOMMIT, &l) != SQL_SUCCESS)
950 return(DispAllErrors(henv, hdbc));
4fdae997 951 cout << wxT("AUTOCOMMIT: ") << (l == SQL_AUTOCOMMIT_OFF ? "OFF" : "ON") << endl;
23f681ec 952
1e92909e
GT		 953 if (SQLGetConnectOption(hdbc, SQL_ODBC_CURSORS, &l) != SQL_SUCCESS)
954 return(DispAllErrors(henv, hdbc));
4fdae997 955 cout << wxT("ODBC CURSORS: ");
1e92909e
GT		 956 switch(l)
957 {
958 case(SQL_CUR_USE_IF_NEEDED):
4fdae997 959 cout << wxT("SQL_CUR_USE_IF_NEEDED");
1e92909e
GT		 960 break;
961 case(SQL_CUR_USE_ODBC):
4fdae997 962 cout << wxT("SQL_CUR_USE_ODBC");
1e92909e
GT		 963 break;
964 case(SQL_CUR_USE_DRIVER):
4fdae997 965 cout << wxT("SQL_CUR_USE_DRIVER");
1e92909e
GT		 966 break;
967 }
968 cout << endl;
23f681ec 969
1e92909e
GT		 970 if (SQLGetConnectOption(hdbc, SQL_OPT_TRACE, &l) != SQL_SUCCESS)
971 return(DispAllErrors(henv, hdbc));
4fdae997 972 cout << wxT("TRACING: ") << (l == SQL_OPT_TRACE_OFF ? wxT("OFF") : wxT("ON")) << endl;
1e92909e
GT		 973
974 cout << endl;
108106cf
JS		 975#endif
976
1e92909e
GT		 977 // Completed Successfully
978 return(TRUE);
108106cf 979
f6bcfd97 980} // wxDb::setConnectionOptions()
108106cf 981
67e9aaa3 982
f6bcfd97
BP		 983/********** wxDb::getDbInfo() **********/
984bool wxDb::getDbInfo(void)
108106cf 985{
1e92909e
GT		 986 SWORD cb;
987 RETCODE retcode;
988
989 if (SQLGetInfo(hdbc, SQL_SERVER_NAME, (UCHAR*) dbInf.serverName, 80, &cb) != SQL_SUCCESS)
990 return(DispAllErrors(henv, hdbc));
108106cf 991
1e92909e
GT		 992 if (SQLGetInfo(hdbc, SQL_DATABASE_NAME, (UCHAR*) dbInf.databaseName, 128, &cb) != SQL_SUCCESS)
993 return(DispAllErrors(henv, hdbc));
108106cf 994
1e92909e
GT		 995 if (SQLGetInfo(hdbc, SQL_DBMS_NAME, (UCHAR*) dbInf.dbmsName, 40, &cb) != SQL_SUCCESS)
996 return(DispAllErrors(henv, hdbc));
108106cf 997
1e92909e
GT		 998 // 16-Mar-1999
999 // After upgrading to MSVC6, the original 20 char buffer below was insufficient,
1000 // causing database connectivity to fail in some cases.
1001 retcode = SQLGetInfo(hdbc, SQL_DBMS_VER, (UCHAR*) dbInf.dbmsVer, 64, &cb);
108106cf 1002
1e92909e
GT		 1003 if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO )
1004 return(DispAllErrors(henv, hdbc));
108106cf 1005
1e92909e
GT		 1006 if (SQLGetInfo(hdbc, SQL_ACTIVE_CONNECTIONS, (UCHAR*) &dbInf.maxConnections, sizeof(dbInf.maxConnections), &cb) != SQL_SUCCESS)
1007 return(DispAllErrors(henv, hdbc));
108106cf 1008
1e92909e
GT		 1009 if (SQLGetInfo(hdbc, SQL_ACTIVE_STATEMENTS, (UCHAR*) &dbInf.maxStmts, sizeof(dbInf.maxStmts), &cb) != SQL_SUCCESS)
1010 return(DispAllErrors(henv, hdbc));
108106cf 1011
1e92909e
GT		 1012 if (SQLGetInfo(hdbc, SQL_DRIVER_NAME, (UCHAR*) dbInf.driverName, 40, &cb) != SQL_SUCCESS)
1013 return(DispAllErrors(henv, hdbc));
108106cf 1014
1e92909e
GT		 1015 if (SQLGetInfo(hdbc, SQL_DRIVER_ODBC_VER, (UCHAR*) dbInf.odbcVer, 60, &cb) == SQL_ERROR)
1016 return(DispAllErrors(henv, hdbc));
108106cf 1017
1e92909e
GT		 1018 retcode = SQLGetInfo(hdbc, SQL_ODBC_VER, (UCHAR*) dbInf.drvMgrOdbcVer, 60, &cb);
1019 if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO)
1020 return(DispAllErrors(henv, hdbc));
108106cf 1021
1e92909e
GT		 1022 if (SQLGetInfo(hdbc, SQL_DRIVER_VER, (UCHAR*) dbInf.driverVer, 60, &cb) == SQL_ERROR)
1023 return(DispAllErrors(henv, hdbc));
108106cf 1024
1e92909e
GT		 1025 if (SQLGetInfo(hdbc, SQL_ODBC_API_CONFORMANCE, (UCHAR*) &dbInf.apiConfLvl, sizeof(dbInf.apiConfLvl), &cb) != SQL_SUCCESS)
1026 return(DispAllErrors(henv, hdbc));
108106cf 1027
1e92909e 1028 if (SQLGetInfo(hdbc, SQL_ODBC_SAG_CLI_CONFORMANCE, (UCHAR*) &dbInf.cliConfLvl, sizeof(dbInf.cliConfLvl), &cb) != SQL_SUCCESS)
a8aa2258
GT		 1029// return(DispAllErrors(henv, hdbc));
1030 {
1031 // Not all drivers support this call - Nick Gorham(unixODBC)
1032 dbInf.cliConfLvl = 0;
1033 }
108106cf 1034
1e92909e
GT		 1035 if (SQLGetInfo(hdbc, SQL_ODBC_SQL_CONFORMANCE, (UCHAR*) &dbInf.sqlConfLvl, sizeof(dbInf.sqlConfLvl), &cb) != SQL_SUCCESS)
1036 return(DispAllErrors(henv, hdbc));
108106cf 1037
1e92909e
GT		 1038 if (SQLGetInfo(hdbc, SQL_OUTER_JOINS, (UCHAR*) dbInf.outerJoins, 2, &cb) != SQL_SUCCESS)
1039 return(DispAllErrors(henv, hdbc));
108106cf 1040
1e92909e
GT		 1041 if (SQLGetInfo(hdbc, SQL_PROCEDURES, (UCHAR*) dbInf.procedureSupport, 2, &cb) != SQL_SUCCESS)
1042 return(DispAllErrors(henv, hdbc));
a8aa2258 1043
3ca6a5f0
BP		 1044 if (SQLGetInfo(hdbc, SQL_ACCESSIBLE_TABLES, (UCHAR*) dbInf.accessibleTables, 2, &cb) != SQL_SUCCESS)
1045 return(DispAllErrors(henv, hdbc));
a8aa2258 1046
1e92909e
GT		 1047 if (SQLGetInfo(hdbc, SQL_CURSOR_COMMIT_BEHAVIOR, (UCHAR*) &dbInf.cursorCommitBehavior, sizeof(dbInf.cursorCommitBehavior), &cb) != SQL_SUCCESS)
1048 return(DispAllErrors(henv, hdbc));
108106cf 1049
1e92909e
GT		 1050 if (SQLGetInfo(hdbc, SQL_CURSOR_ROLLBACK_BEHAVIOR, (UCHAR*) &dbInf.cursorRollbackBehavior, sizeof(dbInf.cursorRollbackBehavior), &cb) != SQL_SUCCESS)
1051 return(DispAllErrors(henv, hdbc));
108106cf 1052
1e92909e
GT		 1053 if (SQLGetInfo(hdbc, SQL_NON_NULLABLE_COLUMNS, (UCHAR*) &dbInf.supportNotNullClause, sizeof(dbInf.supportNotNullClause), &cb) != SQL_SUCCESS)
1054 return(DispAllErrors(henv, hdbc));
108106cf 1055
1e92909e
GT		 1056 if (SQLGetInfo(hdbc, SQL_ODBC_SQL_OPT_IEF, (UCHAR*) dbInf.supportIEF, 2, &cb) != SQL_SUCCESS)
1057 return(DispAllErrors(henv, hdbc));
108106cf 1058
1e92909e
GT		 1059 if (SQLGetInfo(hdbc, SQL_DEFAULT_TXN_ISOLATION, (UCHAR*) &dbInf.txnIsolation, sizeof(dbInf.txnIsolation), &cb) != SQL_SUCCESS)
1060 return(DispAllErrors(henv, hdbc));
108106cf 1061
1e92909e
GT		 1062 if (SQLGetInfo(hdbc, SQL_TXN_ISOLATION_OPTION, (UCHAR*) &dbInf.txnIsolationOptions, sizeof(dbInf.txnIsolationOptions), &cb) != SQL_SUCCESS)
1063 return(DispAllErrors(henv, hdbc));
108106cf 1064
1e92909e
GT		 1065 if (SQLGetInfo(hdbc, SQL_FETCH_DIRECTION, (UCHAR*) &dbInf.fetchDirections, sizeof(dbInf.fetchDirections), &cb) != SQL_SUCCESS)
1066 return(DispAllErrors(henv, hdbc));
108106cf 1067
1e92909e
GT		 1068 if (SQLGetInfo(hdbc, SQL_LOCK_TYPES, (UCHAR*) &dbInf.lockTypes, sizeof(dbInf.lockTypes), &cb) != SQL_SUCCESS)
1069 return(DispAllErrors(henv, hdbc));
108106cf 1070
1e92909e
GT		 1071 if (SQLGetInfo(hdbc, SQL_POS_OPERATIONS, (UCHAR*) &dbInf.posOperations, sizeof(dbInf.posOperations), &cb) != SQL_SUCCESS)
1072 return(DispAllErrors(henv, hdbc));
108106cf 1073
1e92909e
GT		 1074 if (SQLGetInfo(hdbc, SQL_POSITIONED_STATEMENTS, (UCHAR*) &dbInf.posStmts, sizeof(dbInf.posStmts), &cb) != SQL_SUCCESS)
1075 return(DispAllErrors(henv, hdbc));
108106cf 1076
1e92909e
GT		 1077 if (SQLGetInfo(hdbc, SQL_SCROLL_CONCURRENCY, (UCHAR*) &dbInf.scrollConcurrency, sizeof(dbInf.scrollConcurrency), &cb) != SQL_SUCCESS)
1078 return(DispAllErrors(henv, hdbc));
108106cf 1079
1e92909e
GT		 1080 if (SQLGetInfo(hdbc, SQL_SCROLL_OPTIONS, (UCHAR*) &dbInf.scrollOptions, sizeof(dbInf.scrollOptions), &cb) != SQL_SUCCESS)
1081 return(DispAllErrors(henv, hdbc));
108106cf 1082
1e92909e
GT		 1083 if (SQLGetInfo(hdbc, SQL_STATIC_SENSITIVITY, (UCHAR*) &dbInf.staticSensitivity, sizeof(dbInf.staticSensitivity), &cb) != SQL_SUCCESS)
1084 return(DispAllErrors(henv, hdbc));
108106cf 1085
1e92909e
GT		 1086 if (SQLGetInfo(hdbc, SQL_TXN_CAPABLE, (UCHAR*) &dbInf.txnCapable, sizeof(dbInf.txnCapable), &cb) != SQL_SUCCESS)
1087 return(DispAllErrors(henv, hdbc));
108106cf 1088
1e92909e
GT		 1089 if (SQLGetInfo(hdbc, SQL_LOGIN_TIMEOUT, (UCHAR*) &dbInf.loginTimeout, sizeof(dbInf.loginTimeout), &cb) != SQL_SUCCESS)
1090 return(DispAllErrors(henv, hdbc));
108106cf 1091
1fc5dd6f 1092#ifdef DBDEBUG_CONSOLE
4fdae997
GT		 1093 cout << wxT("***** DATA SOURCE INFORMATION *****") << endl;
1094 cout << wxT(wxT("SERVER Name: ") << dbInf.serverName << endl;
1095 cout << wxT("DBMS Name: ") << dbInf.dbmsName << wxT("; DBMS Version: ") << dbInf.dbmsVer << endl;
1096 cout << wxT("ODBC Version: ") << dbInf.odbcVer << wxT("; Driver Version: ") << dbInf.driverVer << endl;
1e92909e 1097
4fdae997 1098 cout << wxT("API Conf. Level: ");
1e92909e
GT		 1099 switch(dbInf.apiConfLvl)
1100 {
4fdae997
GT		 1101 case SQL_OAC_NONE: cout << wxT("None"); break;
1102 case SQL_OAC_LEVEL1: cout << wxT("Level 1"); break;
1103 case SQL_OAC_LEVEL2: cout << wxT("Level 2"); break;
1e92909e
GT		 1104 }
1105 cout << endl;
1106
4fdae997 1107 cout << wxT("SAG CLI Conf. Level: ");
1e92909e
GT		 1108 switch(dbInf.cliConfLvl)
1109 {
4fdae997
GT		 1110 case SQL_OSCC_NOT_COMPLIANT: cout << wxT("Not Compliant"); break;
1111 case SQL_OSCC_COMPLIANT: cout << wxT("Compliant"); break;
1e92909e
GT		 1112 }
1113 cout << endl;
1114
4fdae997 1115 cout << wxT("SQL Conf. Level: ");
1e92909e
GT		 1116 switch(dbInf.sqlConfLvl)
1117 {
4fdae997
GT		 1118 case SQL_OSC_MINIMUM: cout << wxT("Minimum Grammar"); break;
1119 case SQL_OSC_CORE: cout << wxT("Core Grammar"); break;
1120 case SQL_OSC_EXTENDED: cout << wxT("Extended Grammar"); break;
1e92909e
GT		 1121 }
1122 cout << endl;
1123
4fdae997
GT		 1124 cout << wxT("Max. Connections: ") << dbInf.maxConnections << endl;
1125 cout << wxT("Outer Joins: ") << dbInf.outerJoins << endl;
1126 cout << wxT("Support for Procedures: ") << dbInf.procedureSupport << endl;
1127 cout << wxT("All tables accessible : ") << dbInf.accessibleTables << endl;
1128 cout << wxT("Cursor COMMIT Behavior: ");
1e92909e
GT		 1129 switch(dbInf.cursorCommitBehavior)
1130 {
4fdae997
GT		 1131 case SQL_CB_DELETE: cout << wxT("Delete cursors"); break;
1132 case SQL_CB_CLOSE: cout << wxT("Close cursors"); break;
1133 case SQL_CB_PRESERVE: cout << wxT("Preserve cursors"); break;
1e92909e
GT		 1134 }
1135 cout << endl;
1136
4fdae997 1137 cout << wxT("Cursor ROLLBACK Behavior: ");
1e92909e
GT		 1138 switch(dbInf.cursorRollbackBehavior)
1139 {
4fdae997
GT		 1140 case SQL_CB_DELETE: cout << wxT("Delete cursors"); break;
1141 case SQL_CB_CLOSE: cout << wxT("Close cursors"); break;
1142 case SQL_CB_PRESERVE: cout << wxT("Preserve cursors"); break;
1e92909e
GT		 1143 }
1144 cout << endl;
1145
4fdae997 1146 cout << wxT("Support NOT NULL clause: ");
1e92909e
GT		 1147 switch(dbInf.supportNotNullClause)
1148 {
4fdae997
GT		 1149 case SQL_NNC_NULL: cout << wxT("No"); break;
1150 case SQL_NNC_NON_NULL: cout << wxT("Yes"); break;
1e92909e
GT		 1151 }
1152 cout << endl;
1153
4fdae997
GT		 1154 cout << wxT("Support IEF (Ref. Integrity): ") << dbInf.supportIEF << endl;
1155 cout << wxT("Login Timeout: ") << dbInf.loginTimeout << endl;
1e92909e 1156
4fdae997 1157 cout << endl << endl << wxT("more ...") << endl;
1e92909e
GT		 1158 getchar();
1159
4fdae997 1160 cout << wxT("Default Transaction Isolation: ";
1e92909e
GT		 1161 switch(dbInf.txnIsolation)
1162 {
4fdae997
GT		 1163 case SQL_TXN_READ_UNCOMMITTED: cout << wxT("Read Uncommitted"); break;
1164 case SQL_TXN_READ_COMMITTED: cout << wxT("Read Committed"); break;
1165 case SQL_TXN_REPEATABLE_READ: cout << wxT("Repeatable Read"); break;
1166 case SQL_TXN_SERIALIZABLE: cout << wxT("Serializable"); break;
108106cf 1167#ifdef ODBC_V20
4fdae997 1168 case SQL_TXN_VERSIONING: cout << wxT("Versioning"); break;
108106cf 1169#endif
1e92909e
GT		 1170 }
1171 cout << endl;
1172
4fdae997 1173 cout << wxT("Transaction Isolation Options: ");
1e92909e 1174 if (dbInf.txnIsolationOptions & SQL_TXN_READ_UNCOMMITTED)
4fdae997 1175 cout << wxT("Read Uncommitted, ");
1e92909e 1176 if (dbInf.txnIsolationOptions & SQL_TXN_READ_COMMITTED)
4fdae997 1177 cout << wxT("Read Committed, ");
1e92909e 1178 if (dbInf.txnIsolationOptions & SQL_TXN_REPEATABLE_READ)
4fdae997 1179 cout << wxT("Repeatable Read, ");
1e92909e 1180 if (dbInf.txnIsolationOptions & SQL_TXN_SERIALIZABLE)
4fdae997 1181 cout << wxT("Serializable, ");
108106cf 1182#ifdef ODBC_V20
1e92909e 1183 if (dbInf.txnIsolationOptions & SQL_TXN_VERSIONING)
4fdae997 1184 cout << wxT("Versioning");
108106cf 1185#endif
1e92909e
GT		 1186 cout << endl;
1187
4fdae997 1188 cout << wxT("Fetch Directions Supported:") << endl << wxT(" ");
1e92909e 1189 if (dbInf.fetchDirections & SQL_FD_FETCH_NEXT)
4fdae997 1190 cout << wxT("Next, ");
1e92909e 1191 if (dbInf.fetchDirections & SQL_FD_FETCH_PRIOR)
4fdae997 1192 cout << wxT("Prev, ");
1e92909e 1193 if (dbInf.fetchDirections & SQL_FD_FETCH_FIRST)
4fdae997 1194 cout << wxT("First, ");
1e92909e 1195 if (dbInf.fetchDirections & SQL_FD_FETCH_LAST)
4fdae997 1196 cout << wxT("Last, ");
1e92909e 1197 if (dbInf.fetchDirections & SQL_FD_FETCH_ABSOLUTE)
4fdae997 1198 cout << wxT("Absolute, ");
1e92909e 1199 if (dbInf.fetchDirections & SQL_FD_FETCH_RELATIVE)
4fdae997 1200 cout << wxT("Relative, ");
108106cf 1201#ifdef ODBC_V20
1e92909e 1202 if (dbInf.fetchDirections & SQL_FD_FETCH_RESUME)
4fdae997 1203 cout << wxT("Resume, ");
108106cf 1204#endif
1e92909e 1205 if (dbInf.fetchDirections & SQL_FD_FETCH_BOOKMARK)
4fdae997 1206 cout << wxT("Bookmark");
1e92909e
GT		 1207 cout << endl;
1208
4fdae997 1209 cout << wxT("Lock Types Supported (SQLSetPos): ");
1e92909e 1210 if (dbInf.lockTypes & SQL_LCK_NO_CHANGE)
4fdae997 1211 cout << wxT("No Change, ");
1e92909e 1212 if (dbInf.lockTypes & SQL_LCK_EXCLUSIVE)
4fdae997 1213 cout << wxT("Exclusive, ");
1e92909e 1214 if (dbInf.lockTypes & SQL_LCK_UNLOCK)
4fdae997 1215 cout << wxT("UnLock");
1e92909e
GT		 1216 cout << endl;
1217
4fdae997 1218 cout << wxT("Position Operations Supported (SQLSetPos): ");
1e92909e 1219 if (dbInf.posOperations & SQL_POS_POSITION)
4fdae997 1220 cout << wxT("Position, ");
1e92909e 1221 if (dbInf.posOperations & SQL_POS_REFRESH)
4fdae997 1222 cout << wxT("Refresh, ");
1e92909e 1223 if (dbInf.posOperations & SQL_POS_UPDATE)
4fdae997 1224 cout << wxT("Upd, "));
1e92909e 1225 if (dbInf.posOperations & SQL_POS_DELETE)
4fdae997 1226 cout << wxT("Del, ");
1e92909e 1227 if (dbInf.posOperations & SQL_POS_ADD)
4fdae997 1228 cout << wxT("Add");
1e92909e
GT		 1229 cout << endl;
1230
4fdae997 1231 cout << wxT("Positioned Statements Supported: ");
1e92909e 1232 if (dbInf.posStmts & SQL_PS_POSITIONED_DELETE)
4fdae997 1233 cout << wxT("Pos delete, ");
1e92909e 1234 if (dbInf.posStmts & SQL_PS_POSITIONED_UPDATE)
4fdae997 1235 cout << wxT("Pos update, ");
1e92909e 1236 if (dbInf.posStmts & SQL_PS_SELECT_FOR_UPDATE)
4fdae997 1237 cout << wxT("Select for update");
1e92909e
GT		 1238 cout << endl;
1239
4fdae997 1240 cout << wxT("Scroll Concurrency: ");
1e92909e 1241 if (dbInf.scrollConcurrency & SQL_SCCO_READ_ONLY)
4fdae997 1242 cout << wxT("Read Only, ");
1e92909e 1243 if (dbInf.scrollConcurrency & SQL_SCCO_LOCK)
4fdae997 1244 cout << wxT("Lock, ");
1e92909e 1245 if (dbInf.scrollConcurrency & SQL_SCCO_OPT_ROWVER)
4fdae997 1246 cout << wxT("Opt. Rowver, ");
1e92909e 1247 if (dbInf.scrollConcurrency & SQL_SCCO_OPT_VALUES)
4fdae997 1248 cout << wxT("Opt. Values");
1e92909e
GT		 1249 cout << endl;
1250
4fdae997 1251 cout << wxT("Scroll Options: ");
1e92909e 1252 if (dbInf.scrollOptions & SQL_SO_FORWARD_ONLY)
4fdae997 1253 cout << wxT("Fwd Only, ");
1e92909e 1254 if (dbInf.scrollOptions & SQL_SO_STATIC)
4fdae997 1255 cout << wxT("Static, ");
1e92909e 1256 if (dbInf.scrollOptions & SQL_SO_KEYSET_DRIVEN)
4fdae997 1257 cout << wxT("Keyset Driven, ");
1e92909e 1258 if (dbInf.scrollOptions & SQL_SO_DYNAMIC)
4fdae997 1259 cout << wxT("Dynamic, ");
1e92909e 1260 if (dbInf.scrollOptions & SQL_SO_MIXED)
4fdae997 1261 cout << wxT("Mixed");
1e92909e
GT		 1262 cout << endl;
1263
4fdae997 1264 cout << wxT("Static Sensitivity: ");
1e92909e 1265 if (dbInf.staticSensitivity & SQL_SS_ADDITIONS)
4fdae997 1266 cout << wxT("Additions, ");
1e92909e 1267 if (dbInf.staticSensitivity & SQL_SS_DELETIONS)
4fdae997 1268 cout << wxT("Deletions, ");
1e92909e 1269 if (dbInf.staticSensitivity & SQL_SS_UPDATES)
4fdae997 1270 cout << wxT("Updates");
1e92909e
GT		 1271 cout << endl;
1272
4fdae997 1273 cout << wxT("Transaction Capable?: ");
1e92909e
GT		 1274 switch(dbInf.txnCapable)
1275 {
4fdae997
GT		 1276 case SQL_TC_NONE: cout << wxT("No"); break;
1277 case SQL_TC_DML: cout << wxT("DML Only"); break;
1278 case SQL_TC_DDL_COMMIT: cout << wxT("DDL Commit"); break;
1279 case SQL_TC_DDL_IGNORE: cout << wxT("DDL Ignore"); break;
1280 case SQL_TC_ALL: cout << wxT("DDL & DML"); break;
1e92909e
GT		 1281 }
1282 cout << endl;
1283
1284 cout << endl;
108106cf
JS		 1285#endif
1286
1e92909e
GT		 1287 // Completed Successfully
1288 return(TRUE);
108106cf 1289
f6bcfd97 1290} // wxDb::getDbInfo()
108106cf 1291
67e9aaa3 1292
f6bcfd97
BP		 1293/********** wxDb::getDataTypeInfo() **********/
1294bool wxDb::getDataTypeInfo(SWORD fSqlType, wxDbSqlTypeInfo &structSQLTypeInfo)
108106cf 1295{
67e9aaa3
GT		 1296/*
1297 * fSqlType will be something like SQL_VARCHAR. This parameter determines
1298 * the data type inf. is gathered for.
1299 *
f6bcfd97 1300 * wxDbSqlTypeInfo is a structure that is filled in with data type information,
67e9aaa3 1301 */
1e92909e 1302 RETCODE retcode;
f6bcfd97 1303 SDWORD cbRet;
eedb1543 1304
1e92909e
GT		 1305 // Get information about the data type specified
1306 if (SQLGetTypeInfo(hstmt, fSqlType) != SQL_SUCCESS)
1307 return(DispAllErrors(henv, hdbc, hstmt));
1308 // Fetch the record
1309 if ((retcode = SQLFetch(hstmt)) != SQL_SUCCESS)
3ca6a5f0 1310 {
1fc5dd6f 1311#ifdef DBDEBUG_CONSOLE
3ca6a5f0 1312 if (retcode == SQL_NO_DATA_FOUND)
4fdae997 1313 cout << wxT("SQL_NO_DATA_FOUND fetching inf. about data type.") << endl;
108106cf 1314#endif
3ca6a5f0
BP		 1315 DispAllErrors(henv, hdbc, hstmt);
1316 SQLFreeStmt(hstmt, SQL_CLOSE);
1317 return(FALSE);
1318 }
4fdae997
GT		 1319
1320 wxChar typeName[DB_TYPE_NAME_LEN+1];
1e92909e 1321 // Obtain columns from the record
4fdae997 1322 if (SQLGetData(hstmt, 1, SQL_C_CHAR, (UCHAR*) typeName, DB_TYPE_NAME_LEN, &cbRet) != SQL_SUCCESS)
1e92909e 1323 return(DispAllErrors(henv, hdbc, hstmt));
67e9aaa3 1324
4fdae997
GT		 1325 structSQLTypeInfo.TypeName = typeName;
1326
f6bcfd97
BP		 1327 // BJO 20000503: no more needed with new GetColumns...
1328#if OLD_GETCOLUMNS
67e9aaa3
GT		 1329 // BJO 991209
1330 if (Dbms() == dbmsMY_SQL)
3ca6a5f0 1331 {
4fdae997
GT		 1332 if (structSQLTypeInfo.TypeName == wxT("middleint"))
1333 structSQLTypeInfo.TypeName = wxT("mediumint");
1334 else if (structSQLTypeInfo.TypeName == wxT("middleint unsigned"))
1335 structSQLTypeInfo.TypeName = wxT("mediumint unsigned");
1336 else if (structSQLTypeInfo.TypeName == wxT("integer"))
1337 structSQLTypeInfo.TypeName = wxT("int");
1338 else if (structSQLTypeInfo.TypeName == wxT("integer unsigned"))
1339 structSQLTypeInfo.TypeName = wxT("int unsigned");
1340 else if (structSQLTypeInfo.TypeName == wxT("middleint"))
1341 structSQLTypeInfo.TypeName = wxT("mediumint");
1342 else if (structSQLTypeInfo.TypeName == wxT("varchar"))
1343 structSQLTypeInfo.TypeName = wxT("char");
3ca6a5f0 1344 }
eedb1543
DW		 1345
1346 // BJO 20000427 : OpenLink driver
4fdae997
GT		 1347 if (!wxStrncmp(dbInf.driverName, wxT("oplodbc"), 7) ||
1348 !wxStrncmp(dbInf.driverName, wxT("OLOD"), 4))
3ca6a5f0 1349 {
4fdae997
GT		 1350 if (structSQLTypeInfo.TypeName == wxT("double precision"))
1351 structSQLTypeInfo.TypeName = wxT("real");
3ca6a5f0 1352 }
f6bcfd97 1353#endif
67e9aaa3 1354
1e92909e
GT		 1355 if (SQLGetData(hstmt, 3, SQL_C_LONG, (UCHAR*) &structSQLTypeInfo.Precision, 0, &cbRet) != SQL_SUCCESS)
1356 return(DispAllErrors(henv, hdbc, hstmt));
1357 if (SQLGetData(hstmt, 8, SQL_C_SHORT, (UCHAR*) &structSQLTypeInfo.CaseSensitive, 0, &cbRet) != SQL_SUCCESS)
1358 return(DispAllErrors(henv, hdbc, hstmt));
1359// if (SQLGetData(hstmt, 14, SQL_C_SHORT, (UCHAR*) &structSQLTypeInfo.MinimumScale, 0, &cbRet) != SQL_SUCCESS)
1360// return(DispAllErrors(henv, hdbc, hstmt));
a2115c88 1361
1e92909e
GT		 1362 if (SQLGetData(hstmt, 15, SQL_C_SHORT,(UCHAR*) &structSQLTypeInfo.MaximumScale, 0, &cbRet) != SQL_SUCCESS)
1363 return(DispAllErrors(henv, hdbc, hstmt));
108106cf 1364
1e92909e
GT		 1365 if (structSQLTypeInfo.MaximumScale < 0)
1366 structSQLTypeInfo.MaximumScale = 0;
108106cf 1367
1e92909e
GT		 1368 // Close the statement handle which closes open cursors
1369 if (SQLFreeStmt(hstmt, SQL_CLOSE) != SQL_SUCCESS)
1370 return(DispAllErrors(henv, hdbc, hstmt));
108106cf 1371
1e92909e
GT		 1372 // Completed Successfully
1373 return(TRUE);
108106cf 1374
f6bcfd97 1375} // wxDb::getDataTypeInfo()
108106cf 1376
67e9aaa3 1377
f6bcfd97
BP		 1378/********** wxDb::Close() **********/
1379void wxDb::Close(void)
108106cf 1380{
1e92909e
GT		 1381 // Close the Sql Log file
1382 if (fpSqlLog)
1383 {
1384 fclose(fpSqlLog);
1385 fpSqlLog = 0;
1386 }
1387
1388 // Free statement handle
1389 if (dbIsOpen)
1390 {
1391 if (SQLFreeStmt(hstmt, SQL_DROP) != SQL_SUCCESS)
1392 DispAllErrors(henv, hdbc);
1393 }
1394
1395 // Disconnect from the datasource
1396 if (SQLDisconnect(hdbc) != SQL_SUCCESS)
1397 DispAllErrors(henv, hdbc);
1398
1399 // Free the connection to the datasource
1400 if (SQLFreeConnect(hdbc) != SQL_SUCCESS)
1401 DispAllErrors(henv, hdbc);
1402
1403 // There should be zero Ctable objects still connected to this db object
4fdae997 1404 wxASSERT(nTables == 0);
a2115c88 1405
e041ce57 1406#ifdef __WXDEBUG__
fdc03678 1407 wxTablesInUse *tiu;
1e92909e
GT		 1408 wxNode *pNode;
1409 pNode = TablesInUse.First();
1410 wxString s,s2;
1411 while (pNode)
1412 {
fdc03678 1413 tiu = (wxTablesInUse *)pNode->Data();
1e92909e
GT		 1414 if (tiu->pDb == this)
1415 {
4fdae997
GT		 1416 s.Printf(wxT("(%-20s) tableID:[%6lu] pDb:[%p]"), tiu->tableName,tiu->tableID,tiu->pDb);
1417 s2.Printf(wxT("Orphaned found using pDb:[%p]"),this);
1418 wxLogDebug (s,s2);
1e92909e
GT		 1419 }
1420 pNode = pNode->Next();
1421 }
a2115c88
GT		 1422#endif
1423
1e92909e
GT		 1424 // Copy the error messages to a global variable
1425 int i;
1426 for (i = 0; i < DB_MAX_ERROR_HISTORY; i++)
942e67c3 1427 wxStrcpy(DBerrorList[i], errorList[i]);
a2115c88 1428
081eb1b1 1429 dbmsType = dbmsUNIDENTIFIED;
a8aa2258
GT		 1430 dbIsOpen = FALSE;
1431
f6bcfd97 1432} // wxDb::Close()
108106cf 1433
67e9aaa3 1434
f6bcfd97
BP		 1435/********** wxDb::CommitTrans() **********/
1436bool wxDb::CommitTrans(void)
108106cf 1437{
1e92909e
GT		 1438 if (this)
1439 {
1440 // Commit the transaction
1441 if (SQLTransact(henv, hdbc, SQL_COMMIT) != SQL_SUCCESS)
1442 return(DispAllErrors(henv, hdbc));
1443 }
108106cf 1444
1e92909e
GT		 1445 // Completed successfully
1446 return(TRUE);
108106cf 1447
f6bcfd97 1448} // wxDb::CommitTrans()
108106cf 1449
67e9aaa3 1450
f6bcfd97
BP		 1451/********** wxDb::RollbackTrans() **********/
1452bool wxDb::RollbackTrans(void)
108106cf 1453{
1e92909e
GT		 1454 // Rollback the transaction
1455 if (SQLTransact(henv, hdbc, SQL_ROLLBACK) != SQL_SUCCESS)
1456 return(DispAllErrors(henv, hdbc));
108106cf 1457
1e92909e
GT		 1458 // Completed successfully
1459 return(TRUE);
108106cf 1460
f6bcfd97 1461} // wxDb::RollbackTrans()
108106cf 1462
67e9aaa3 1463
f6bcfd97
BP		 1464/********** wxDb::DispAllErrors() **********/
1465bool wxDb::DispAllErrors(HENV aHenv, HDBC aHdbc, HSTMT aHstmt)
a8aa2258
GT		 1466/*
1467 * This function is called internally whenever an error condition prevents the user's
1468 * request from being executed. This function will query the datasource as to the
1469 * actual error(s) that just occured on the previous request of the datasource.
1470 *
eedb1543 1471 * The function will retrieve each error condition from the datasource and
4fdae997 1472 * Printf the codes/text values into a string which it then logs via logError().
a8aa2258
GT		 1473 * If in DBDEBUG_CONSOLE mode, the constructed string will be displayed in the console
1474 * window and program execution will be paused until the user presses a key.
1475 *
1476 * This function always returns a FALSE, so that functions which call this function
1477 * can have a line like "return (DispAllErrors(henv, hdbc));" to indicate the failure
1478 * of the users request, so that the calling code can then process the error msg log
1479 */
108106cf 1480{
1e92909e
GT		 1481 wxString odbcErrMsg;
1482
1483 while (SQLError(aHenv, aHdbc, aHstmt, (UCHAR FAR *) sqlState, &nativeError, (UCHAR FAR *) errorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &cbErrorMsg) == SQL_SUCCESS)
1484 {
4fdae997
GT		 1485 odbcErrMsg.Printf(wxT("SQL State = %s\nNative Error Code = %li\nError Message = %s\n"), sqlState, nativeError, errorMsg);
1486 logError(odbcErrMsg, sqlState);
1e92909e
GT		 1487 if (!silent)
1488 {
1fc5dd6f 1489#ifdef DBDEBUG_CONSOLE
1e92909e 1490 // When run in console mode, use standard out to display errors.
f6bcfd97 1491 cout << odbcErrMsg.c_str() << endl;
4fdae997 1492 cout << wxT("Press any key to continue...") << endl;
1e92909e 1493 getchar();
108106cf 1494#endif
a2115c88
GT		 1495
1496#ifdef __WXDEBUG__
4fdae997 1497 wxLogDebug(odbcErrMsg,wxT("ODBC DEBUG MESSAGE from DispAllErrors()"));
a2115c88 1498#endif
f6bcfd97 1499 }
1e92909e 1500 }
108106cf 1501
1e92909e 1502 return(FALSE); // This function always returns false.
108106cf 1503
f6bcfd97 1504} // wxDb::DispAllErrors()
108106cf 1505
67e9aaa3 1506
f6bcfd97
BP		 1507/********** wxDb::GetNextError() **********/
1508bool wxDb::GetNextError(HENV aHenv, HDBC aHdbc, HSTMT aHstmt)
108106cf 1509{
1e92909e
GT		 1510 if (SQLError(aHenv, aHdbc, aHstmt, (UCHAR FAR *) sqlState, &nativeError, (UCHAR FAR *) errorMsg, SQL_MAX_MESSAGE_LENGTH - 1, &cbErrorMsg) == SQL_SUCCESS)
1511 return(TRUE);
1512 else
1513 return(FALSE);
108106cf 1514
f6bcfd97 1515} // wxDb::GetNextError()
108106cf 1516
67e9aaa3 1517
f6bcfd97
BP		 1518/********** wxDb::DispNextError() **********/
1519void wxDb::DispNextError(void)
108106cf 1520{
1e92909e 1521 wxString odbcErrMsg;
108106cf 1522
4fdae997
GT		 1523 odbcErrMsg.Printf(wxT("SQL State = %s\nNative Error Code = %li\nError Message = %s\n"), sqlState, nativeError, errorMsg);
1524 logError(odbcErrMsg, sqlState);
108106cf 1525
1e92909e
GT		 1526 if (silent)
1527 return;
108106cf 1528
1fc5dd6f 1529#ifdef DBDEBUG_CONSOLE
1e92909e 1530 // When run in console mode, use standard out to display errors.
f6bcfd97 1531 cout << odbcErrMsg.c_str() << endl;
4fdae997 1532 cout << wxT("Press any key to continue...") << endl;
1e92909e 1533 getchar();
108106cf
JS		 1534#endif
1535
f6bcfd97
BP		 1536#ifdef __WXDEBUG__
1537 wxLogDebug(odbcErrMsg,wxT("ODBC DEBUG MESSAGE"));
1538#endif // __WXDEBUG__
108106cf 1539
f6bcfd97
BP		 1540} // wxDb::DispNextError()
1541
1542
1543/********** wxDb::logError() **********/
4fdae997 1544void wxDb::logError(const wxString &errMsg, const wxString &SQLState)
108106cf 1545{
4fdae997 1546 wxASSERT(errMsg.Length());
108106cf 1547
1e92909e
GT		 1548 static int pLast = -1;
1549 int dbStatus;
108106cf 1550
1e92909e
GT		 1551 if (++pLast == DB_MAX_ERROR_HISTORY)
1552 {
1553 int i;
1554 for (i = 0; i < DB_MAX_ERROR_HISTORY; i++)
1555 wxStrcpy(errorList[i], errorList[i+1]);
1556 pLast--;
1557 }
108106cf 1558
1e92909e 1559 wxStrcpy(errorList[pLast], errMsg);
108106cf 1560
4fdae997 1561 if (SQLState.Length())
1e92909e
GT		 1562 if ((dbStatus = TranslateSqlState(SQLState)) != DB_ERR_FUNCTION_SEQUENCE_ERROR)
1563 DB_STATUS = dbStatus;
108106cf 1564
1e92909e
GT		 1565 // Add the errmsg to the sql log
1566 WriteSqlLog(errMsg);
a2115c88 1567
f6bcfd97 1568} // wxDb::logError()
108106cf 1569
67e9aaa3 1570
f6bcfd97 1571/**********wxDb::TranslateSqlState() **********/
4fdae997 1572int wxDb::TranslateSqlState(const wxString &SQLState)
108106cf 1573{
f6bcfd97 1574 if (!wxStrcmp(SQLState, wxT("01000")))
1e92909e 1575 return(DB_ERR_GENERAL_WARNING);
f6bcfd97 1576 if (!wxStrcmp(SQLState, wxT("01002")))
1e92909e 1577 return(DB_ERR_DISCONNECT_ERROR);
f6bcfd97 1578 if (!wxStrcmp(SQLState, wxT("01004")))
1e92909e 1579 return(DB_ERR_DATA_TRUNCATED);
f6bcfd97 1580 if (!wxStrcmp(SQLState, wxT("01006")))
1e92909e 1581 return(DB_ERR_PRIV_NOT_REVOKED);
f6bcfd97 1582 if (!wxStrcmp(SQLState, wxT("01S00")))
1e92909e 1583 return(DB_ERR_INVALID_CONN_STR_ATTR);
f6bcfd97 1584 if (!wxStrcmp(SQLState, wxT("01S01")))
1e92909e 1585 return(DB_ERR_ERROR_IN_ROW);
f6bcfd97 1586 if (!wxStrcmp(SQLState, wxT("01S02")))
1e92909e 1587 return(DB_ERR_OPTION_VALUE_CHANGED);
f6bcfd97 1588 if (!wxStrcmp(SQLState, wxT("01S03")))
1e92909e 1589 return(DB_ERR_NO_ROWS_UPD_OR_DEL);
f6bcfd97 1590 if (!wxStrcmp(SQLState, wxT("01S04")))
1e92909e 1591 return(DB_ERR_MULTI_ROWS_UPD_OR_DEL);
f6bcfd97 1592 if (!wxStrcmp(SQLState, wxT("07001")))
1e92909e 1593 return(DB_ERR_WRONG_NO_OF_PARAMS);
f6bcfd97 1594 if (!wxStrcmp(SQLState, wxT("07006")))
1e92909e 1595 return(DB_ERR_DATA_TYPE_ATTR_VIOL);
f6bcfd97 1596 if (!wxStrcmp(SQLState, wxT("08001")))
1e92909e 1597 return(DB_ERR_UNABLE_TO_CONNECT);
f6bcfd97 1598 if (!wxStrcmp(SQLState, wxT("08002")))
1e92909e 1599 return(DB_ERR_CONNECTION_IN_USE);
f6bcfd97 1600 if (!wxStrcmp(SQLState, wxT("08003")))
1e92909e 1601 return(DB_ERR_CONNECTION_NOT_OPEN);
f6bcfd97 1602 if (!wxStrcmp(SQLState, wxT("08004")))
1e92909e 1603 return(DB_ERR_REJECTED_CONNECTION);
f6bcfd97 1604 if (!wxStrcmp(SQLState, wxT("08007")))
1e92909e 1605 return(DB_ERR_CONN_FAIL_IN_TRANS);
f6bcfd97 1606 if (!wxStrcmp(SQLState, wxT("08S01")))
1e92909e 1607 return(DB_ERR_COMM_LINK_FAILURE);
f6bcfd97 1608 if (!wxStrcmp(SQLState, wxT("21S01")))
1e92909e 1609 return(DB_ERR_INSERT_VALUE_LIST_MISMATCH);
f6bcfd97 1610 if (!wxStrcmp(SQLState, wxT("21S02")))
1e92909e 1611 return(DB_ERR_DERIVED_TABLE_MISMATCH);
f6bcfd97 1612 if (!wxStrcmp(SQLState, wxT("22001")))
1e92909e 1613 return(DB_ERR_STRING_RIGHT_TRUNC);
f6bcfd97 1614 if (!wxStrcmp(SQLState, wxT("22003")))
1e92909e 1615 return(DB_ERR_NUMERIC_VALUE_OUT_OF_RNG);
f6bcfd97 1616 if (!wxStrcmp(SQLState, wxT("22005")))
1e92909e 1617 return(DB_ERR_ERROR_IN_ASSIGNMENT);
f6bcfd97 1618 if (!wxStrcmp(SQLState, wxT("22008")))
1e92909e 1619 return(DB_ERR_DATETIME_FLD_OVERFLOW);
f6bcfd97 1620 if (!wxStrcmp(SQLState, wxT("22012")))
1e92909e 1621 return(DB_ERR_DIVIDE_BY_ZERO);
f6bcfd97 1622 if (!wxStrcmp(SQLState, wxT("22026")))
1e92909e 1623 return(DB_ERR_STR_DATA_LENGTH_MISMATCH);
f6bcfd97 1624 if (!wxStrcmp(SQLState, wxT("23000")))
1e92909e 1625 return(DB_ERR_INTEGRITY_CONSTRAINT_VIOL);
f6bcfd97 1626 if (!wxStrcmp(SQLState, wxT("24000")))
1e92909e 1627 return(DB_ERR_INVALID_CURSOR_STATE);
f6bcfd97 1628 if (!wxStrcmp(SQLState, wxT("25000")))
1e92909e 1629 return(DB_ERR_INVALID_TRANS_STATE);
f6bcfd97 1630 if (!wxStrcmp(SQLState, wxT("28000")))
1e92909e 1631 return(DB_ERR_INVALID_AUTH_SPEC);
f6bcfd97 1632 if (!wxStrcmp(SQLState, wxT("34000")))
1e92909e 1633 return(DB_ERR_INVALID_CURSOR_NAME);
f6bcfd97 1634 if (!wxStrcmp(SQLState, wxT("37000")))
1e92909e 1635 return(DB_ERR_SYNTAX_ERROR_OR_ACCESS_VIOL);
f6bcfd97 1636 if (!wxStrcmp(SQLState, wxT("3C000")))
1e92909e 1637 return(DB_ERR_DUPLICATE_CURSOR_NAME);
f6bcfd97 1638 if (!wxStrcmp(SQLState, wxT("40001")))
1e92909e 1639 return(DB_ERR_SERIALIZATION_FAILURE);
f6bcfd97 1640 if (!wxStrcmp(SQLState, wxT("42000")))
1e92909e 1641 return(DB_ERR_SYNTAX_ERROR_OR_ACCESS_VIOL2);
f6bcfd97 1642 if (!wxStrcmp(SQLState, wxT("70100")))
1e92909e 1643 return(DB_ERR_OPERATION_ABORTED);
f6bcfd97 1644 if (!wxStrcmp(SQLState, wxT("IM001")))
1e92909e 1645 return(DB_ERR_UNSUPPORTED_FUNCTION);
f6bcfd97 1646 if (!wxStrcmp(SQLState, wxT("IM002")))
1e92909e 1647 return(DB_ERR_NO_DATA_SOURCE);
f6bcfd97 1648 if (!wxStrcmp(SQLState, wxT("IM003")))
1e92909e 1649 return(DB_ERR_DRIVER_LOAD_ERROR);
f6bcfd97 1650 if (!wxStrcmp(SQLState, wxT("IM004")))
1e92909e 1651 return(DB_ERR_SQLALLOCENV_FAILED);
f6bcfd97 1652 if (!wxStrcmp(SQLState, wxT("IM005")))
1e92909e 1653 return(DB_ERR_SQLALLOCCONNECT_FAILED);
f6bcfd97 1654 if (!wxStrcmp(SQLState, wxT("IM006")))
1e92909e 1655 return(DB_ERR_SQLSETCONNECTOPTION_FAILED);
f6bcfd97 1656 if (!wxStrcmp(SQLState, wxT("IM007")))
1e92909e 1657 return(DB_ERR_NO_DATA_SOURCE_DLG_PROHIB);
f6bcfd97 1658 if (!wxStrcmp(SQLState, wxT("IM008")))
1e92909e 1659 return(DB_ERR_DIALOG_FAILED);
f6bcfd97 1660 if (!wxStrcmp(SQLState, wxT("IM009")))
1e92909e 1661 return(DB_ERR_UNABLE_TO_LOAD_TRANSLATION_DLL);
f6bcfd97 1662 if (!wxStrcmp(SQLState, wxT("IM010")))
1e92909e 1663 return(DB_ERR_DATA_SOURCE_NAME_TOO_LONG);
f6bcfd97 1664 if (!wxStrcmp(SQLState, wxT("IM011")))
1e92909e 1665 return(DB_ERR_DRIVER_NAME_TOO_LONG);
f6bcfd97 1666 if (!wxStrcmp(SQLState, wxT("IM012")))
1e92909e 1667 return(DB_ERR_DRIVER_KEYWORD_SYNTAX_ERROR);
f6bcfd97 1668 if (!wxStrcmp(SQLState, wxT("IM013")))
1e92909e 1669 return(DB_ERR_TRACE_FILE_ERROR);
f6bcfd97 1670 if (!wxStrcmp(SQLState, wxT("S0001")))
1e92909e 1671 return(DB_ERR_TABLE_OR_VIEW_ALREADY_EXISTS);
f6bcfd97 1672 if (!wxStrcmp(SQLState, wxT("S0002")))
1e92909e 1673 return(DB_ERR_TABLE_NOT_FOUND);
f6bcfd97 1674 if (!wxStrcmp(SQLState, wxT("S0011")))
1e92909e 1675 return(DB_ERR_INDEX_ALREADY_EXISTS);
f6bcfd97 1676 if (!wxStrcmp(SQLState, wxT("S0012")))
1e92909e 1677 return(DB_ERR_INDEX_NOT_FOUND);
f6bcfd97 1678 if (!wxStrcmp(SQLState, wxT("S0021")))
1e92909e 1679 return(DB_ERR_COLUMN_ALREADY_EXISTS);
f6bcfd97 1680 if (!wxStrcmp(SQLState, wxT("S0022")))
1e92909e 1681 return(DB_ERR_COLUMN_NOT_FOUND);
f6bcfd97 1682 if (!wxStrcmp(SQLState, wxT("S0023")))
1e92909e 1683 return(DB_ERR_NO_DEFAULT_FOR_COLUMN);
f6bcfd97 1684 if (!wxStrcmp(SQLState, wxT("S1000")))
1e92909e 1685 return(DB_ERR_GENERAL_ERROR);
f6bcfd97 1686 if (!wxStrcmp(SQLState, wxT("S1001")))
1e92909e 1687 return(DB_ERR_MEMORY_ALLOCATION_FAILURE);
f6bcfd97 1688 if (!wxStrcmp(SQLState, wxT("S1002")))
1e92909e 1689 return(DB_ERR_INVALID_COLUMN_NUMBER);
f6bcfd97 1690 if (!wxStrcmp(SQLState, wxT("S1003")))
1e92909e 1691 return(DB_ERR_PROGRAM_TYPE_OUT_OF_RANGE);
f6bcfd97 1692 if (!wxStrcmp(SQLState, wxT("S1004")))
1e92909e 1693 return(DB_ERR_SQL_DATA_TYPE_OUT_OF_RANGE);
f6bcfd97 1694 if (!wxStrcmp(SQLState, wxT("S1008")))
1e92909e 1695 return(DB_ERR_OPERATION_CANCELLED);
f6bcfd97 1696 if (!wxStrcmp(SQLState, wxT("S1009")))
1e92909e 1697 return(DB_ERR_INVALID_ARGUMENT_VALUE);
f6bcfd97 1698 if (!wxStrcmp(SQLState, wxT("S1010")))
1e92909e 1699 return(DB_ERR_FUNCTION_SEQUENCE_ERROR);
f6bcfd97 1700 if (!wxStrcmp(SQLState, wxT("S1011")))
1e92909e 1701 return(DB_ERR_OPERATION_INVALID_AT_THIS_TIME);
f6bcfd97 1702 if (!wxStrcmp(SQLState, wxT("S1012")))
1e92909e 1703 return(DB_ERR_INVALID_TRANS_OPERATION_CODE);
f6bcfd97 1704 if (!wxStrcmp(SQLState, wxT("S1015")))
1e92909e 1705 return(DB_ERR_NO_CURSOR_NAME_AVAIL);
f6bcfd97 1706 if (!wxStrcmp(SQLState, wxT("S1090")))
1e92909e 1707 return(DB_ERR_INVALID_STR_OR_BUF_LEN);
f6bcfd97 1708 if (!wxStrcmp(SQLState, wxT("S1091")))
1e92909e 1709 return(DB_ERR_DESCRIPTOR_TYPE_OUT_OF_RANGE);
f6bcfd97 1710 if (!wxStrcmp(SQLState, wxT("S1092")))
1e92909e 1711 return(DB_ERR_OPTION_TYPE_OUT_OF_RANGE);
f6bcfd97 1712 if (!wxStrcmp(SQLState, wxT("S1093")))
1e92909e 1713 return(DB_ERR_INVALID_PARAM_NO);
f6bcfd97 1714 if (!wxStrcmp(SQLState, wxT("S1094")))
1e92909e 1715 return(DB_ERR_INVALID_SCALE_VALUE);
f6bcfd97 1716 if (!wxStrcmp(SQLState, wxT("S1095")))
1e92909e 1717 return(DB_ERR_FUNCTION_TYPE_OUT_OF_RANGE);
f6bcfd97 1718 if (!wxStrcmp(SQLState, wxT("S1096")))
1e92909e 1719 return(DB_ERR_INF_TYPE_OUT_OF_RANGE);
f6bcfd97 1720 if (!wxStrcmp(SQLState, wxT("S1097")))
1e92909e 1721 return(DB_ERR_COLUMN_TYPE_OUT_OF_RANGE);
f6bcfd97 1722 if (!wxStrcmp(SQLState, wxT("S1098")))
1e92909e 1723 return(DB_ERR_SCOPE_TYPE_OUT_OF_RANGE);
f6bcfd97 1724 if (!wxStrcmp(SQLState, wxT("S1099")))
1e92909e 1725 return(DB_ERR_NULLABLE_TYPE_OUT_OF_RANGE);
f6bcfd97 1726 if (!wxStrcmp(SQLState, wxT("S1100")))
1e92909e 1727 return(DB_ERR_UNIQUENESS_OPTION_TYPE_OUT_OF_RANGE);
f6bcfd97 1728 if (!wxStrcmp(SQLState, wxT("S1101")))
1e92909e 1729 return(DB_ERR_ACCURACY_OPTION_TYPE_OUT_OF_RANGE);
f6bcfd97 1730 if (!wxStrcmp(SQLState, wxT("S1103")))
1e92909e 1731 return(DB_ERR_DIRECTION_OPTION_OUT_OF_RANGE);
f6bcfd97 1732 if (!wxStrcmp(SQLState, wxT("S1104")))
1e92909e 1733 return(DB_ERR_INVALID_PRECISION_VALUE);
f6bcfd97 1734 if (!wxStrcmp(SQLState, wxT("S1105")))
1e92909e 1735 return(DB_ERR_INVALID_PARAM_TYPE);
f6bcfd97 1736 if (!wxStrcmp(SQLState, wxT("S1106")))
1e92909e 1737 return(DB_ERR_FETCH_TYPE_OUT_OF_RANGE);
f6bcfd97 1738 if (!wxStrcmp(SQLState, wxT("S1107")))
1e92909e 1739 return(DB_ERR_ROW_VALUE_OUT_OF_RANGE);
f6bcfd97 1740 if (!wxStrcmp(SQLState, wxT("S1108")))
1e92909e 1741 return(DB_ERR_CONCURRENCY_OPTION_OUT_OF_RANGE);
f6bcfd97 1742 if (!wxStrcmp(SQLState, wxT("S1109")))
1e92909e 1743 return(DB_ERR_INVALID_CURSOR_POSITION);
f6bcfd97 1744 if (!wxStrcmp(SQLState, wxT("S1110")))
1e92909e 1745 return(DB_ERR_INVALID_DRIVER_COMPLETION);
f6bcfd97 1746 if (!wxStrcmp(SQLState, wxT("S1111")))
1e92909e 1747 return(DB_ERR_INVALID_BOOKMARK_VALUE);
f6bcfd97 1748 if (!wxStrcmp(SQLState, wxT("S1C00")))
1e92909e 1749 return(DB_ERR_DRIVER_NOT_CAPABLE);
f6bcfd97 1750 if (!wxStrcmp(SQLState, wxT("S1T00")))
1e92909e
GT		 1751 return(DB_ERR_TIMEOUT_EXPIRED);
1752
1753 // No match
1754 return(0);
108106cf 1755
f6bcfd97 1756} // wxDb::TranslateSqlState()
67e9aaa3 1757
23f681ec 1758
f6bcfd97 1759/********** wxDb::Grant() **********/
4fdae997 1760bool wxDb::Grant(int privileges, const wxString &tableName, const wxString &userList)
108106cf 1761{
1e92909e
GT		 1762 wxString sqlStmt;
1763
1764 // Build the grant statement
4fdae997 1765 sqlStmt = wxT("GRANT ");
1e92909e 1766 if (privileges == DB_GRANT_ALL)
4fdae997 1767 sqlStmt += wxT("ALL");
1e92909e
GT		 1768 else
1769 {
1770 int c = 0;
1771 if (privileges & DB_GRANT_SELECT)
1772 {
4fdae997 1773 sqlStmt += wxT("SELECT");
1e92909e
GT		 1774 c++;
1775 }
1776 if (privileges & DB_GRANT_INSERT)
1777 {
1778 if (c++)
4fdae997
GT		 1779 sqlStmt += wxT(", ");
1780 sqlStmt += wxT("INSERT");
1e92909e
GT		 1781 }
1782 if (privileges & DB_GRANT_UPDATE)
1783 {
1784 if (c++)
4fdae997
GT		 1785 sqlStmt += wxT(", ");
1786 sqlStmt += wxT("UPDATE");
1e92909e
GT		 1787 }
1788 if (privileges & DB_GRANT_DELETE)
1789 {
1790 if (c++)
4fdae997
GT		 1791 sqlStmt += wxT(", ");
1792 sqlStmt += wxT("DELETE");
1e92909e
GT		 1793 }
1794 }
1795
4fdae997 1796 sqlStmt += wxT(" ON ");
1e92909e 1797 sqlStmt += tableName;
4fdae997 1798 sqlStmt += wxT(" TO ");
1e92909e 1799 sqlStmt += userList;
108106cf 1800
1fc5dd6f 1801#ifdef DBDEBUG_CONSOLE
f6bcfd97 1802 cout << endl << sqlStmt.c_str() << endl;
108106cf
JS		 1803#endif
1804
4fdae997 1805 WriteSqlLog(sqlStmt);
1fc5dd6f 1806
4fdae997 1807 return(ExecSql(sqlStmt));
108106cf 1808
f6bcfd97 1809} // wxDb::Grant()
108106cf 1810
67e9aaa3 1811
f6bcfd97 1812/********** wxDb::CreateView() **********/
4fdae997
GT		 1813bool wxDb::CreateView(const wxString &viewName, const wxString &colList,
1814 const wxString &pSqlStmt, bool attemptDrop)
108106cf 1815{
1e92909e
GT		 1816 wxString sqlStmt;
1817
1818 // Drop the view first
1819 if (attemptDrop && !DropView(viewName))
1820 return FALSE;
1821
1822 // Build the create view statement
4fdae997 1823 sqlStmt = wxT("CREATE VIEW ");
1e92909e 1824 sqlStmt += viewName;
23f681ec 1825
4fdae997 1826 if (colList.Length())
1e92909e 1827 {
4fdae997 1828 sqlStmt += wxT(" (");
1e92909e 1829 sqlStmt += colList;
4fdae997 1830 sqlStmt += wxT(")");
1e92909e 1831 }
108106cf 1832
4fdae997 1833 sqlStmt += wxT(" AS ");
1e92909e 1834 sqlStmt += pSqlStmt;
108106cf 1835
4fdae997 1836 WriteSqlLog(sqlStmt);
1fc5dd6f
JS		 1837
1838#ifdef DBDEBUG_CONSOLE
f6bcfd97 1839 cout << sqlStmt.c_str() << endl;
108106cf
JS		 1840#endif
1841
4fdae997 1842 return(ExecSql(sqlStmt));
108106cf 1843
f6bcfd97 1844} // wxDb::CreateView()
108106cf 1845
67e9aaa3 1846
f6bcfd97 1847/********** wxDb::DropView() **********/
4fdae997 1848bool wxDb::DropView(const wxString &viewName)
a2115c88 1849{
67e9aaa3
GT		 1850/*
1851 * NOTE: This function returns TRUE if the View does not exist, but
1852 * only for identified databases. Code will need to be added
1e92909e 1853 * below for any other databases when those databases are defined
67e9aaa3
GT		 1854 * to handle this situation consistently
1855 */
1e92909e 1856 wxString sqlStmt;
a2115c88 1857
942e67c3 1858 sqlStmt.Printf(wxT("DROP VIEW %s"), viewName.c_str());
a2115c88 1859
4fdae997 1860 WriteSqlLog(sqlStmt);
a2115c88
GT		 1861
1862#ifdef DBDEBUG_CONSOLE
f6bcfd97 1863 cout << endl << sqlStmt.c_str() << endl;
a2115c88
GT		 1864#endif
1865
f6bcfd97 1866 if (SQLExecDirect(hstmt, (UCHAR FAR *) sqlStmt.c_str(), SQL_NTS) != SQL_SUCCESS)
1e92909e
GT		 1867 {
1868 // Check for "Base table not found" error and ignore
1869 GetNextError(henv, hdbc, hstmt);
f6bcfd97 1870 if (wxStrcmp(sqlState,wxT("S0002"))) // "Base table not found"
1e92909e
GT		 1871 {
1872 // Check for product specific error codes
f6bcfd97 1873 if (!((Dbms() == dbmsSYBASE_ASA && !wxStrcmp(sqlState,wxT("42000"))))) // 5.x (and lower?)
1e92909e
GT		 1874 {
1875 DispNextError();
1876 DispAllErrors(henv, hdbc, hstmt);
1877 RollbackTrans();
1878 return(FALSE);
1879 }
1880 }
1881 }
1882
1883 // Commit the transaction
1884 if (! CommitTrans())
1885 return(FALSE);
1886
1887 return TRUE;
a2115c88 1888
f6bcfd97 1889} // wxDb::DropView()
a2115c88
GT		 1890
1891
f6bcfd97 1892/********** wxDb::ExecSql() **********/
4fdae997 1893bool wxDb::ExecSql(const wxString &pSqlStmt)
108106cf 1894{
2beca662
GT		 1895 RETCODE retcode;
1896
1e92909e 1897 SQLFreeStmt(hstmt, SQL_CLOSE);
2beca662
GT		 1898
1899 retcode = SQLExecDirect(hstmt, (UCHAR FAR *) pSqlStmt.c_str(), SQL_NTS);
5600884a 1900 if (retcode == SQL_SUCCESS ||
2beca662
GT		 1901 (Dbms() == dbmsDB2 && (retcode == SQL_SUCCESS_WITH_INFO || retcode == SQL_NO_DATA_FOUND)))
1902 {
1e92909e 1903 return(TRUE);
2beca662 1904 }
1e92909e
GT		 1905 else
1906 {
1907 DispAllErrors(henv, hdbc, hstmt);
1908 return(FALSE);
1909 }
108106cf 1910
f6bcfd97 1911} // wxDb::ExecSql()
108106cf 1912
67e9aaa3 1913
f6bcfd97
BP		 1914/********** wxDb::GetNext() **********/
1915bool wxDb::GetNext(void)
a2115c88 1916{
1e92909e
GT		 1917 if (SQLFetch(hstmt) == SQL_SUCCESS)
1918 return(TRUE);
1919 else
1920 {
1921 DispAllErrors(henv, hdbc, hstmt);
1922 return(FALSE);
1923 }
a2115c88 1924
f6bcfd97 1925} // wxDb::GetNext()
a2115c88 1926
67e9aaa3 1927
f6bcfd97
BP		 1928/********** wxDb::GetData() **********/
1929bool wxDb::GetData(UWORD colNo, SWORD cType, PTR pData, SDWORD maxLen, SDWORD FAR *cbReturned)
a2115c88 1930{
4fdae997
GT		 1931 wxASSERT(pData);
1932 wxASSERT(cbReturned);
a2115c88 1933
1e92909e
GT		 1934 if (SQLGetData(hstmt, colNo, cType, pData, maxLen, cbReturned) == SQL_SUCCESS)
1935 return(TRUE);
1936 else
1937 {
1938 DispAllErrors(henv, hdbc, hstmt);
1939 return(FALSE);
1940 }
a2115c88 1941
f6bcfd97 1942} // wxDb::GetData()
a2115c88 1943
67e9aaa3 1944
f6bcfd97 1945/********** wxDb::GetKeyFields() **********/
02cf6fdd 1946int wxDb::GetKeyFields(const wxString &tableName, wxDbColInf* colInf, UWORD noCols)
67e9aaa3 1947{
4fdae997
GT		 1948 wxChar szPkTable[DB_MAX_TABLE_NAME_LEN+1]; /* Primary key table name */
1949 wxChar szFkTable[DB_MAX_TABLE_NAME_LEN+1]; /* Foreign key table name */
67e9aaa3
GT		 1950 short iKeySeq;
1951// SQLSMALLINT iKeySeq;
4fdae997
GT		 1952 wxChar szPkCol[DB_MAX_COLUMN_NAME_LEN+1]; /* Primary key column */
1953 wxChar szFkCol[DB_MAX_COLUMN_NAME_LEN+1]; /* Foreign key column */
67e9aaa3
GT		 1954 SQLRETURN retcode;
1955 SDWORD cb;
02cf6fdd 1956 SWORD i;
4fdae997 1957 wxString tempStr;
67e9aaa3 1958 /*
4fdae997
GT		 1959 * -----------------------------------------------------------------------
1960 * -- 19991224 : mj10777 : Create ------
1961 * -- : Three things are done and stored here : ------
1962 * -- : 1) which Column(s) is/are Primary Key(s) ------
1963 * -- : 2) which tables use this Key as a Foreign Key ------
1964 * -- : 3) which columns are Foreign Key and the name ------
1965 * -- : of the Table where the Key is the Primary Key -----
1966 * -- : Called from GetColumns(const wxString &tableName, ------
1967 * -- int *numCols,const wxChar *userID ) ------
1968 * -----------------------------------------------------------------------
67e9aaa3
GT		 1969 */
1970
1971 /*---------------------------------------------------------------------*/
1972 /* Get the names of the columns in the primary key. */
1973 /*---------------------------------------------------------------------*/
1974 retcode = SQLPrimaryKeys(hstmt,
4fdae997
GT		 1975 NULL, 0, /* Catalog name */
1976 NULL, 0, /* Schema name */
1977 (UCHAR FAR *) tableName.c_str(), SQL_NTS); /* Table name */
67e9aaa3
GT		 1978
1979 /*---------------------------------------------------------------------*/
1980 /* Fetch and display the result set. This will be a list of the */
1981 /* columns in the primary key of the tableName table. */
1982 /*---------------------------------------------------------------------*/
1983 while ((retcode == SQL_SUCCESS) || (retcode == SQL_SUCCESS_WITH_INFO))
1984 {
1985 retcode = SQLFetch(hstmt);
1986 if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO)
1987 {
1988 GetData( 4, SQL_C_CHAR, szPkCol, DB_MAX_COLUMN_NAME_LEN+1, &cb);
1989 GetData( 5, SQL_C_SSHORT, &iKeySeq, 0, &cb);
1990 //-------
1991 for (i=0;i<noCols;i++) // Find the Column name
1992 if (!wxStrcmp(colInf[i].colName,szPkCol)) // We have found the Column
1993 colInf[i].PkCol = iKeySeq; // Which Primary Key is this (first, second usw.) ?
3ca6a5f0
BP		 1994 } // if
1995 } // while
67e9aaa3
GT		 1996 SQLFreeStmt(hstmt, SQL_CLOSE); /* Close the cursor (the hstmt is still allocated). */
1997
1998 /*---------------------------------------------------------------------*/
1999 /* Get all the foreign keys that refer to tableName primary key. */
2000 /*---------------------------------------------------------------------*/
2001 retcode = SQLForeignKeys(hstmt,
4fdae997
GT		 2002 NULL, 0, /* Primary catalog */
2003 NULL, 0, /* Primary schema */
2004 (UCHAR FAR *)tableName.c_str(), SQL_NTS,/* Primary table */
2005 NULL, 0, /* Foreign catalog */
2006 NULL, 0, /* Foreign schema */
2007 NULL, 0); /* Foreign table */
67e9aaa3
GT		 2008
2009 /*---------------------------------------------------------------------*/
2010 /* Fetch and display the result set. This will be all of the foreign */
2011 /* keys in other tables that refer to the tableName primary key. */
2012 /*---------------------------------------------------------------------*/
4fdae997 2013 tempStr.Empty();
67e9aaa3
GT		 2014 szPkCol[0] = 0;
2015 while ((retcode == SQL_SUCCESS) || (retcode == SQL_SUCCESS_WITH_INFO))
2016 {
2017 retcode = SQLFetch(hstmt);
2018 if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO)
2019 {
2020 GetData( 3, SQL_C_CHAR, szPkTable, DB_MAX_TABLE_NAME_LEN+1, &cb);
2021 GetData( 4, SQL_C_CHAR, szPkCol, DB_MAX_COLUMN_NAME_LEN+1, &cb);
2022 GetData( 5, SQL_C_SSHORT, &iKeySeq, 0, &cb);
2023 GetData( 7, SQL_C_CHAR, szFkTable, DB_MAX_TABLE_NAME_LEN+1, &cb);
2024 GetData( 8, SQL_C_CHAR, szFkCol, DB_MAX_COLUMN_NAME_LEN+1, &cb);
4fdae997 2025 tempStr.Printf(wxT("%s[%s] "),tempStr.c_str(),szFkTable); // [ ] in case there is a blank in the Table name
3ca6a5f0
BP		 2026 } // if
2027 } // while
4fdae997
GT		 2028
2029 tempStr.Trim(); // Get rid of any unneeded blanks
2030 if (!tempStr.IsEmpty())
67e9aaa3 2031 {
4fdae997 2032 for (i=0; i<noCols; i++)
3ca6a5f0 2033 { // Find the Column name
4fdae997
GT		 2034 if (!wxStrcmp(colInf[i].colName, szPkCol)) // We have found the Column, store the Information
2035 wxStrcpy(colInf[i].PkTableName, tempStr.c_str()); // Name of the Tables where this Primary Key is used as a Foreign Key
3ca6a5f0
BP		 2036 }
2037 } // if
4fdae997 2038
67e9aaa3
GT		 2039 SQLFreeStmt(hstmt, SQL_CLOSE); /* Close the cursor (the hstmt is still allocated). */
2040
2041 /*---------------------------------------------------------------------*/
2042 /* Get all the foreign keys in the tablename table. */
2043 /*---------------------------------------------------------------------*/
2044 retcode = SQLForeignKeys(hstmt,
4fdae997
GT		 2045 NULL, 0, /* Primary catalog */
2046 NULL, 0, /* Primary schema */
2047 NULL, 0, /* Primary table */
2048 NULL, 0, /* Foreign catalog */
2049 NULL, 0, /* Foreign schema */
2050 (UCHAR *)tableName.c_str(), SQL_NTS);/* Foreign table */
67e9aaa3
GT		 2051
2052 /*---------------------------------------------------------------------*/
2053 /* Fetch and display the result set. This will be all of the */
2054 /* primary keys in other tables that are referred to by foreign */
2055 /* keys in the tableName table. */
2056 /*---------------------------------------------------------------------*/
2057 i = 0;
2058 while ((retcode == SQL_SUCCESS) || (retcode == SQL_SUCCESS_WITH_INFO))
2059 {
2060 retcode = SQLFetch(hstmt);
2061 if (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO)
2062 {
2063 GetData( 3, SQL_C_CHAR, szPkTable, DB_MAX_TABLE_NAME_LEN+1, &cb);
2064 GetData( 5, SQL_C_SSHORT, &iKeySeq, 0, &cb);
2065 GetData( 8, SQL_C_CHAR, szFkCol, DB_MAX_COLUMN_NAME_LEN+1, &cb);
2066 //-------
4fdae997 2067 for (i=0; i<noCols; i++) // Find the Column name
67e9aaa3
GT		 2068 {
2069 if (!wxStrcmp(colInf[i].colName,szFkCol)) // We have found the (Foreign Key) Column
2070 {
2071 colInf[i].FkCol = iKeySeq; // Which Foreign Key is this (first, second usw.) ?
3ca6a5f0
BP		 2072 wxStrcpy(colInf[i].FkTableName,szPkTable); // Name of the Table where this Foriegn is the Primary Key
2073 } // if
2074 } // for
2075 } // if
2076 } // while
67e9aaa3
GT		 2077 SQLFreeStmt(hstmt, SQL_CLOSE); /* Close the cursor (the hstmt is still allocated). */
2078
67e9aaa3 2079 return TRUE;
3ca6a5f0 2080
f6bcfd97 2081} // wxDb::GetKeyFields()
67e9aaa3
GT		 2082
2083
f6bcfd97
BP		 2084#if OLD_GETCOLUMNS
2085/********** wxDb::GetColumns() **********/
4fdae997 2086wxDbColInf *wxDb::GetColumns(wxChar *tableName[], const wxChar *userID)
108106cf 2087/*
1e92909e
GT		 2088 * 1) The last array element of the tableName[] argument must be zero (null).
2089 * This is how the end of the array is detected.
f6bcfd97 2090 * 2) This function returns an array of wxDbColInf structures. If no columns
1e92909e
GT		 2091 * were found, or an error occured, this pointer will be zero (null). THE
2092 * CALLING FUNCTION IS RESPONSIBLE FOR DELETING THE MEMORY RETURNED WHEN IT
2093 * IS FINISHED WITH IT. i.e.
108106cf 2094 *
f6bcfd97 2095 * wxDbColInf *colInf = pDb->GetColumns(tableList, userID);
1e92909e
GT		 2096 * if (colInf)
2097 * {
2098 * // Use the column inf
2099 * .......
2100 * // Destroy the memory
2101 * delete [] colInf;
2102 * }
67e9aaa3
GT		 2103 *
2104 * userID is evaluated in the following manner:
1e92909e
GT		 2105 * userID == NULL ... UserID is ignored
2106 * userID == "" ... UserID set equal to 'this->uid'
2107 * userID != "" ... UserID set equal to 'userID'
67e9aaa3 2108 *
f6bcfd97
BP		 2109 * NOTE: ALL column bindings associated with this wxDb instance are unbound
2110 * by this function. This function should use its own wxDb instance
ea5d599d 2111 * to avoid undesired unbinding of columns.
108106cf 2112 */
108106cf 2113{
081eb1b1
GT		 2114 UWORD noCols = 0;
2115 UWORD colNo = 0;
f6bcfd97 2116 wxDbColInf *colInf = 0;
1e92909e
GT		 2117
2118 RETCODE retcode;
2119 SDWORD cb;
2120
1e92909e
GT		 2121 wxString TableName;
2122
4fdae997
GT		 2123 wxString UserID;
2124 convertUserID(userID,UserID);
1e92909e
GT		 2125
2126 // Pass 1 - Determine how many columns there are.
f6bcfd97 2127 // Pass 2 - Allocate the wxDbColInf array and fill in
1e92909e
GT		 2128 // the array with the column information.
2129 int pass;
2130 for (pass = 1; pass <= 2; pass++)
2131 {
2132 if (pass == 2)
2133 {
2134 if (noCols == 0) // Probably a bogus table name(s)
2135 break;
f6bcfd97
BP		 2136 // Allocate n wxDbColInf objects to hold the column information
2137 colInf = new wxDbColInf[noCols+1];
1e92909e
GT		 2138 if (!colInf)
2139 break;
2140 // Mark the end of the array
da99271d
GT		 2141 wxStrcpy(colInf[noCols].tableName,wxEmptyString);
2142 wxStrcpy(colInf[noCols].colName,wxEmptyString);
1e92909e
GT		 2143 colInf[noCols].sqlDataType = 0;
2144 }
2145 // Loop through each table name
2146 int tbl;
2147 for (tbl = 0; tableName[tbl]; tbl++)
2148 {
2149 TableName = tableName[tbl];
d8a0a1c9 2150 // Oracle and Interbase table names are uppercase only, so force
1e92909e 2151 // the name to uppercase just in case programmer forgot to do this
eedb1543 2152 if ((Dbms() == dbmsORACLE) ||
d8a0a1c9 2153 (Dbms() == dbmsINTERBASE))
1e92909e
GT		 2154 TableName = TableName.Upper();
2155
2156 SQLFreeStmt(hstmt, SQL_CLOSE);
2157
a8aa2258 2158 // MySQL, SQLServer, and Access cannot accept a user name when looking up column names, so we
1e92909e 2159 // use the call below that leaves out the user name
4fdae997
GT		 2160 if (!UserID.IsEmpty() &&
2161 Dbms() != dbmsMY_SQL &&
2162 Dbms() != dbmsACCESS &&
2163 Dbms() != dbmsMS_SQL_SERVER)
1e92909e
GT		 2164 {
2165 retcode = SQLColumns(hstmt,
2166 NULL, 0, // All qualifiers
4fdae997 2167 (UCHAR *) UserID.c_str(), SQL_NTS, // Owner
f6bcfd97 2168 (UCHAR *) TableName.c_str(), SQL_NTS,
1e92909e
GT		 2169 NULL, 0); // All columns
2170 }
2171 else
2172 {
2173 retcode = SQLColumns(hstmt,
2174 NULL, 0, // All qualifiers
2175 NULL, 0, // Owner
f6bcfd97 2176 (UCHAR *) TableName.c_str(), SQL_NTS,
1e92909e
GT		 2177 NULL, 0); // All columns
2178 }
2179 if (retcode != SQL_SUCCESS)
2180 { // Error occured, abort
2181 DispAllErrors(henv, hdbc, hstmt);
2182 if (colInf)
2183 delete [] colInf;
2184 SQLFreeStmt(hstmt, SQL_CLOSE);
2185 return(0);
2186 }
2187
2188 while ((retcode = SQLFetch(hstmt)) == SQL_SUCCESS)
2189 {
2190 if (pass == 1) // First pass, just add up the number of columns
2191 noCols++;
2192 else // Pass 2; Fill in the array of structures
2193 {
2194 if (colNo < noCols) // Some extra error checking to prevent memory overwrites
2195 {
2196 // NOTE: Only the ODBC 1.x fields are retrieved
2197 GetData( 1, SQL_C_CHAR, (UCHAR*) colInf[colNo].catalog, 128+1, &cb);
2198 GetData( 2, SQL_C_CHAR, (UCHAR*) colInf[colNo].schema, 128+1, &cb);
2199 GetData( 3, SQL_C_CHAR, (UCHAR*) colInf[colNo].tableName, DB_MAX_TABLE_NAME_LEN+1, &cb);
2200 GetData( 4, SQL_C_CHAR, (UCHAR*) colInf[colNo].colName, DB_MAX_COLUMN_NAME_LEN+1, &cb);
2201 GetData( 5, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].sqlDataType, 0, &cb);
2202 GetData( 6, SQL_C_CHAR, (UCHAR*) colInf[colNo].typeName, 128+1, &cb);
2203 GetData( 7, SQL_C_SLONG, (UCHAR*) &colInf[colNo].columnSize, 0, &cb);
2204 GetData( 8, SQL_C_SLONG, (UCHAR*) &colInf[colNo].bufferLength, 0, &cb);
2205 GetData( 9, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].decimalDigits,0, &cb);
2206 GetData(10, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].numPrecRadix, 0, &cb);
2207 GetData(11, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].nullable, 0, &cb);
52a17fe5 2208 GetData(12, SQL_C_CHAR, (UCHAR*) colInf[colNo].remarks, 254+1, &cb);
eedb1543 2209
f6bcfd97 2210 // Determine the wxDb data type that is used to represent the native data type of this data source
1e92909e
GT		 2211 colInf[colNo].dbDataType = 0;
2212 if (!wxStricmp(typeInfVarchar.TypeName,colInf[colNo].typeName))
52a17fe5 2213 {
eedb1543 2214#ifdef _IODBC_
a8aa2258
GT		 2215 // IODBC does not return a correct columnSize, so we set
2216 // columnSize = bufferLength if no column size was returned
2217 // IODBC returns the columnSize in bufferLength.. (bug)
52a17fe5
GT		 2218 if (colInf[colNo].columnSize < 1)
2219 {
52a17fe5
GT		 2220 colInf[colNo].columnSize = colInf[colNo].bufferLength;
2221 }
a8aa2258 2222#endif
1e92909e 2223 colInf[colNo].dbDataType = DB_DATA_TYPE_VARCHAR;
52a17fe5 2224 }
bf5423ea 2225 else if (!wxStricmp(typeInfInteger.TypeName, colInf[colNo].typeName))
1e92909e 2226 colInf[colNo].dbDataType = DB_DATA_TYPE_INTEGER;
bf5423ea 2227 else if (!wxStricmp(typeInfFloat.TypeName, colInf[colNo].typeName))
1e92909e 2228 colInf[colNo].dbDataType = DB_DATA_TYPE_FLOAT;
bf5423ea 2229 else if (!wxStricmp(typeInfDate.TypeName, colInf[colNo].typeName))
1e92909e 2230 colInf[colNo].dbDataType = DB_DATA_TYPE_DATE;
bf5423ea
GT		 2231 else if (!wxStricmp(typeInfBlob.TypeName, colInf[colNo].typeName))
2232 colInf[colNo].dbDataType = DB_DATA_TYPE_BLOB;
1e92909e
GT		 2233 colNo++;
2234 }
2235 }
2236 }
2237 if (retcode != SQL_NO_DATA_FOUND)
2238 { // Error occured, abort
2239 DispAllErrors(henv, hdbc, hstmt);
2240 if (colInf)
2241 delete [] colInf;
2242 SQLFreeStmt(hstmt, SQL_CLOSE);
2243 return(0);
2244 }
2245 }
2246 }
2247
2248 SQLFreeStmt(hstmt, SQL_CLOSE);
2249 return colInf;
108106cf 2250
f6bcfd97 2251} // wxDb::GetColumns()
108106cf
JS		 2252
2253
f6bcfd97
BP		 2254/********** wxDb::GetColumns() **********/
2255
02cf6fdd 2256wxDbColInf *wxDb::GetColumns(const wxString &tableName, UWORD *numCols, const wxChar *userID)
f6bcfd97
BP		 2257//
2258// Same as the above GetColumns() function except this one gets columns
2259// only for a single table, and if 'numCols' is not NULL, the number of
2260// columns stored in the returned wxDbColInf is set in '*numCols'
2261//
2262// userID is evaluated in the following manner:
2263// userID == NULL ... UserID is ignored
2264// userID == "" ... UserID set equal to 'this->uid'
2265// userID != "" ... UserID set equal to 'userID'
2266//
2267// NOTE: ALL column bindings associated with this wxDb instance are unbound
2268// by this function. This function should use its own wxDb instance
2269// to avoid undesired unbinding of columns.
2270
67e9aaa3 2271{
02cf6fdd 2272 UWORD noCols = 0;
e938ff5e 2273 UWORD colNo = 0;
f6bcfd97 2274 wxDbColInf *colInf = 0;
1e92909e
GT		 2275
2276 RETCODE retcode;
2277 SDWORD cb;
2278
1e92909e
GT		 2279 wxString TableName;
2280
4fdae997
GT		 2281 wxString UserID;
2282 convertUserID(userID,UserID);
1e92909e
GT		 2283
2284 // Pass 1 - Determine how many columns there are.
f6bcfd97 2285 // Pass 2 - Allocate the wxDbColInf array and fill in
1e92909e
GT		 2286 // the array with the column information.
2287 int pass;
2288 for (pass = 1; pass <= 2; pass++)
2289 {
2290 if (pass == 2)
2291 {
2292 if (noCols == 0) // Probably a bogus table name(s)
2293 break;
f6bcfd97
BP		 2294 // Allocate n wxDbColInf objects to hold the column information
2295 colInf = new wxDbColInf[noCols+1];
1e92909e
GT		 2296 if (!colInf)
2297 break;
2298 // Mark the end of the array
da99271d
GT		 2299 wxStrcpy(colInf[noCols].tableName, wxEmptyString);
2300 wxStrcpy(colInf[noCols].colName, wxEmptyString);
4fdae997 2301 colInf[noCols].sqlDataType = 0;
1e92909e
GT		 2302 }
2303
2304 TableName = tableName;
d8a0a1c9 2305 // Oracle and Interbase table names are uppercase only, so force
1e92909e 2306 // the name to uppercase just in case programmer forgot to do this
eedb1543 2307 if ((Dbms() == dbmsORACLE) ||
d8a0a1c9 2308 (Dbms() == dbmsINTERBASE))
1e92909e
GT		 2309 TableName = TableName.Upper();
2310
2311 SQLFreeStmt(hstmt, SQL_CLOSE);
2312
a8aa2258 2313 // MySQL, SQLServer, and Access cannot accept a user name when looking up column names, so we
1e92909e 2314 // use the call below that leaves out the user name
4fdae997
GT		 2315 if (!UserID.IsEmpty() &&
2316 Dbms() != dbmsMY_SQL &&
2317 Dbms() != dbmsACCESS &&
2318 Dbms() != dbmsMS_SQL_SERVER)
1e92909e
GT		 2319 {
2320 retcode = SQLColumns(hstmt,
2321 NULL, 0, // All qualifiers
f6bcfd97
BP		 2322 (UCHAR *) UserID.c_str(), SQL_NTS, // Owner
2323 (UCHAR *) TableName.c_str(), SQL_NTS,
1e92909e
GT		 2324 NULL, 0); // All columns
2325 }
2326 else
2327 {
2328 retcode = SQLColumns(hstmt,
2329 NULL, 0, // All qualifiers
2330 NULL, 0, // Owner
f6bcfd97 2331 (UCHAR *) TableName.c_str(), SQL_NTS,
1e92909e
GT		 2332 NULL, 0); // All columns
2333 }
2334 if (retcode != SQL_SUCCESS)
2335 { // Error occured, abort
2336 DispAllErrors(henv, hdbc, hstmt);
2337 if (colInf)
2338 delete [] colInf;
2339 SQLFreeStmt(hstmt, SQL_CLOSE);
2340 if (numCols)
2341 *numCols = 0;
2342 return(0);
2343 }
2344
2345 while ((retcode = SQLFetch(hstmt)) == SQL_SUCCESS)
2346 {
2347 if (pass == 1) // First pass, just add up the number of columns
2348 noCols++;
2349 else // Pass 2; Fill in the array of structures
2350 {
2351 if (colNo < noCols) // Some extra error checking to prevent memory overwrites
2352 {
2353 // NOTE: Only the ODBC 1.x fields are retrieved
2354 GetData( 1, SQL_C_CHAR, (UCHAR*) colInf[colNo].catalog, 128+1, &cb);
2355 GetData( 2, SQL_C_CHAR, (UCHAR*) colInf[colNo].schema, 128+1, &cb);
2356 GetData( 3, SQL_C_CHAR, (UCHAR*) colInf[colNo].tableName, DB_MAX_TABLE_NAME_LEN+1, &cb);
2357 GetData( 4, SQL_C_CHAR, (UCHAR*) colInf[colNo].colName, DB_MAX_COLUMN_NAME_LEN+1, &cb);
2358 GetData( 5, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].sqlDataType, 0, &cb);
2359 GetData( 6, SQL_C_CHAR, (UCHAR*) colInf[colNo].typeName, 128+1, &cb);
2360 GetData( 7, SQL_C_SLONG, (UCHAR*) &colInf[colNo].columnSize, 0, &cb);
67e9aaa3 2361 // BJO 991214 : SQL_C_SSHORT instead of SQL_C_SLONG, otherwise fails on Sparc (probably all 64 bit architectures)
23f681ec 2362 GetData( 8, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].bufferLength, 0, &cb);
1e92909e
GT		 2363 GetData( 9, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].decimalDigits,0, &cb);
2364 GetData(10, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].numPrecRadix, 0, &cb);
2365 GetData(11, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].nullable, 0, &cb);
2366 GetData(12, SQL_C_CHAR, (UCHAR*) colInf[colNo].remarks, 254+1, &cb);
67e9aaa3
GT		 2367 // Start Values for Primary/Foriegn Key (=No)
2368 colInf[colNo].PkCol = 0; // Primary key column 0=No; 1= First Key, 2 = Second Key etc.
2369 colInf[colNo].PkTableName[0] = 0; // Tablenames where Primary Key is used as a Foreign Key
2370 colInf[colNo].FkCol = 0; // Foreign key column 0=No; 1= First Key, 2 = Second Key etc.
2371 colInf[colNo].FkTableName[0] = 0; // Foreign key table name
2372
3ca6a5f0
BP		 2373 // BJO 20000428 : Virtuoso returns type names with upper cases!
2374 if (Dbms() == dbmsVIRTUOSO)
2375 {
4fdae997 2376 wxString s = colInf[colNo].typeName;
3ca6a5f0 2377 s = s.MakeLower();
eedb1543 2378 wxStrcmp(colInf[colNo].typeName, s.c_str());
3ca6a5f0 2379 }
eedb1543 2380
3ca6a5f0
BP		 2381 // Determine the wxDb data type that is used to represent the native data type of this data source
2382 colInf[colNo].dbDataType = 0;
bf5423ea 2383 if (!wxStricmp(typeInfVarchar.TypeName, colInf[colNo].typeName))
3ca6a5f0 2384 {
eedb1543 2385#ifdef _IODBC_
a8aa2258
GT		 2386 // IODBC does not return a correct columnSize, so we set
2387 // columnSize = bufferLength if no column size was returned
2388 // IODBC returns the columnSize in bufferLength.. (bug)
3ca6a5f0
BP		 2389 if (colInf[colNo].columnSize < 1)
2390 {
a8aa2258 2391 colInf[colNo].columnSize = colInf[colNo].bufferLength;
3ca6a5f0 2392 }
a8aa2258
GT		 2393#endif
2394
3ca6a5f0
BP		 2395 colInf[colNo].dbDataType = DB_DATA_TYPE_VARCHAR;
2396 }
bf5423ea 2397 else if (!wxStricmp(typeInfInteger.TypeName, colInf[colNo].typeName))
3ca6a5f0 2398 colInf[colNo].dbDataType = DB_DATA_TYPE_INTEGER;
bf5423ea 2399 else if (!wxStricmp(typeInfFloat.TypeName, colInf[colNo].typeName))
3ca6a5f0 2400 colInf[colNo].dbDataType = DB_DATA_TYPE_FLOAT;
bf5423ea 2401 else if (!wxStricmp(typeInfDate.TypeName, colInf[colNo].typeName))
eedb1543 2402 colInf[colNo].dbDataType = DB_DATA_TYPE_DATE;
bf5423ea
GT		 2403 else if (!wxStricmp(typeInfBlob.TypeName, colInf[colNo].typeName))
2404 colInf[colNo].dbDataType = DB_DATA_TYPE_BLOB;
eedb1543 2405
1e92909e
GT		 2406 colNo++;
2407 }
2408 }
2409 }
2410 if (retcode != SQL_NO_DATA_FOUND)
3ca6a5f0 2411 { // Error occured, abort
1e92909e
GT		 2412 DispAllErrors(henv, hdbc, hstmt);
2413 if (colInf)
3ca6a5f0 2414 delete [] colInf;
1e92909e
GT		 2415 SQLFreeStmt(hstmt, SQL_CLOSE);
2416 if (numCols)
3ca6a5f0 2417 *numCols = 0;
1e92909e 2418 return(0);
3ca6a5f0 2419 }
1e92909e 2420 }
67e9aaa3
GT		 2421
2422 SQLFreeStmt(hstmt, SQL_CLOSE);
2423
2424 // Store Primary and Foriegn Keys
2425 GetKeyFields(tableName,colInf,noCols);
2426
2427 if (numCols)
1e92909e
GT		 2428 *numCols = noCols;
2429 return colInf;
67e9aaa3 2430
f6bcfd97
BP		 2431} // wxDb::GetColumns()
2432
f6bcfd97 2433
3ca6a5f0 2434#else // New GetColumns
67e9aaa3
GT		 2435
2436
f6bcfd97 2437/*
3ca6a5f0
BP		 2438 BJO 20000503
2439 These are tentative new GetColumns members which should be more database
eedb1543 2440 independant and which always returns the columns in the order they were
3ca6a5f0
BP		 2441 created.
2442
4fdae997
GT		 2443 - The first one (wxDbColInf *wxDb::GetColumns(wxChar *tableName[], const
2444 wxChar* userID)) calls the second implementation for each separate table
eedb1543 2445 before merging the results. This makes the code easier to maintain as
3ca6a5f0 2446 only one member (the second) makes the real work
4fdae997
GT		 2447 - wxDbColInf *wxDb::GetColumns(const wxString &tableName, int *numCols, const
2448 wxChar *userID) is a little bit improved
eedb1543 2449 - It doesn't anymore rely on the type-name to find out which database-type
3ca6a5f0 2450 each column has
eedb1543 2451 - It ends by sorting the columns, so that they are returned in the same
3ca6a5f0 2452 order they were created
f6bcfd97
BP		 2453*/
2454
2455typedef struct
2456{
02cf6fdd 2457 UWORD noCols;
3ca6a5f0 2458 wxDbColInf *colInf;
f6bcfd97
BP		 2459} _TableColumns;
2460
3ca6a5f0 2461
4fdae997 2462wxDbColInf *wxDb::GetColumns(wxChar *tableName[], const wxChar *userID)
f6bcfd97 2463{
3ca6a5f0
BP		 2464 int i, j;
2465 // The last array element of the tableName[] argument must be zero (null).
2466 // This is how the end of the array is detected.
2467
02cf6fdd 2468 UWORD noCols = 0;
3ca6a5f0
BP		 2469
2470 // How many tables ?
2471 int tbl;
eedb1543
DW		 2472 for (tbl = 0 ; tableName[tbl]; tbl++);
2473
3ca6a5f0
BP		 2474 // Create a table to maintain the columns for each separate table
2475 _TableColumns *TableColumns = new _TableColumns[tbl];
eedb1543 2476
3ca6a5f0
BP		 2477 // Fill the table
2478 for (i = 0 ; i < tbl ; i++)
eedb1543 2479
3ca6a5f0
BP		 2480 {
2481 TableColumns[i].colInf = GetColumns(tableName[i], &TableColumns[i].noCols, userID);
eedb1543 2482 if (TableColumns[i].colInf == NULL)
3ca6a5f0
BP		 2483 return NULL;
2484 noCols += TableColumns[i].noCols;
2485 }
eedb1543 2486
3ca6a5f0
BP		 2487 // Now merge all the separate table infos
2488 wxDbColInf *colInf = new wxDbColInf[noCols+1];
eedb1543 2489
3ca6a5f0 2490 // Mark the end of the array
da99271d
GT		 2491 wxStrcpy(colInf[noCols].tableName, wxEmptyString);
2492 wxStrcpy(colInf[noCols].colName, wxEmptyString);
4fdae997 2493 colInf[noCols].sqlDataType = 0;
eedb1543 2494
3ca6a5f0
BP		 2495 // Merge ...
2496 int offset = 0;
eedb1543 2497
3ca6a5f0
BP		 2498 for (i = 0 ; i < tbl ; i++)
2499 {
2500 for (j = 0 ; j < TableColumns[i].noCols ; j++)
2501 {
eedb1543 2502 colInf[offset++] = TableColumns[i].colInf[j];
3ca6a5f0
BP		 2503 }
2504 }
eedb1543 2505
3ca6a5f0 2506 delete [] TableColumns;
eedb1543 2507
3ca6a5f0
BP		 2508 return colInf;
2509} // wxDb::GetColumns() -- NEW
f6bcfd97
BP		 2510
2511
4fdae997 2512wxDbColInf *wxDb::GetColumns(const wxString &tableName, int *numCols, const wxChar *userID)
3ca6a5f0
BP		 2513//
2514// Same as the above GetColumns() function except this one gets columns
2515// only for a single table, and if 'numCols' is not NULL, the number of
2516// columns stored in the returned wxDbColInf is set in '*numCols'
2517//
2518// userID is evaluated in the following manner:
2519// userID == NULL ... UserID is ignored
2520// userID == "" ... UserID set equal to 'this->uid'
2521// userID != "" ... UserID set equal to 'userID'
2522//
2523// NOTE: ALL column bindings associated with this wxDb instance are unbound
2524// by this function. This function should use its own wxDb instance
2525// to avoid undesired unbinding of columns.
f6bcfd97 2526{
02cf6fdd 2527 UWORD noCols = 0;
e938ff5e 2528 UWORD colNo = 0;
3ca6a5f0 2529 wxDbColInf *colInf = 0;
eedb1543 2530
3ca6a5f0
BP		 2531 RETCODE retcode;
2532 SDWORD cb;
eedb1543 2533
3ca6a5f0 2534 wxString TableName;
eedb1543 2535
4fdae997
GT		 2536 wxString UserID;
2537 convertUserID(userID,UserID);
eedb1543 2538
3ca6a5f0
BP		 2539 // Pass 1 - Determine how many columns there are.
2540 // Pass 2 - Allocate the wxDbColInf array and fill in
2541 // the array with the column information.
2542 int pass;
2543 for (pass = 1; pass <= 2; pass++)
2544 {
2545 if (pass == 2)
f6bcfd97 2546 {
3ca6a5f0
BP		 2547 if (noCols == 0) // Probably a bogus table name(s)
2548 break;
2549 // Allocate n wxDbColInf objects to hold the column information
2550 colInf = new wxDbColInf[noCols+1];
2551 if (!colInf)
2552 break;
2553 // Mark the end of the array
da99271d
GT		 2554 wxStrcpy(colInf[noCols].tableName, wxEmptyString);
2555 wxStrcpy(colInf[noCols].colName, wxEmptyString);
3ca6a5f0 2556 colInf[noCols].sqlDataType = 0;
f6bcfd97 2557 }
eedb1543 2558
3ca6a5f0 2559 TableName = tableName;
d8a0a1c9 2560 // Oracle and Interbase table names are uppercase only, so force
3ca6a5f0 2561 // the name to uppercase just in case programmer forgot to do this
eedb1543 2562 if ((Dbms() == dbmsORACLE) ||
d8a0a1c9 2563 (Dbms() == dbmsINTERBASE))
3ca6a5f0 2564 TableName = TableName.Upper();
eedb1543 2565
3ca6a5f0 2566 SQLFreeStmt(hstmt, SQL_CLOSE);
eedb1543 2567
a8aa2258 2568 // MySQL, SQLServer, and Access cannot accept a user name when looking up column names, so we
3ca6a5f0 2569 // use the call below that leaves out the user name
4fdae997 2570 if (!UserID.IsEmpty() &&
3ca6a5f0 2571 Dbms() != dbmsMY_SQL &&
a8aa2258
GT		 2572 Dbms() != dbmsACCESS &&
2573 Dbms() != dbmsMS_SQL_SERVER)
f6bcfd97 2574 {
3ca6a5f0
BP		 2575 retcode = SQLColumns(hstmt,
2576 NULL, 0, // All qualifiers
2577 (UCHAR *) UserID.c_str(), SQL_NTS, // Owner
2578 (UCHAR *) TableName.c_str(), SQL_NTS,
2579 NULL, 0); // All columns
f6bcfd97 2580 }
3ca6a5f0 2581 else
f6bcfd97 2582 {
3ca6a5f0
BP		 2583 retcode = SQLColumns(hstmt,
2584 NULL, 0, // All qualifiers
2585 NULL, 0, // Owner
2586 (UCHAR *) TableName.c_str(), SQL_NTS,
2587 NULL, 0); // All columns
f6bcfd97 2588 }
3ca6a5f0 2589 if (retcode != SQL_SUCCESS)
f6bcfd97 2590 { // Error occured, abort
3ca6a5f0
BP		 2591 DispAllErrors(henv, hdbc, hstmt);
2592 if (colInf)
2593 delete [] colInf;
2594 SQLFreeStmt(hstmt, SQL_CLOSE);
2595 if (numCols)
2596 *numCols = 0;
2597 return(0);
f6bcfd97 2598 }
eedb1543 2599
f6bcfd97
BP		 2600 while ((retcode = SQLFetch(hstmt)) == SQL_SUCCESS)
2601 {
2602 if (pass == 1) // First pass, just add up the number of columns
2603 noCols++;
2604 else // Pass 2; Fill in the array of structures
2605 {
2606 if (colNo < noCols) // Some extra error checking to prevent memory overwrites
2607 {
2608 // NOTE: Only the ODBC 1.x fields are retrieved
2609 GetData( 1, SQL_C_CHAR, (UCHAR*) colInf[colNo].catalog, 128+1, &cb);
2610 GetData( 2, SQL_C_CHAR, (UCHAR*) colInf[colNo].schema, 128+1, &cb);
2611 GetData( 3, SQL_C_CHAR, (UCHAR*) colInf[colNo].tableName, DB_MAX_TABLE_NAME_LEN+1, &cb);
2612 GetData( 4, SQL_C_CHAR, (UCHAR*) colInf[colNo].colName, DB_MAX_COLUMN_NAME_LEN+1, &cb);
2613 GetData( 5, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].sqlDataType, 0, &cb);
2614 GetData( 6, SQL_C_CHAR, (UCHAR*) colInf[colNo].typeName, 128+1, &cb);
eedb1543 2615 GetData( 7, SQL_C_SLONG, (UCHAR*) &colInf[colNo].columnSize, 0, &cb);
f6bcfd97
BP		 2616 GetData( 8, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].bufferLength, 0, &cb);
2617 GetData( 9, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].decimalDigits,0, &cb);
2618 GetData(10, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].numPrecRadix, 0, &cb);
2619 GetData(11, SQL_C_SSHORT, (UCHAR*) &colInf[colNo].nullable, 0, &cb);
2620 GetData(12, SQL_C_CHAR, (UCHAR*) colInf[colNo].remarks, 254+1, &cb);
2621 // Start Values for Primary/Foriegn Key (=No)
2622 colInf[colNo].PkCol = 0; // Primary key column 0=No; 1= First Key, 2 = Second Key etc.
2623 colInf[colNo].PkTableName[0] = 0; // Tablenames where Primary Key is used as a Foreign Key
2624 colInf[colNo].FkCol = 0; // Foreign key column 0=No; 1= First Key, 2 = Second Key etc.
2625 colInf[colNo].FkTableName[0] = 0; // Foreign key table name
eedb1543
DW		 2626
2627#ifdef _IODBC_
a8aa2258
GT		 2628 // IODBC does not return a correct columnSize, so we set
2629 // columnSize = bufferLength if no column size was returned
3ca6a5f0 2630 // IODBC returns the columnSize in bufferLength.. (bug)
a8aa2258
GT		 2631 if (colInf[colNo].columnSize < 1)
2632 {
2633 colInf[colNo].columnSize = colInf[colNo].bufferLength;
2634 }
f6bcfd97 2635#endif
eedb1543 2636
3ca6a5f0
BP		 2637 // Determine the wxDb data type that is used to represent the native data type of this data source
2638 colInf[colNo].dbDataType = 0;
2639 // Get the intern datatype
2640 switch (colInf[colNo].sqlDataType)
2641 {
2642 case SQL_VARCHAR:
2643 case SQL_CHAR:
eedb1543 2644 colInf[colNo].dbDataType = DB_DATA_TYPE_VARCHAR;
3ca6a5f0 2645 break;
eedb1543 2646
3ca6a5f0
BP		 2647 case SQL_TINYINT:
2648 case SQL_SMALLINT:
2649 case SQL_INTEGER:
eedb1543 2650 colInf[colNo].dbDataType = DB_DATA_TYPE_INTEGER;
3ca6a5f0
BP		 2651 break;
2652 case SQL_DOUBLE:
2653 case SQL_DECIMAL:
2654 case SQL_NUMERIC:
2655 case SQL_FLOAT:
2656 case SQL_REAL:
eedb1543 2657 colInf[colNo].dbDataType = DB_DATA_TYPE_FLOAT;
3ca6a5f0
BP		 2658 break;
2659 case SQL_DATE:
eedb1543 2660 colInf[colNo].dbDataType = DB_DATA_TYPE_DATE;
3ca6a5f0 2661 break;
bf5423ea
GT		 2662 case SQL_BINARY:
2663 colInf[colNo].dbDataType = DB_DATA_TYPE_BLOB;
2664 break;
f6bcfd97 2665#ifdef __WXDEBUG__
3ca6a5f0
BP		 2666 default:
2667 wxString errMsg;
4fdae997 2668 errMsg.Printf(wxT("SQL Data type %d currently not supported by wxWindows"), colInf[colNo].sqlDataType);
3ca6a5f0 2669 wxLogDebug(errMsg,wxT("ODBC DEBUG MESSAGE"));
eedb1543 2670#endif
3ca6a5f0 2671 }
f6bcfd97
BP		 2672 colNo++;
2673 }
2674 }
2675 }
2676 if (retcode != SQL_NO_DATA_FOUND)
3ca6a5f0 2677 { // Error occured, abort
f6bcfd97
BP		 2678 DispAllErrors(henv, hdbc, hstmt);
2679 if (colInf)
3ca6a5f0 2680 delete [] colInf;
f6bcfd97
BP		 2681 SQLFreeStmt(hstmt, SQL_CLOSE);
2682 if (numCols)
3ca6a5f0 2683 *numCols = 0;
f6bcfd97 2684 return(0);
3ca6a5f0
BP		 2685 }
2686 }
eedb1543 2687
3ca6a5f0 2688 SQLFreeStmt(hstmt, SQL_CLOSE);
eedb1543 2689
3ca6a5f0
BP		 2690 // Store Primary and Foreign Keys
2691 GetKeyFields(tableName,colInf,noCols);
2692
2693 ///////////////////////////////////////////////////////////////////////////
2694 // Now sort the the columns in order to make them appear in the right order
2695 ///////////////////////////////////////////////////////////////////////////
eedb1543 2696
3ca6a5f0
BP		 2697 // Build a generic SELECT statement which returns 0 rows
2698 wxString Stmt;
eedb1543 2699
4fdae997 2700 Stmt.Printf(wxT("select * from %s where 0=1"), tableName);
eedb1543
DW		 2701
2702 // Execute query
3ca6a5f0
BP		 2703 if (SQLExecDirect(hstmt, (UCHAR FAR *) Stmt.c_str(), SQL_NTS) != SQL_SUCCESS)
2704 {
2705 DispAllErrors(henv, hdbc, hstmt);
2706 return NULL;
eedb1543
DW		 2707 }
2708
3ca6a5f0
BP		 2709 // Get the number of result columns
2710 if (SQLNumResultCols (hstmt, &noCols) != SQL_SUCCESS)
2711 {
2712 DispAllErrors(henv, hdbc, hstmt);
2713 return NULL;
2714 }
eedb1543 2715
3ca6a5f0
BP		 2716 if (noCols == 0) // Probably a bogus table name
2717 return NULL;
eedb1543
DW		 2718
2719 // Get the name
3ca6a5f0
BP		 2720 int i;
2721 short colNum;
2722 UCHAR name[100];
2723 SWORD Sword;
2724 SDWORD Sdword;
2725 for (colNum = 0; colNum < noCols; colNum++)
eedb1543
DW		 2726 {
2727 if (SQLColAttributes(hstmt,colNum+1, SQL_COLUMN_NAME,
2728 name, sizeof(name),
3ca6a5f0
BP		 2729 &Sword, &Sdword) != SQL_SUCCESS)
2730 {
2731 DispAllErrors(henv, hdbc, hstmt);
2732 return NULL;
eedb1543
DW		 2733 }
2734
3ca6a5f0
BP		 2735 wxString Name1 = name;
2736 Name1 = Name1.Upper();
eedb1543 2737
3ca6a5f0
BP		 2738 // Where is this name in the array ?
2739 for (i = colNum ; i < noCols ; i++)
2740 {
2741 wxString Name2 = colInf[i].colName;
2742 Name2 = Name2.Upper();
2743 if (Name2 == Name1)
2744 {
2745 if (colNum != i) // swap to sort
2746 {
2747 wxDbColInf tmpColInf = colInf[colNum];
2748 colInf[colNum] = colInf[i];
2749 colInf[i] = tmpColInf;
2750 }
2751 break;
eedb1543
DW		 2752 }
2753 }
2754 }
3ca6a5f0 2755 SQLFreeStmt(hstmt, SQL_CLOSE);
f6bcfd97 2756
3ca6a5f0
BP		 2757 ///////////////////////////////////////////////////////////////////////////
2758 // End sorting
2759 ///////////////////////////////////////////////////////////////////////////
f6bcfd97 2760
3ca6a5f0
BP		 2761 if (numCols)
2762 *numCols = noCols;
2763 return colInf;
eedb1543 2764
f6bcfd97
BP		 2765} // wxDb::GetColumns()
2766
2767
3ca6a5f0 2768#endif // #else OLD_GETCOLUMNS
f6bcfd97
BP		 2769
2770
2771/********** wxDb::GetColumnCount() **********/
02cf6fdd 2772UWORD wxDb::GetColumnCount(const wxString &tableName, const wxChar *userID)
67e9aaa3
GT		 2773/*
2774 * Returns a count of how many columns are in a table.
2775 * If an error occurs in computing the number of columns
2776 * this function will return a -1 for the count
2777 *
2778 * userID is evaluated in the following manner:
1e92909e
GT		 2779 * userID == NULL ... UserID is ignored
2780 * userID == "" ... UserID set equal to 'this->uid'
2781 * userID != "" ... UserID set equal to 'userID'
67e9aaa3 2782 *
f6bcfd97
BP		 2783 * NOTE: ALL column bindings associated with this wxDb instance are unbound
2784 * by this function. This function should use its own wxDb instance
67e9aaa3
GT		 2785 * to avoid undesired unbinding of columns.
2786 */
2787{
02cf6fdd 2788 UWORD noCols = 0;
1e92909e
GT		 2789
2790 RETCODE retcode;
2791
1e92909e
GT		 2792 wxString TableName;
2793
4fdae997
GT		 2794 wxString UserID;
2795 convertUserID(userID,UserID);
1e92909e 2796
4fdae997
GT		 2797 TableName = tableName;
2798 // Oracle and Interbase table names are uppercase only, so force
2799 // the name to uppercase just in case programmer forgot to do this
2800 if ((Dbms() == dbmsORACLE) ||
2801 (Dbms() == dbmsINTERBASE))
2802 TableName = TableName.Upper();
1e92909e 2803
4fdae997 2804 SQLFreeStmt(hstmt, SQL_CLOSE);
1e92909e 2805
4fdae997
GT		 2806 // MySQL, SQLServer, and Access cannot accept a user name when looking up column names, so we
2807 // use the call below that leaves out the user name
2808 if (!UserID.IsEmpty() &&
2809 Dbms() != dbmsMY_SQL &&
2810 Dbms() != dbmsACCESS &&
2811 Dbms() != dbmsMS_SQL_SERVER)
1e92909e 2812 {
4fdae997
GT		 2813 retcode = SQLColumns(hstmt,
2814 NULL, 0, // All qualifiers
2815 (UCHAR *) UserID.c_str(), SQL_NTS, // Owner
2816 (UCHAR *) TableName.c_str(), SQL_NTS,
2817 NULL, 0); // All columns
2818 }
2819 else
2820 {
2821 retcode = SQLColumns(hstmt,
2822 NULL, 0, // All qualifiers
2823 NULL, 0, // Owner
2824 (UCHAR *) TableName.c_str(), SQL_NTS,
2825 NULL, 0); // All columns
2826 }
2827 if (retcode != SQL_SUCCESS)
2828 { // Error occured, abort
2829 DispAllErrors(henv, hdbc, hstmt);
2830 SQLFreeStmt(hstmt, SQL_CLOSE);
2831 return(-1);
2832 }
1e92909e 2833
4fdae997
GT		 2834 // Count the columns
2835 while ((retcode = SQLFetch(hstmt)) == SQL_SUCCESS)
2836 noCols++;
1e92909e 2837
4fdae997
GT		 2838 if (retcode != SQL_NO_DATA_FOUND)
2839 { // Error occured, abort
2840 DispAllErrors(henv, hdbc, hstmt);
2841 SQLFreeStmt(hstmt, SQL_CLOSE);
2842 return(-1);
1e92909e
GT		 2843 }
2844
2845 SQLFreeStmt(hstmt, SQL_CLOSE);
2846 return noCols;
67e9aaa3 2847
f6bcfd97 2848} // wxDb::GetColumnCount()
67e9aaa3
GT		 2849
2850
f6bcfd97 2851/********** wxDb::GetCatalog() *******/
4fdae997 2852wxDbInf *wxDb::GetCatalog(const wxChar *userID)
67e9aaa3
GT		 2853/*
2854 * ---------------------------------------------------------------------
0cd121f9 2855 * -- 19991203 : mj10777 : Create ------
67e9aaa3
GT		 2856 * -- : Creates a wxDbInf with Tables / Cols Array ------
2857 * -- : uses SQLTables and fills pTableInf; ------
2858 * -- : pColInf is set to NULL and numCols to 0; ------
2859 * -- : returns pDbInf (wxDbInf) ------
2860 * -- - if unsuccesfull (pDbInf == NULL) ------
2861 * -- : pColInf can be filled with GetColumns(..); ------
2862 * -- : numCols can be filled with GetColumnCount(..); ------
2863 * ---------------------------------------------------------------------
2864 *
2865 * userID is evaluated in the following manner:
1e92909e
GT		 2866 * userID == NULL ... UserID is ignored
2867 * userID == "" ... UserID set equal to 'this->uid'
2868 * userID != "" ... UserID set equal to 'userID'
67e9aaa3 2869 *
f6bcfd97
BP		 2870 * NOTE: ALL column bindings associated with this wxDb instance are unbound
2871 * by this function. This function should use its own wxDb instance
67e9aaa3
GT		 2872 * to avoid undesired unbinding of columns.
2873 */
2874{
1e92909e
GT		 2875 wxDbInf *pDbInf = NULL; // Array of catalog entries
2876 int noTab = 0; // Counter while filling table entries
2877 int pass;
2878 RETCODE retcode;
2879 SDWORD cb;
1e92909e
GT		 2880 wxString tblNameSave;
2881
2882 wxString UserID;
4fdae997 2883 convertUserID(userID,UserID);
1e92909e
GT		 2884
2885 //-------------------------------------------------------------
4fdae997 2886 pDbInf = new wxDbInf; // Create the Database Array
1e92909e
GT		 2887 //-------------------------------------------------------------
2888 // Table Information
2889 // Pass 1 - Determine how many Tables there are.
2890 // Pass 2 - Create the Table array and fill it
2891 // - Create the Cols array = NULL
2892 //-------------------------------------------------------------
f6bcfd97 2893
1e92909e
GT		 2894 for (pass = 1; pass <= 2; pass++)
2895 {
2896 SQLFreeStmt(hstmt, SQL_CLOSE); // Close if Open
4fdae997 2897 tblNameSave.Empty();
1e92909e 2898
4fdae997 2899 if (!UserID.IsEmpty() &&
3ca6a5f0 2900 Dbms() != dbmsMY_SQL &&
4fdae997
GT		 2901 Dbms() != dbmsACCESS &&
2902 Dbms() != dbmsMS_SQL_SERVER)
1e92909e
GT		 2903 {
2904 retcode = SQLTables(hstmt,
2905 NULL, 0, // All qualifiers
3ca6a5f0 2906 (UCHAR *) UserID.c_str(), SQL_NTS, // User specified
1e92909e
GT		 2907 NULL, 0, // All tables
2908 NULL, 0); // All columns
2909 }
2910 else
2911 {
2912 retcode = SQLTables(hstmt,
2913 NULL, 0, // All qualifiers
2914 NULL, 0, // User specified
2915 NULL, 0, // All tables
2916 NULL, 0); // All columns
2917 }
f6bcfd97 2918
1e92909e
GT		 2919 if (retcode != SQL_SUCCESS)
2920 {
2921 DispAllErrors(henv, hdbc, hstmt);
2922 pDbInf = NULL;
2923 SQLFreeStmt(hstmt, SQL_CLOSE);
2924 return pDbInf;
2925 }
eedb1543 2926
1e92909e
GT		 2927 while ((retcode = SQLFetch(hstmt)) == SQL_SUCCESS) // Table Information
2928 {
2929 if (pass == 1) // First pass, just count the Tables
2930 {
2931 if (pDbInf->numTables == 0)
2932 {
2933 GetData( 1, SQL_C_CHAR, (UCHAR*) pDbInf->catalog, 128+1, &cb);
2934 GetData( 2, SQL_C_CHAR, (UCHAR*) pDbInf->schema, 128+1, &cb);
2935 }
2936 pDbInf->numTables++; // Counter for Tables
2937 } // if (pass == 1)
2938 if (pass == 2) // Create and fill the Table entries
2939 {
2940 if (pDbInf->pTableInf == NULL) // Has the Table Array been created
2941 { // no, then create the Array
f6bcfd97 2942 pDbInf->pTableInf = new wxDbTableInf[pDbInf->numTables];
1e92909e 2943 noTab = 0;
eedb1543 2944 } // if (pDbInf->pTableInf == NULL) // Has the Table Array been created
f6bcfd97 2945
1e92909e
GT		 2946 GetData( 3, SQL_C_CHAR, (UCHAR*) (pDbInf->pTableInf+noTab)->tableName, DB_MAX_TABLE_NAME_LEN+1, &cb);
2947 GetData( 4, SQL_C_CHAR, (UCHAR*) (pDbInf->pTableInf+noTab)->tableType, 30+1, &cb);
2948 GetData( 5, SQL_C_CHAR, (UCHAR*) (pDbInf->pTableInf+noTab)->tableRemarks, 254+1, &cb);
3ca6a5f0 2949
1e92909e 2950 noTab++;
3ca6a5f0
BP		 2951 } // if
2952 } // while
2953 } // for
1e92909e
GT		 2954 SQLFreeStmt(hstmt, SQL_CLOSE);
2955
2956 // Query how many columns are in each table
2957 for (noTab=0;noTab<pDbInf->numTables;noTab++)
2958 {
2959 (pDbInf->pTableInf+noTab)->numCols = GetColumnCount((pDbInf->pTableInf+noTab)->tableName,UserID);
2960 }
3ca6a5f0 2961
1e92909e 2962 return pDbInf;
3ca6a5f0 2963
f6bcfd97 2964} // wxDb::GetCatalog()
67e9aaa3
GT		 2965
2966
f6bcfd97 2967/********** wxDb::Catalog() **********/
4fdae997 2968bool wxDb::Catalog(const wxChar *userID, const wxString &fileName)
67e9aaa3
GT		 2969/*
2970 * Creates the text file specified in 'filename' which will contain
2971 * a minimal data dictionary of all tables accessible by the user specified
2972 * in 'userID'
2973 *
2974 * userID is evaluated in the following manner:
1e92909e
GT		 2975 * userID == NULL ... UserID is ignored
2976 * userID == "" ... UserID set equal to 'this->uid'
2977 * userID != "" ... UserID set equal to 'userID'
67e9aaa3 2978 *
f6bcfd97
BP		 2979 * NOTE: ALL column bindings associated with this wxDb instance are unbound
2980 * by this function. This function should use its own wxDb instance
67e9aaa3
GT		 2981 * to avoid undesired unbinding of columns.
2982 */
1fc5dd6f 2983{
4fdae997 2984 wxASSERT(fileName.Length());
1e92909e
GT		 2985
2986 RETCODE retcode;
2987 SDWORD cb;
4fdae997 2988 wxChar tblName[DB_MAX_TABLE_NAME_LEN+1];
1e92909e 2989 wxString tblNameSave;
4fdae997 2990 wxChar colName[DB_MAX_COLUMN_NAME_LEN+1];
1e92909e 2991 SWORD sqlDataType;
4fdae997 2992 wxChar typeName[30+1];
1e92909e
GT		 2993 SWORD precision, length;
2994
4fdae997 2995 FILE *fp = fopen(fileName.c_str(),wxT("wt"));
1e92909e
GT		 2996 if (fp == NULL)
2997 return(FALSE);
2998
2999 SQLFreeStmt(hstmt, SQL_CLOSE);
3000
4fdae997
GT		 3001 wxString UserID;
3002 convertUserID(userID,UserID);
1e92909e 3003
4fdae997
GT		 3004 if (!UserID.IsEmpty() &&
3005 Dbms() != dbmsMY_SQL &&
3006 Dbms() != dbmsACCESS &&
081eb1b1 3007 Dbms() != dbmsINTERBASE &&
4fdae997 3008 Dbms() != dbmsMS_SQL_SERVER)
1e92909e
GT		 3009 {
3010 retcode = SQLColumns(hstmt,
3011 NULL, 0, // All qualifiers
3ca6a5f0 3012 (UCHAR *) UserID.c_str(), SQL_NTS, // User specified
1e92909e
GT		 3013 NULL, 0, // All tables
3014 NULL, 0); // All columns
3015 }
3016 else
3017 {
3018 retcode = SQLColumns(hstmt,
3019 NULL, 0, // All qualifiers
3020 NULL, 0, // User specified
3021 NULL, 0, // All tables
3022 NULL, 0); // All columns
3023 }
3024 if (retcode != SQL_SUCCESS)
3025 {
3026 DispAllErrors(henv, hdbc, hstmt);
3027 fclose(fp);
3028 return(FALSE);
3029 }
3030
3031 wxString outStr;
4fdae997 3032 tblNameSave.Empty();
1e92909e
GT		 3033 int cnt = 0;
3034
3035 while ((retcode = SQLFetch(hstmt)) == SQL_SUCCESS)
3036 {
4fdae997 3037 if (wxStrcmp(tblName, tblNameSave.c_str()))
1e92909e
GT		 3038 {
3039 if (cnt)
4fdae997
GT		 3040 fputs(wxT("\n"), fp);
3041 fputs(wxT("================================ "), fp);
3042 fputs(wxT("================================ "), fp);
3043 fputs(wxT("===================== "), fp);
3044 fputs(wxT("========= "), fp);
3045 fputs(wxT("=========\n"), fp);
3046 outStr.Printf(wxT("%-32s %-32s %-21s %9s %9s\n"),
f6bcfd97
BP		 3047 wxT("TABLE NAME"), wxT("COLUMN NAME"), wxT("DATA TYPE"), wxT("PRECISION"), wxT("LENGTH"));
3048 fputs(outStr.c_str(), fp);
4fdae997
GT		 3049 fputs(wxT("================================ "), fp);
3050 fputs(wxT("================================ "), fp);
3051 fputs(wxT("===================== "), fp);
3052 fputs(wxT("========= "), fp);
3053 fputs(wxT("=========\n"), fp);
1e92909e
GT		 3054 tblNameSave = tblName;
3055 }
67e9aaa3
GT		 3056
3057 GetData(3,SQL_C_CHAR, (UCHAR *)tblName, DB_MAX_TABLE_NAME_LEN+1, &cb);
3058 GetData(4,SQL_C_CHAR, (UCHAR *)colName, DB_MAX_COLUMN_NAME_LEN+1,&cb);
3059 GetData(5,SQL_C_SSHORT,(UCHAR *)&sqlDataType,0, &cb);
3060 GetData(6,SQL_C_CHAR, (UCHAR *)typeName, sizeof(typeName), &cb);
3061 GetData(7,SQL_C_SSHORT,(UCHAR *)&precision, 0, &cb);
3062 GetData(8,SQL_C_SSHORT,(UCHAR *)&length, 0, &cb);
3063
4fdae997 3064 outStr.Printf(wxT("%-32s %-32s (%04d)%-15s %9d %9d\n"),
1e92909e 3065 tblName, colName, sqlDataType, typeName, precision, length);
f6bcfd97 3066 if (fputs(outStr.c_str(), fp) == EOF)
1e92909e
GT		 3067 {
3068 SQLFreeStmt(hstmt, SQL_CLOSE);
3069 fclose(fp);
3070 return(FALSE);
3071 }
3072 cnt++;
3073 }
1fc5dd6f 3074
1e92909e
GT		 3075 if (retcode != SQL_NO_DATA_FOUND)
3076 DispAllErrors(henv, hdbc, hstmt);
1fc5dd6f 3077
1e92909e 3078 SQLFreeStmt(hstmt, SQL_CLOSE);
a2115c88 3079
1e92909e
GT		 3080 fclose(fp);
3081 return(retcode == SQL_NO_DATA_FOUND);
1fc5dd6f 3082
f6bcfd97 3083} // wxDb::Catalog()
1fc5dd6f
JS		 3084
3085
4fdae997 3086bool wxDb::TableExists(const wxString &tableName, const wxChar *userID, const wxString &tablePath)
67e9aaa3
GT		 3087/*
3088 * Table name can refer to a table, view, alias or synonym. Returns true
3089 * if the object exists in the database. This function does not indicate
3090 * whether or not the user has privleges to query or perform other functions
3091 * on the table.
3092 *
3093 * userID is evaluated in the following manner:
1e92909e
GT		 3094 * userID == NULL ... UserID is ignored
3095 * userID == "" ... UserID set equal to 'this->uid'
3096 * userID != "" ... UserID set equal to 'userID'
67e9aaa3 3097 */
108106cf 3098{
4fdae997 3099 wxASSERT(tableName.Length());
eedb1543 3100
4fdae997 3101 wxString TableName;
eedb1543
DW		 3102
3103 if (Dbms() == dbmsDBASE)
1e92909e 3104 {
3ca6a5f0 3105 wxString dbName;
4fdae997 3106 if (tablePath.Length())
942e67c3 3107 dbName.Printf(wxT("%s/%s.dbf"), tablePath.c_str(), tableName.c_str());
3ca6a5f0 3108 else
942e67c3 3109 dbName.Printf(wxT("%s.dbf"), tableName.c_str());
eedb1543 3110
3ca6a5f0 3111 bool exists;
4fdae997 3112 exists = wxFileExists(dbName);
3ca6a5f0 3113 return exists;
1e92909e 3114 }
eedb1543 3115
4fdae997
GT		 3116 wxString UserID;
3117 convertUserID(userID,UserID);
eedb1543 3118
1e92909e 3119 TableName = tableName;
d8a0a1c9 3120 // Oracle and Interbase table names are uppercase only, so force
1e92909e 3121 // the name to uppercase just in case programmer forgot to do this
eedb1543 3122 if ((Dbms() == dbmsORACLE) ||
d8a0a1c9 3123 (Dbms() == dbmsINTERBASE))
1e92909e 3124 TableName = TableName.Upper();
eedb1543 3125
1e92909e
GT		 3126 SQLFreeStmt(hstmt, SQL_CLOSE);
3127 RETCODE retcode;
eedb1543 3128
a8aa2258
GT		 3129 // Some databases cannot accept a user name when looking up table names,
3130 // so we use the call below that leaves out the user name
4fdae997 3131 if (!UserID.IsEmpty() &&
3ca6a5f0 3132 Dbms() != dbmsMY_SQL &&
a8aa2258 3133 Dbms() != dbmsACCESS &&
2beca662
GT		 3134 Dbms() != dbmsMS_SQL_SERVER &&
3135 Dbms() != dbmsDB2 &&
081eb1b1 3136 Dbms() != dbmsINTERBASE &&
2beca662 3137 Dbms() != dbmsPERVASIVE_SQL)
1e92909e
GT		 3138 {
3139 retcode = SQLTables(hstmt,
3ca6a5f0 3140 NULL, 0, // All qualifiers
a8aa2258 3141 (UCHAR *) UserID.c_str(), SQL_NTS, // Only tables owned by this user
f6bcfd97 3142 (UCHAR FAR *)TableName.c_str(), SQL_NTS,
3ca6a5f0 3143 NULL, 0); // All table types
1e92909e
GT		 3144 }
3145 else
3146 {
3147 retcode = SQLTables(hstmt,
3ca6a5f0
BP		 3148 NULL, 0, // All qualifiers
3149 NULL, 0, // All owners
f6bcfd97 3150 (UCHAR FAR *)TableName.c_str(), SQL_NTS,
3ca6a5f0 3151 NULL, 0); // All table types
1e92909e
GT		 3152 }
3153 if (retcode != SQL_SUCCESS)
3154 return(DispAllErrors(henv, hdbc, hstmt));
eedb1543 3155
1e92909e 3156 retcode = SQLFetch(hstmt);
a8aa2258 3157 if (retcode != SQL_SUCCESS && retcode != SQL_SUCCESS_WITH_INFO)
1e92909e
GT		 3158 {
3159 SQLFreeStmt(hstmt, SQL_CLOSE);
3160 return(DispAllErrors(henv, hdbc, hstmt));
3161 }
eedb1543 3162
1e92909e 3163 SQLFreeStmt(hstmt, SQL_CLOSE);
108106cf 3164
3ca6a5f0 3165 return(TRUE);
eedb1543 3166
f6bcfd97 3167} // wxDb::TableExists()
108106cf
JS		 3168
3169
a8aa2258 3170/********** wxDb::TablePrivileges() **********/
4fdae997
GT		 3171bool wxDb::TablePrivileges(const wxString &tableName, const wxString &priv, const wxChar *userID,
3172 const wxChar *schema, const wxString &tablePath)
3ca6a5f0 3173{
4fdae997
GT		 3174 wxASSERT(tableName.Length());
3175
3ca6a5f0
BP		 3176 wxDbTablePrivilegeInfo result;
3177 SDWORD cbRetVal;
3178 RETCODE retcode;
eedb1543 3179
4fdae997
GT		 3180 // We probably need to be able to dynamically set this based on
3181 // the driver type, and state.
3182 wxChar curRole[]=wxT("public");
eedb1543 3183
3ca6a5f0 3184 wxString TableName;
eedb1543 3185
02cf6fdd 3186 wxString UserID,Schema;
4fdae997 3187 convertUserID(userID,UserID);
02cf6fdd 3188 convertUserID(schema,Schema);
eedb1543 3189
3ca6a5f0 3190 TableName = tableName;
d8a0a1c9 3191 // Oracle and Interbase table names are uppercase only, so force
3ca6a5f0 3192 // the name to uppercase just in case programmer forgot to do this
eedb1543 3193 if ((Dbms() == dbmsORACLE) ||
d8a0a1c9 3194 (Dbms() == dbmsINTERBASE))
3ca6a5f0 3195 TableName = TableName.Upper();
eedb1543 3196
3ca6a5f0 3197 SQLFreeStmt(hstmt, SQL_CLOSE);
d8a0a1c9 3198
02cf6fdd
GT		 3199 // Some databases cannot accept a user name when looking up table names,
3200 // so we use the call below that leaves out the user name
3201 if (!Schema.IsEmpty() &&
3202 Dbms() != dbmsMY_SQL &&
3203 Dbms() != dbmsACCESS &&
3204 Dbms() != dbmsMS_SQL_SERVER)
d8a0a1c9
GT		 3205 {
3206 retcode = SQLTablePrivileges(hstmt,
3207 NULL, 0, // Catalog
02cf6fdd 3208 (UCHAR FAR *)Schema.c_str(), SQL_NTS, // Schema
eedb1543 3209 (UCHAR FAR *)TableName.c_str(), SQL_NTS);
d8a0a1c9
GT		 3210 }
3211 else
3212 {
3213 retcode = SQLTablePrivileges(hstmt,
3214 NULL, 0, // Catalog
02cf6fdd 3215 NULL, 0, // Schema
eedb1543 3216 (UCHAR FAR *)TableName.c_str(), SQL_NTS);
d8a0a1c9 3217 }
a8aa2258 3218
eedb1543 3219#ifdef DBDEBUG_CONSOLE
4fdae997 3220 fprintf(stderr ,wxT("SQLTablePrivileges() returned %i \n"),retcode);
3ca6a5f0 3221#endif
eedb1543 3222
a8aa2258
GT		 3223 if ((retcode != SQL_SUCCESS) && (retcode != SQL_SUCCESS_WITH_INFO))
3224 return(DispAllErrors(henv, hdbc, hstmt));
3225
5a226de0 3226 bool failed = FALSE;
d8a0a1c9 3227 retcode = SQLFetch(hstmt);
eedb1543 3228 while (retcode == SQL_SUCCESS || retcode == SQL_SUCCESS_WITH_INFO)
d8a0a1c9
GT		 3229 {
3230 if (SQLGetData(hstmt, 1, SQL_C_CHAR, (UCHAR*) result.tableQual, sizeof(result.tableQual), &cbRetVal) != SQL_SUCCESS)
5600884a 3231 failed = TRUE;
eedb1543 3232
5a226de0 3233 if (!failed && SQLGetData(hstmt, 2, SQL_C_CHAR, (UCHAR*) result.tableOwner, sizeof(result.tableOwner), &cbRetVal) != SQL_SUCCESS)
5600884a 3234 failed = TRUE;
eedb1543 3235
5a226de0 3236 if (!failed && SQLGetData(hstmt, 3, SQL_C_CHAR, (UCHAR*) result.tableName, sizeof(result.tableName), &cbRetVal) != SQL_SUCCESS)
5600884a 3237 failed = TRUE;
eedb1543 3238
5a226de0 3239 if (!failed && SQLGetData(hstmt, 4, SQL_C_CHAR, (UCHAR*) result.grantor, sizeof(result.grantor), &cbRetVal) != SQL_SUCCESS)
5600884a 3240 failed = TRUE;
eedb1543 3241
5a226de0 3242 if (!failed && SQLGetData(hstmt, 5, SQL_C_CHAR, (UCHAR*) result.grantee, sizeof(result.grantee), &cbRetVal) != SQL_SUCCESS)
5600884a 3243 failed = TRUE;
eedb1543 3244
5a226de0 3245 if (!failed && SQLGetData(hstmt, 6, SQL_C_CHAR, (UCHAR*) result.privilege, sizeof(result.privilege), &cbRetVal) != SQL_SUCCESS)
5600884a 3246 failed = TRUE;
eedb1543 3247
5a226de0 3248 if (!failed && SQLGetData(hstmt, 7, SQL_C_CHAR, (UCHAR*) result.grantable, sizeof(result.grantable), &cbRetVal) != SQL_SUCCESS)
5600884a 3249 failed = TRUE;
d8a0a1c9 3250
5a226de0
GT		 3251 if (failed)
3252 {
3253 return(DispAllErrors(henv, hdbc, hstmt));
3254 }
3ca6a5f0 3255#ifdef DBDEBUG_CONSOLE
4fdae997 3256 fprintf(stderr,wxT("Scanning %s privilege on table %s.%s granted by %s to %s\n"),
a8aa2258 3257 result.privilege,result.tableOwner,result.tableName,
3ca6a5f0 3258 result.grantor, result.grantee);
eedb1543 3259#endif
d8a0a1c9 3260
eedb1543 3261 if (UserID.IsSameAs(result.tableOwner,FALSE))
a8aa2258
GT		 3262 {
3263 SQLFreeStmt(hstmt, SQL_CLOSE);
3ca6a5f0 3264 return TRUE;
a8aa2258 3265 }
eedb1543
DW		 3266
3267 if (UserID.IsSameAs(result.grantee,FALSE) &&
a8aa2258
GT		 3268 !wxStrcmp(result.privilege,priv))
3269 {
3270 SQLFreeStmt(hstmt, SQL_CLOSE);
3ca6a5f0 3271 return TRUE;
a8aa2258 3272 }
eedb1543 3273
a8aa2258
GT		 3274 if (!wxStrcmp(result.grantee,curRole) &&
3275 !wxStrcmp(result.privilege,priv))
3276 {
3277 SQLFreeStmt(hstmt, SQL_CLOSE);
3ca6a5f0 3278 return TRUE;
a8aa2258 3279 }
eedb1543 3280
3ca6a5f0 3281 retcode = SQLFetch(hstmt);
eedb1543
DW		 3282 }
3283
a8aa2258 3284 SQLFreeStmt(hstmt, SQL_CLOSE);
3ca6a5f0
BP		 3285 return FALSE;
3286
a8aa2258 3287} // wxDb::TablePrivileges
3ca6a5f0
BP		 3288
3289
f6bcfd97 3290/********** wxDb::SetSqlLogging() **********/
4fdae997 3291bool wxDb::SetSqlLogging(wxDbSqlLogState state, const wxString &filename, bool append)
1fc5dd6f 3292{
4fdae997
GT		 3293 wxASSERT(state == sqlLogON || state == sqlLogOFF);
3294 wxASSERT(state == sqlLogOFF || filename.Length());
1e92909e 3295
ea5d599d
GT		 3296 if (state == sqlLogON)
3297 {
3298 if (fpSqlLog == 0)
3299 {
4fdae997 3300 fpSqlLog = fopen(filename, (append ? wxT("at") : wxT("wt")));
ea5d599d
GT		 3301 if (fpSqlLog == NULL)
3302 return(FALSE);
3303 }
3304 }
3305 else // sqlLogOFF
3306 {
3307 if (fpSqlLog)
3308 {
3309 if (fclose(fpSqlLog))
3310 return(FALSE);
3311 fpSqlLog = 0;
3312 }
3313 }
1e92909e 3314
ea5d599d
GT		 3315 sqlLogState = state;
3316 return(TRUE);
1fc5dd6f 3317
f6bcfd97 3318} // wxDb::SetSqlLogging()
1fc5dd6f
JS		 3319
3320
f6bcfd97 3321/********** wxDb::WriteSqlLog() **********/
4fdae997 3322bool wxDb::WriteSqlLog(const wxString &logMsg)
1fc5dd6f 3323{
4fdae997 3324 wxASSERT(logMsg.Length());
1fc5dd6f 3325
1e92909e
GT		 3326 if (fpSqlLog == 0 || sqlLogState == sqlLogOFF)
3327 return(FALSE);
1fc5dd6f 3328
4fdae997
GT		 3329 if (fputs(wxT("\n"), fpSqlLog) == EOF)
3330 return(FALSE);
3331 if (fputs(logMsg, fpSqlLog) == EOF)
3332 return(FALSE);
3333 if (fputs(wxT("\n"), fpSqlLog) == EOF)
3334 return(FALSE);
1fc5dd6f 3335
1e92909e 3336 return(TRUE);
1fc5dd6f 3337
f6bcfd97 3338} // wxDb::WriteSqlLog()
1fc5dd6f
JS		 3339
3340
f6bcfd97
BP		 3341/********** wxDb::Dbms() **********/
3342wxDBMS wxDb::Dbms(void)
a2115c88
GT		 3343/*
3344 * Be aware that not all database engines use the exact same syntax, and not
3345 * every ODBC compliant database is compliant to the same level of compliancy.
3346 * Some manufacturers support the minimum Level 1 compliancy, and others up
3347 * through Level 3. Others support subsets of features for levels above 1.
3348 *
f6bcfd97 3349 * If you find an inconsistency between the wxDb class and a specific database
a2115c88
GT		 3350 * engine, and an identifier to this section, and special handle the database in
3351 * the area where behavior is non-conforming with the other databases.
3352 *
3353 *
3354 * NOTES ABOUT ISSUES SPECIFIC TO EACH DATABASE ENGINE
3355 * ---------------------------------------------------
3356 *
3357 * ORACLE
1e92909e 3358 * - Currently the only database supported by the class to support VIEWS
a2115c88
GT		 3359 *
3360 * DBASE
1e92909e
GT		 3361 * - Does not support the SQL_TIMESTAMP structure
3362 * - Supports only one cursor and one connect (apparently? with Microsoft driver only?)
fdc03678
GT		 3363 * - Does not automatically create the primary index if the 'keyField' param of SetColDef
3364 * is TRUE. The user must create ALL indexes from their program.
1e92909e
GT		 3365 * - Table names can only be 8 characters long
3366 * - Column names can only be 10 characters long
a2115c88
GT		 3367 *
3368 * SYBASE (all)
1e92909e
GT		 3369 * - To lock a record during QUERY functions, the reserved word 'HOLDLOCK' must be added
3370 * after every table name involved in the query/join if that tables matching record(s)
3371 * are to be locked
3372 * - Ignores the keywords 'FOR UPDATE'. Use the HOLDLOCK functionality described above
a2115c88
GT		 3373 *
3374 * SYBASE (Enterprise)
1e92909e 3375 * - If a column is part of the Primary Key, the column cannot be NULL
3ca6a5f0 3376 * - Maximum row size is somewhere in the neighborhood of 1920 bytes
a2115c88
GT		 3377 *
3378 * MY_SQL
1e92909e
GT		 3379 * - If a column is part of the Primary Key, the column cannot be NULL
3380 * - Cannot support selecting for update [::CanSelectForUpdate()]. Always returns FALSE
3ca6a5f0
BP		 3381 * - Columns that are part of primary or secondary keys must be defined as being NOT NULL
3382 * when they are created. Some code is added in ::CreateIndex to try to adjust the
3383 * column definition if it is not defined correctly, but it is experimental
3384 * - Does not support sub-queries in SQL statements
a2115c88
GT		 3385 *
3386 * POSTGRES
23f681ec 3387 * - Does not support the keywords 'ASC' or 'DESC' as of release v6.5.0
3ca6a5f0 3388 * - Does not support sub-queries in SQL statements
a2115c88 3389 *
a8aa2258
GT		 3390 * DB2
3391 * - Primary keys must be declared as NOT NULL
2beca662
GT		 3392 * - Table and index names must not be longer than 13 characters in length (technically
3393 * table names can be up to 18 characters, but the primary index is created using the
3394 * base table name plus "_PIDX", so the limit if the table has a primary index is 13.
3395 *
3396 * PERVASIVE SQL
a8aa2258 3397 *
081eb1b1
GT		 3398 * INTERBASE
3399 * - Columns that are part of primary keys must be defined as being NOT NULL
3400 * when they are created. Some code is added in ::CreateIndex to try to adjust the
3401 * column definition if it is not defined correctly, but it is experimental
a2115c88 3402 */
a2115c88 3403{
a8aa2258 3404 // Should only need to do this once for each new database connection
eedb1543 3405 // so return the value we already determined it to be to save time
a8aa2258
GT		 3406 // and lots of string comparisons
3407 if (dbmsType != dbmsUNIDENTIFIED)
3408 return(dbmsType);
3409
1e92909e 3410 wxChar baseName[25+1];
1e92909e 3411 wxStrncpy(baseName,dbInf.dbmsName,25);
3ca6a5f0 3412 baseName[25] = 0;
f6bcfd97 3413
d8a0a1c9
GT		 3414 // RGG 20001025 : add support for Interbase
3415 // GT : Integrated to base classes on 20001121
4fdae997 3416 if (!wxStricmp(dbInf.dbmsName,wxT("Interbase")))
d8a0a1c9
GT		 3417 return((wxDBMS)(dbmsType = dbmsINTERBASE));
3418
f6bcfd97 3419 // BJO 20000428 : add support for Virtuoso
4fdae997 3420 if (!wxStricmp(dbInf.dbmsName,wxT("OpenLink Virtuoso VDBMS")))
a8aa2258 3421 return((wxDBMS)(dbmsType = dbmsVIRTUOSO));
f6bcfd97 3422
4fdae997 3423 if (!wxStricmp(dbInf.dbmsName,wxT("Adaptive Server Anywhere")))
a8aa2258
GT		 3424 return((wxDBMS)(dbmsType = dbmsSYBASE_ASA));
3425
f6bcfd97
BP		 3426 // BJO 20000427 : The "SQL Server" string is also returned by SQLServer when
3427 // connected through an OpenLink driver.
eedb1543
DW		 3428 // Is it also returned by Sybase Adapatitve server?
3429 // OpenLink driver name is OLOD3032.DLL for msw and oplodbc.so for unix
4fdae997 3430 if (!wxStricmp(dbInf.dbmsName,wxT("SQL Server")))
3ca6a5f0 3431 {
4fdae997
GT		 3432 if (!wxStrncmp(dbInf.driverName, wxT("oplodbc"), 7) ||
3433 !wxStrncmp(dbInf.driverName, wxT("OLOD"), 4))
081eb1b1
GT		 3434 return ((wxDBMS)(dbmsMS_SQL_SERVER));
3435 else
3436 return ((wxDBMS)(dbmsType = dbmsSYBASE_ASE));
3ca6a5f0 3437 }
f6bcfd97 3438
4fdae997 3439 if (!wxStricmp(dbInf.dbmsName,wxT("Microsoft SQL Server")))
a8aa2258 3440 return((wxDBMS)(dbmsType = dbmsMS_SQL_SERVER));
4fdae997 3441 if (!wxStricmp(dbInf.dbmsName,wxT("MySQL")))
a8aa2258 3442 return((wxDBMS)(dbmsType = dbmsMY_SQL));
4fdae997 3443 if (!wxStricmp(dbInf.dbmsName,wxT("PostgreSQL"))) // v6.5.0
a8aa2258 3444 return((wxDBMS)(dbmsType = dbmsPOSTGRES));
1e92909e 3445
2beca662 3446 baseName[9] = 0;
081eb1b1
GT		 3447 if (!wxStricmp(dbInf.dbmsName,wxT("Pervasive")))
3448 return((wxDBMS)(dbmsType = dbmsPERVASIVE_SQL));
2beca662 3449
1e92909e 3450 baseName[8] = 0;
4fdae997 3451 if (!wxStricmp(baseName,wxT("Informix")))
a8aa2258 3452 return((wxDBMS)(dbmsType = dbmsINFORMIX));
1e92909e
GT		 3453
3454 baseName[6] = 0;
4fdae997 3455 if (!wxStricmp(baseName,wxT("Oracle")))
a8aa2258 3456 return((wxDBMS)(dbmsType = dbmsORACLE));
4fdae997 3457 if (!wxStricmp(dbInf.dbmsName,wxT("ACCESS")))
a8aa2258 3458 return((wxDBMS)(dbmsType = dbmsACCESS));
4fdae997 3459 if (!wxStricmp(dbInf.dbmsName,wxT("MySQL")))
a8aa2258 3460 return((wxDBMS)(dbmsType = dbmsMY_SQL));
4fdae997 3461 if (!wxStricmp(baseName,wxT("Sybase")))
a8aa2258 3462 return((wxDBMS)(dbmsType = dbmsSYBASE_ASE));
1e92909e
GT		 3463
3464 baseName[5] = 0;
4fdae997 3465 if (!wxStricmp(baseName,wxT("DBASE")))
a8aa2258 3466 return((wxDBMS)(dbmsType = dbmsDBASE));
1e92909e 3467
a8aa2258 3468 baseName[3] = 0;
4fdae997 3469 if (!wxStricmp(baseName,wxT("DB2")))
a8aa2258
GT		 3470 return((wxDBMS)(dbmsType = dbmsDBASE));
3471
3472 return((wxDBMS)(dbmsType = dbmsUNIDENTIFIED));
3ca6a5f0 3473
f6bcfd97 3474} // wxDb::Dbms()
a2115c88
GT		 3475
3476
4fdae997
GT		 3477bool wxDb::ModifyColumn(const wxString &tableName, const wxString &columnName,
3478 int dataType, ULONG columnLength,
3479 const wxString &optionalParam)
3480{
3481 wxASSERT(tableName.Length());
3482 wxASSERT(columnName.Length());
3483 wxASSERT((dataType == DB_DATA_TYPE_VARCHAR && columnLength > 0) ||
3484 dataType != DB_DATA_TYPE_VARCHAR);
3485
3486 // Must specify a columnLength if modifying a VARCHAR type column
3487 if (dataType == DB_DATA_TYPE_VARCHAR && !columnLength)
3488 return FALSE;
5600884a 3489
4fdae997 3490 wxString dataTypeName;
081eb1b1 3491 wxString sqlStmt;
4fdae997
GT		 3492 wxString alterSlashModify;
3493
081eb1b1
GT		 3494 switch(dataType)
3495 {
3496 case DB_DATA_TYPE_VARCHAR :
3497 dataTypeName = typeInfVarchar.TypeName;
3498 break;
3499 case DB_DATA_TYPE_INTEGER :
3500 dataTypeName = typeInfInteger.TypeName;
3501 break;
3502 case DB_DATA_TYPE_FLOAT :
3503 dataTypeName = typeInfFloat.TypeName;
3504 break;
3505 case DB_DATA_TYPE_DATE :
3506 dataTypeName = typeInfDate.TypeName;
3507 break;
3508 case DB_DATA_TYPE_BLOB :
3509 dataTypeName = typeInfBlob.TypeName;
3510 break;
3511 default:
4fdae997 3512 return FALSE;
081eb1b1
GT		 3513 }
3514
3515 // Set the modify or alter syntax depending on the type of database connected to
3516 switch (Dbms())
3517 {
3518 case dbmsORACLE :
3519 alterSlashModify = "MODIFY";
3520 break;
3521 case dbmsMS_SQL_SERVER :
3522 alterSlashModify = "ALTER COLUMN";
3523 break;
3524 case dbmsUNIDENTIFIED :
3525 return FALSE;
3526 case dbmsSYBASE_ASA :
3527 case dbmsSYBASE_ASE :
3528 case dbmsMY_SQL :
3529 case dbmsPOSTGRES :
3530 case dbmsACCESS :
3531 case dbmsDBASE :
3532 default :
3533 alterSlashModify = "MODIFY";
3534 break;
3535 }
3536
3537 // create the SQL statement
3538 sqlStmt.Printf(wxT("ALTER TABLE %s %s %s %s"), tableName.c_str(), alterSlashModify.c_str(),
3539 columnName.c_str(), dataTypeName.c_str());
4fdae997
GT		 3540
3541 // For varchars only, append the size of the column
3542 if (dataType == DB_DATA_TYPE_VARCHAR)
3543 {
3544 wxString s;
3545 s.Printf(wxT("(%d)"), columnLength);
3546 sqlStmt += s;
3547 }
3548
3549 // for passing things like "NOT NULL"
3550 if (optionalParam.Length())
3551 {
3552 sqlStmt += wxT(" ");
3553 sqlStmt += optionalParam;
3554 }
3555
081eb1b1 3556 return ExecSql(sqlStmt);
4fdae997
GT		 3557
3558} // wxDb::ModifyColumn()
3559
3560
fdc03678 3561/********** wxDbGetConnection() **********/
f6bcfd97 3562wxDb WXDLLEXPORT *wxDbGetConnection(wxDbConnectInf *pDbConfig, bool FwdOnlyCursors)
108106cf 3563{
fdc03678 3564 wxDbList *pList;
1e92909e 3565
a8aa2258
GT		 3566 // Used to keep a pointer to a DB connection that matches the requested
3567 // DSN and FwdOnlyCursors settings, even if it is not FREE, so that the
3568 // data types can be copied from it (using the wxDb::Open(wxDb *) function)
3569 // rather than having to re-query the datasource to get all the values
3570 // using the wxDb::Open(Dsn,Uid,AuthStr) function
3571 wxDb *matchingDbConnection = NULL;
3572
1e92909e
GT		 3573 // Scan the linked list searching for an available database connection
3574 // that's already been opened but is currently not in use.
3575 for (pList = PtrBegDbList; pList; pList = pList->PtrNext)
3576 {
3577 // The database connection must be for the same datasource
3578 // name and must currently not be in use.
3ca6a5f0
BP		 3579 if (pList->Free &&
3580 (pList->PtrDb->FwdOnlyCursors() == FwdOnlyCursors) &&
942e67c3 3581 (!wxStrcmp(pDbConfig->GetDsn(), pList->Dsn))) // Found a free connection
1e92909e
GT		 3582 {
3583 pList->Free = FALSE;
3584 return(pList->PtrDb);
3585 }
a8aa2258 3586
942e67c3
GT		 3587 if (!wxStrcmp(pDbConfig->GetDsn(), pList->Dsn) &&
3588 !wxStrcmp(pDbConfig->GetUserID(), pList->Uid) &&
3589 !wxStrcmp(pDbConfig->GetPassword(), pList->AuthStr))
a8aa2258 3590 matchingDbConnection = pList->PtrDb;
1e92909e
GT		 3591 }
3592
3593 // No available connections. A new connection must be made and
3594 // appended to the end of the linked list.
3595 if (PtrBegDbList)
3596 {
3597 // Find the end of the list
3598 for (pList = PtrBegDbList; pList->PtrNext; pList = pList->PtrNext);
3599 // Append a new list item
fdc03678 3600 pList->PtrNext = new wxDbList;
1e92909e
GT		 3601 pList->PtrNext->PtrPrev = pList;
3602 pList = pList->PtrNext;
3603 }
3ca6a5f0 3604 else // Empty list
1e92909e
GT		 3605 {
3606 // Create the first node on the list
fdc03678 3607 pList = PtrBegDbList = new wxDbList;
1e92909e
GT		 3608 pList->PtrPrev = 0;
3609 }
3610
3611 // Initialize new node in the linked list
4fdae997
GT		 3612 pList->PtrNext = 0;
3613 pList->Free = FALSE;
942e67c3
GT		 3614 pList->Dsn = pDbConfig->GetDsn(); //glt - will this assignment work?
3615 pList->Uid = pDbConfig->GetUserID();
3616 pList->AuthStr = pDbConfig->GetPassword();
a8aa2258 3617
9556da13 3618 pList->PtrDb = new wxDb(pDbConfig->GetHenv(), FwdOnlyCursors);
1e92909e 3619
a8aa2258
GT		 3620 bool opened = FALSE;
3621
3622 if (!matchingDbConnection)
942e67c3 3623 opened = pList->PtrDb->Open(pDbConfig->GetDsn(), pDbConfig->GetUserID(), pDbConfig->GetPassword());
a8aa2258
GT		 3624 else
3625 opened = pList->PtrDb->Open(matchingDbConnection);
3626
1e92909e 3627 // Connect to the datasource
a8aa2258 3628 if (opened)
1e92909e 3629 {
f6bcfd97 3630 pList->PtrDb->SetSqlLogging(SQLLOGstate,SQLLOGfn,TRUE);
1e92909e
GT		 3631 return(pList->PtrDb);
3632 }
3633 else // Unable to connect, destroy list item
3634 {
3635 if (pList->PtrPrev)
3636 pList->PtrPrev->PtrNext = 0;
3637 else
3638 PtrBegDbList = 0; // Empty list again
f6bcfd97
BP		 3639 pList->PtrDb->CommitTrans(); // Commit any open transactions on wxDb object
3640 pList->PtrDb->Close(); // Close the wxDb object
3641 delete pList->PtrDb; // Deletes the wxDb object
1e92909e
GT		 3642 delete pList; // Deletes the linked list object
3643 return(0);
3644 }
108106cf 3645
fdc03678 3646} // wxDbGetConnection()
108106cf 3647
67e9aaa3 3648
fdc03678 3649/********** wxDbFreeConnection() **********/
f6bcfd97 3650bool WXDLLEXPORT wxDbFreeConnection(wxDb *pDb)
108106cf 3651{
fdc03678 3652 wxDbList *pList;
108106cf 3653
1e92909e
GT		 3654 // Scan the linked list searching for the database connection
3655 for (pList = PtrBegDbList; pList; pList = pList->PtrNext)
3656 {
3ca6a5f0
BP		 3657 if (pList->PtrDb == pDb) // Found it, now free it!!!
3658 return (pList->Free = TRUE);
1e92909e 3659 }
108106cf 3660
1e92909e
GT		 3661 // Never found the database object, return failure
3662 return(FALSE);
108106cf 3663
fdc03678 3664} // wxDbFreeConnection()
108106cf 3665
67e9aaa3 3666
fdc03678
GT		 3667/********** wxDbCloseConnections() **********/
3668void WXDLLEXPORT wxDbCloseConnections(void)
108106cf 3669{
fdc03678 3670 wxDbList *pList, *pNext;
23f681ec 3671
1e92909e
GT		 3672 // Traverse the linked list closing database connections and freeing memory as I go.
3673 for (pList = PtrBegDbList; pList; pList = pNext)
3674 {
3675 pNext = pList->PtrNext; // Save the pointer to next
f6bcfd97
BP		 3676 pList->PtrDb->CommitTrans(); // Commit any open transactions on wxDb object
3677 pList->PtrDb->Close(); // Close the wxDb object
3678 delete pList->PtrDb; // Deletes the wxDb object
1e92909e
GT		 3679 delete pList; // Deletes the linked list object
3680 }
3681
3682 // Mark the list as empty
3683 PtrBegDbList = 0;
108106cf 3684
fdc03678 3685} // wxDbCloseConnections()
108106cf 3686
67e9aaa3 3687
eb3b9dda 3688/********** wxDbConnectionsInUse() **********/
fdc03678 3689int WXDLLEXPORT wxDbConnectionsInUse(void)
108106cf 3690{
fdc03678 3691 wxDbList *pList;
1e92909e 3692 int cnt = 0;
108106cf 3693
1e92909e
GT		 3694 // Scan the linked list counting db connections that are currently in use
3695 for (pList = PtrBegDbList; pList; pList = pList->PtrNext)
3696 {
3697 if (pList->Free == FALSE)
3698 cnt++;
3699 }
108106cf 3700
1e92909e 3701 return(cnt);
108106cf 3702
fdc03678 3703} // wxDbConnectionsInUse()
108106cf 3704
67e9aaa3 3705
fdc03678 3706/********** wxDbSqlLog() **********/
f6bcfd97 3707bool wxDbSqlLog(wxDbSqlLogState state, const wxChar *filename)
a2115c88 3708{
1e92909e 3709 bool append = FALSE;
fdc03678 3710 wxDbList *pList;
a2115c88 3711
1e92909e
GT		 3712 for (pList = PtrBegDbList; pList; pList = pList->PtrNext)
3713 {
f6bcfd97 3714 if (!pList->PtrDb->SetSqlLogging(state,filename,append))
1e92909e
GT		 3715 return(FALSE);
3716 append = TRUE;
3717 }
a2115c88 3718
1e92909e 3719 SQLLOGstate = state;
3ca6a5f0 3720 SQLLOGfn = filename;
a2115c88 3721
1e92909e 3722 return(TRUE);
a2115c88 3723
fdc03678 3724} // wxDbSqlLog()
a2115c88 3725
67e9aaa3 3726
a8aa2258 3727#if 0
fdc03678 3728/********** wxDbCreateDataSource() **********/
4fdae997
GT		 3729int wxDbCreateDataSource(const wxString &driverName, const wxString &dsn, const wxString &description,
3730 bool sysDSN, const wxString &defDir, wxWindow *parent)
fdc03678
GT		 3731/*
3732 * !!!! ONLY FUNCTIONAL UNDER MSW with VC6 !!!!
eedb1543 3733 * Very rudimentary creation of an ODBC data source.
a8aa2258
GT		 3734 *
3735 * ODBC driver must be ODBC 3.0 compliant to use this function
fdc03678
GT		 3736 */
3737{
3738 int result = FALSE;
3739
a8aa2258
GT		 3740//!!!! ONLY FUNCTIONAL UNDER MSW with VC6 !!!!
3741#ifdef __VISUALC__
fdc03678
GT		 3742 int dsnLocation;
3743 wxString setupStr;
3744
3745 if (sysDSN)
3746 dsnLocation = ODBC_ADD_SYS_DSN;
3747 else
3748 dsnLocation = ODBC_ADD_DSN;
3749
3750 // NOTE: The decimal 2 is an invalid character in all keyword pairs
eedb1543 3751 // so that is why I used it, as wxString does not deal well with
fdc03678 3752 // embedded nulls in strings
4fdae997 3753 setupStr.Printf(wxT("DSN=%s%cDescription=%s%cDefaultDir=%s%c"),dsn,2,description,2,defDir,2);
fdc03678
GT		 3754
3755 // Replace the separator from above with the '\0' seperator needed
3756 // by the SQLConfigDataSource() function
3757 int k;
3758 do
3759 {
3760 k = setupStr.Find((wxChar)2,TRUE);
3761 if (k != wxNOT_FOUND)
4fdae997 3762 setupStr[(UINT)k] = wxT('\0');
fdc03678
GT		 3763 }
3764 while (k != wxNOT_FOUND);
3765
3766 result = SQLConfigDataSource((HWND)parent->GetHWND(), dsnLocation,
f6bcfd97 3767 driverName, setupStr.c_str());
fdc03678 3768
a8aa2258 3769 if ((result != SQL_SUCCESS) && (result != SQL_SUCCESS_WITH_INFO))
fdc03678
GT		 3770 {
3771 // check for errors caused by ConfigDSN based functions
3772 DWORD retcode = 0;
3773 WORD cb;
a8aa2258 3774 wxChar errMsg[SQL_MAX_MESSAGE_LENGTH];
4fdae997 3775 errMsg[0] = wxT('\0');
fdc03678 3776
a8aa2258
GT		 3777 // This function is only supported in ODBC drivers v3.0 compliant and above
3778 SQLInstallerError(1,&retcode,errMsg,SQL_MAX_MESSAGE_LENGTH-1,&cb);
fdc03678
GT		 3779 if (retcode)
3780 {
fdc03678 3781#ifdef DBDEBUG_CONSOLE
f6bcfd97
BP		 3782 // When run in console mode, use standard out to display errors.
3783 cout << errMsg << endl;
a8aa2258 3784 cout << wxT("Press any key to continue...") << endl;
f6bcfd97 3785 getchar();
fdc03678 3786#endif // DBDEBUG_CONSOLE
fdc03678
GT		 3787
3788#ifdef __WXDEBUG__
f6bcfd97 3789 wxLogDebug(errMsg,wxT("ODBC DEBUG MESSAGE"));
fdc03678
GT		 3790#endif // __WXDEBUG__
3791 }
3792 }
3793 else
3794 result = TRUE;
a8aa2258
GT		 3795#else
3796 // Using iODBC/unixODBC or some other compiler which does not support the APIs
3797 // necessary to use this function, so this function is not supported
fdc03678 3798#ifdef __WXDEBUG__
4fdae997 3799 wxLogDebug(wxT("wxDbCreateDataSource() not available except under VC++/MSW"),wxT("ODBC DEBUG MESSAGE"));
fdc03678 3800#endif
a8aa2258
GT		 3801 result = FALSE;
3802#endif // __VISUALC__
fdc03678
GT		 3803
3804 return result;
3805
3806} // wxDbCreateDataSource()
3807#endif
3808
3809
3810/********** wxDbGetDataSource() **********/
4fdae997
GT		 3811bool wxDbGetDataSource(HENV henv, wxChar *Dsn, SWORD DsnMax, wxChar *DsDesc,
3812 SWORD DsDescMax, UWORD direction)
67e9aaa3
GT		 3813/*
3814 * Dsn and DsDesc will contain the data source name and data source
3815 * description upon return
3816 */
108106cf 3817{
1e92909e 3818 SWORD cb1,cb2;
108106cf 3819
1e92909e
GT		 3820 if (SQLDataSources(henv, direction, (UCHAR FAR *) Dsn, DsnMax, &cb1,
3821 (UCHAR FAR *) DsDesc, DsDescMax, &cb2) == SQL_SUCCESS)
3822 return(TRUE);
3823 else
3824 return(FALSE);
108106cf 3825
fdc03678
GT		 3826} // wxDbGetDataSource()
3827
3828
3829// Change this to 0 to remove use of all deprecated functions
f6bcfd97 3830#if wxODBC_BACKWARD_COMPATABILITY
fdc03678
GT		 3831/********************************************************************
3832 ********************************************************************
3833 *
3834 * The following functions are all DEPRECATED and are included for
3835 * backward compatability reasons only
3836 *
3837 ********************************************************************
3838 ********************************************************************/
f6bcfd97 3839bool SqlLog(sqlLog state, const wxChar *filename)
fdc03678 3840{
f6bcfd97 3841 return wxDbSqlLog((enum wxDbSqlLogState)state, filename);
fdc03678
GT		 3842}
3843/***** DEPRECATED: use wxGetDataSource() *****/
3844bool GetDataSource(HENV henv, char *Dsn, SWORD DsnMax, char *DsDesc, SWORD DsDescMax,
3845 UWORD direction)
3846{
3847 return wxDbGetDataSource(henv, Dsn, DsnMax, DsDesc, DsDescMax, direction);
3848}
3849/***** DEPRECATED: use wxDbGetConnection() *****/
f6bcfd97 3850wxDb WXDLLEXPORT *GetDbConnection(DbStuff *pDbStuff, bool FwdOnlyCursors)
fdc03678
GT		 3851{
3852 return wxDbGetConnection((wxDbConnectInf *)pDbStuff, FwdOnlyCursors);
3853}
3854/***** DEPRECATED: use wxDbFreeConnection() *****/
f6bcfd97 3855bool WXDLLEXPORT FreeDbConnection(wxDb *pDb)
fdc03678
GT		 3856{
3857 return wxDbFreeConnection(pDb);
3858}
3859/***** DEPRECATED: use wxDbCloseConnections() *****/
3860void WXDLLEXPORT CloseDbConnections(void)
3861{
3862 wxDbCloseConnections();
3863}
3864/***** DEPRECATED: use wxDbConnectionsInUse() *****/
3865int WXDLLEXPORT NumberDbConnectionsInUse(void)
3866{
3867 return wxDbConnectionsInUse();
3868}
3869#endif
3870
3871
108106cf 3872#endif
1fc5dd6f 3873 // wxUSE_ODBC
wxWidgets (Impactor)