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