|
1 /**************************************************************************** |
|
2 ** |
|
3 ** Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies). |
|
4 ** All rights reserved. |
|
5 ** Contact: Nokia Corporation (qt-info@nokia.com) |
|
6 ** |
|
7 ** This file is part of the test suite of the Qt Toolkit. |
|
8 ** |
|
9 ** $QT_BEGIN_LICENSE:LGPL$ |
|
10 ** No Commercial Usage |
|
11 ** This file contains pre-release code and may not be distributed. |
|
12 ** You may use this file in accordance with the terms and conditions |
|
13 ** contained in the Technology Preview License Agreement accompanying |
|
14 ** this package. |
|
15 ** |
|
16 ** GNU Lesser General Public License Usage |
|
17 ** Alternatively, this file may be used under the terms of the GNU Lesser |
|
18 ** General Public License version 2.1 as published by the Free Software |
|
19 ** Foundation and appearing in the file LICENSE.LGPL included in the |
|
20 ** packaging of this file. Please review the following information to |
|
21 ** ensure the GNU Lesser General Public License version 2.1 requirements |
|
22 ** will be met: http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html. |
|
23 ** |
|
24 ** In addition, as a special exception, Nokia gives you certain additional |
|
25 ** rights. These rights are described in the Nokia Qt LGPL Exception |
|
26 ** version 1.1, included in the file LGPL_EXCEPTION.txt in this package. |
|
27 ** |
|
28 ** If you have questions regarding the use of this file, please contact |
|
29 ** Nokia at qt-info@nokia.com. |
|
30 ** |
|
31 ** |
|
32 ** |
|
33 ** |
|
34 ** |
|
35 ** |
|
36 ** |
|
37 ** |
|
38 ** $QT_END_LICENSE$ |
|
39 ** |
|
40 ****************************************************************************/ |
|
41 |
|
42 |
|
43 #include <QtTest/QtTest> |
|
44 #include <qsqldatabase.h> |
|
45 #include <qsqlquery.h> |
|
46 #include <qsqldriver.h> |
|
47 #ifdef QT3_SUPPORT |
|
48 #include <q3sqlcursor.h> |
|
49 #include <q3sqlrecordinfo.h> |
|
50 #include <q3cstring.h> |
|
51 #endif |
|
52 #include <qsqlrecord.h> |
|
53 #include <qsqlfield.h> |
|
54 #include <qsqlindex.h> |
|
55 #include <qregexp.h> |
|
56 #include <qvariant.h> |
|
57 #include <qdatetime.h> |
|
58 #include <qdebug.h> |
|
59 |
|
60 #define NODATABASE_SKIP "No database drivers are available in this Qt configuration" |
|
61 |
|
62 #include "tst_databases.h" |
|
63 |
|
64 //TESTED_FILES= |
|
65 |
|
66 QT_FORWARD_DECLARE_CLASS(QSqlDatabase) |
|
67 struct FieldDef; |
|
68 |
|
69 class tst_QSqlDatabase : public QObject |
|
70 { |
|
71 Q_OBJECT |
|
72 |
|
73 public: |
|
74 tst_QSqlDatabase(); |
|
75 virtual ~tst_QSqlDatabase(); |
|
76 |
|
77 public slots: |
|
78 void initTestCase(); |
|
79 void cleanupTestCase(); |
|
80 void init(); |
|
81 void cleanup(); |
|
82 private slots: |
|
83 void record_data() { generic_data(); } |
|
84 //void record(); |
|
85 void open_data() { generic_data(); } |
|
86 void open(); |
|
87 void tables_data() { generic_data(); } |
|
88 void tables(); |
|
89 void oci_tables_data() { generic_data("QOCI"); } |
|
90 void oci_tables(); |
|
91 void transaction_data() { generic_data(); } |
|
92 void transaction(); |
|
93 void eventNotification_data() { generic_data(); } |
|
94 void eventNotification(); |
|
95 void addDatabase(); |
|
96 |
|
97 //database specific tests |
|
98 void recordMySQL_data() { generic_data("QMYSQL"); } |
|
99 void recordMySQL(); |
|
100 void recordPSQL_data() { generic_data("QPSQL"); } |
|
101 void recordPSQL(); |
|
102 void recordOCI_data() { generic_data("QOCI"); } |
|
103 void recordOCI(); |
|
104 void recordTDS_data() { generic_data("QTDS"); } |
|
105 void recordTDS(); |
|
106 void recordDB2_data() { generic_data("QDB2"); } |
|
107 void recordDB2(); |
|
108 void recordSQLite_data() { generic_data("QSQLITE"); } |
|
109 void recordSQLite(); |
|
110 void recordAccess_data() { generic_data("QODBC"); } |
|
111 void recordAccess(); |
|
112 void recordSQLServer_data() { generic_data("QODBC"); } |
|
113 void recordSQLServer(); |
|
114 void recordIBase_data() {generic_data("QIBASE"); } |
|
115 void recordIBase(); |
|
116 |
|
117 void eventNotificationIBase_data() { generic_data("QIBASE"); } |
|
118 void eventNotificationIBase(); |
|
119 void eventNotificationPSQL_data() { generic_data("QPSQL"); } |
|
120 void eventNotificationPSQL(); |
|
121 |
|
122 //database specific 64 bit integer test |
|
123 void bigIntField_data() { generic_data(); } |
|
124 void bigIntField(); |
|
125 |
|
126 // general tests |
|
127 void getConnectionName_data() { generic_data(); } |
|
128 void getConnectionName(); // For task 129992 |
|
129 |
|
130 //problem specific tests |
|
131 void alterTable_data() { generic_data(); } |
|
132 void alterTable(); |
|
133 void recordNonSelect_data() { generic_data(); } |
|
134 void recordNonSelect(); |
|
135 void caseSensivity_data() { generic_data(); } |
|
136 void caseSensivity(); |
|
137 void noEscapedFieldNamesInRecord_data() { generic_data(); } |
|
138 void noEscapedFieldNamesInRecord(); |
|
139 void whitespaceInIdentifiers_data() { generic_data(); } |
|
140 void whitespaceInIdentifiers(); |
|
141 void formatValueTrimStrings_data() { generic_data(); } |
|
142 void formatValueTrimStrings(); |
|
143 void precisionPolicy_data() { generic_data(); } |
|
144 void precisionPolicy(); |
|
145 |
|
146 void db2_valueCacheUpdate_data() { generic_data("QDB2"); } |
|
147 void db2_valueCacheUpdate(); |
|
148 |
|
149 void psql_schemas_data() { generic_data("QPSQL"); } |
|
150 void psql_schemas(); |
|
151 void psql_escapedIdentifiers_data() { generic_data("QPSQL"); } |
|
152 void psql_escapedIdentifiers(); |
|
153 void psql_escapeBytea_data() { generic_data("QPSQL"); } |
|
154 void psql_escapeBytea(); |
|
155 void bug_249059_data() { generic_data("QPSQL"); } |
|
156 void bug_249059(); |
|
157 |
|
158 void mysqlOdbc_unsignedIntegers_data() { generic_data(); } |
|
159 void mysqlOdbc_unsignedIntegers(); |
|
160 void mysql_multiselect_data() { generic_data("QMYSQL"); } |
|
161 void mysql_multiselect(); // For task 144331 |
|
162 void mysql_savepointtest_data() { generic_data("QMYSQL"); } |
|
163 void mysql_savepointtest(); |
|
164 |
|
165 void accessOdbc_strings_data() { generic_data(); } |
|
166 void accessOdbc_strings(); |
|
167 |
|
168 void ibase_numericFields_data() { generic_data("QIBASE"); } |
|
169 void ibase_numericFields(); // For task 125053 |
|
170 void ibase_fetchBlobs_data() { generic_data("QIBASE"); } |
|
171 void ibase_fetchBlobs(); // For task 143471 |
|
172 void ibase_useCustomCharset_data() { generic_data("QIBASE"); } |
|
173 void ibase_useCustomCharset(); // For task 134608 |
|
174 void ibase_procWithoutReturnValues_data() { generic_data("QIBASE"); } // For task 165423 |
|
175 void ibase_procWithoutReturnValues(); |
|
176 void ibase_procWithReturnValues_data() { generic_data("QIBASE"); } // For task 177530 |
|
177 void ibase_procWithReturnValues(); |
|
178 |
|
179 void odbc_reopenDatabase_data() { generic_data("QODBC"); } |
|
180 void odbc_reopenDatabase(); |
|
181 void odbc_uniqueidentifier_data() { generic_data("QODBC"); } |
|
182 void odbc_uniqueidentifier(); // For task 141822 |
|
183 void odbc_uintfield_data() { generic_data("QODBC"); } |
|
184 void odbc_uintfield(); |
|
185 void odbc_bindBoolean_data() { generic_data("QODBC"); } |
|
186 void odbc_bindBoolean(); |
|
187 void odbc_testqGetString_data() { generic_data("QODBC"); } |
|
188 void odbc_testqGetString(); |
|
189 |
|
190 void oci_serverDetach_data() { generic_data("QOCI"); } |
|
191 void oci_serverDetach(); // For task 154518 |
|
192 void oci_xmltypeSupport_data() { generic_data("QOCI"); } |
|
193 void oci_xmltypeSupport(); |
|
194 void oci_fieldLength_data() { generic_data("QOCI"); } |
|
195 void oci_fieldLength(); |
|
196 void oci_synonymstest_data() { generic_data("QOCI"); } |
|
197 void oci_synonymstest(); |
|
198 |
|
199 void sqlite_bindAndFetchUInt_data() { generic_data("QSQLITE"); } |
|
200 void sqlite_bindAndFetchUInt(); |
|
201 |
|
202 void sqlStatementUseIsNull_189093_data() { generic_data(); } |
|
203 void sqlStatementUseIsNull_189093(); |
|
204 |
|
205 void sqlite_enable_cache_mode_data() { generic_data("QSQLITE"); } |
|
206 void sqlite_enable_cache_mode(); |
|
207 |
|
208 private: |
|
209 void createTestTables(QSqlDatabase db); |
|
210 void dropTestTables(QSqlDatabase db); |
|
211 void populateTestTables(QSqlDatabase db); |
|
212 void generic_data(const QString &engine=QString()); |
|
213 |
|
214 #ifdef QT3_SUPPORT |
|
215 void testRecordInfo(const FieldDef fieldDefs[], const Q3SqlRecordInfo& inf); |
|
216 #endif |
|
217 void testRecord(const FieldDef fieldDefs[], const QSqlRecord& inf, QSqlDatabase db); |
|
218 void commonFieldTest(const FieldDef fieldDefs[], QSqlDatabase, const int); |
|
219 void checkValues(const FieldDef fieldDefs[], QSqlDatabase db); |
|
220 void checkNullValues(const FieldDef fieldDefs[], QSqlDatabase db); |
|
221 |
|
222 tst_Databases dbs; |
|
223 }; |
|
224 |
|
225 // number of records to be inserted per testfunction |
|
226 static const int ITERATION_COUNT = 2; |
|
227 static int pkey = 1; |
|
228 |
|
229 //helper class for database specific tests |
|
230 struct FieldDef { |
|
231 FieldDef(QString tn = QString(), |
|
232 QVariant::Type t = QVariant::Invalid, |
|
233 QVariant v = QVariant(), |
|
234 bool nl = true): |
|
235 typeName(tn), type(t), val(v), nullable(nl) {} |
|
236 |
|
237 QString fieldName() const |
|
238 { |
|
239 QString rt = typeName; |
|
240 rt.replace(QRegExp("\\s"), QString("_")); |
|
241 #ifdef QT3_SUPPORT |
|
242 int i = rt.find("("); |
|
243 #else |
|
244 int i = rt.indexOf("("); |
|
245 #endif |
|
246 if (i == -1) |
|
247 i = rt.length(); |
|
248 if (i > 20) |
|
249 i = 20; |
|
250 return "t_" + rt.left(i); |
|
251 } |
|
252 QString typeName; |
|
253 QVariant::Type type; |
|
254 QVariant val; |
|
255 bool nullable; |
|
256 }; |
|
257 |
|
258 // creates a table out of the FieldDefs and returns the number of fields |
|
259 // excluding the primary key field |
|
260 static int createFieldTable(const FieldDef fieldDefs[], QSqlDatabase db) |
|
261 { |
|
262 tst_Databases::safeDropTable(db, qTableName("qtestfields", __FILE__)); |
|
263 QSqlQuery q(db); |
|
264 // construct a create table statement consisting of all fieldtypes |
|
265 QString qs = "create table " + qTableName("qtestfields", __FILE__); |
|
266 QString autoName = tst_Databases::autoFieldName(db); |
|
267 if (tst_Databases::isMSAccess(db)) |
|
268 qs.append(" (id int not null"); |
|
269 else if (tst_Databases::isPostgreSQL(db)) |
|
270 qs.append(" (id serial not null"); |
|
271 else |
|
272 qs.append(QString("(id integer not null %1 primary key").arg(autoName)); |
|
273 |
|
274 int i = 0; |
|
275 for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) { |
|
276 qs += QString(",\n %1 %2").arg(fieldDefs[ i ].fieldName()).arg(fieldDefs[ i ].typeName); |
|
277 if ((db.driverName().startsWith("QTDS") || tst_Databases::isSqlServer(db)) && fieldDefs[ i ].nullable) { |
|
278 qs += " null"; |
|
279 } |
|
280 } |
|
281 |
|
282 if (tst_Databases::isMSAccess(db)) |
|
283 qs.append(",\n primary key (id)"); |
|
284 |
|
285 qs += ')'; |
|
286 if (!q.exec(qs)) { |
|
287 qDebug() << "Creation of Table failed:" << tst_Databases::printError(q.lastError(), db); |
|
288 qDebug() << "Query: " << qs; |
|
289 return -1; |
|
290 } |
|
291 return i; |
|
292 } |
|
293 |
|
294 tst_QSqlDatabase::tst_QSqlDatabase() |
|
295 { |
|
296 } |
|
297 |
|
298 tst_QSqlDatabase::~tst_QSqlDatabase() |
|
299 { |
|
300 } |
|
301 |
|
302 void tst_QSqlDatabase::createTestTables(QSqlDatabase db) |
|
303 { |
|
304 if (!db.isValid()) |
|
305 return; |
|
306 QSqlQuery q(db); |
|
307 if (db.driverName().startsWith("QMYSQL")) |
|
308 // ### stupid workaround until we find a way to hardcode this |
|
309 // in the MySQL server startup script |
|
310 q.exec("set table_type=innodb"); |
|
311 else if (tst_Databases::isSqlServer(db)) { |
|
312 QVERIFY_SQL(q, exec("SET ANSI_DEFAULTS ON")); |
|
313 QVERIFY_SQL(q, exec("SET IMPLICIT_TRANSACTIONS OFF")); |
|
314 } else if(tst_Databases::isPostgreSQL(db)) |
|
315 QVERIFY_SQL( q, exec("set client_min_messages='warning'")); |
|
316 |
|
317 // please never ever change this table; otherwise fix all tests ;) |
|
318 if (tst_Databases::isMSAccess(db)) { |
|
319 QVERIFY_SQL(q, exec("create table " + qTableName("qtest", __FILE__) + |
|
320 " (id int not null, t_varchar varchar(40) not null, t_char char(40), " |
|
321 "t_numeric number, primary key (id, t_varchar))")); |
|
322 } else { |
|
323 QVERIFY_SQL(q, exec("create table " + qTableName("qtest", __FILE__) + |
|
324 " (id integer not null, t_varchar varchar(40) not null, " |
|
325 "t_char char(40), t_numeric numeric(6, 3), primary key (id, t_varchar))")); |
|
326 } |
|
327 |
|
328 if (testWhiteSpaceNames(db.driverName())) { |
|
329 QString qry = "create table " |
|
330 + db.driver()->escapeIdentifier(qTableName("qtest", __FILE__) + " test", QSqlDriver::TableName) |
|
331 + '(' |
|
332 + db.driver()->escapeIdentifier(QLatin1String("test test"), QSqlDriver::FieldName) |
|
333 + " int not null primary key)"; |
|
334 QVERIFY_SQL(q, exec(qry)); |
|
335 } |
|
336 } |
|
337 |
|
338 void tst_QSqlDatabase::dropTestTables(QSqlDatabase db) |
|
339 { |
|
340 if (!db.isValid()) |
|
341 return; |
|
342 |
|
343 if(tst_Databases::isPostgreSQL(db)) { |
|
344 QSqlQuery q(db); |
|
345 QVERIFY_SQL( q, exec("set client_min_messages='warning'")); |
|
346 } |
|
347 |
|
348 // drop the view first, otherwise we'll get dependency problems |
|
349 tst_Databases::safeDropViews(db, QStringList() << qTableName("qtest_view", __FILE__) << qTableName("qtest_view2", __FILE__)); |
|
350 |
|
351 QStringList tableNames; |
|
352 tableNames << qTableName("qtest", __FILE__) |
|
353 << qTableName("qtestfields", __FILE__) |
|
354 << qTableName("qtestalter", __FILE__) |
|
355 << qTableName("qtest_temp", __FILE__) |
|
356 << qTableName("qtest_bigint", __FILE__) |
|
357 << qTableName("qtest_xmltype", __FILE__) |
|
358 << qTableName("latin1table", __FILE__) |
|
359 << qTableName("qtest_sqlguid", __FILE__) |
|
360 << qTableName("batable", __FILE__) |
|
361 << qTableName("qtest_prec", __FILE__) |
|
362 << qTableName("uint", __FILE__) |
|
363 << qTableName("strings", __FILE__) |
|
364 << qTableName("numericfields", __FILE__) |
|
365 << qTableName("qtest_ibaseblobs", __FILE__) |
|
366 << qTableName("qtestBindBool", __FILE__) |
|
367 << qTableName("testqGetString", __FILE__) |
|
368 << qTableName("qtest_sqlguid", __FILE__) |
|
369 << qTableName("uint_table", __FILE__) |
|
370 << qTableName("uint_test", __FILE__) |
|
371 << qTableName("bug_249059", __FILE__); |
|
372 |
|
373 QSqlQuery q(0, db); |
|
374 if (db.driverName().startsWith("QPSQL")) { |
|
375 q.exec("drop schema " + qTableName("qtestschema", __FILE__) + " cascade"); |
|
376 q.exec("drop schema " + qTableName("qtestScHeMa", __FILE__) + " cascade"); |
|
377 } |
|
378 |
|
379 if (testWhiteSpaceNames(db.driverName())) |
|
380 tableNames << db.driver()->escapeIdentifier(qTableName("qtest", __FILE__) + " test", QSqlDriver::TableName); |
|
381 |
|
382 tst_Databases::safeDropTables(db, tableNames); |
|
383 |
|
384 if (db.driverName().startsWith("QOCI")) { |
|
385 q.exec("drop user "+qTableName("CREATOR", __FILE__)+" cascade"); |
|
386 q.exec("drop user "+qTableName("APPUSER", __FILE__)+" cascade"); |
|
387 q.exec("DROP TABLE system."+qTableName("mypassword", __FILE__)); |
|
388 |
|
389 } |
|
390 } |
|
391 |
|
392 void tst_QSqlDatabase::populateTestTables(QSqlDatabase db) |
|
393 { |
|
394 if (!db.isValid()) |
|
395 return; |
|
396 QSqlQuery q(db); |
|
397 const QString qtest(qTableName("qtest", __FILE__)); |
|
398 |
|
399 q.exec("delete from " + qtest); //non-fatal |
|
400 QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (0, 'VarChar0', 'Char0', 1.1)")); |
|
401 QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (1, 'VarChar1', 'Char1', 2.2)")); |
|
402 QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (2, 'VarChar2', 'Char2', 3.3)")); |
|
403 QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (3, 'VarChar3', 'Char3', 4.4)")); |
|
404 QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (4, 'VarChar4', NULL, NULL)")); |
|
405 } |
|
406 |
|
407 void tst_QSqlDatabase::initTestCase() |
|
408 { |
|
409 dbs.open(); |
|
410 |
|
411 for (QStringList::ConstIterator it = dbs.dbNames.begin(); it != dbs.dbNames.end(); ++it) { |
|
412 QSqlDatabase db = QSqlDatabase::database((*it)); |
|
413 CHECK_DATABASE(db); |
|
414 dropTestTables(db); //in case of leftovers |
|
415 createTestTables(db); |
|
416 populateTestTables(db); |
|
417 } |
|
418 } |
|
419 |
|
420 void tst_QSqlDatabase::cleanupTestCase() |
|
421 { |
|
422 for (QStringList::ConstIterator it = dbs.dbNames.begin(); it != dbs.dbNames.end(); ++it) { |
|
423 QSqlDatabase db = QSqlDatabase::database((*it)); |
|
424 CHECK_DATABASE(db); |
|
425 dropTestTables(db); |
|
426 } |
|
427 |
|
428 dbs.close(); |
|
429 } |
|
430 |
|
431 void tst_QSqlDatabase::init() |
|
432 { |
|
433 } |
|
434 |
|
435 void tst_QSqlDatabase::cleanup() |
|
436 { |
|
437 } |
|
438 |
|
439 void tst_QSqlDatabase::generic_data(const QString& engine) |
|
440 { |
|
441 if ( dbs.fillTestTable(engine) == 0 ) { |
|
442 if(engine.isEmpty()) |
|
443 QSKIP( "No database drivers are available in this Qt configuration", SkipAll ); |
|
444 else |
|
445 QSKIP( (QString("No database drivers of type %1 are available in this Qt configuration").arg(engine)).toLocal8Bit(), SkipAll ); |
|
446 } |
|
447 } |
|
448 |
|
449 void tst_QSqlDatabase::addDatabase() |
|
450 { |
|
451 QTest::ignoreMessage(QtWarningMsg, "QSqlDatabase: BLAH_FOO_NONEXISTENT_DRIVER driver not loaded"); |
|
452 QTest::ignoreMessage(QtWarningMsg, qPrintable("QSqlDatabase: available drivers: " + QSqlDatabase::drivers().join(QLatin1String(" ")))); |
|
453 { |
|
454 QSqlDatabase db = QSqlDatabase::addDatabase("BLAH_FOO_NONEXISTENT_DRIVER", |
|
455 "INVALID_CONNECTION"); |
|
456 QVERIFY(!db.isValid()); |
|
457 } |
|
458 QVERIFY(QSqlDatabase::contains("INVALID_CONNECTION")); |
|
459 QSqlDatabase::removeDatabase("INVALID_CONNECTION"); |
|
460 QVERIFY(!QSqlDatabase::contains("INVALID_CONNECTION")); |
|
461 } |
|
462 |
|
463 void tst_QSqlDatabase::open() |
|
464 { |
|
465 QFETCH(QString, dbName); |
|
466 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
467 CHECK_DATABASE(db); |
|
468 |
|
469 int i; |
|
470 for (i = 0; i < 10; ++i) { |
|
471 db.close(); |
|
472 QVERIFY(!db.isOpen()); |
|
473 QVERIFY_SQL(db, open()); |
|
474 QVERIFY(db.isOpen()); |
|
475 QVERIFY(!db.isOpenError()); |
|
476 } |
|
477 |
|
478 if (db.driverName().startsWith("QSQLITE") && db.databaseName() == ":memory:") { |
|
479 // tables in in-memory databases don't survive an open/close |
|
480 createTestTables(db); |
|
481 populateTestTables(db); |
|
482 } |
|
483 } |
|
484 |
|
485 void tst_QSqlDatabase::recordNonSelect() |
|
486 { |
|
487 #ifdef QT3_SUPPORT |
|
488 QFETCH(QString, dbName); |
|
489 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
490 CHECK_DATABASE(db); |
|
491 |
|
492 QSqlQuery q(db); |
|
493 |
|
494 // nothing should happen on an empty query |
|
495 QSqlRecord rec = db.record(q); |
|
496 QVERIFY(rec.isEmpty()); |
|
497 Q3SqlRecordInfo rInf = db.recordInfo(q); |
|
498 QVERIFY(rInf.isEmpty()); |
|
499 |
|
500 QVERIFY_SQL(q, exec("create table " + qTableName("qtest_temp", __FILE__) + " (id int)")); |
|
501 |
|
502 // query without result set should return empty record |
|
503 rec = db.record(q); |
|
504 QVERIFY(rec.isEmpty()); |
|
505 rInf = db.recordInfo(q); |
|
506 QVERIFY(rInf.isEmpty()); |
|
507 #endif |
|
508 } |
|
509 |
|
510 void tst_QSqlDatabase::tables() |
|
511 { |
|
512 QFETCH(QString, dbName); |
|
513 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
514 CHECK_DATABASE(db); |
|
515 |
|
516 const QString qtest(qTableName("qtest", __FILE__)), qtest_view(qTableName("qtest_view", __FILE__)), temp_tab(qTableName("test_tab", __FILE__)); |
|
517 |
|
518 bool views = true; |
|
519 bool tempTables = false; |
|
520 |
|
521 QSqlQuery q(db); |
|
522 if ( db.driverName().startsWith( "QMYSQL" ) && tst_Databases::getMySqlVersion( db ).section( QChar('.'), 0, 0 ).toInt()<5 ) |
|
523 QSKIP( "Test requires MySQL >= 5.0", SkipSingle ); |
|
524 |
|
525 |
|
526 if (!q.exec("CREATE VIEW " + qtest_view + " as select * from " + qtest)) { |
|
527 qDebug(QString("DBMS '%1' cannot handle VIEWs: %2").arg( |
|
528 tst_Databases::dbToString(db)).arg(QString(tst_Databases::printError(q.lastError()))).toLatin1()); |
|
529 views = false; |
|
530 } |
|
531 |
|
532 if (db.driverName().startsWith("QSQLITE3")) { |
|
533 QVERIFY_SQL(q, exec("CREATE TEMPORARY TABLE " + temp_tab + " (id int)")); |
|
534 tempTables = true; |
|
535 } |
|
536 |
|
537 QStringList tables = db.tables(QSql::Tables); |
|
538 QVERIFY(tables.contains(qtest, Qt::CaseInsensitive)); |
|
539 QVERIFY(!tables.contains("sql_features", Qt::CaseInsensitive)); //check for postgres 7.4 internal tables |
|
540 if (views) { |
|
541 QVERIFY(!tables.contains(qtest_view, Qt::CaseInsensitive)); |
|
542 } |
|
543 if (tempTables) |
|
544 QVERIFY(tables.contains(temp_tab, Qt::CaseInsensitive)); |
|
545 |
|
546 tables = db.tables(QSql::Views); |
|
547 if (views) { |
|
548 if(!tables.contains(qtest_view, Qt::CaseInsensitive)) |
|
549 qDebug() << "failed to find" << qtest_view << "in" << tables; |
|
550 QVERIFY(tables.contains(qtest_view, Qt::CaseInsensitive)); |
|
551 } |
|
552 if (tempTables) |
|
553 QVERIFY(!tables.contains(temp_tab, Qt::CaseInsensitive)); |
|
554 QVERIFY(!tables.contains(qtest, Qt::CaseInsensitive)); |
|
555 |
|
556 tables = db.tables(QSql::SystemTables); |
|
557 QVERIFY(!tables.contains(qtest, Qt::CaseInsensitive)); |
|
558 QVERIFY(!tables.contains(qtest_view, Qt::CaseInsensitive)); |
|
559 QVERIFY(!tables.contains(temp_tab, Qt::CaseInsensitive)); |
|
560 |
|
561 tables = db.tables(QSql::AllTables); |
|
562 if (views) |
|
563 QVERIFY(tables.contains(qtest_view, Qt::CaseInsensitive)); |
|
564 if (tempTables) |
|
565 QVERIFY(tables.contains(temp_tab, Qt::CaseInsensitive)); |
|
566 QVERIFY(tables.contains(qtest, Qt::CaseInsensitive)); |
|
567 |
|
568 if (db.driverName().startsWith("QPSQL")) { |
|
569 QVERIFY(tables.contains(qtest + " test")); |
|
570 } |
|
571 } |
|
572 |
|
573 void tst_QSqlDatabase::whitespaceInIdentifiers() |
|
574 { |
|
575 QFETCH(QString, dbName); |
|
576 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
577 CHECK_DATABASE(db); |
|
578 |
|
579 if (testWhiteSpaceNames(db.driverName())) { |
|
580 const QString tableName(qTableName("qtest", __FILE__) + " test"); |
|
581 QVERIFY(db.tables().contains(tableName, Qt::CaseInsensitive)); |
|
582 |
|
583 QSqlRecord rec = db.record(db.driver()->escapeIdentifier(tableName, QSqlDriver::TableName)); |
|
584 QCOMPARE(rec.count(), 1); |
|
585 QCOMPARE(rec.fieldName(0), QString("test test")); |
|
586 if(db.driverName().startsWith("QOCI")) |
|
587 QCOMPARE(rec.field(0).type(), QVariant::Double); |
|
588 else |
|
589 QCOMPARE(rec.field(0).type(), QVariant::Int); |
|
590 |
|
591 QSqlIndex idx = db.primaryIndex(db.driver()->escapeIdentifier(tableName, QSqlDriver::TableName)); |
|
592 QCOMPARE(idx.count(), 1); |
|
593 QCOMPARE(idx.fieldName(0), QString("test test")); |
|
594 if(db.driverName().startsWith("QOCI")) |
|
595 QCOMPARE(idx.field(0).type(), QVariant::Double); |
|
596 else |
|
597 QCOMPARE(idx.field(0).type(), QVariant::Int); |
|
598 } else { |
|
599 QSKIP("DBMS does not support whitespaces in identifiers", SkipSingle); |
|
600 } |
|
601 } |
|
602 |
|
603 void tst_QSqlDatabase::alterTable() |
|
604 { |
|
605 QFETCH(QString, dbName); |
|
606 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
607 CHECK_DATABASE(db); |
|
608 const QString qtestalter(qTableName("qtestalter", __FILE__)); |
|
609 |
|
610 QSqlQuery q(db); |
|
611 |
|
612 QVERIFY_SQL(q, exec("create table " + qtestalter + " (F1 char(20), F2 char(20), F3 char(20))")); |
|
613 QSqlRecord rec = db.record(qtestalter); |
|
614 QCOMPARE((int)rec.count(), 3); |
|
615 #ifdef QT3_SUPPORT |
|
616 Q3SqlRecordInfo rinf = db.recordInfo(qtestalter); |
|
617 QCOMPARE((int)rinf.count(), 3); |
|
618 #endif |
|
619 |
|
620 |
|
621 int i; |
|
622 for (i = 0; i < 3; ++i) { |
|
623 QCOMPARE(rec.field(i).name().toUpper(), QString("F%1").arg(i + 1)); |
|
624 #ifdef QT3_SUPPORT |
|
625 QCOMPARE(rinf[ i ].name().upper(), QString("F%1").arg(i + 1)); |
|
626 #endif |
|
627 } |
|
628 |
|
629 if (!q.exec("alter table " + qtestalter + " drop column F2")) { |
|
630 QSKIP("DBMS doesn't support dropping columns in ALTER TABLE statement", SkipSingle); |
|
631 } |
|
632 |
|
633 rec = db.record(qtestalter); |
|
634 #ifdef QT3_SUPPORT |
|
635 rinf = db.recordInfo(qtestalter); |
|
636 #endif |
|
637 |
|
638 QCOMPARE((int)rec.count(), 2); |
|
639 #ifdef QT3_SUPPORT |
|
640 QCOMPARE((int)rinf.count(), 2); |
|
641 #endif |
|
642 |
|
643 QCOMPARE(rec.field(0).name().toUpper(), QString("F1")); |
|
644 QCOMPARE(rec.field(1).name().toUpper(), QString("F3")); |
|
645 #ifdef QT3_SUPPORT |
|
646 QCOMPARE(rinf[ 0 ].name().upper(), QString("F1")); |
|
647 QCOMPARE(rinf[ 1 ].name().upper(), QString("F3")); |
|
648 #endif |
|
649 |
|
650 q.exec("select * from " + qtestalter); |
|
651 |
|
652 #ifdef QT3_SUPPORT |
|
653 rec = db.record(q); |
|
654 rinf = db.recordInfo(q); |
|
655 |
|
656 QCOMPARE((int)rec.count(), 2); |
|
657 QCOMPARE((int)rinf.count(), 2); |
|
658 |
|
659 QCOMPARE(rec.field(0).name().upper(), QString("F1")); |
|
660 QCOMPARE(rec.field(1).name().upper(), QString("F3")); |
|
661 QCOMPARE(rinf[ 0 ].name().upper(), QString("F1")); |
|
662 QCOMPARE(rinf[ 1 ].name().upper(), QString("F3")); |
|
663 #endif |
|
664 } |
|
665 |
|
666 #if 0 |
|
667 // this is the general test that should work on all databases. |
|
668 // unfortunately no DBMS supports SQL 92/ 99 so the general |
|
669 // test is more or less a joke. Please write a test for each |
|
670 // database plugin (see recordOCI and so on). Use this test |
|
671 // as a template. |
|
672 void tst_QSqlDatabase::record() |
|
673 { |
|
674 QFETCH(QString, dbName); |
|
675 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
676 CHECK_DATABASE(db); |
|
677 |
|
678 static const FieldDef fieldDefs[] = { |
|
679 FieldDef("char(20)", QVariant::String, QString("blah1"), false), |
|
680 FieldDef("varchar(20)", QVariant::String, QString("blah2"), false), |
|
681 FieldDef() |
|
682 }; |
|
683 |
|
684 const int fieldCount = createFieldTable(fieldDefs, db); |
|
685 QVERIFY(fieldCount > 0); |
|
686 |
|
687 // doesn't work with oracle: checkNullValues(fieldDefs, db); |
|
688 commonFieldTest(fieldDefs, db, fieldCount); |
|
689 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
690 checkValues(fieldDefs, db); |
|
691 } |
|
692 } |
|
693 #endif |
|
694 |
|
695 #ifdef QT3_SUPPORT |
|
696 void tst_QSqlDatabase::testRecordInfo(const FieldDef fieldDefs[], const Q3SqlRecordInfo& inf) |
|
697 { |
|
698 int i = 0; |
|
699 for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) { |
|
700 QCOMPARE(inf[i+1].name().upper(), fieldDefs[ i ].fieldName().upper()); |
|
701 if (inf[i+1].type() != fieldDefs[ i ].type) { |
|
702 QFAIL(QString(" Expected: '%1' Received: '%2' for field %3 in testRecordInfo").arg( |
|
703 QVariant::typeToName(fieldDefs[ i ].type)).arg( |
|
704 QVariant::typeToName(inf[i+1].type())).arg( |
|
705 fieldDefs[ i ].fieldName())); |
|
706 } |
|
707 } |
|
708 } |
|
709 #endif |
|
710 |
|
711 void tst_QSqlDatabase::testRecord(const FieldDef fieldDefs[], const QSqlRecord& inf, QSqlDatabase db) |
|
712 { |
|
713 int i = 0; |
|
714 if (!tst_Databases::autoFieldName(db).isEmpty()) // Currently only MySQL is tested |
|
715 QVERIFY2(inf.field(i).isAutoValue(), qPrintable(inf.field(i).name() + " should be reporting as an autovalue")); |
|
716 for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) { |
|
717 QCOMPARE(inf.field(i+1).name().toUpper(), fieldDefs[ i ].fieldName().toUpper()); |
|
718 if (inf.field(i+1).type() != fieldDefs[ i ].type) { |
|
719 QFAIL(qPrintable(QString(" Expected: '%1' Received: '%2' for field %3 in testRecord").arg( |
|
720 QVariant::typeToName(fieldDefs[ i ].type)).arg( |
|
721 QVariant::typeToName(inf.field(i+1).type())).arg( |
|
722 fieldDefs[ i ].fieldName()))); |
|
723 } |
|
724 QVERIFY(!inf.field(i+1).isAutoValue()); |
|
725 |
|
726 // qDebug(QString(" field: %1 type: %2 variant type: %3").arg(fieldDefs[ i ].fieldName()).arg(QVariant::typeToName(inf.field(i+1)->type())).arg(QVariant::typeToName(inf.field(i+1)->value().type()))); |
|
727 } |
|
728 } |
|
729 |
|
730 // non-dbms specific tests |
|
731 void tst_QSqlDatabase::commonFieldTest(const FieldDef fieldDefs[], QSqlDatabase db, const int fieldCount) |
|
732 { |
|
733 CHECK_DATABASE(db); |
|
734 |
|
735 // check whether recordInfo returns the right types |
|
736 #ifdef QT3_SUPPORT |
|
737 Q3SqlRecordInfo inf = db.recordInfo(qTableName("qtestfields", __FILE__)); |
|
738 QCOMPARE((int)inf.count(), fieldCount+1); |
|
739 testRecordInfo(fieldDefs, inf); |
|
740 #endif |
|
741 |
|
742 QSqlRecord rec = db.record(qTableName("qtestfields", __FILE__)); |
|
743 QCOMPARE((int)rec.count(), fieldCount+1); |
|
744 testRecord(fieldDefs, rec, db); |
|
745 |
|
746 QSqlQuery q(db); |
|
747 QVERIFY_SQL(q, exec("select * from " + qTableName("qtestfields", __FILE__))); |
|
748 |
|
749 #ifdef QT3_SUPPORT |
|
750 inf = db.recordInfo(q); |
|
751 QCOMPARE((int)inf.count(), fieldCount+1); |
|
752 testRecordInfo(fieldDefs, inf); |
|
753 |
|
754 rec = db.record(q); |
|
755 QCOMPARE((int)rec.count(), fieldCount+1); |
|
756 testRecord(fieldDefs, rec, db); |
|
757 #endif |
|
758 } |
|
759 |
|
760 // inserts testdata into the testtable, fetches and compares them |
|
761 void tst_QSqlDatabase::checkValues(const FieldDef fieldDefs[], QSqlDatabase db) |
|
762 { |
|
763 Q_UNUSED(fieldDefs); |
|
764 #ifdef QT3_SUPPORT |
|
765 CHECK_DATABASE(db); |
|
766 |
|
767 Q3SqlCursor cur(qTableName("qtestfields", __FILE__), true, db); |
|
768 QVERIFY_SQL(cur, select()); |
|
769 QSqlRecord* rec = cur.primeInsert(); |
|
770 Q_ASSERT(rec); |
|
771 rec->setValue("id", pkey++); |
|
772 int i = 0; |
|
773 for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) { |
|
774 rec->setValue(fieldDefs[ i ].fieldName(), fieldDefs[ i ].val); |
|
775 // qDebug(QString("inserting %1 into %2").arg(fieldDefs[ i ].val.toString()).arg(fieldDefs[ i ].fieldName())); |
|
776 } |
|
777 QVERIFY_SQL(cur, insert()); |
|
778 cur.setForwardOnly(true); |
|
779 QVERIFY_SQL(cur, select("id = " + QString::number(pkey - 1))); |
|
780 QVERIFY_SQL(cur, next()); |
|
781 |
|
782 for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) { |
|
783 bool ok = false; |
|
784 QVariant val1 = cur.value(fieldDefs[ i ].fieldName()); |
|
785 QVariant val2 = fieldDefs[ i ].val; |
|
786 if (val1.type() == QVariant::String) |
|
787 //TDS Workaround |
|
788 val1 = val1.toString().stripWhiteSpace(); |
|
789 if (fieldDefs[ i ].fieldName() == "t_real") { |
|
790 // strip precision |
|
791 val1 = (float)val1.toDouble(); |
|
792 val2 = (float)val2.toDouble(); |
|
793 } |
|
794 if (val1.canCast(QVariant::Double) && val2.type() == QVariant::Double) { |
|
795 // we don't care about precision here, we just want to know whether |
|
796 // we can insert/fetch the right values |
|
797 ok = (val1.toDouble() - val2.toDouble() < 0.00001); |
|
798 } else if (val1.type() == val2.type()) { |
|
799 ok = (val1 == val2); |
|
800 } else { |
|
801 ok = (val1.toString() == val2.toString()); |
|
802 } |
|
803 if (!ok) { |
|
804 if (val2.type() == QVariant::DateTime || val2.type() == QVariant::Time) |
|
805 qDebug("Expected Time: " + val2.toTime().toString("hh:mm:ss.zzz")); |
|
806 if (val1.type() == QVariant::DateTime || val1.type() == QVariant::Time) |
|
807 qDebug("Received Time: " + val1.toTime().toString("hh:mm:ss.zzz")); |
|
808 QFAIL(QString(" Expected: '%1' Received: '%2' for field %3 (etype %4 rtype %5) in checkValues").arg( |
|
809 val2.type() == QVariant::ByteArray ? val2.toByteArray().toHex() : val2.toString()).arg( |
|
810 val1.type() == QVariant::ByteArray ? val1.toByteArray().toHex() : val1.toString()).arg( |
|
811 fieldDefs[ i ].fieldName()).arg( |
|
812 val2.typeName()).arg( |
|
813 val1.typeName()) |
|
814 ); |
|
815 } |
|
816 } |
|
817 #endif |
|
818 } |
|
819 |
|
820 // inserts a NULL value for each nullable field in testdata, fetches and checks whether |
|
821 // we get back NULL |
|
822 void tst_QSqlDatabase::checkNullValues(const FieldDef fieldDefs[], QSqlDatabase db) |
|
823 { |
|
824 Q_UNUSED(fieldDefs); |
|
825 #ifdef QT3_SUPPORT |
|
826 CHECK_DATABASE(db); |
|
827 |
|
828 Q3SqlCursor cur(qTableName("qtestfields", __FILE__), true, db); |
|
829 QVERIFY_SQL(cur, select()); |
|
830 QSqlRecord* rec = cur.primeInsert(); |
|
831 Q_ASSERT(rec); |
|
832 rec->setValue("id", pkey++); |
|
833 int i = 0; |
|
834 for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) { |
|
835 if (fieldDefs[ i ].fieldName(), fieldDefs[ i ].nullable) |
|
836 rec->setNull(fieldDefs[ i ].fieldName()); |
|
837 else |
|
838 rec->setValue(fieldDefs[ i ].fieldName(), fieldDefs[ i ].val); |
|
839 } |
|
840 QVERIFY_SQL(cur, insert()); |
|
841 cur.setForwardOnly(true); |
|
842 QVERIFY_SQL(cur, select("id = " + QString::number(pkey - 1))); |
|
843 QVERIFY_SQL(cur, next()); |
|
844 |
|
845 for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) { |
|
846 if (fieldDefs[ i ].nullable == false) |
|
847 continue; |
|
848 // multiple inheritance sucks so much |
|
849 QVERIFY2(((QSqlQuery)cur).isNull(i + 1), "Check whether '" + fieldDefs[ i ].fieldName() + "' is null in QSqlQuery"); |
|
850 QVERIFY2(((QSqlRecord)cur).isNull(fieldDefs[ i ].fieldName()), "Check whether '" + fieldDefs[ i ].fieldName() + "' is null in QSqlRecord"); |
|
851 if (!cur.value(fieldDefs[ i ].fieldName()).isNull()) |
|
852 qDebug(QString("QVariant is not null for NULL-Value in Field '%1'").arg(fieldDefs[ i ].fieldName())); |
|
853 } |
|
854 #endif |
|
855 } |
|
856 |
|
857 void tst_QSqlDatabase::recordTDS() |
|
858 { |
|
859 QFETCH(QString, dbName); |
|
860 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
861 CHECK_DATABASE(db); |
|
862 |
|
863 static const FieldDef fieldDefs[] = { |
|
864 FieldDef("tinyint", QVariant::Int, 255), |
|
865 FieldDef("smallint", QVariant::Int, 32767), |
|
866 FieldDef("int", QVariant::Int, 2147483647), |
|
867 FieldDef("numeric(10,9)", QVariant::Double, 1.23456789), |
|
868 FieldDef("decimal(10,9)", QVariant::Double, 1.23456789), |
|
869 FieldDef("float(4)", QVariant::Double, 1.23456789), |
|
870 FieldDef("double precision", QVariant::Double, 1.23456789), |
|
871 FieldDef("real", QVariant::Double, 1.23456789), |
|
872 FieldDef("smallmoney", QVariant::Double, 100.42), |
|
873 FieldDef("money", QVariant::Double, 200.42), |
|
874 // accuracy is that of a minute |
|
875 FieldDef("smalldatetime", QVariant::DateTime, QDateTime(QDate::currentDate(), QTime(1, 2, 0, 0))), |
|
876 // accuracy is that of a second |
|
877 FieldDef("datetime", QVariant::DateTime, QDateTime(QDate::currentDate(), QTime(1, 2, 3, 0))), |
|
878 FieldDef("char(20)", QVariant::String, "blah1"), |
|
879 FieldDef("varchar(20)", QVariant::String, "blah2"), |
|
880 FieldDef("nchar(20)", QVariant::String, "blah3"), |
|
881 FieldDef("nvarchar(20)", QVariant::String, "blah4"), |
|
882 FieldDef("text", QVariant::String, "blah5"), |
|
883 #ifdef QT3_SUPPORT |
|
884 FieldDef("binary(20)", QVariant::ByteArray, Q3CString("blah6")), |
|
885 FieldDef("varbinary(20)", QVariant::ByteArray, Q3CString("blah7")), |
|
886 FieldDef("image", QVariant::ByteArray, Q3CString("blah8")), |
|
887 #endif |
|
888 FieldDef("bit", QVariant::Int, 1, false), |
|
889 |
|
890 FieldDef() |
|
891 }; |
|
892 |
|
893 const int fieldCount = createFieldTable(fieldDefs, db); |
|
894 QVERIFY(fieldCount > 0); |
|
895 |
|
896 commonFieldTest(fieldDefs, db, fieldCount); |
|
897 checkNullValues(fieldDefs, db); |
|
898 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
899 checkValues(fieldDefs, db); |
|
900 } |
|
901 } |
|
902 |
|
903 void tst_QSqlDatabase::recordOCI() |
|
904 { |
|
905 bool hasTimeStamp = false; |
|
906 |
|
907 QFETCH(QString, dbName); |
|
908 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
909 CHECK_DATABASE(db); |
|
910 |
|
911 // runtime check for Oracle version since V8 doesn't support TIMESTAMPs |
|
912 if (tst_Databases::getOraVersion(db) >= 9) |
|
913 hasTimeStamp = true; |
|
914 |
|
915 FieldDef tsdef; |
|
916 FieldDef tstzdef; |
|
917 FieldDef tsltzdef; |
|
918 FieldDef intytm; |
|
919 FieldDef intdts; |
|
920 |
|
921 static const QDateTime dt(QDate::currentDate(), QTime(1, 2, 3, 0)); |
|
922 |
|
923 if (hasTimeStamp) { |
|
924 tsdef = FieldDef("timestamp", QVariant::DateTime, dt); |
|
925 tstzdef = FieldDef("timestamp with time zone", QVariant::DateTime, dt); |
|
926 tsltzdef = FieldDef("timestamp with local time zone", QVariant::DateTime, dt); |
|
927 intytm = FieldDef("interval year to month", QVariant::String, QString("+01-01")); |
|
928 intdts = FieldDef("interval day to second", QVariant::String, QString("+01 00:00:01.000000")); |
|
929 } |
|
930 |
|
931 const FieldDef fieldDefs[] = { |
|
932 FieldDef("char(20)", QVariant::String, QString("blah1")), |
|
933 FieldDef("varchar(20)", QVariant::String, QString("blah2")), |
|
934 FieldDef("nchar(20)", QVariant::String, QString("blah3")), |
|
935 FieldDef("nvarchar2(20)", QVariant::String, QString("blah4")), |
|
936 FieldDef("number(10,5)", QVariant::Double, 1.1234567), |
|
937 FieldDef("date", QVariant::DateTime, dt), |
|
938 FieldDef("long raw", QVariant::ByteArray, QByteArray("blah5")), |
|
939 FieldDef("raw(2000)", QVariant::ByteArray, QByteArray("blah6"), false), |
|
940 FieldDef("blob", QVariant::ByteArray, QByteArray("blah7")), |
|
941 FieldDef("clob", QVariant::String, QString("blah8")), |
|
942 FieldDef("nclob", QVariant::String, QString("blah9")), |
|
943 // FieldDef("bfile", QVariant::ByteArray, QByteArray("blah10")), |
|
944 |
|
945 intytm, |
|
946 intdts, |
|
947 tsdef, |
|
948 tstzdef, |
|
949 tsltzdef, |
|
950 FieldDef() |
|
951 }; |
|
952 |
|
953 const int fieldCount = createFieldTable(fieldDefs, db); |
|
954 QVERIFY(fieldCount > 0); |
|
955 |
|
956 commonFieldTest(fieldDefs, db, fieldCount); |
|
957 checkNullValues(fieldDefs, db); |
|
958 for (int i = 0; i < ITERATION_COUNT; ++i) |
|
959 checkValues(fieldDefs, db); |
|
960 |
|
961 // some additional tests |
|
962 QSqlRecord rec = db.record(qTableName("qtestfields", __FILE__)); |
|
963 QCOMPARE(rec.field("T_NUMBER").length(), 10); |
|
964 QCOMPARE(rec.field("T_NUMBER").precision(), 5); |
|
965 |
|
966 QSqlQuery q(db); |
|
967 QVERIFY_SQL(q, exec("SELECT * FROM " + qTableName("qtestfields", __FILE__))); |
|
968 rec = q.record(); |
|
969 QCOMPARE(rec.field("T_NUMBER").length(), 10); |
|
970 QCOMPARE(rec.field("T_NUMBER").precision(), 5); |
|
971 } |
|
972 |
|
973 void tst_QSqlDatabase::recordPSQL() |
|
974 { |
|
975 QFETCH(QString, dbName); |
|
976 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
977 CHECK_DATABASE(db); |
|
978 |
|
979 FieldDef byteadef; |
|
980 if (db.driver()->hasFeature(QSqlDriver::BLOB)) |
|
981 #ifdef QT3_SUPPORT |
|
982 byteadef = FieldDef("bytea", QVariant::ByteArray, QByteArray(Q3CString("bl\\ah"))); |
|
983 #else |
|
984 byteadef = FieldDef("bytea", QVariant::ByteArray, QByteArray("bl\\ah")); |
|
985 #endif |
|
986 static FieldDef fieldDefs[] = { |
|
987 FieldDef("bigint", QVariant::LongLong, Q_INT64_C(9223372036854775807)), |
|
988 FieldDef("bigserial", QVariant::LongLong, 100, false), |
|
989 FieldDef("bit", QVariant::String, "1"), // a bit in postgres is a bit-string |
|
990 #ifdef QT3_SUPPORT |
|
991 FieldDef("boolean", QVariant::Bool, QVariant(bool(true), 0)), |
|
992 #endif |
|
993 FieldDef("box", QVariant::String, "(5,6),(1,2)"), |
|
994 FieldDef("char(20)", QVariant::String, "blah5678901234567890"), |
|
995 FieldDef("varchar(20)", QVariant::String, "blah5678901234567890"), |
|
996 FieldDef("cidr", QVariant::String, "12.123.0.0/24"), |
|
997 FieldDef("circle", QVariant::String, "<(1,2),3>"), |
|
998 FieldDef("date", QVariant::Date, QDate::currentDate()), |
|
999 FieldDef("float8", QVariant::Double, 1.12345678912), |
|
1000 FieldDef("inet", QVariant::String, "12.123.12.23"), |
|
1001 FieldDef("integer", QVariant::Int, 2147483647), |
|
1002 FieldDef("interval", QVariant::String, "1 day 12:59:10"), |
|
1003 // LOL... you can create a "line" datatype in PostgreSQL <= 7.2.x but |
|
1004 // as soon as you want to insert data you get a "not implemented yet" error |
|
1005 // FieldDef("line", QVariant::Polygon, QPolygon(QRect(1, 2, 3, 4))), |
|
1006 FieldDef("lseg", QVariant::String, "[(1,1),(2,2)]"), |
|
1007 FieldDef("macaddr", QVariant::String, "08:00:2b:01:02:03"), |
|
1008 FieldDef("money", QVariant::String, "$12.23"), |
|
1009 FieldDef("numeric", QVariant::Double, 1.2345678912), |
|
1010 FieldDef("path", QVariant::String, "((1,2),(3,2),(3,5),(1,5))"), |
|
1011 FieldDef("point", QVariant::String, "(1,2)"), |
|
1012 FieldDef("polygon", QVariant::String, "((1,2),(3,2),(3,5),(1,5))"), |
|
1013 FieldDef("real", QVariant::Double, 1.1234), |
|
1014 FieldDef("smallint", QVariant::Int, 32767), |
|
1015 FieldDef("serial", QVariant::Int, 100, false), |
|
1016 FieldDef("text", QVariant::String, "blah"), |
|
1017 FieldDef("time(6)", QVariant::Time, QTime(1, 2, 3)), |
|
1018 FieldDef("timetz", QVariant::Time, QTime(1, 2, 3)), |
|
1019 FieldDef("timestamp(6)", QVariant::DateTime, QDateTime::currentDateTime()), |
|
1020 FieldDef("timestamptz", QVariant::DateTime, QDateTime::currentDateTime()), |
|
1021 byteadef, |
|
1022 |
|
1023 FieldDef() |
|
1024 }; |
|
1025 |
|
1026 QSqlQuery q(db); |
|
1027 |
|
1028 if(tst_Databases::isPostgreSQL(db)) |
|
1029 QVERIFY_SQL( q, exec("set client_min_messages='warning'")); |
|
1030 |
|
1031 q.exec("drop sequence " + qTableName("qtestfields", __FILE__) + "_t_bigserial_seq"); |
|
1032 q.exec("drop sequence " + qTableName("qtestfields", __FILE__) + "_t_serial_seq"); |
|
1033 // older psql cut off the table name |
|
1034 q.exec("drop sequence " + qTableName("qtestfields", __FILE__).left(15) + "_t_bigserial_seq"); |
|
1035 q.exec("drop sequence " + qTableName("qtestfields", __FILE__).left(18) + "_t_serial_seq"); |
|
1036 |
|
1037 const int fieldCount = createFieldTable(fieldDefs, db); |
|
1038 QVERIFY(fieldCount > 0); |
|
1039 |
|
1040 commonFieldTest(fieldDefs, db, fieldCount); |
|
1041 checkNullValues(fieldDefs, db); |
|
1042 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
1043 // increase serial values |
|
1044 for (int i2 = 0; !fieldDefs[ i2 ].typeName.isNull(); ++i2) { |
|
1045 if (fieldDefs[ i2 ].typeName == "serial" || |
|
1046 fieldDefs[ i2 ].typeName == "bigserial") { |
|
1047 |
|
1048 FieldDef def = fieldDefs[ i2 ]; |
|
1049 #ifdef QT3_SUPPORT |
|
1050 def.val = def.val.asInt() + 1; |
|
1051 #else |
|
1052 def.val = def.val.toInt() + 1; |
|
1053 #endif |
|
1054 fieldDefs[ i2 ] = def; |
|
1055 } |
|
1056 } |
|
1057 checkValues(fieldDefs, db); |
|
1058 } |
|
1059 } |
|
1060 |
|
1061 void tst_QSqlDatabase::recordMySQL() |
|
1062 { |
|
1063 QFETCH(QString, dbName); |
|
1064 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1065 CHECK_DATABASE(db); |
|
1066 |
|
1067 FieldDef bin10, varbin10; |
|
1068 int major = tst_Databases::getMySqlVersion( db ).section( QChar('.'), 0, 0 ).toInt(); |
|
1069 int minor = tst_Databases::getMySqlVersion( db ).section( QChar('.'), 1, 1 ).toInt(); |
|
1070 int revision = tst_Databases::getMySqlVersion( db ).section( QChar('.'), 2, 2 ).toInt(); |
|
1071 int vernum = (major << 16) + (minor << 8) + revision; |
|
1072 |
|
1073 /* The below is broken in mysql below 5.0.15 |
|
1074 see http://dev.mysql.com/doc/refman/5.0/en/binary-varbinary.html |
|
1075 specifically: Before MySQL 5.0.15, the pad value is space. Values are right-padded |
|
1076 with space on insert, and trailing spaces are removed on select. |
|
1077 */ |
|
1078 if( vernum >= ((5 << 16) + 15) ) { |
|
1079 #ifdef QT3_SUPPORT |
|
1080 bin10 = FieldDef("binary(10)", QVariant::ByteArray, QByteArray(Q3CString("123abc "))); |
|
1081 varbin10 = FieldDef("varbinary(10)", QVariant::ByteArray, QByteArray(Q3CString("123abcv "))); |
|
1082 #else |
|
1083 bin10 = FieldDef("binary(10)", QVariant::ByteArray, QString("123abc ")); |
|
1084 varbin10 = FieldDef("varbinary(10)", QVariant::ByteArray, QString("123abcv ")); |
|
1085 #endif |
|
1086 } |
|
1087 |
|
1088 static QDateTime dt(QDate::currentDate(), QTime(1, 2, 3, 0)); |
|
1089 static const FieldDef fieldDefs[] = { |
|
1090 FieldDef("tinyint", QVariant::Int, 127), |
|
1091 FieldDef("tinyint unsigned", QVariant::UInt, 255), |
|
1092 FieldDef("smallint", QVariant::Int, 32767), |
|
1093 FieldDef("smallint unsigned", QVariant::UInt, 65535), |
|
1094 FieldDef("mediumint", QVariant::Int, 8388607), |
|
1095 FieldDef("mediumint unsigned", QVariant::UInt, 16777215), |
|
1096 FieldDef("integer", QVariant::Int, 2147483647), |
|
1097 FieldDef("integer unsigned", QVariant::UInt, 4294967295u), |
|
1098 FieldDef("bigint", QVariant::LongLong, Q_INT64_C(9223372036854775807)), |
|
1099 FieldDef("bigint unsigned", QVariant::ULongLong, Q_UINT64_C(18446744073709551615)), |
|
1100 FieldDef("float", QVariant::Double, 1.12345), |
|
1101 FieldDef("double", QVariant::Double, 1.123456789), |
|
1102 FieldDef("decimal(10, 9)", QVariant::Double,1.123456789), |
|
1103 FieldDef("numeric(5, 2)", QVariant::Double, 123.67), |
|
1104 FieldDef("date", QVariant::Date, QDate::currentDate()), |
|
1105 FieldDef("datetime", QVariant::DateTime, dt), |
|
1106 FieldDef("timestamp", QVariant::DateTime, dt, false), |
|
1107 FieldDef("time", QVariant::Time, dt.time()), |
|
1108 FieldDef("year", QVariant::Int, 2003), |
|
1109 FieldDef("char(20)", QVariant::String, "Blah"), |
|
1110 FieldDef("varchar(20)", QVariant::String, "BlahBlah"), |
|
1111 #ifdef QT3_SUPPORT |
|
1112 FieldDef("tinyblob", QVariant::ByteArray, QByteArray(Q3CString("blah1"))), |
|
1113 FieldDef("blob", QVariant::ByteArray, QByteArray(Q3CString("blah2"))), |
|
1114 FieldDef("mediumblob", QVariant::ByteArray,QByteArray(Q3CString("blah3"))), |
|
1115 FieldDef("longblob", QVariant::ByteArray, QByteArray(Q3CString("blah4"))), |
|
1116 #endif |
|
1117 FieldDef("tinytext", QVariant::String, QString("blah5")), |
|
1118 FieldDef("text", QVariant::String, QString("blah6")), |
|
1119 FieldDef("mediumtext", QVariant::String, QString("blah7")), |
|
1120 FieldDef("longtext", QVariant::String, QString("blah8")), |
|
1121 #ifdef QT3_SUPPORT |
|
1122 bin10, |
|
1123 varbin10, |
|
1124 #endif |
|
1125 // SET OF? |
|
1126 |
|
1127 FieldDef() |
|
1128 }; |
|
1129 |
|
1130 const int fieldCount = createFieldTable(fieldDefs, db); |
|
1131 QVERIFY(fieldCount > 0); |
|
1132 |
|
1133 commonFieldTest(fieldDefs, db, fieldCount); |
|
1134 checkNullValues(fieldDefs, db); |
|
1135 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
1136 checkValues(fieldDefs, db); |
|
1137 } |
|
1138 |
|
1139 QSqlQuery q(db); |
|
1140 QVERIFY_SQL(q, exec("SELECT DATE_SUB(CURDATE(), INTERVAL 2 DAY)")); |
|
1141 QVERIFY(q.next()); |
|
1142 QCOMPARE(q.value(0).toDateTime().date(), QDate::currentDate().addDays(-2)); |
|
1143 } |
|
1144 |
|
1145 void tst_QSqlDatabase::recordDB2() |
|
1146 { |
|
1147 QFETCH(QString, dbName); |
|
1148 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1149 CHECK_DATABASE(db); |
|
1150 |
|
1151 static const FieldDef fieldDefs[] = { |
|
1152 FieldDef("char(20)", QVariant::String, QString("Blah1")), |
|
1153 FieldDef("varchar(20)", QVariant::String, QString("Blah2")), |
|
1154 FieldDef("long varchar", QVariant::String, QString("Blah3")), |
|
1155 // using BOOLEAN results in "SQL0486N The BOOLEAN data type is currently only supported internally." |
|
1156 //X FieldDef("boolean" , QVariant::Bool, QVariant(true, 1)), |
|
1157 FieldDef("smallint", QVariant::Int, 32767), |
|
1158 FieldDef("integer", QVariant::Int, 2147483647), |
|
1159 FieldDef("bigint", QVariant::LongLong, Q_INT64_C(9223372036854775807)), |
|
1160 FieldDef("real", QVariant::Double, 1.12345), |
|
1161 FieldDef("double", QVariant::Double, 1.23456789), |
|
1162 FieldDef("float", QVariant::Double, 1.23456789), |
|
1163 FieldDef("decimal(10,9)", QVariant::Double, 1.234567891), |
|
1164 FieldDef("numeric(10,9)", QVariant::Double, 1.234567891), |
|
1165 FieldDef("date", QVariant::Date, QDate::currentDate()), |
|
1166 FieldDef("time", QVariant::Time, QTime(1, 2, 3)), |
|
1167 FieldDef("timestamp", QVariant::DateTime, QDateTime::currentDateTime()), |
|
1168 // FieldDef("graphic(20)", QVariant::String, QString("Blah4")), |
|
1169 // FieldDef("vargraphic(20)", QVariant::String, QString("Blah5")), |
|
1170 // FieldDef("long vargraphic", QVariant::String, QString("Blah6")), |
|
1171 #ifdef QT3_SUPPORT |
|
1172 // FieldDef("clob(20)", QVariant::CString, QString("Blah7")), |
|
1173 // FieldDef("dbclob(20)", QVariant::CString, QString("Blah8")), |
|
1174 // FieldDef("blob(20)", QVariant::ByteArray, QByteArray(Q3CString("Blah9"))), |
|
1175 #endif |
|
1176 //X FieldDef("datalink", QVariant::String, QString("DLVALUE('Blah10')")), |
|
1177 FieldDef() |
|
1178 }; |
|
1179 |
|
1180 const int fieldCount = createFieldTable(fieldDefs, db); |
|
1181 QVERIFY(fieldCount > 0); |
|
1182 |
|
1183 commonFieldTest(fieldDefs, db, fieldCount); |
|
1184 checkNullValues(fieldDefs, db); |
|
1185 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
1186 checkValues(fieldDefs, db); |
|
1187 } |
|
1188 } |
|
1189 |
|
1190 void tst_QSqlDatabase::recordIBase() |
|
1191 { |
|
1192 QFETCH(QString, dbName); |
|
1193 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1194 CHECK_DATABASE(db); |
|
1195 |
|
1196 static const FieldDef fieldDefs[] = { |
|
1197 FieldDef("char(20)", QVariant::String, QString("Blah1"), false), |
|
1198 FieldDef("varchar(20)", QVariant::String, QString("Blah2")), |
|
1199 FieldDef("smallint", QVariant::Int, 32767), |
|
1200 FieldDef("float", QVariant::Double, 1.2345), |
|
1201 FieldDef("double precision", QVariant::Double, 1.2345678), |
|
1202 FieldDef("timestamp", QVariant::DateTime, QDateTime::currentDateTime()), |
|
1203 FieldDef("time", QVariant::Time, QTime::currentTime()), |
|
1204 FieldDef("decimal(18)", QVariant::LongLong, Q_INT64_C(9223372036854775807)), |
|
1205 FieldDef("numeric(5,2)", QVariant::Double, 123.45), |
|
1206 |
|
1207 FieldDef() |
|
1208 }; |
|
1209 |
|
1210 const int fieldCount = createFieldTable(fieldDefs, db); |
|
1211 QVERIFY(fieldCount > 0); |
|
1212 |
|
1213 commonFieldTest(fieldDefs, db, fieldCount); |
|
1214 checkNullValues(fieldDefs, db); |
|
1215 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
1216 checkValues(fieldDefs, db); |
|
1217 } |
|
1218 } |
|
1219 |
|
1220 void tst_QSqlDatabase::recordSQLite() |
|
1221 { |
|
1222 QFETCH(QString, dbName); |
|
1223 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1224 CHECK_DATABASE(db); |
|
1225 |
|
1226 static const FieldDef fieldDefs[] = { |
|
1227 // The affinity of these fields are TEXT so SQLite should give us strings, not ints or doubles. |
|
1228 FieldDef("char(20)", QVariant::String, QString("123")), |
|
1229 FieldDef("varchar(20)", QVariant::String, QString("123.4")), |
|
1230 FieldDef("clob", QVariant::String, QString("123.45")), |
|
1231 FieldDef("text", QVariant::String, QString("123.456")), |
|
1232 |
|
1233 FieldDef("integer", QVariant::Int, QVariant(13)), |
|
1234 FieldDef("int", QVariant::Int, QVariant(12)), |
|
1235 FieldDef("real", QVariant::String, QVariant(1.234567890123456)), |
|
1236 |
|
1237 FieldDef() |
|
1238 }; |
|
1239 |
|
1240 const int fieldCount = createFieldTable(fieldDefs, db); |
|
1241 QVERIFY(fieldCount > 0); |
|
1242 |
|
1243 commonFieldTest(fieldDefs, db, fieldCount); |
|
1244 checkNullValues(fieldDefs, db); |
|
1245 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
1246 checkValues(fieldDefs, db); |
|
1247 } |
|
1248 } |
|
1249 |
|
1250 void tst_QSqlDatabase::recordSQLServer() |
|
1251 { |
|
1252 QFETCH(QString, dbName); |
|
1253 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1254 CHECK_DATABASE(db); |
|
1255 |
|
1256 if (!tst_Databases::isSqlServer(db)) { |
|
1257 QSKIP("SQL server specific test", SkipSingle); |
|
1258 return; |
|
1259 } |
|
1260 |
|
1261 // ### TODO: Add the rest of the fields |
|
1262 static const FieldDef fieldDefs[] = { |
|
1263 FieldDef("varchar(20)", QVariant::String, QString("Blah1")), |
|
1264 FieldDef("bigint", QVariant::LongLong, 12345), |
|
1265 FieldDef("int", QVariant::Int, 123456), |
|
1266 FieldDef("tinyint", QVariant::UInt, 255), |
|
1267 #ifdef QT3_SUPPORT |
|
1268 FieldDef("image", QVariant::ByteArray, Q3CString("Blah1")), |
|
1269 #endif |
|
1270 FieldDef("float", QVariant::Double, 1.12345), |
|
1271 FieldDef("numeric(5,2)", QVariant::Double, 123.45), |
|
1272 FieldDef("uniqueidentifier", QVariant::String, |
|
1273 QString("AA7DF450-F119-11CD-8465-00AA00425D90")), |
|
1274 |
|
1275 FieldDef() |
|
1276 }; |
|
1277 |
|
1278 const int fieldCount = createFieldTable(fieldDefs, db); |
|
1279 QVERIFY(fieldCount > 0); |
|
1280 |
|
1281 commonFieldTest(fieldDefs, db, fieldCount); |
|
1282 checkNullValues(fieldDefs, db); |
|
1283 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
1284 checkValues(fieldDefs, db); |
|
1285 } |
|
1286 } |
|
1287 |
|
1288 void tst_QSqlDatabase::recordAccess() |
|
1289 { |
|
1290 QFETCH(QString, dbName); |
|
1291 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1292 CHECK_DATABASE(db); |
|
1293 |
|
1294 if (!tst_Databases::isMSAccess(db)) { |
|
1295 QSKIP("MS Access specific test", SkipSingle); |
|
1296 return; |
|
1297 } |
|
1298 |
|
1299 QString memo; |
|
1300 for (int i = 0; i < 32; i++) |
|
1301 memo.append("ABCDEFGH12345678abcdefgh12345678"); |
|
1302 |
|
1303 // ### TODO: Add the rest of the fields |
|
1304 static const FieldDef fieldDefs[] = { |
|
1305 FieldDef("varchar(20)", QVariant::String, QString("Blah1")), |
|
1306 FieldDef("single", QVariant::Double, 1.12345), |
|
1307 FieldDef("double", QVariant::Double, 1.123456), |
|
1308 FieldDef("byte", QVariant::UInt, 255), |
|
1309 #ifdef QT3_SUPPORT |
|
1310 FieldDef("binary(5)", QVariant::ByteArray, Q3CString("Blah2")), |
|
1311 #endif |
|
1312 FieldDef("long", QVariant::Int, 2147483647), |
|
1313 FieldDef("memo", QVariant::String, memo), |
|
1314 FieldDef() |
|
1315 }; |
|
1316 |
|
1317 const int fieldCount = createFieldTable(fieldDefs, db); |
|
1318 QVERIFY(fieldCount > 0); |
|
1319 |
|
1320 commonFieldTest(fieldDefs, db, fieldCount); |
|
1321 checkNullValues(fieldDefs, db); |
|
1322 for (int i = 0; i < ITERATION_COUNT; ++i) { |
|
1323 checkValues(fieldDefs, db); |
|
1324 } |
|
1325 } |
|
1326 |
|
1327 void tst_QSqlDatabase::transaction() |
|
1328 { |
|
1329 QFETCH(QString, dbName); |
|
1330 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1331 CHECK_DATABASE(db); |
|
1332 const QString qtest(qTableName("qtest", __FILE__)); |
|
1333 |
|
1334 if (!db.driver()->hasFeature(QSqlDriver::Transactions)) { |
|
1335 QSKIP("DBMS not transaction capable", SkipSingle); |
|
1336 } |
|
1337 |
|
1338 QVERIFY(db.transaction()); |
|
1339 |
|
1340 QSqlQuery q(db); |
|
1341 QVERIFY_SQL(q, exec("insert into " + qtest + " values (40, 'VarChar40', 'Char40', 40.40)")); |
|
1342 QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 40")); |
|
1343 QVERIFY(q.next()); |
|
1344 QCOMPARE(q.value(0).toInt(), 40); |
|
1345 q.clear(); |
|
1346 |
|
1347 QVERIFY(db.commit()); |
|
1348 |
|
1349 QVERIFY(db.transaction()); |
|
1350 QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 40")); |
|
1351 QVERIFY(q.next()); |
|
1352 QCOMPARE(q.value(0).toInt(), 40); |
|
1353 q.clear(); |
|
1354 QVERIFY(db.commit()); |
|
1355 |
|
1356 QVERIFY(db.transaction()); |
|
1357 QVERIFY_SQL(q, exec("insert into " + qtest + " values (41, 'VarChar41', 'Char41', 41.41)")); |
|
1358 QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 41")); |
|
1359 QVERIFY(q.next()); |
|
1360 QCOMPARE(q.value(0).toInt(), 41); |
|
1361 q.clear(); // for SQLite which does not allow any references on rows that shall be rolled back |
|
1362 if (!db.rollback()) { |
|
1363 if (db.driverName().startsWith("QMYSQL")) { |
|
1364 qDebug("MySQL: " + tst_Databases::printError(db.lastError())); |
|
1365 QSKIP("MySQL transaction failed ", SkipSingle); //non-fatal |
|
1366 } else { |
|
1367 QFAIL("Could not rollback transaction: " + tst_Databases::printError(db.lastError())); |
|
1368 } |
|
1369 } |
|
1370 |
|
1371 QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 41")); |
|
1372 if(db.driverName().startsWith("QODBC") && dbName.contains("MySQL")) |
|
1373 QEXPECT_FAIL("", "Some odbc drivers don't actually roll back despite telling us they do, especially the mysql driver", Continue); |
|
1374 QVERIFY(!q.next()); |
|
1375 |
|
1376 populateTestTables(db); |
|
1377 } |
|
1378 |
|
1379 void tst_QSqlDatabase::bigIntField() |
|
1380 { |
|
1381 QFETCH(QString, dbName); |
|
1382 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1383 CHECK_DATABASE(db); |
|
1384 QString drvName = db.driverName(); |
|
1385 const QString qtest_bigint(qTableName("qtest_bigint", __FILE__)); |
|
1386 |
|
1387 QSqlQuery q(db); |
|
1388 q.setForwardOnly(true); |
|
1389 if (drvName.startsWith("QOCI")) |
|
1390 q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64); |
|
1391 |
|
1392 if (drvName.startsWith("QMYSQL")) { |
|
1393 QVERIFY_SQL(q, exec("create table " + qtest_bigint + " (id int, t_s64bit bigint, t_u64bit bigint unsigned)")); |
|
1394 } else if (drvName.startsWith("QPSQL") |
|
1395 || drvName.startsWith("QDB2") |
|
1396 || tst_Databases::isSqlServer(db)) { |
|
1397 QVERIFY_SQL(q, exec("create table " + qtest_bigint + "(id int, t_s64bit bigint, t_u64bit bigint)")); |
|
1398 } else if (drvName.startsWith("QOCI")) { |
|
1399 QVERIFY_SQL(q, exec("create table " + qtest_bigint + " (id int, t_s64bit int, t_u64bit int)")); |
|
1400 //} else if (drvName.startsWith("QIBASE")) { |
|
1401 // QVERIFY_SQL(q, exec("create table " + qtest_bigint + " (id int, t_s64bit int64, t_u64bit int64)")); |
|
1402 } else { |
|
1403 QSKIP("no 64 bit integer support", SkipAll); |
|
1404 } |
|
1405 QVERIFY(q.prepare("insert into " + qtest_bigint + " values (?, ?, ?)")); |
|
1406 qlonglong ll = Q_INT64_C(9223372036854775807); |
|
1407 qulonglong ull = Q_UINT64_C(18446744073709551615); |
|
1408 |
|
1409 if (drvName.startsWith("QMYSQL") || drvName.startsWith("QOCI")) { |
|
1410 q.bindValue(0, 0); |
|
1411 q.bindValue(1, ll); |
|
1412 q.bindValue(2, ull); |
|
1413 QVERIFY_SQL(q, exec()); |
|
1414 q.bindValue(0, 1); |
|
1415 q.bindValue(1, -ll); |
|
1416 q.bindValue(2, ull); |
|
1417 QVERIFY_SQL(q, exec()); |
|
1418 } else { |
|
1419 // usinged bigint fields not supported - a cast is necessary |
|
1420 q.bindValue(0, 0); |
|
1421 q.bindValue(1, ll); |
|
1422 q.bindValue(2, (qlonglong) ull); |
|
1423 QVERIFY_SQL(q, exec()); |
|
1424 q.bindValue(0, 1); |
|
1425 q.bindValue(1, -ll); |
|
1426 q.bindValue(2, (qlonglong) ull); |
|
1427 QVERIFY_SQL(q, exec()); |
|
1428 } |
|
1429 QVERIFY(q.exec("select * from " + qtest_bigint + " order by id")); |
|
1430 QVERIFY(q.next()); |
|
1431 QCOMPARE(q.value(1).toDouble(), (double)ll); |
|
1432 QCOMPARE(q.value(1).toLongLong(), ll); |
|
1433 if(drvName.startsWith("QOCI")) |
|
1434 QEXPECT_FAIL("", "Oracle driver lacks support for unsigned int64 types", Continue); |
|
1435 QCOMPARE(q.value(2).toULongLong(), ull); |
|
1436 QVERIFY(q.next()); |
|
1437 QCOMPARE(q.value(1).toLongLong(), -ll); |
|
1438 if(drvName.startsWith("QOCI")) |
|
1439 QEXPECT_FAIL("", "Oracle driver lacks support for unsigned int64 types", Continue); |
|
1440 QCOMPARE(q.value(2).toULongLong(), ull); |
|
1441 } |
|
1442 |
|
1443 void tst_QSqlDatabase::caseSensivity() |
|
1444 { |
|
1445 QFETCH(QString, dbName); |
|
1446 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1447 CHECK_DATABASE(db); |
|
1448 |
|
1449 bool cs = false; |
|
1450 if (db.driverName().startsWith("QMYSQL") |
|
1451 || db.driverName().startsWith("QSQLITE") |
|
1452 || db.driverName().startsWith("QTDS") |
|
1453 || db.driverName().startsWith("QODBC")) |
|
1454 cs = true; |
|
1455 |
|
1456 QSqlRecord rec = db.record(qTableName("qtest", __FILE__)); |
|
1457 QVERIFY((int)rec.count() > 0); |
|
1458 if (!cs) { |
|
1459 rec = db.record(qTableName("QTEST", __FILE__).toUpper()); |
|
1460 QVERIFY((int)rec.count() > 0); |
|
1461 rec = db.record(qTableName("qTesT", __FILE__)); |
|
1462 QVERIFY((int)rec.count() > 0); |
|
1463 } |
|
1464 |
|
1465 #ifdef QT3_SUPPORT |
|
1466 Q3SqlRecordInfo rInf = db.recordInfo(qTableName("qtest", __FILE__)); |
|
1467 QVERIFY((int)rInf.count() > 0); |
|
1468 if (!cs) { |
|
1469 rInf = db.recordInfo(qTableName("QTEST", __FILE__).upper()); |
|
1470 QVERIFY((int)rInf.count() > 0); |
|
1471 rInf = db.recordInfo(qTableName("qTesT", __FILE__)); |
|
1472 QVERIFY((int)rInf.count() > 0); |
|
1473 } |
|
1474 #endif |
|
1475 |
|
1476 rec = db.primaryIndex(qTableName("qtest", __FILE__)); |
|
1477 QVERIFY((int)rec.count() > 0); |
|
1478 if (!cs) { |
|
1479 rec = db.primaryIndex(qTableName("QTEST", __FILE__).toUpper()); |
|
1480 QVERIFY((int)rec.count() > 0); |
|
1481 rec = db.primaryIndex(qTableName("qTesT", __FILE__)); |
|
1482 QVERIFY((int)rec.count() > 0); |
|
1483 } |
|
1484 } |
|
1485 |
|
1486 void tst_QSqlDatabase::noEscapedFieldNamesInRecord() |
|
1487 { |
|
1488 QFETCH(QString, dbName); |
|
1489 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1490 CHECK_DATABASE(db); |
|
1491 |
|
1492 QString fieldname("t_varchar"); |
|
1493 if (db.driverName().startsWith("QOCI") || db.driverName().startsWith("QIBASE") || db.driverName().startsWith("QDB2")) |
|
1494 fieldname = fieldname.toUpper(); |
|
1495 |
|
1496 QSqlQuery q(db); |
|
1497 QString query = "SELECT " + db.driver()->escapeIdentifier(fieldname, QSqlDriver::FieldName) + " FROM " + qTableName("qtest", __FILE__); |
|
1498 QVERIFY_SQL(q, exec(query)); |
|
1499 QCOMPARE(q.record().fieldName(0), fieldname); |
|
1500 } |
|
1501 |
|
1502 void tst_QSqlDatabase::psql_schemas() |
|
1503 { |
|
1504 QFETCH(QString, dbName); |
|
1505 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1506 CHECK_DATABASE(db); |
|
1507 |
|
1508 if (!db.tables(QSql::SystemTables).contains("pg_namespace")) |
|
1509 QSKIP("server does not support schemas", SkipSingle); |
|
1510 |
|
1511 QSqlQuery q(db); |
|
1512 |
|
1513 if(tst_Databases::isPostgreSQL(db)) { |
|
1514 QVERIFY_SQL( q, exec("set client_min_messages='warning'")); |
|
1515 } |
|
1516 |
|
1517 QVERIFY_SQL(q, exec("CREATE SCHEMA " + qTableName("qtestschema", __FILE__))); |
|
1518 |
|
1519 QString table = qTableName("qtestschema", __FILE__) + '.' + qTableName("qtesttable", __FILE__); |
|
1520 QVERIFY_SQL(q, exec("CREATE TABLE " + table + " (id int primary key, name varchar(20))")); |
|
1521 |
|
1522 QVERIFY(db.tables().contains(table)); |
|
1523 |
|
1524 QSqlRecord rec = db.record(table); |
|
1525 QCOMPARE(rec.count(), 2); |
|
1526 QCOMPARE(rec.fieldName(0), QString("id")); |
|
1527 QCOMPARE(rec.fieldName(1), QString("name")); |
|
1528 |
|
1529 #ifdef QT3_SUPPORT |
|
1530 rec = db.record(QSqlQuery("select * from " + table, db)); |
|
1531 QCOMPARE(rec.count(), 2); |
|
1532 QCOMPARE(rec.fieldName(0), QString("id")); |
|
1533 QCOMPARE(rec.fieldName(1), QString("name")); |
|
1534 #endif |
|
1535 QSqlIndex idx = db.primaryIndex(table); |
|
1536 QCOMPARE(idx.count(), 1); |
|
1537 QCOMPARE(idx.fieldName(0), QString("id")); |
|
1538 } |
|
1539 |
|
1540 void tst_QSqlDatabase::psql_escapedIdentifiers() |
|
1541 { |
|
1542 QFETCH(QString, dbName); |
|
1543 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1544 QSqlDriver* drv = db.driver(); |
|
1545 CHECK_DATABASE(db); |
|
1546 |
|
1547 if (!db.tables(QSql::SystemTables).contains("pg_namespace")) |
|
1548 QSKIP("server does not support schemas", SkipSingle); |
|
1549 |
|
1550 QSqlQuery q(db); |
|
1551 |
|
1552 if(tst_Databases::isPostgreSQL(db)) |
|
1553 QVERIFY_SQL( q, exec("set client_min_messages='warning'")); |
|
1554 |
|
1555 const QString schemaName(qTableName("qtestScHeMa", __FILE__)), |
|
1556 tableName(qTableName("qtest", __FILE__)), |
|
1557 field1Name(QLatin1String("fIeLdNaMe")), |
|
1558 field2Name(QLatin1String("ZuLu")); |
|
1559 |
|
1560 q.exec(QString("DROP SCHEMA \"%1\" CASCADE").arg(schemaName)); |
|
1561 QString createSchema = QString("CREATE SCHEMA \"%1\"").arg(schemaName); |
|
1562 QVERIFY_SQL(q, exec(createSchema)); |
|
1563 QString createTable = QString("CREATE TABLE \"%1\".\"%2\" (\"%3\" int PRIMARY KEY, \"%4\" varchar(20))").arg(schemaName).arg(tableName).arg(field1Name).arg(field2Name); |
|
1564 QVERIFY_SQL(q, exec(createTable)); |
|
1565 |
|
1566 QVERIFY(db.tables().contains(schemaName + '.' + tableName, Qt::CaseSensitive)); |
|
1567 |
|
1568 QSqlField fld1(field1Name, QVariant::Int); |
|
1569 QSqlField fld2(field2Name, QVariant::String); |
|
1570 QSqlRecord rec; |
|
1571 rec.append(fld1); |
|
1572 rec.append(fld2); |
|
1573 |
|
1574 QVERIFY_SQL(q, exec(drv->sqlStatement(QSqlDriver::SelectStatement, db.driver()->escapeIdentifier(schemaName, QSqlDriver::TableName) + '.' + db.driver()->escapeIdentifier(tableName, QSqlDriver::TableName), rec, false))); |
|
1575 |
|
1576 rec = q.record(); |
|
1577 QCOMPARE(rec.count(), 2); |
|
1578 QCOMPARE(rec.fieldName(0), field1Name); |
|
1579 QCOMPARE(rec.fieldName(1), field2Name); |
|
1580 QCOMPARE(rec.field(0).type(), QVariant::Int); |
|
1581 |
|
1582 q.exec(QString("DROP SCHEMA \"%1\" CASCADE").arg(schemaName)); |
|
1583 } |
|
1584 |
|
1585 void tst_QSqlDatabase::psql_escapeBytea() |
|
1586 { |
|
1587 QFETCH(QString, dbName); |
|
1588 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1589 CHECK_DATABASE(db); |
|
1590 |
|
1591 const char dta[4] = {'\x71', '\x14', '\x32', '\x81'}; |
|
1592 QByteArray ba(dta, 4); |
|
1593 |
|
1594 QSqlQuery q(db); |
|
1595 const QString tableName(qTableName("batable", __FILE__)); |
|
1596 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (ba bytea)").arg(tableName))); |
|
1597 |
|
1598 QSqlQuery iq(db); |
|
1599 QVERIFY_SQL(iq, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName))); |
|
1600 iq.bindValue(0, QVariant(ba)); |
|
1601 QVERIFY_SQL(iq, exec()); |
|
1602 |
|
1603 QVERIFY_SQL(q, exec(QString("SELECT ba FROM %1").arg(tableName))); |
|
1604 QVERIFY_SQL(q, next()); |
|
1605 |
|
1606 QByteArray res = q.value(0).toByteArray(); |
|
1607 int i = 0; |
|
1608 for (; i < ba.size(); ++i){ |
|
1609 if (ba[i] != res[i]) |
|
1610 break; |
|
1611 } |
|
1612 |
|
1613 QCOMPARE(i, 4); |
|
1614 } |
|
1615 |
|
1616 void tst_QSqlDatabase::bug_249059() |
|
1617 { |
|
1618 QFETCH(QString, dbName); |
|
1619 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1620 CHECK_DATABASE(db); |
|
1621 |
|
1622 QString version=tst_Databases::getPSQLVersion( db ); |
|
1623 double ver=version.section(QChar::fromLatin1('.'),0,1).toDouble(); |
|
1624 if (ver < 7.3) |
|
1625 QSKIP("Test requires PostgreSQL >= 7.3", SkipSingle); |
|
1626 |
|
1627 QSqlQuery q(db); |
|
1628 const QString tableName(qTableName("bug_249059", __FILE__)); |
|
1629 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (dt timestamp, t time)").arg(tableName))); |
|
1630 |
|
1631 QSqlQuery iq(db); |
|
1632 QVERIFY_SQL(iq, prepare(QString("INSERT INTO %1 VALUES (?, ?)").arg(tableName))); |
|
1633 iq.bindValue(0, QVariant(QString("2001-09-09 04:05:06.789 -5:00"))); |
|
1634 iq.bindValue(1, QVariant(QString("04:05:06.789 -5:00"))); |
|
1635 QVERIFY_SQL(iq, exec()); |
|
1636 iq.bindValue(0, QVariant(QString("2001-09-09 04:05:06.789 +5:00"))); |
|
1637 iq.bindValue(1, QVariant(QString("04:05:06.789 +5:00"))); |
|
1638 QVERIFY_SQL(iq, exec()); |
|
1639 |
|
1640 QVERIFY_SQL(q, exec(QString("SELECT dt, t FROM %1").arg(tableName))); |
|
1641 QVERIFY_SQL(q, next()); |
|
1642 QDateTime dt1=q.value(0).toDateTime(); |
|
1643 QTime t1=q.value(1).toTime(); |
|
1644 QVERIFY_SQL(q, next()); |
|
1645 QDateTime dt2=q.value(0).toDateTime(); |
|
1646 QTime t2=q.value(1).toTime(); |
|
1647 |
|
1648 // These will fail when timezone support is added, when that's the case, set the second record to 14:05:06.789 and it should work correctly |
|
1649 QCOMPARE(dt1, dt2); |
|
1650 QCOMPARE(t1, t2); |
|
1651 } |
|
1652 |
|
1653 // This test should be rewritten to work with Oracle as well - or the Oracle driver |
|
1654 // should be fixed to make this test pass (handle overflows) |
|
1655 void tst_QSqlDatabase::precisionPolicy() |
|
1656 { |
|
1657 QFETCH(QString, dbName); |
|
1658 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1659 CHECK_DATABASE(db); |
|
1660 // DBMS_SPECIFIC(db, "QPSQL"); |
|
1661 |
|
1662 QSqlQuery q(db); |
|
1663 const QString tableName(qTableName("qtest_prec", __FILE__)); |
|
1664 if(!db.driver()->hasFeature(QSqlDriver::LowPrecisionNumbers)) |
|
1665 QSKIP("Driver or database doesn't support setting precision policy", SkipSingle); |
|
1666 |
|
1667 // Create a test table with some data |
|
1668 if(tst_Databases::isMSAccess(db)) |
|
1669 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (id smallint, num number)").arg(tableName))); |
|
1670 else |
|
1671 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (id smallint, num numeric(18,5))").arg(tableName))); |
|
1672 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?, ?)").arg(tableName))); |
|
1673 q.bindValue(0, 1); |
|
1674 q.bindValue(1, 123); |
|
1675 QVERIFY_SQL(q, exec()); |
|
1676 q.bindValue(0, 2); |
|
1677 q.bindValue(1, 1850000000000.0001); |
|
1678 QVERIFY_SQL(q, exec()); |
|
1679 |
|
1680 // These are expected to pass |
|
1681 q.setNumericalPrecisionPolicy(QSql::HighPrecision); |
|
1682 QString query = QString("SELECT num FROM %1 WHERE id = 1").arg(tableName); |
|
1683 QVERIFY_SQL(q, exec(query)); |
|
1684 QVERIFY_SQL(q, next()); |
|
1685 if(db.driverName().startsWith("QSQLITE")) |
|
1686 QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue); |
|
1687 QCOMPARE(q.value(0).type(), QVariant::String); |
|
1688 |
|
1689 q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64); |
|
1690 QVERIFY_SQL(q, exec(query)); |
|
1691 QVERIFY_SQL(q, next()); |
|
1692 if(q.value(0).type() != QVariant::LongLong) |
|
1693 QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue); |
|
1694 QCOMPARE(q.value(0).type(), QVariant::LongLong); |
|
1695 QCOMPARE(q.value(0).toLongLong(), (qlonglong)123); |
|
1696 |
|
1697 q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt32); |
|
1698 QVERIFY_SQL(q, exec(query)); |
|
1699 if(db.driverName().startsWith("QOCI")) |
|
1700 QEXPECT_FAIL("", "Oracle fails to move to next when data columns are oversize", Abort); |
|
1701 QVERIFY_SQL(q, next()); |
|
1702 if(db.driverName().startsWith("QSQLITE")) |
|
1703 QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue); |
|
1704 QCOMPARE(q.value(0).type(), QVariant::Int); |
|
1705 QCOMPARE(q.value(0).toInt(), 123); |
|
1706 |
|
1707 q.setNumericalPrecisionPolicy(QSql::LowPrecisionDouble); |
|
1708 QVERIFY_SQL(q, exec(query)); |
|
1709 QVERIFY_SQL(q, next()); |
|
1710 if(db.driverName().startsWith("QSQLITE")) |
|
1711 QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue); |
|
1712 QCOMPARE(q.value(0).type(), QVariant::Double); |
|
1713 QCOMPARE(q.value(0).toDouble(), (double)123); |
|
1714 |
|
1715 query = QString("SELECT num FROM %1 WHERE id = 2").arg(tableName); |
|
1716 QVERIFY_SQL(q, exec(query)); |
|
1717 QVERIFY_SQL(q, next()); |
|
1718 if(db.driverName().startsWith("QSQLITE")) |
|
1719 QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue); |
|
1720 QCOMPARE(q.value(0).type(), QVariant::Double); |
|
1721 QCOMPARE(q.value(0).toDouble(), QString("1850000000000.0001").toDouble()); |
|
1722 |
|
1723 // Postgres returns invalid QVariants on overflow |
|
1724 q.setNumericalPrecisionPolicy(QSql::HighPrecision); |
|
1725 QVERIFY_SQL(q, exec(query)); |
|
1726 QVERIFY_SQL(q, next()); |
|
1727 if(db.driverName().startsWith("QSQLITE")) |
|
1728 QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue); |
|
1729 QCOMPARE(q.value(0).type(), QVariant::String); |
|
1730 |
|
1731 q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64); |
|
1732 QEXPECT_FAIL("QOCI", "Oracle fails here, to retrieve next", Continue); |
|
1733 QVERIFY_SQL(q, exec(query)); |
|
1734 QVERIFY_SQL(q, next()); |
|
1735 QCOMPARE(q.value(0).type(), QVariant::LongLong); |
|
1736 |
|
1737 QSql::NumericalPrecisionPolicy oldPrecision= db.numericalPrecisionPolicy(); |
|
1738 db.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64); |
|
1739 QSqlQuery q2(db); |
|
1740 q2.exec(QString("SELECT num FROM %1 WHERE id = 2").arg(tableName)); |
|
1741 QVERIFY_SQL(q2, exec(query)); |
|
1742 QVERIFY_SQL(q2, next()); |
|
1743 QCOMPARE(q2.value(0).type(), QVariant::LongLong); |
|
1744 db.setNumericalPrecisionPolicy(oldPrecision); |
|
1745 } |
|
1746 |
|
1747 // This test needs a ODBC data source containing MYSQL in it's name |
|
1748 void tst_QSqlDatabase::mysqlOdbc_unsignedIntegers() |
|
1749 { |
|
1750 QFETCH(QString, dbName); |
|
1751 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1752 CHECK_DATABASE(db); |
|
1753 |
|
1754 if (!db.driverName().startsWith("QODBC") || !dbName.toUpper().contains("MYSQL")) { |
|
1755 QSKIP("MySQL through ODBC-driver specific test", SkipSingle); |
|
1756 return; |
|
1757 } |
|
1758 |
|
1759 QSqlQuery q(db); |
|
1760 const QString tableName(qTableName("uint", __FILE__)); |
|
1761 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (foo integer(10) unsigned, bar integer(10))").arg(tableName))); |
|
1762 QVERIFY_SQL(q, exec(QString("INSERT INTO %1 VALUES (-4000000000, -4000000000)").arg(tableName))); |
|
1763 QVERIFY_SQL(q, exec(QString("INSERT INTO %1 VALUES (4000000000, 4000000000)").arg(tableName))); |
|
1764 |
|
1765 QVERIFY_SQL(q, exec(QString("SELECT foo, bar FROM %1").arg(tableName))); |
|
1766 QVERIFY(q.next()); |
|
1767 QCOMPARE(q.value(0).toString(), QString("0")); |
|
1768 QCOMPARE(q.value(1).toString(), QString("-2147483648")); |
|
1769 QVERIFY(q.next()); |
|
1770 QCOMPARE(q.value(0).toString(), QString("4000000000")); |
|
1771 QCOMPARE(q.value(1).toString(), QString("2147483647")); |
|
1772 } |
|
1773 |
|
1774 void tst_QSqlDatabase::accessOdbc_strings() |
|
1775 { |
|
1776 QFETCH(QString, dbName); |
|
1777 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1778 CHECK_DATABASE(db); |
|
1779 |
|
1780 if (!tst_Databases::isMSAccess(db)) { |
|
1781 QSKIP("MS Access specific test", SkipSingle); |
|
1782 return; |
|
1783 } |
|
1784 |
|
1785 QSqlQuery q(db); |
|
1786 const QString tableName(qTableName("strings", __FILE__)); |
|
1787 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (aStr memo, bStr memo, cStr memo, dStr memo" |
|
1788 ", eStr memo, fStr memo, gStr memo, hStr memo)").arg(tableName))); |
|
1789 |
|
1790 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?, ?, ?, ?, ?, ?, ?, ?)").arg(tableName))); |
|
1791 QString aStr, bStr, cStr, dStr, eStr, fStr, gStr, hStr; |
|
1792 |
|
1793 q.bindValue(0, aStr.fill('A', 32)); |
|
1794 q.bindValue(1, bStr.fill('B', 127)); |
|
1795 q.bindValue(2, cStr.fill('C', 128)); |
|
1796 q.bindValue(3, dStr.fill('D', 129)); |
|
1797 q.bindValue(4, eStr.fill('E', 254)); |
|
1798 q.bindValue(5, fStr.fill('F', 255)); |
|
1799 q.bindValue(6, gStr.fill('G', 256)); |
|
1800 q.bindValue(7, hStr.fill('H', 512)); |
|
1801 |
|
1802 QVERIFY_SQL(q, exec()); |
|
1803 |
|
1804 QVERIFY_SQL(q, exec(QString("SELECT aStr, bStr, cStr, dStr, eStr, fStr, gStr, hStr FROM %1").arg(tableName))); |
|
1805 q.next(); |
|
1806 QCOMPARE(q.value(0).toString(), aStr); |
|
1807 QCOMPARE(q.value(1).toString(), bStr); |
|
1808 QCOMPARE(q.value(2).toString(), cStr); |
|
1809 QCOMPARE(q.value(3).toString(), dStr); |
|
1810 QCOMPARE(q.value(4).toString(), eStr); |
|
1811 QCOMPARE(q.value(5).toString(), fStr); |
|
1812 QCOMPARE(q.value(6).toString(), gStr); |
|
1813 QCOMPARE(q.value(7).toString(), hStr); |
|
1814 } |
|
1815 |
|
1816 // For task 125053 |
|
1817 void tst_QSqlDatabase::ibase_numericFields() |
|
1818 { |
|
1819 QFETCH(QString, dbName); |
|
1820 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1821 CHECK_DATABASE(db); |
|
1822 |
|
1823 QSqlQuery q(db); |
|
1824 const QString tableName(qTableName("numericfields", __FILE__)); |
|
1825 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (id int not null, num1 NUMERIC(2,1), " |
|
1826 "num2 NUMERIC(5,2), num3 NUMERIC(10,3), " |
|
1827 "num4 NUMERIC(18,4))").arg(tableName))); |
|
1828 |
|
1829 QVERIFY_SQL(q, exec(QString("INSERT INTO %1 VALUES (1, 1.1, 123.45, 1234567.123, 10203040506070.8090)").arg(tableName))); |
|
1830 |
|
1831 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?, ?, ?, ?, ?)").arg(tableName))); |
|
1832 |
|
1833 double num1 = 1.1; |
|
1834 double num2 = 123.45; |
|
1835 double num3 = 1234567.123; |
|
1836 double num4 = 10203040506070.8090; |
|
1837 |
|
1838 q.bindValue(0, 2); |
|
1839 q.bindValue(1, QVariant(num1)); |
|
1840 q.bindValue(2, QVariant(num2)); |
|
1841 q.bindValue(3, QVariant(num3)); |
|
1842 q.bindValue(4, QVariant(num4)); |
|
1843 QVERIFY_SQL(q, exec()); |
|
1844 |
|
1845 QVERIFY_SQL(q, exec(QString("SELECT id, num1, num2, num3, num4 FROM %1").arg(tableName))); |
|
1846 |
|
1847 int id = 0; |
|
1848 while (q.next()) { |
|
1849 QCOMPARE(q.value(0).toInt(), ++id); |
|
1850 QCOMPARE(q.value(1).toString(), QString("%1").arg(num1)); |
|
1851 QCOMPARE(q.value(2).toString(), QString("%1").arg(num2)); |
|
1852 QCOMPARE(QString("%1").arg(q.value(3).toDouble()), QString("%1").arg(num3)); |
|
1853 QCOMPARE(QString("%1").arg(q.value(4).toDouble()), QString("%1").arg(num4)); |
|
1854 QVERIFY(q.value(0).type() == QVariant::Int); |
|
1855 QVERIFY(q.value(1).type() == QVariant::Double); |
|
1856 QVERIFY(q.value(2).type() == QVariant::Double); |
|
1857 QVERIFY(q.value(3).type() == QVariant::Double); |
|
1858 QVERIFY(q.value(4).type() == QVariant::Double); |
|
1859 |
|
1860 QCOMPARE(q.record().field(1).length(), 2); |
|
1861 QCOMPARE(q.record().field(1).precision(), 1); |
|
1862 QCOMPARE(q.record().field(2).length(), 5); |
|
1863 QCOMPARE(q.record().field(2).precision(), 2); |
|
1864 QCOMPARE(q.record().field(3).length(), 10); |
|
1865 QCOMPARE(q.record().field(3).precision(), 3); |
|
1866 QCOMPARE(q.record().field(4).length(), 18); |
|
1867 QCOMPARE(q.record().field(4).precision(), 4); |
|
1868 QVERIFY(q.record().field(0).requiredStatus() == QSqlField::Required); |
|
1869 QVERIFY(q.record().field(1).requiredStatus() == QSqlField::Optional); |
|
1870 } |
|
1871 |
|
1872 QSqlRecord r = db.record(tableName); |
|
1873 QVERIFY(r.field(0).type() == QVariant::Int); |
|
1874 QVERIFY(r.field(1).type() == QVariant::Double); |
|
1875 QVERIFY(r.field(2).type() == QVariant::Double); |
|
1876 QVERIFY(r.field(3).type() == QVariant::Double); |
|
1877 QVERIFY(r.field(4).type() == QVariant::Double); |
|
1878 QCOMPARE(r.field(1).length(), 2); |
|
1879 QCOMPARE(r.field(1).precision(), 1); |
|
1880 QCOMPARE(r.field(2).length(), 5); |
|
1881 QCOMPARE(r.field(2).precision(), 2); |
|
1882 QCOMPARE(r.field(3).length(), 10); |
|
1883 QCOMPARE(r.field(3).precision(), 3); |
|
1884 QCOMPARE(r.field(4).length(), 18); |
|
1885 QCOMPARE(r.field(4).precision(), 4); |
|
1886 QVERIFY(r.field(0).requiredStatus() == QSqlField::Required); |
|
1887 QVERIFY(r.field(1).requiredStatus() == QSqlField::Optional); |
|
1888 } |
|
1889 |
|
1890 void tst_QSqlDatabase::ibase_fetchBlobs() |
|
1891 { |
|
1892 QFETCH(QString, dbName); |
|
1893 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1894 CHECK_DATABASE(db); |
|
1895 |
|
1896 const QString tableName(qTableName("qtest_ibaseblobs", __FILE__)); |
|
1897 QSqlQuery q(db); |
|
1898 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (blob1 BLOB segment size 256)").arg(tableName))); |
|
1899 |
|
1900 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName))); |
|
1901 q.bindValue(0, QByteArray().fill('x', 1024)); |
|
1902 QVERIFY_SQL(q, exec()); |
|
1903 |
|
1904 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName))); |
|
1905 q.bindValue(0, QByteArray().fill('x', 16383)); |
|
1906 QVERIFY_SQL(q, exec()); |
|
1907 |
|
1908 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName))); |
|
1909 q.bindValue(0, QByteArray().fill('x', 17408)); |
|
1910 QVERIFY_SQL(q, exec()); |
|
1911 |
|
1912 QVERIFY_SQL(q, exec(QString("SELECT * FROM %1").arg(tableName))); |
|
1913 |
|
1914 QVERIFY_SQL(q, next()); |
|
1915 QCOMPARE(q.value(0).toByteArray().size(), 1024); |
|
1916 QVERIFY_SQL(q, next()); |
|
1917 QCOMPARE(q.value(0).toByteArray().size(), 16383); |
|
1918 QVERIFY_SQL(q, next()); |
|
1919 QCOMPARE(q.value(0).toByteArray().size(), 17408); |
|
1920 } |
|
1921 |
|
1922 void tst_QSqlDatabase::ibase_procWithoutReturnValues() |
|
1923 { |
|
1924 QFETCH(QString, dbName); |
|
1925 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1926 CHECK_DATABASE(db); |
|
1927 |
|
1928 QSqlQuery q(db); |
|
1929 const QString procName(qTableName("qtest_proc1", __FILE__)); |
|
1930 q.exec(QString("drop procedure %1").arg(procName)); |
|
1931 QVERIFY_SQL(q, exec("CREATE PROCEDURE " + procName + " (str VARCHAR(10))\nAS BEGIN\nstr='test';\nEND;")); |
|
1932 QVERIFY_SQL(q, exec(QString("execute procedure %1('qtest')").arg(procName))); |
|
1933 q.exec(QString("drop procedure %1").arg(procName)); |
|
1934 } |
|
1935 |
|
1936 void tst_QSqlDatabase::ibase_procWithReturnValues() |
|
1937 { |
|
1938 QFETCH(QString, dbName); |
|
1939 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1940 CHECK_DATABASE(db); |
|
1941 |
|
1942 if (!db.driverName().startsWith("QIBASE")) { |
|
1943 QSKIP("InterBase specific test", SkipSingle); |
|
1944 return; |
|
1945 } |
|
1946 |
|
1947 const QString procName(qTableName("qtest_proc2", __FILE__)); |
|
1948 |
|
1949 QSqlQuery q(db); |
|
1950 q.exec(QString("drop procedure %1").arg(procName)); |
|
1951 QVERIFY_SQL(q, exec("CREATE PROCEDURE " + procName + " (" |
|
1952 "\nABC INTEGER)" |
|
1953 "\nRETURNS (" |
|
1954 "\nRESULT INTEGER)" |
|
1955 "\nAS" |
|
1956 "\nbegin" |
|
1957 "\nRESULT = 10 * ABC;" |
|
1958 "\nsuspend;" |
|
1959 "\nend")); |
|
1960 |
|
1961 // Interbase procedures can be executed in two ways: EXECUTE PROCEDURE or SELECT |
|
1962 QVERIFY_SQL(q, exec(QString("execute procedure %1(123)").arg(procName))); |
|
1963 QVERIFY_SQL(q, next()); |
|
1964 QCOMPARE(q.value(0).toInt(), 1230); |
|
1965 QVERIFY_SQL(q, exec(QString("select result from %1(456)").arg(procName))); |
|
1966 QVERIFY_SQL(q, next()); |
|
1967 QCOMPARE(q.value(0).toInt(), 4560); |
|
1968 QVERIFY_SQL(q, prepare(QLatin1String("execute procedure ")+procName+QLatin1String("(?)"))); |
|
1969 q.bindValue(0, 123); |
|
1970 QVERIFY_SQL(q, exec()); |
|
1971 QVERIFY_SQL(q, next()); |
|
1972 QCOMPARE(q.value(0).toInt(), 1230); |
|
1973 q.bindValue(0, 456); |
|
1974 QVERIFY_SQL(q, exec()); |
|
1975 QVERIFY_SQL(q, next()); |
|
1976 QCOMPARE(q.value(0).toInt(), 4560); |
|
1977 |
|
1978 q.exec(QString("drop procedure %1").arg(procName)); |
|
1979 } |
|
1980 |
|
1981 void tst_QSqlDatabase::formatValueTrimStrings() |
|
1982 { |
|
1983 QFETCH(QString, dbName); |
|
1984 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
1985 CHECK_DATABASE(db); |
|
1986 |
|
1987 QSqlQuery q(db); |
|
1988 |
|
1989 QVERIFY_SQL(q, exec(QString("INSERT INTO %1 (id, t_varchar, t_char) values (50, 'Trim Test ', 'Trim Test 2 ')").arg(qTableName("qtest", __FILE__)))); |
|
1990 QVERIFY_SQL(q, exec(QString("INSERT INTO %1 (id, t_varchar, t_char) values (51, 'TrimTest', 'Trim Test 2')").arg(qTableName("qtest", __FILE__)))); |
|
1991 QVERIFY_SQL(q, exec(QString("INSERT INTO %1 (id, t_varchar, t_char) values (52, ' ', ' ')").arg(qTableName("qtest", __FILE__)))); |
|
1992 |
|
1993 QVERIFY_SQL(q, exec(QString("SELECT t_varchar, t_char FROM %1 WHERE id >= 50 AND id <= 52 ORDER BY id").arg(qTableName("qtest", __FILE__)))); |
|
1994 |
|
1995 QVERIFY_SQL(q, next()); |
|
1996 |
|
1997 QCOMPARE(db.driver()->formatValue(q.record().field(0), true), QString("'Trim Test'")); |
|
1998 QCOMPARE(db.driver()->formatValue(q.record().field(1), true), QString("'Trim Test 2'")); |
|
1999 |
|
2000 QVERIFY_SQL(q, next()); |
|
2001 QCOMPARE(db.driver()->formatValue(q.record().field(0), true), QString("'TrimTest'")); |
|
2002 QCOMPARE(db.driver()->formatValue(q.record().field(1), true), QString("'Trim Test 2'")); |
|
2003 |
|
2004 QVERIFY_SQL(q, next()); |
|
2005 QCOMPARE(db.driver()->formatValue(q.record().field(0), true), QString("''")); |
|
2006 QCOMPARE(db.driver()->formatValue(q.record().field(1), true), QString("''")); |
|
2007 |
|
2008 } |
|
2009 |
|
2010 void tst_QSqlDatabase::odbc_reopenDatabase() |
|
2011 { |
|
2012 QFETCH(QString, dbName); |
|
2013 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2014 CHECK_DATABASE(db); |
|
2015 |
|
2016 QSqlQuery q(db); |
|
2017 QVERIFY_SQL(q, exec("SELECT * from " + qTableName("qtest", __FILE__))); |
|
2018 QVERIFY_SQL(q, next()); |
|
2019 db.open(); |
|
2020 QVERIFY_SQL(q, exec("SELECT * from " + qTableName("qtest", __FILE__))); |
|
2021 QVERIFY_SQL(q, next()); |
|
2022 db.open(); |
|
2023 } |
|
2024 |
|
2025 void tst_QSqlDatabase::odbc_bindBoolean() |
|
2026 { |
|
2027 QFETCH(QString, dbName); |
|
2028 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2029 CHECK_DATABASE(db); |
|
2030 |
|
2031 if (tst_Databases::isMySQL(db)) { |
|
2032 QSKIP("MySql has inconsistent behaviour of bit field type across versions.", SkipSingle); |
|
2033 return; |
|
2034 } |
|
2035 |
|
2036 QSqlQuery q(db); |
|
2037 QVERIFY_SQL(q, exec("CREATE TABLE " + qTableName("qtestBindBool", __FILE__) + "(id int, boolvalue bit)")); |
|
2038 |
|
2039 // Bind and insert |
|
2040 QVERIFY_SQL(q, prepare("INSERT INTO " + qTableName("qtestBindBool", __FILE__) + " VALUES(?, ?)")); |
|
2041 q.bindValue(0, 1); |
|
2042 q.bindValue(1, true); |
|
2043 QVERIFY_SQL(q, exec()); |
|
2044 q.bindValue(0, 2); |
|
2045 q.bindValue(1, false); |
|
2046 QVERIFY_SQL(q, exec()); |
|
2047 |
|
2048 // Retrive |
|
2049 QVERIFY_SQL(q, exec("SELECT id, boolvalue FROM " + qTableName("qtestBindBool", __FILE__) + " ORDER BY id")); |
|
2050 QVERIFY_SQL(q, next()); |
|
2051 QCOMPARE(q.value(0).toInt(), 1); |
|
2052 QCOMPARE(q.value(1).toBool(), true); |
|
2053 QVERIFY_SQL(q, next()); |
|
2054 QCOMPARE(q.value(0).toInt(), 2); |
|
2055 QCOMPARE(q.value(1).toBool(), false); |
|
2056 } |
|
2057 |
|
2058 void tst_QSqlDatabase::odbc_testqGetString() |
|
2059 { |
|
2060 QFETCH(QString, dbName); |
|
2061 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2062 CHECK_DATABASE(db); |
|
2063 const QString testqGetString(qTableName("testqGetString", __FILE__)); |
|
2064 |
|
2065 QSqlQuery q(db); |
|
2066 if (tst_Databases::isSqlServer(db)) |
|
2067 QVERIFY_SQL(q, exec("CREATE TABLE " + testqGetString + "(id int, vcvalue varchar(MAX))")); |
|
2068 else if(tst_Databases::isMSAccess(db)) |
|
2069 QVERIFY_SQL(q, exec("CREATE TABLE " + testqGetString + "(id int, vcvalue memo)")); |
|
2070 else |
|
2071 QVERIFY_SQL(q, exec("CREATE TABLE " + testqGetString + "(id int, vcvalue varchar(65538))")); |
|
2072 |
|
2073 QString largeString; |
|
2074 largeString.fill('A', 65536); |
|
2075 |
|
2076 // Bind and insert |
|
2077 QVERIFY_SQL(q, prepare("INSERT INTO " + testqGetString + " VALUES(?, ?)")); |
|
2078 q.bindValue(0, 1); |
|
2079 q.bindValue(1, largeString); |
|
2080 QVERIFY_SQL(q, exec()); |
|
2081 q.bindValue(0, 2); |
|
2082 q.bindValue(1, largeString+QLatin1Char('B')); |
|
2083 QVERIFY_SQL(q, exec()); |
|
2084 q.bindValue(0, 3); |
|
2085 q.bindValue(1, largeString+QLatin1Char('B')+QLatin1Char('C')); |
|
2086 QVERIFY_SQL(q, exec()); |
|
2087 |
|
2088 // Retrive |
|
2089 QVERIFY_SQL(q, exec("SELECT id, vcvalue FROM " + testqGetString + " ORDER BY id")); |
|
2090 QVERIFY_SQL(q, next()); |
|
2091 QCOMPARE(q.value(0).toInt(), 1); |
|
2092 QCOMPARE(q.value(1).toString().length(), 65536); |
|
2093 QVERIFY_SQL(q, next()); |
|
2094 QCOMPARE(q.value(0).toInt(), 2); |
|
2095 QCOMPARE(q.value(1).toString().length(), 65537); |
|
2096 QVERIFY_SQL(q, next()); |
|
2097 QCOMPARE(q.value(0).toInt(), 3); |
|
2098 QCOMPARE(q.value(1).toString().length(), 65538); |
|
2099 } |
|
2100 |
|
2101 |
|
2102 void tst_QSqlDatabase::mysql_multiselect() |
|
2103 { |
|
2104 QFETCH(QString, dbName); |
|
2105 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2106 CHECK_DATABASE(db); |
|
2107 const QString qtest(qTableName("qtest", __FILE__)); |
|
2108 |
|
2109 QSqlQuery q(db); |
|
2110 QString version=tst_Databases::getMySqlVersion( db ); |
|
2111 double ver=version.section(QChar::fromLatin1('.'),0,1).toDouble(); |
|
2112 if (ver < 4.1) |
|
2113 QSKIP("Test requires MySQL >= 4.1", SkipSingle); |
|
2114 |
|
2115 QVERIFY_SQL(q, exec("SELECT * FROM " + qtest + "; SELECT * FROM " + qtest)); |
|
2116 QVERIFY_SQL(q, next()); |
|
2117 QVERIFY_SQL(q, exec("SELECT * FROM " + qtest + "; SELECT * FROM " + qtest)); |
|
2118 QVERIFY_SQL(q, next()); |
|
2119 QVERIFY_SQL(q, exec("SELECT * FROM " + qtest)); |
|
2120 } |
|
2121 |
|
2122 void tst_QSqlDatabase::ibase_useCustomCharset() |
|
2123 { |
|
2124 QFETCH(QString, dbName); |
|
2125 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2126 CHECK_DATABASE(db); |
|
2127 QString nonlatin1string("��"); |
|
2128 |
|
2129 db.close(); |
|
2130 db.setConnectOptions("ISC_DPB_LC_CTYPE=Latin1"); |
|
2131 db.open(); |
|
2132 |
|
2133 const QString tableName(qTableName("latin1table", __FILE__)); |
|
2134 |
|
2135 QSqlQuery q(db); |
|
2136 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(text VARCHAR(6) CHARACTER SET Latin1)").arg(tableName))); |
|
2137 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName))); |
|
2138 q.addBindValue(nonlatin1string); |
|
2139 QVERIFY_SQL(q, exec()); |
|
2140 QVERIFY_SQL(q, exec(QString("SELECT text FROM %1").arg(tableName))); |
|
2141 QVERIFY_SQL(q, next()); |
|
2142 QCOMPARE(toHex(q.value(0).toString()), toHex(nonlatin1string)); |
|
2143 } |
|
2144 |
|
2145 void tst_QSqlDatabase::oci_serverDetach() |
|
2146 { |
|
2147 QFETCH(QString, dbName); |
|
2148 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2149 CHECK_DATABASE(db); |
|
2150 |
|
2151 for (int i = 0; i < 2; i++) { |
|
2152 db.close(); |
|
2153 if (db.open()) { |
|
2154 QSqlQuery query(db); |
|
2155 query.exec("SELECT 1 FROM DUAL"); |
|
2156 db.close(); |
|
2157 } else { |
|
2158 QFAIL(tst_Databases::printError(db.lastError(), db)); |
|
2159 } |
|
2160 } |
|
2161 if(!db.open()) |
|
2162 qFatal(tst_Databases::printError(db.lastError(), db)); |
|
2163 } |
|
2164 |
|
2165 void tst_QSqlDatabase::oci_xmltypeSupport() |
|
2166 { |
|
2167 QFETCH(QString, dbName); |
|
2168 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2169 CHECK_DATABASE(db); |
|
2170 |
|
2171 const QString tableName(qTableName("qtest_xmltype", __FILE__)); |
|
2172 QString xml("<?xml version=\"1.0\"?><TABLE_NAME>MY_TABLE</TABLE_NAME>"); |
|
2173 QSqlQuery q(db); |
|
2174 |
|
2175 // Embedding the XML in the statement |
|
2176 if(!q.exec(QString("CREATE TABLE %1(xmldata xmltype)").arg(tableName))) |
|
2177 QSKIP("This test requries xml type support", SkipSingle); |
|
2178 QVERIFY_SQL(q, exec(QString("INSERT INTO %1 values('%2')").arg(tableName).arg(xml))); |
|
2179 QVERIFY_SQL(q, exec(QString("SELECT a.xmldata.getStringVal() FROM %1 a").arg(tableName))); |
|
2180 QVERIFY_SQL(q, last()); |
|
2181 QCOMPARE(q.value(0).toString(), xml); |
|
2182 |
|
2183 // Binding the XML with a prepared statement |
|
2184 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 values(?)").arg(tableName))); |
|
2185 q.addBindValue(xml); |
|
2186 QVERIFY_SQL(q, exec()); |
|
2187 QVERIFY_SQL(q, exec(QString("SELECT a.xmldata.getStringVal() FROM %1 a").arg(tableName))); |
|
2188 QVERIFY_SQL(q, last()); |
|
2189 QCOMPARE(q.value(0).toString(), xml); |
|
2190 } |
|
2191 |
|
2192 |
|
2193 void tst_QSqlDatabase::oci_fieldLength() |
|
2194 { |
|
2195 QFETCH(QString, dbName); |
|
2196 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2197 CHECK_DATABASE(db); |
|
2198 |
|
2199 const QString tableName(qTableName("qtest", __FILE__)); |
|
2200 QSqlQuery q(db); |
|
2201 |
|
2202 QVERIFY_SQL(q, exec(QString("SELECT t_varchar, t_char FROM %1").arg(tableName))); |
|
2203 QVERIFY_SQL(q, next()); |
|
2204 QCOMPARE(q.record().field(0).length(), 40); |
|
2205 QCOMPARE(q.record().field(1).length(), 40); |
|
2206 } |
|
2207 |
|
2208 void tst_QSqlDatabase::oci_synonymstest() |
|
2209 { |
|
2210 QFETCH(QString, dbName); |
|
2211 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2212 CHECK_DATABASE(db); |
|
2213 |
|
2214 QSqlQuery q(db); |
|
2215 const QString creator(qTableName("CREATOR", __FILE__)), appuser(qTableName("APPUSER", __FILE__)), table1(qTableName("TABLE1", __FILE__)); |
|
2216 // QVERIFY_SQL(q, exec("drop public synonym "+table1)); |
|
2217 QVERIFY_SQL(q, exec(QString("create user %1 identified by %2 default tablespace users temporary tablespace temp").arg(creator).arg(creator))); |
|
2218 QVERIFY_SQL(q, exec(QString("grant CONNECT to %1").arg(creator))); |
|
2219 QVERIFY_SQL(q, exec(QString("grant RESOURCE to %1").arg(creator))); |
|
2220 QSqlDatabase db2=db.cloneDatabase(db, QLatin1String("oci_synonymstest")); |
|
2221 db2.close(); |
|
2222 QVERIFY_SQL(db2, open(creator,creator)); |
|
2223 QSqlQuery q2(db2); |
|
2224 QVERIFY_SQL(q2, exec(QString("create table %1(id int primary key)").arg(table1))); |
|
2225 QVERIFY_SQL(q, exec(QString("create user %1 identified by %2 default tablespace users temporary tablespace temp").arg(appuser).arg(appuser))); |
|
2226 QVERIFY_SQL(q, exec(QString("grant CREATE ANY SYNONYM to %1").arg(appuser))); |
|
2227 QVERIFY_SQL(q, exec(QString("grant CONNECT to %1").arg(appuser))); |
|
2228 QVERIFY_SQL(q2, exec(QString("grant select, insert, update, delete on %1 to %2").arg(table1).arg(appuser))); |
|
2229 QSqlDatabase db3=db.cloneDatabase(db, QLatin1String("oci_synonymstest2")); |
|
2230 db3.close(); |
|
2231 QVERIFY_SQL(db3, open(appuser,appuser)); |
|
2232 QSqlQuery q3(db3); |
|
2233 QVERIFY_SQL(q3, exec("create synonym "+appuser+'.'+qTableName("synonyms", __FILE__)+" for "+creator+'.'+table1)); |
|
2234 QVERIFY_SQL(db3, tables().filter(qTableName("synonyms", __FILE__), Qt::CaseInsensitive).count() >= 1); |
|
2235 } |
|
2236 |
|
2237 |
|
2238 // This test isn't really necessary as SQL_GUID / uniqueidentifier is |
|
2239 // already tested in recordSQLServer(). |
|
2240 void tst_QSqlDatabase::odbc_uniqueidentifier() |
|
2241 { |
|
2242 QFETCH(QString, dbName); |
|
2243 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2244 CHECK_DATABASE(db); |
|
2245 if (!tst_Databases::isSqlServer(db)) { |
|
2246 QSKIP("SQL Server (ODBC) specific test", SkipSingle); |
|
2247 return; |
|
2248 } |
|
2249 |
|
2250 const QString tableName(qTableName("qtest_sqlguid", __FILE__)); |
|
2251 QString guid = QString("AAAAAAAA-BBBB-CCCC-DDDD-EEEEEEEEEEEE"); |
|
2252 QString invalidGuid = QString("GAAAAAAA-BBBB-CCCC-DDDD-EEEEEEEEEEEE"); |
|
2253 |
|
2254 QSqlQuery q(db); |
|
2255 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(id uniqueidentifier)").arg(tableName))); |
|
2256 |
|
2257 q.prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName));; |
|
2258 q.addBindValue(guid); |
|
2259 QVERIFY_SQL(q, exec()); |
|
2260 |
|
2261 q.addBindValue(invalidGuid); |
|
2262 QEXPECT_FAIL("", "The GUID string is required to be correctly formated!", |
|
2263 Continue); |
|
2264 QVERIFY_SQL(q, exec()); |
|
2265 |
|
2266 QVERIFY_SQL(q, exec(QString("SELECT id FROM %1").arg(tableName))); |
|
2267 QVERIFY_SQL(q, next()); |
|
2268 QCOMPARE(q.value(0).toString(), guid); |
|
2269 } |
|
2270 |
|
2271 void tst_QSqlDatabase::getConnectionName() |
|
2272 { |
|
2273 QFETCH(QString, dbName); |
|
2274 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2275 CHECK_DATABASE(db); |
|
2276 |
|
2277 QCOMPARE(db.connectionName(), dbName); |
|
2278 QSqlDatabase clone = QSqlDatabase::cloneDatabase(db, "clonedDatabase"); |
|
2279 QCOMPARE(clone.connectionName(), QString("clonedDatabase")); |
|
2280 QTest::ignoreMessage(QtWarningMsg, "QSqlDatabasePrivate::removeDatabase: " |
|
2281 "connection 'clonedDatabase' is still in use, all queries will cease to work."); |
|
2282 QSqlDatabase::removeDatabase("clonedDatabase"); |
|
2283 QCOMPARE(clone.connectionName(), QString()); |
|
2284 QCOMPARE(db.connectionName(), dbName); |
|
2285 } |
|
2286 |
|
2287 void tst_QSqlDatabase::odbc_uintfield() |
|
2288 { |
|
2289 QFETCH(QString, dbName); |
|
2290 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2291 CHECK_DATABASE(db); |
|
2292 |
|
2293 const QString tableName(qTableName("uint_table", __FILE__)); |
|
2294 unsigned int val = 4294967295U; |
|
2295 |
|
2296 QSqlQuery q(db); |
|
2297 if ( tst_Databases::isMSAccess( db ) ) |
|
2298 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(num number)").arg(tableName))); |
|
2299 else |
|
2300 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(num numeric(10))").arg(tableName))); |
|
2301 q.prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName)); |
|
2302 q.addBindValue(val); |
|
2303 QVERIFY_SQL(q, exec()); |
|
2304 |
|
2305 q.exec(QString("SELECT num FROM %1").arg(tableName)); |
|
2306 if (q.next()) |
|
2307 QCOMPARE(q.value(0).toUInt(), val); |
|
2308 } |
|
2309 |
|
2310 void tst_QSqlDatabase::eventNotification() |
|
2311 { |
|
2312 QFETCH(QString, dbName); |
|
2313 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2314 CHECK_DATABASE(db); |
|
2315 |
|
2316 QSqlDriver *driver = db.driver(); |
|
2317 if (!driver->hasFeature(QSqlDriver::EventNotifications)) |
|
2318 QSKIP("DBMS doesn't support event notifications", SkipSingle); |
|
2319 |
|
2320 // Not subscribed to any events yet |
|
2321 QCOMPARE(driver->subscribedToNotifications().size(), 0); |
|
2322 |
|
2323 // Subscribe to "event_foo" |
|
2324 QVERIFY_SQL(*driver, subscribeToNotification(QLatin1String("event_foo"))); |
|
2325 QCOMPARE(driver->subscribedToNotifications().size(), 1); |
|
2326 QVERIFY(driver->subscribedToNotifications().contains("event_foo")); |
|
2327 |
|
2328 // Can't subscribe to the same event multiple times |
|
2329 QVERIFY2(!driver->subscribeToNotification(QLatin1String("event_foo")), "Shouldn't be able to subscribe to event_foo twice"); |
|
2330 QCOMPARE(driver->subscribedToNotifications().size(), 1); |
|
2331 |
|
2332 // Unsubscribe from "event_foo" |
|
2333 QVERIFY_SQL(*driver, unsubscribeFromNotification(QLatin1String("event_foo"))); |
|
2334 QCOMPARE(driver->subscribedToNotifications().size(), 0); |
|
2335 |
|
2336 // Re-subscribing to "event_foo" now is allowed |
|
2337 QVERIFY_SQL(*driver, subscribeToNotification(QLatin1String("event_foo"))); |
|
2338 QCOMPARE(driver->subscribedToNotifications().size(), 1); |
|
2339 |
|
2340 // closing the connection causes automatically unsubscription from all events |
|
2341 db.close(); |
|
2342 QCOMPARE(driver->subscribedToNotifications().size(), 0); |
|
2343 |
|
2344 // Can't subscribe to anything while database is closed |
|
2345 QVERIFY2(!driver->subscribeToNotification(QLatin1String("event_foo")), "Shouldn't be able to subscribe to event_foo"); |
|
2346 QCOMPARE(driver->subscribedToNotifications().size(), 0); |
|
2347 |
|
2348 db.open(); |
|
2349 } |
|
2350 |
|
2351 void tst_QSqlDatabase::eventNotificationIBase() |
|
2352 { |
|
2353 QFETCH(QString, dbName); |
|
2354 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2355 CHECK_DATABASE(db); |
|
2356 |
|
2357 const QString procedureName(qTableName("posteventProc", __FILE__)); |
|
2358 QSqlDriver *driver=db.driver(); |
|
2359 QVERIFY_SQL(*driver, subscribeToNotification(procedureName)); |
|
2360 QTest::qWait(300); // Interbase needs some time to call the driver callback. |
|
2361 |
|
2362 db.transaction(); // InterBase events are posted from within transactions. |
|
2363 QSqlQuery q(db); |
|
2364 q.exec(QString("DROP PROCEDURE %1").arg(procedureName)); |
|
2365 q.exec(QString("CREATE PROCEDURE %1\nAS BEGIN\nPOST_EVENT '%1';\nEND;").arg(procedureName)); |
|
2366 q.exec(QString("EXECUTE PROCEDURE %1").arg(procedureName)); |
|
2367 QSignalSpy spy(driver, SIGNAL(notification(const QString&))); |
|
2368 db.commit(); // No notifications are posted until the transaction is committed. |
|
2369 QTest::qWait(300); // Interbase needs some time to post the notification and call the driver callback. |
|
2370 // This happends from another thread, and we have to process events in order for the |
|
2371 // event handler in the driver to be executed and emit the notification signal. |
|
2372 |
|
2373 QCOMPARE(spy.count(), 1); |
|
2374 QList<QVariant> arguments = spy.takeFirst(); |
|
2375 QVERIFY(arguments.at(0).toString() == procedureName); |
|
2376 QVERIFY_SQL(*driver, unsubscribeFromNotification(procedureName)); |
|
2377 q.exec(QString("DROP PROCEDURE %1").arg(procedureName)); |
|
2378 } |
|
2379 |
|
2380 void tst_QSqlDatabase::eventNotificationPSQL() |
|
2381 { |
|
2382 QFETCH(QString, dbName); |
|
2383 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2384 CHECK_DATABASE(db); |
|
2385 |
|
2386 #if defined(Q_OS_LINUX) |
|
2387 QSKIP( "Event support doesn't work on linux", SkipAll ); |
|
2388 #endif |
|
2389 |
|
2390 QSqlQuery query(db); |
|
2391 QString procedureName = qTableName("posteventProc", __FILE__); |
|
2392 |
|
2393 QSqlDriver &driver=*(db.driver()); |
|
2394 QVERIFY_SQL(driver, subscribeToNotification(procedureName)); |
|
2395 QSignalSpy spy(db.driver(), SIGNAL(notification(const QString&))); |
|
2396 query.exec(QString("NOTIFY \"%1\"").arg(procedureName)); |
|
2397 QCoreApplication::processEvents(); |
|
2398 QCOMPARE(spy.count(), 1); |
|
2399 QList<QVariant> arguments = spy.takeFirst(); |
|
2400 QVERIFY(arguments.at(0).toString() == procedureName); |
|
2401 QVERIFY_SQL(driver, unsubscribeFromNotification(procedureName)); |
|
2402 } |
|
2403 |
|
2404 void tst_QSqlDatabase::sqlite_bindAndFetchUInt() |
|
2405 { |
|
2406 QFETCH(QString, dbName); |
|
2407 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2408 CHECK_DATABASE(db); |
|
2409 if (db.driverName().startsWith("QSQLITE2")) { |
|
2410 QSKIP("SQLite3 specific test", SkipSingle); |
|
2411 return; |
|
2412 } |
|
2413 |
|
2414 QSqlQuery q(db); |
|
2415 const QString tableName(qTableName("uint_test", __FILE__)); |
|
2416 QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(uint_field UNSIGNED INTEGER)").arg(tableName))); |
|
2417 QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName))); |
|
2418 q.addBindValue(4000000000U); |
|
2419 QVERIFY_SQL(q, exec()); |
|
2420 QVERIFY_SQL(q, exec(QString("SELECT uint_field FROM %1").arg(tableName))); |
|
2421 QVERIFY_SQL(q, next()); |
|
2422 |
|
2423 // All integers in SQLite are signed, so even though we bound the value |
|
2424 // as an UInt it will come back as a LongLong |
|
2425 QCOMPARE(q.value(0).type(), QVariant::LongLong); |
|
2426 QCOMPARE(q.value(0).toUInt(), 4000000000U); |
|
2427 } |
|
2428 |
|
2429 void tst_QSqlDatabase::db2_valueCacheUpdate() |
|
2430 { |
|
2431 QFETCH(QString, dbName); |
|
2432 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2433 CHECK_DATABASE(db); |
|
2434 |
|
2435 const QString tableName(qTableName("qtest", __FILE__)); |
|
2436 QSqlQuery q(db); |
|
2437 q.exec(QString("SELECT id, t_varchar, t_char, t_numeric FROM %1").arg(tableName)); |
|
2438 q.next(); |
|
2439 QVariant c4 = q.value(3); |
|
2440 QVariant c3 = q.value(2); |
|
2441 QVariant c2 = q.value(1); |
|
2442 QVariant c1 = q.value(0); |
|
2443 QCOMPARE(c4.toString(), q.value(3).toString()); |
|
2444 QCOMPARE(c3.toString(), q.value(2).toString()); |
|
2445 QCOMPARE(c2.toString(), q.value(1).toString()); |
|
2446 QCOMPARE(c1.toString(), q.value(0).toString()); |
|
2447 } |
|
2448 |
|
2449 void tst_QSqlDatabase::sqlStatementUseIsNull_189093() |
|
2450 { |
|
2451 // NULL = NULL is unknown, the sqlStatment must use IS NULL |
|
2452 QFETCH(QString, dbName); |
|
2453 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2454 CHECK_DATABASE(db); |
|
2455 |
|
2456 // select a record with NULL value |
|
2457 QSqlQuery q(QString::null, db); |
|
2458 QVERIFY_SQL(q, exec("select * from " + qTableName("qtest", __FILE__) + " where id = 4")); |
|
2459 QVERIFY_SQL(q, next()); |
|
2460 |
|
2461 QSqlDriver *driver = db.driver(); |
|
2462 QVERIFY(driver); |
|
2463 |
|
2464 QString preparedStatment = driver->sqlStatement(QSqlDriver::WhereStatement, QString("qtest"), q.record(), true); |
|
2465 QCOMPARE(preparedStatment.count("IS NULL", Qt::CaseInsensitive), 2); |
|
2466 |
|
2467 QString statment = driver->sqlStatement(QSqlDriver::WhereStatement, QString("qtest"), q.record(), false); |
|
2468 QCOMPARE(statment.count("IS NULL", Qt::CaseInsensitive), 2); |
|
2469 } |
|
2470 |
|
2471 void tst_QSqlDatabase::mysql_savepointtest() |
|
2472 { |
|
2473 QFETCH(QString, dbName); |
|
2474 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2475 CHECK_DATABASE(db); |
|
2476 if ( db.driverName().startsWith( "QMYSQL" ) && tst_Databases::getMySqlVersion( db ).section( QChar('.'), 0, 1 ).toDouble()<4.1 ) |
|
2477 QSKIP( "Test requires MySQL >= 4.1", SkipSingle ); |
|
2478 |
|
2479 QSqlQuery q(db); |
|
2480 QVERIFY_SQL(q, exec("begin")); |
|
2481 QVERIFY_SQL(q, exec("insert into "+qTableName("qtest", __FILE__)+" VALUES (54, 'foo', 'foo', 54.54)")); |
|
2482 QVERIFY_SQL(q, exec("savepoint foo")); |
|
2483 } |
|
2484 |
|
2485 void tst_QSqlDatabase::oci_tables() |
|
2486 { |
|
2487 QFETCH(QString, dbName); |
|
2488 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2489 CHECK_DATABASE(db); |
|
2490 QSqlQuery q(db); |
|
2491 const QString systemTableName("system."+qTableName("mypassword", __FILE__)); |
|
2492 QVERIFY_SQL(q, exec("CREATE TABLE "+systemTableName+"(name VARCHAR(20))")); |
|
2493 QVERIFY(!db.tables().contains(systemTableName.toUpper())); |
|
2494 QVERIFY(db.tables(QSql::SystemTables).contains(systemTableName.toUpper())); |
|
2495 } |
|
2496 |
|
2497 void tst_QSqlDatabase::sqlite_enable_cache_mode() |
|
2498 { |
|
2499 QFETCH(QString, dbName); |
|
2500 if(dbName.endsWith(":memory:")) |
|
2501 QSKIP( "cache mode is meaningless for :memory: databases", SkipSingle ); |
|
2502 QSqlDatabase db = QSqlDatabase::database(dbName); |
|
2503 CHECK_DATABASE(db); |
|
2504 db.close(); |
|
2505 db.setConnectOptions("QSQLITE_ENABLE_SHARED_CACHE"); |
|
2506 QVERIFY_SQL(db, open()); |
|
2507 QSqlDatabase db2 = QSqlDatabase::cloneDatabase(db, dbName+":cachemodeconn2"); |
|
2508 db2.setConnectOptions("QSQLITE_ENABLE_SHARED_CACHE"); |
|
2509 QVERIFY_SQL(db2, open()); |
|
2510 QSqlQuery q(db), q2(db2); |
|
2511 QVERIFY_SQL(q, exec("select * from "+qTableName("qtest", __FILE__))); |
|
2512 QVERIFY_SQL(q2, exec("select * from "+qTableName("qtest", __FILE__))); |
|
2513 } |
|
2514 |
|
2515 QTEST_MAIN(tst_QSqlDatabase) |
|
2516 #include "tst_qsqldatabase.moc" |