summaryrefslogtreecommitdiffstats
path: root/tests/auto/qsqldatabase
diff options
context:
space:
mode:
Diffstat (limited to 'tests/auto/qsqldatabase')
-rw-r--r--tests/auto/qsqldatabase/.gitignore1
-rw-r--r--tests/auto/qsqldatabase/qsqldatabase.pro32
-rwxr-xr-xtests/auto/qsqldatabase/testdata/qtest.mdbbin65536 -> 0 bytes
-rw-r--r--tests/auto/qsqldatabase/tst_databases.h571
-rw-r--r--tests/auto/qsqldatabase/tst_qsqldatabase.cpp2218
5 files changed, 0 insertions, 2822 deletions
diff --git a/tests/auto/qsqldatabase/.gitignore b/tests/auto/qsqldatabase/.gitignore
deleted file mode 100644
index 1dfa12b8d49..00000000000
--- a/tests/auto/qsqldatabase/.gitignore
+++ /dev/null
@@ -1 +0,0 @@
-tst_qsqldatabase
diff --git a/tests/auto/qsqldatabase/qsqldatabase.pro b/tests/auto/qsqldatabase/qsqldatabase.pro
deleted file mode 100644
index ee78b79c36d..00000000000
--- a/tests/auto/qsqldatabase/qsqldatabase.pro
+++ /dev/null
@@ -1,32 +0,0 @@
-load(qttest_p4)
-SOURCES += tst_qsqldatabase.cpp
-
-QT += sql
-
-win32: {
- !wince*: LIBS += -lws2_32
- else: LIBS += -lws2
-}
-
-wince*: {
- DEPLOYMENT_PLUGIN += qsqlite
-
- testData.files = testdata
- testData.path = .
-
- DEPLOYMENT += testData
-}
-
-symbian {
- TARGET.EPOCHEAPSIZE=5000 5000000
- TARGET.EPOCSTACKSIZE=50000
-
- qt_not_deployed {
- contains(S60_VERSION, 3.1)|contains(S60_VERSION, 3.2)|contains(S60_VERSION, 5.0) {
- sqlite.path = /sys/bin
- sqlite.files = sqlite3.dll
- DEPLOYMENT += sqlite
- }
- }
-}
-
diff --git a/tests/auto/qsqldatabase/testdata/qtest.mdb b/tests/auto/qsqldatabase/testdata/qtest.mdb
deleted file mode 100755
index f388f192ac7..00000000000
--- a/tests/auto/qsqldatabase/testdata/qtest.mdb
+++ /dev/null
Binary files differ
diff --git a/tests/auto/qsqldatabase/tst_databases.h b/tests/auto/qsqldatabase/tst_databases.h
deleted file mode 100644
index 497f5a49dfa..00000000000
--- a/tests/auto/qsqldatabase/tst_databases.h
+++ /dev/null
@@ -1,571 +0,0 @@
-/****************************************************************************
-**
-** Copyright (C) 2011 Nokia Corporation and/or its subsidiary(-ies).
-** All rights reserved.
-** Contact: Nokia Corporation (qt-info@nokia.com)
-**
-** This file is part of the test suite of the Qt Toolkit.
-**
-** $QT_BEGIN_LICENSE:LGPL$
-** GNU Lesser General Public License Usage
-** This file may be used under the terms of the GNU Lesser General Public
-** License version 2.1 as published by the Free Software Foundation and
-** appearing in the file LICENSE.LGPL included in the packaging of this
-** file. Please review the following information to ensure the GNU Lesser
-** General Public License version 2.1 requirements will be met:
-** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
-**
-** In addition, as a special exception, Nokia gives you certain additional
-** rights. These rights are described in the Nokia Qt LGPL Exception
-** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
-**
-** GNU General Public License Usage
-** Alternatively, this file may be used under the terms of the GNU General
-** Public License version 3.0 as published by the Free Software Foundation
-** and appearing in the file LICENSE.GPL included in the packaging of this
-** file. Please review the following information to ensure the GNU General
-** Public License version 3.0 requirements will be met:
-** http://www.gnu.org/copyleft/gpl.html.
-**
-** Other Usage
-** Alternatively, this file may be used in accordance with the terms and
-** conditions contained in a signed written agreement between you and Nokia.
-**
-**
-**
-**
-**
-** $QT_END_LICENSE$
-**
-****************************************************************************/
-/* possible connection parameters */
-
-#ifndef TST_DATABASES_H
-#define TST_DATABASES_H
-
-#include <QSqlDatabase>
-#include <QSqlDriver>
-#include <QSqlError>
-#include <QSqlQuery>
-#include <QRegExp>
-#include <QDir>
-#include <QVariant>
-#include <QDebug>
-#include <QSqlTableModel>
-
-#include <QtTest/QtTest>
-
-#if defined (Q_OS_WIN) || defined (Q_OS_WIN32)
-# include <qt_windows.h>
-# if defined (Q_OS_WINCE)
-# include <winsock2.h>
-# endif
-#else
-#include <unistd.h>
-#endif
-
-#define CHECK_DATABASE( db ) \
- if ( !db.isValid() ) { qFatal( "db is Invalid" ); }
-
-#define QVERIFY_SQL(q, stmt) QVERIFY2((q).stmt, tst_Databases::printError((q).lastError(), db))
-#define QFAIL_SQL(q, stmt) QVERIFY2(!(q).stmt, tst_Databases::printError((q).lastError(), db))
-
-#define DBMS_SPECIFIC(db, driver) \
- if (!db.driverName().startsWith(driver)) { QSKIP(driver " specific test", SkipSingle); return; }
-
-// ### use QSystem::hostName if it is integrated in qtest/main
-static QString qGetHostName()
-{
- static QString hostname;
-
- if ( !hostname.isEmpty() )
- return hostname;
-
- char hn[257];
-
- if ( gethostname( hn, 255 ) == 0 ) {
- hn[256] = '\0';
- hostname = QString::fromLatin1( hn );
- hostname.replace( QLatin1Char( '.' ), QLatin1Char( '_' ) );
- hostname.replace( QLatin1Char( '-' ), QLatin1Char( '_' ) );
- }
-
- return hostname;
-}
-
-// to prevent nameclashes on our database server, each machine
-// will use its own set of table names. Call this function to get
-// "tablename_hostname"
-inline static QString qTableName( const QString& prefix, const char *sourceFileName )
-{
- return QLatin1String("dbtst")+QString::number(qHash(QLatin1String(sourceFileName) + "_" + qGetHostName().replace( "-", "_" )), 16)+"_"+prefix;
-}
-
-inline static QString qTableName( const QString& prefix, QSqlDriver* driver )
-{
- return driver->escapeIdentifier( prefix + "_" + qGetHostName(), QSqlDriver::TableName );
-}
-
-inline static bool testWhiteSpaceNames( const QString &name )
-{
-/* return name.startsWith( "QPSQL" )
- || name.startsWith( "QODBC" )
- || name.startsWith( "QSQLITE" )
- || name.startsWith( "QMYSQL" );*/
- return name != QLatin1String("QSQLITE2");
-}
-
-inline static QString toHex( const QString& binary )
-{
- QString str;
- static char const hexchars[] = "0123456789ABCDEF";
-
- for ( int i = 0; i < binary.size(); i++ ) {
- ushort code = binary.at(i).unicode();
- str += (QChar)(hexchars[ (code >> 12) & 0x0F ]);
- str += (QChar)(hexchars[ (code >> 8) & 0x0F ]);
- str += (QChar)(hexchars[ (code >> 4) & 0x0F ]);
- str += (QChar)(hexchars[ code & 0x0F ]);
- }
-
- return str;
-}
-
-
-class tst_Databases
-{
-
-public:
- tst_Databases(): counter( 0 )
- {
- }
-
- ~tst_Databases()
- {
- close();
- }
-
- // returns a testtable consisting of the names of all database connections if
- // driverPrefix is empty, otherwise only those that start with driverPrefix.
- int fillTestTable( const QString& driverPrefix = QString() ) const
- {
- QTest::addColumn<QString>( "dbName" );
- int count = 0;
-
- for ( int i = 0; i < dbNames.count(); ++i ) {
- QSqlDatabase db = QSqlDatabase::database( dbNames.at( i ) );
-
- if ( !db.isValid() )
- continue;
-
- if ( driverPrefix.isEmpty() || db.driverName().startsWith( driverPrefix ) ) {
- QTest::newRow( dbNames.at( i ).toLatin1() ) << dbNames.at( i );
- ++count;
- }
- }
-
- return count;
- }
-
- int fillTestTableWithStrategies( const QString& driverPrefix = QString() ) const
- {
- QTest::addColumn<QString>( "dbName" );
- QTest::addColumn<int>("submitpolicy_i");
- int count = 0;
-
- for ( int i = 0; i < dbNames.count(); ++i ) {
- QSqlDatabase db = QSqlDatabase::database( dbNames.at( i ) );
-
- if ( !db.isValid() )
- continue;
-
- if ( driverPrefix.isEmpty() || db.driverName().startsWith( driverPrefix ) ) {
- QTest::newRow( QString("%1 [field]").arg(dbNames.at( i )).toLatin1() ) << dbNames.at( i ) << (int)QSqlTableModel::OnFieldChange;
- QTest::newRow( QString("%1 [row]").arg(dbNames.at( i )).toLatin1() ) << dbNames.at( i ) << (int)QSqlTableModel::OnRowChange;
- QTest::newRow( QString("%1 [manual]").arg(dbNames.at( i )).toLatin1() ) << dbNames.at( i ) << (int)QSqlTableModel::OnManualSubmit;
- ++count;
- }
- }
-
- return count;
- }
-
- void addDb( const QString& driver, const QString& dbName,
- const QString& user = QString(), const QString& passwd = QString(),
- const QString& host = QString(), int port = -1, const QString params = QString() )
- {
- QSqlDatabase db;
-
- if ( !QSqlDatabase::drivers().contains( driver ) ) {
- qWarning() << "Driver" << driver << "is not installed";
- return;
- }
-
- // construct a stupid unique name
- QString cName = QString::number( counter++ ) + "_" + driver + "@";
-
- cName += host.isEmpty() ? dbName : host;
-
- if ( port > 0 )
- cName += ":" + QString::number( port );
-
- db = QSqlDatabase::addDatabase( driver, cName );
-
- if ( !db.isValid() ) {
- qWarning( "Could not create database object" );
- return;
- }
-
- db.setDatabaseName( dbName );
-
- db.setUserName( user );
- db.setPassword( passwd );
- db.setHostName( host );
- db.setPort( port );
- db.setConnectOptions( params );
- dbNames.append( cName );
- }
-
- void addDbs()
- {
-// addDb( "QOCI8", "//horsehead.nokia.troll.no:1521/pony.troll.no", "scott", "tiger" ); // Oracle 9i on horsehead
-// addDb( "QOCI8", "//horsehead.nokia.troll.no:1521/ustest.troll.no", "scott", "tiger", "" ); // Oracle 9i on horsehead
-// addDb( "QOCI8", "//iceblink.nokia.troll.no:1521/ice.troll.no", "scott", "tiger", "" ); // Oracle 8 on iceblink (not currently working)
-// addDb( "QOCI", "//silence.nokia.troll.no:1521/testdb", "scott", "tiger" ); // Oracle 10g on silence
-// addDb( "QOCI", "//bq-oracle10g.apac.nokia.com:1521/XE", "scott", "tiger" ); // Oracle 10gexpress
-
-// This requires a local ODBC data source to be configured( pointing to a MySql database )
-// addDb( "QODBC", "mysqlodbc", "troll", "trond" );
-// addDb( "QODBC", "SqlServer", "troll", "trond" );
-// addDb( "QTDS7", "testdb", "troll", "trondk", "horsehead" );
-// addDb( "QODBC", "silencetestdb", "troll", "trond", "silence" );
-// addDb( "QODBC", "horseheadtestdb", "troll", "trondk", "horsehead" );
-
-// addDb( "QMYSQL3", "testdb", "troll", "trond", "horsehead.nokia.troll.no" );
-// addDb( "QMYSQL3", "testdb", "troll", "trond", "horsehead.nokia.troll.no", 3307 );
-// addDb( "QMYSQL3", "testdb", "troll", "trond", "horsehead.nokia.troll.no", 3308, "CLIENT_COMPRESS=1;CLIENT_SSL=1" ); // MySQL 4.1.1
-// addDb( "QMYSQL3", "testdb", "troll", "trond", "horsehead.nokia.troll.no", 3309, "CLIENT_COMPRESS=1;CLIENT_SSL=1" ); // MySQL 5.0.18 Linux
-// addDb( "QMYSQL3", "testdb", "troll", "trond", "silence.nokia.troll.no" ); // MySQL 5.1.36 Windows
-// addDb( "QMYSQL3", "testdb", "testuser", "Ee4Gabf6_", "mysql4-nokia.trolltech.com.au" ); // MySQL 4.1.22-2.el4 linux
-// addDb( "QMYSQL3", "testdb", "testuser", "Ee4Gabf6_", "bq-mysql50.apac.nokia.com" ); // MySQL 5.0.45-7.el5 linux
-// addDb( "QMYSQL3", "testdb", "testuser", "Ee4Gabf6_", "bq-mysql51.apac.nokia.com" ); // MySQL 5.1.36-6.7.2.i586 linux
-
-// addDb( "QPSQL7", "testdb", "troll", "trond", "horsehead.nokia.troll.no" ); // V7.2 NOT SUPPORTED!
-// addDb( "QPSQL7", "testdb", "troll", "trond", "horsehead.nokia.troll.no", 5434 ); // V7.2 NOT SUPPORTED! Multi-byte
-// addDb( "QPSQL7", "testdb", "troll", "trond", "horsehead.nokia.troll.no", 5435 ); // V7.3
-// addDb( "QPSQL7", "testdb", "troll", "trond", "horsehead.nokia.troll.no", 5436 ); // V7.4
-// addDb( "QPSQL7", "testdb", "troll", "trond", "horsehead.nokia.troll.no", 5437 ); // V8.0.3
-// addDb( "QPSQL7", "testdb", "troll", "trond", "silence.nokia.troll.no" ); // V8.2.1, UTF-8
-// addDb( "QPSQL7", "testdb", "testuser", "Ee4Gabf6_", "postgres74-nokia.trolltech.com.au" ); // Version 7.4.19-1.el4_6.1
-// addDb( "QPSQL7", "testdb", "testuser", "Ee4Gabf6_", "bq-pgsql81.apac.nokia.com" ); // Version 8.1.11-1.el5_1.1
-// addDb( "QPSQL7", "testdb", "testuser", "Ee4Gabf6_", "bq-pgsql84.apac.nokia.com" ); // Version 8.4.1-2.1.i586
-// addDb( "QPSQL7", "testdb", "testuser", "Ee4Gabf6_", "bq-pgsql90.apac.nokia.com" ); // Version 9.0.0
-
-
-// addDb( "QDB2", "testdb", "troll", "trond", "silence.nokia.troll.no" ); // DB2 v9.1 on silence
-
-// yes - interbase really wants the physical path on the host machine.
-// addDb( "QIBASE", "/opt/interbase/qttest.gdb", "SYSDBA", "masterkey", "horsehead.nokia.troll.no" );
-// addDb( "QIBASE", "silence.troll.no:c:\\ibase\\testdb", "SYSDBA", "masterkey", "" ); // InterBase 7.5 on silence
-// addDb( "QIBASE", "silence.troll.no:c:\\ibase\\testdb_ascii", "SYSDBA", "masterkey", "" ); // InterBase 7.5 on silence
-// addDb( "QIBASE", "/opt/firebird/databases/testdb.fdb", "testuser", "Ee4Gabf6_", "firebird1-nokia.trolltech.com.au" ); // Firebird 1.5.5
-// addDb( "QIBASE", "/opt/firebird/databases/testdb.fdb", "testuser", "Ee4Gabf6_", "firebird2-nokia.trolltech.com.au" ); // Firebird 2.1.1
-
-// use in-memory database to prevent local files
-// addDb("QSQLITE", ":memory:");
- addDb( "QSQLITE", QDir::toNativeSeparators(QDir::tempPath()+"/foo.db") );
-// addDb( "QSQLITE2", QDir::toNativeSeparators(QDir::tempPath()+"/foo2.db") );
-// addDb( "QODBC3", "DRIVER={SQL SERVER};SERVER=iceblink.nokia.troll.no\\ICEBLINK", "troll", "trond", "" );
-// addDb( "QODBC3", "DRIVER={SQL Native Client};SERVER=silence.nokia.troll.no\\SQLEXPRESS", "troll", "trond", "" );
-
-// addDb( "QODBC", "DRIVER={MySQL ODBC 5.1 Driver};SERVER=bq-mysql50.apac.nokia.com;DATABASE=testdb", "testuser", "Ee4Gabf6_", "" );
-// addDb( "QODBC", "DRIVER={MySQL ODBC 5.1 Driver};SERVER=bq-mysql51.apac.nokia.com;DATABASE=testdb", "testuser", "Ee4Gabf6_", "" );
-// addDb( "QODBC", "DRIVER={FreeTDS};SERVER=horsehead.nokia.troll.no;DATABASE=testdb;PORT=4101;UID=troll;PWD=trondk", "troll", "trondk", "" );
-// addDb( "QODBC", "DRIVER={FreeTDS};SERVER=silence.nokia.troll.no;DATABASE=testdb;PORT=2392;UID=troll;PWD=trond", "troll", "trond", "" );
-// addDb( "QODBC", "DRIVER={FreeTDS};SERVER=bq-winserv2003-x86-01.apac.nokia.com;DATABASE=testdb;PORT=1433;UID=testuser;PWD=Ee4Gabf6_;TDS_Version=8.0", "", "", "" );
-// addDb( "QODBC", "DRIVER={FreeTDS};SERVER=bq-winserv2008-x86-01.apac.nokia.com;DATABASE=testdb;PORT=1433;UID=testuser;PWD=Ee4Gabf6_;TDS_Version=8.0", "", "", "" );
-// addDb( "QTDS7", "testdb", "testuser", "Ee4Gabf6_", "bq-winserv2003" );
-// addDb( "QTDS7", "testdb", "testuser", "Ee4Gabf6_", "bq-winserv2008" );
-// addDb( "QODBC3", "DRIVER={SQL SERVER};SERVER=bq-winserv2003-x86-01.apac.nokia.com;DATABASE=testdb;PORT=1433", "testuser", "Ee4Gabf6_", "" );
-// addDb( "QODBC3", "DRIVER={SQL SERVER};SERVER=bq-winserv2008-x86-01.apac.nokia.com;DATABASE=testdb;PORT=1433", "testuser", "Ee4Gabf6_", "" );
-// addDb( "QODBC", "DRIVER={Microsoft Access Driver (*.mdb)};DBQ=c:\\dbs\\access\\testdb.mdb", "", "", "" );
-// addDb( "QODBC", "DRIVER={Postgresql};SERVER=bq-pgsql84.apac.nokia.com;DATABASE=testdb", "testuser", "Ee4Gabf6_", "" );
- }
-
- void open()
- {
- addDbs();
-
- QStringList::Iterator it = dbNames.begin();
-
- while ( it != dbNames.end() ) {
- QSqlDatabase db = QSqlDatabase::database(( *it ), false );
- qDebug() << "Opening:" << (*it);
-
- if ( db.isValid() && !db.isOpen() ) {
- if ( !db.open() ) {
- qWarning( "tst_Databases: Unable to open %s on %s:\n%s", qPrintable( db.driverName() ), qPrintable( *it ), qPrintable( db.lastError().databaseText() ) );
- // well... opening failed, so we just ignore the server, maybe it is not running
- it = dbNames.erase( it );
- } else {
- ++it;
- }
- }
- }
- }
-
- void close()
- {
- for ( QStringList::Iterator it = dbNames.begin(); it != dbNames.end(); ++it ) {
- {
- QSqlDatabase db = QSqlDatabase::database(( *it ), false );
-
- if ( db.isValid() && db.isOpen() )
- db.close();
- }
-
- QSqlDatabase::removeDatabase(( *it ) );
- }
-
- dbNames.clear();
- }
-
- // for debugging only: outputs the connection as string
- static QString dbToString( const QSqlDatabase db )
- {
- QString res = db.driverName() + "@";
-
- if ( db.driverName().startsWith( "QODBC" ) || db.driverName().startsWith( "QOCI" ) ) {
- res += db.databaseName();
- } else {
- res += db.hostName();
- }
-
- if ( db.port() > 0 ) {
- res += ":" + QString::number( db.port() );
- }
-
- return res;
- }
-
- // drop a table only if it exists to prevent warnings
- static void safeDropTables( QSqlDatabase db, const QStringList& tableNames )
- {
- bool wasDropped;
- QSqlQuery q( db );
- QStringList dbtables=db.tables();
-
- foreach(const QString &tableName, tableNames)
- {
- wasDropped = true;
- QString table=tableName;
- if ( db.driver()->isIdentifierEscaped(table, QSqlDriver::TableName))
- table = db.driver()->stripDelimiters(table, QSqlDriver::TableName);
-
- if ( dbtables.contains( table, Qt::CaseInsensitive ) ) {
- foreach(const QString &table2, dbtables.filter(table, Qt::CaseInsensitive)) {
- if(table2.compare(table.section('.', -1, -1), Qt::CaseInsensitive) == 0) {
- table=db.driver()->escapeIdentifier(table2, QSqlDriver::TableName);
- if(isPostgreSQL(db))
- wasDropped = q.exec( "drop table " + table + " cascade");
- else
- wasDropped = q.exec( "drop table " + table);
- dbtables.removeAll(table2);
- }
- }
- }
- if ( !wasDropped ) {
- qWarning() << dbToString(db) << "unable to drop table" << tableName << ':' << q.lastError();
-// qWarning() << "last query:" << q.lastQuery();
-// qWarning() << "dbtables:" << dbtables;
-// qWarning() << "db.tables():" << db.tables();
- }
- }
- }
-
- static void safeDropTable( QSqlDatabase db, const QString& tableName )
- {
- safeDropTables(db, QStringList() << tableName);
- }
-
- static void safeDropViews( QSqlDatabase db, const QStringList &viewNames )
- {
- if ( isMSAccess( db ) ) // Access is sooo stupid.
- safeDropTables( db, viewNames );
-
- bool wasDropped;
- QSqlQuery q( db );
- QStringList dbtables=db.tables(QSql::Views);
-
- foreach(QString viewName, viewNames)
- {
- wasDropped = true;
- QString view=viewName;
- if ( db.driver()->isIdentifierEscaped(view, QSqlDriver::TableName))
- view = db.driver()->stripDelimiters(view, QSqlDriver::TableName);
-
- if ( dbtables.contains( view, Qt::CaseInsensitive ) ) {
- foreach(const QString &view2, dbtables.filter(view, Qt::CaseInsensitive)) {
- if(view2.compare(view.section('.', -1, -1), Qt::CaseInsensitive) == 0) {
- view=db.driver()->escapeIdentifier(view2, QSqlDriver::TableName);
- wasDropped = q.exec( "drop view " + view);
- dbtables.removeAll(view);
- }
- }
- }
-
- if ( !wasDropped )
- qWarning() << dbToString(db) << "unable to drop view" << viewName << ':' << q.lastError();
-// << "\nlast query:" << q.lastQuery()
-// << "\ndbtables:" << dbtables
-// << "\ndb.tables(QSql::Views):" << db.tables(QSql::Views);
- }
- }
-
- static void safeDropView( QSqlDatabase db, const QString& tableName )
- {
- safeDropViews(db, QStringList() << tableName);
- }
-
- // returns the type name of the blob datatype for the database db.
- // blobSize is only used if the db doesn't have a generic blob type
- static QString blobTypeName( QSqlDatabase db, int blobSize = 10000 )
- {
- if ( db.driverName().startsWith( "QMYSQL" ) )
- return "longblob";
-
- if ( db.driverName().startsWith( "QPSQL" ) )
- return "bytea";
-
- if ( db.driverName().startsWith( "QTDS" )
- || isSqlServer( db )
- || isMSAccess( db ) )
- return "image";
-
- if ( db.driverName().startsWith( "QDB2" ) )
- return QString( "blob(%1)" ).arg( blobSize );
-
- if ( db.driverName().startsWith( "QIBASE" ) )
- return QString( "blob sub_type 0 segment size 4096" );
-
- if ( db.driverName().startsWith( "QOCI" )
- || db.driverName().startsWith( "QSQLITE" ) )
- return "blob";
-
- qDebug() << "tst_Databases::blobTypeName: Don't know the blob type for" << dbToString( db );
-
- return "blob";
- }
-
- static QString autoFieldName( QSqlDatabase db )
- {
- if ( db.driverName().startsWith( "QMYSQL" ) )
- return "AUTO_INCREMENT";
- if ( db.driverName().startsWith( "QTDS" ) )
- return "IDENTITY";
-/* if ( db.driverName().startsWith( "QPSQL" ) )
- return "SERIAL";*/
-// if ( db.driverName().startsWith( "QDB2" ) )
-// return "GENERATED BY DEFAULT AS IDENTITY";
-
- return QString();
- }
-
- static QByteArray printError( const QSqlError& err )
- {
- QString result;
- if(err.number() > 0)
- result += '(' + QString::number(err.number()) + ") ";
- result += '\'';
- if(!err.driverText().isEmpty())
- result += err.driverText() + "' || '";
- result += err.databaseText() + "'";
- return result.toLocal8Bit();
- }
-
- static QByteArray printError( const QSqlError& err, const QSqlDatabase& db )
- {
- QString result(dbToString(db) + ": ");
- if(err.number() > 0)
- result += '(' + QString::number(err.number()) + ") ";
- result += '\'';
- if(!err.driverText().isEmpty())
- result += err.driverText() + "' || '";
- result += err.databaseText() + "'";
- return result.toLocal8Bit();
- }
-
- static bool isSqlServer( QSqlDatabase db )
- {
- return db.databaseName().contains( "sql server", Qt::CaseInsensitive )
- || db.databaseName().contains( "sqlserver", Qt::CaseInsensitive )
- || db.databaseName().contains( "sql native client", Qt::CaseInsensitive )
- || db.databaseName().contains( "bq-winserv", Qt::CaseInsensitive )
- || db.hostName().contains( "bq-winserv", Qt::CaseInsensitive );
- }
-
- static bool isMSAccess( QSqlDatabase db )
- {
- return db.databaseName().contains( "Access Driver", Qt::CaseInsensitive );
- }
-
- static bool isPostgreSQL( QSqlDatabase db )
- {
- return db.driverName().startsWith("QPSQL") || (db.driverName().startsWith("QODBC") && ( db.databaseName().contains("PostgreSQL", Qt::CaseInsensitive) || db.databaseName().contains("pgsql", Qt::CaseInsensitive) ) );
- }
-
- static bool isMySQL( QSqlDatabase db )
- {
- return db.driverName().startsWith("QMYSQL") || (db.driverName().startsWith("QODBC") && db.databaseName().contains("MySQL", Qt::CaseInsensitive) );
- }
- static bool isDB2( QSqlDatabase db )
- {
- return db.driverName().startsWith("QDB2") || (db.driverName().startsWith("QODBC") && db.databaseName().contains("db2", Qt::CaseInsensitive) );
- }
-
- // -1 on fail, else Oracle version
- static int getOraVersion( QSqlDatabase db )
- {
- int ver = -1;
- QSqlQuery q( "SELECT banner FROM v$version", db );
- q.next();
-
- QRegExp vers( "([0-9]+)\\.[0-9\\.]+[0-9]" );
-
- if ( vers.indexIn( q.value( 0 ).toString() ) ) {
- bool ok;
- ver = vers.cap( 1 ).toInt( &ok );
-
- if ( !ok )
- ver = -1;
- }
-
- return ver;
- }
-
- static QString getMySqlVersion( const QSqlDatabase &db )
- {
- QSqlQuery q(db);
- q.exec( "select version()" );
- if(q.next())
- return q.value( 0 ).toString();
- else
- return QString();
- }
-
- static QString getPSQLVersion( const QSqlDatabase &db )
- {
- QSqlQuery q(db);
- q.exec( "select version()" );
- if(q.next())
- return q.value( 0 ).toString();
- else
- return QString();
- }
-
- QStringList dbNames;
- int counter;
-};
-
-#endif
-
diff --git a/tests/auto/qsqldatabase/tst_qsqldatabase.cpp b/tests/auto/qsqldatabase/tst_qsqldatabase.cpp
deleted file mode 100644
index 85ec28a671d..00000000000
--- a/tests/auto/qsqldatabase/tst_qsqldatabase.cpp
+++ /dev/null
@@ -1,2218 +0,0 @@
-/****************************************************************************
-**
-** Copyright (C) 2011 Nokia Corporation and/or its subsidiary(-ies).
-** All rights reserved.
-** Contact: Nokia Corporation (qt-info@nokia.com)
-**
-** This file is part of the test suite of the Qt Toolkit.
-**
-** $QT_BEGIN_LICENSE:LGPL$
-** GNU Lesser General Public License Usage
-** This file may be used under the terms of the GNU Lesser General Public
-** License version 2.1 as published by the Free Software Foundation and
-** appearing in the file LICENSE.LGPL included in the packaging of this
-** file. Please review the following information to ensure the GNU Lesser
-** General Public License version 2.1 requirements will be met:
-** http://www.gnu.org/licenses/old-licenses/lgpl-2.1.html.
-**
-** In addition, as a special exception, Nokia gives you certain additional
-** rights. These rights are described in the Nokia Qt LGPL Exception
-** version 1.1, included in the file LGPL_EXCEPTION.txt in this package.
-**
-** GNU General Public License Usage
-** Alternatively, this file may be used under the terms of the GNU General
-** Public License version 3.0 as published by the Free Software Foundation
-** and appearing in the file LICENSE.GPL included in the packaging of this
-** file. Please review the following information to ensure the GNU General
-** Public License version 3.0 requirements will be met:
-** http://www.gnu.org/copyleft/gpl.html.
-**
-** Other Usage
-** Alternatively, this file may be used in accordance with the terms and
-** conditions contained in a signed written agreement between you and Nokia.
-**
-**
-**
-**
-**
-** $QT_END_LICENSE$
-**
-****************************************************************************/
-
-
-#include <QtTest/QtTest>
-#include <qsqldatabase.h>
-#include <qsqlquery.h>
-#include <qsqldriver.h>
-#include <qsqlrecord.h>
-#include <qsqlfield.h>
-#include <qsqlindex.h>
-#include <qregexp.h>
-#include <qvariant.h>
-#include <qdatetime.h>
-#include <qdebug.h>
-
-#define NODATABASE_SKIP "No database drivers are available in this Qt configuration"
-
-#include "tst_databases.h"
-
-//TESTED_FILES=
-
-QT_FORWARD_DECLARE_CLASS(QSqlDatabase)
-struct FieldDef;
-
-class tst_QSqlDatabase : public QObject
-{
- Q_OBJECT
-
-public:
- tst_QSqlDatabase();
- virtual ~tst_QSqlDatabase();
-
-public slots:
- void initTestCase();
- void cleanupTestCase();
- void init();
- void cleanup();
-private slots:
- void record_data() { generic_data(); }
- //void record();
- void open_data() { generic_data(); }
- void open();
- void tables_data() { generic_data(); }
- void tables();
- void oci_tables_data() { generic_data("QOCI"); }
- void oci_tables();
- void transaction_data() { generic_data(); }
- void transaction();
- void eventNotification_data() { generic_data(); }
- void eventNotification();
- void addDatabase();
-
- //database specific tests
- void recordMySQL_data() { generic_data("QMYSQL"); }
- void recordMySQL();
- void recordPSQL_data() { generic_data("QPSQL"); }
- void recordPSQL();
- void recordOCI_data() { generic_data("QOCI"); }
- void recordOCI();
- void recordTDS_data() { generic_data("QTDS"); }
- void recordTDS();
- void recordDB2_data() { generic_data("QDB2"); }
- void recordDB2();
- void recordSQLite_data() { generic_data("QSQLITE"); }
- void recordSQLite();
- void recordAccess_data() { generic_data("QODBC"); }
- void recordAccess();
- void recordSQLServer_data() { generic_data("QODBC"); }
- void recordSQLServer();
- void recordIBase_data() {generic_data("QIBASE"); }
- void recordIBase();
-
- void eventNotificationIBase_data() { generic_data("QIBASE"); }
- void eventNotificationIBase();
- void eventNotificationPSQL_data() { generic_data("QPSQL"); }
- void eventNotificationPSQL();
-
- //database specific 64 bit integer test
- void bigIntField_data() { generic_data(); }
- void bigIntField();
-
- // general tests
- void getConnectionName_data() { generic_data(); }
- void getConnectionName(); // For task 129992
-
- //problem specific tests
- void alterTable_data() { generic_data(); }
- void alterTable();
- void caseSensivity_data() { generic_data(); }
- void caseSensivity();
- void noEscapedFieldNamesInRecord_data() { generic_data(); }
- void noEscapedFieldNamesInRecord();
- void whitespaceInIdentifiers_data() { generic_data(); }
- void whitespaceInIdentifiers();
- void formatValueTrimStrings_data() { generic_data(); }
- void formatValueTrimStrings();
- void precisionPolicy_data() { generic_data(); }
- void precisionPolicy();
-
- void db2_valueCacheUpdate_data() { generic_data("QDB2"); }
- void db2_valueCacheUpdate();
-
- void psql_schemas_data() { generic_data("QPSQL"); }
- void psql_schemas();
- void psql_escapedIdentifiers_data() { generic_data("QPSQL"); }
- void psql_escapedIdentifiers();
- void psql_escapeBytea_data() { generic_data("QPSQL"); }
- void psql_escapeBytea();
- void bug_249059_data() { generic_data("QPSQL"); }
- void bug_249059();
-
- void mysqlOdbc_unsignedIntegers_data() { generic_data(); }
- void mysqlOdbc_unsignedIntegers();
- void mysql_multiselect_data() { generic_data("QMYSQL"); }
- void mysql_multiselect(); // For task 144331
- void mysql_savepointtest_data() { generic_data("QMYSQL"); }
- void mysql_savepointtest();
-
- void accessOdbc_strings_data() { generic_data(); }
- void accessOdbc_strings();
-
- void ibase_numericFields_data() { generic_data("QIBASE"); }
- void ibase_numericFields(); // For task 125053
- void ibase_fetchBlobs_data() { generic_data("QIBASE"); }
- void ibase_fetchBlobs(); // For task 143471
- void ibase_useCustomCharset_data() { generic_data("QIBASE"); }
- void ibase_useCustomCharset(); // For task 134608
- void ibase_procWithoutReturnValues_data() { generic_data("QIBASE"); } // For task 165423
- void ibase_procWithoutReturnValues();
- void ibase_procWithReturnValues_data() { generic_data("QIBASE"); } // For task 177530
- void ibase_procWithReturnValues();
-
- void odbc_reopenDatabase_data() { generic_data("QODBC"); }
- void odbc_reopenDatabase();
- void odbc_uniqueidentifier_data() { generic_data("QODBC"); }
- void odbc_uniqueidentifier(); // For task 141822
- void odbc_uintfield_data() { generic_data("QODBC"); }
- void odbc_uintfield();
- void odbc_bindBoolean_data() { generic_data("QODBC"); }
- void odbc_bindBoolean();
- void odbc_testqGetString_data() { generic_data("QODBC"); }
- void odbc_testqGetString();
-
- void oci_serverDetach_data() { generic_data("QOCI"); }
- void oci_serverDetach(); // For task 154518
- void oci_xmltypeSupport_data() { generic_data("QOCI"); }
- void oci_xmltypeSupport();
- void oci_fieldLength_data() { generic_data("QOCI"); }
- void oci_fieldLength();
- void oci_synonymstest_data() { generic_data("QOCI"); }
- void oci_synonymstest();
-
- void sqlite_bindAndFetchUInt_data() { generic_data("QSQLITE"); }
- void sqlite_bindAndFetchUInt();
-
- void sqlStatementUseIsNull_189093_data() { generic_data(); }
- void sqlStatementUseIsNull_189093();
-
- void sqlite_enable_cache_mode_data() { generic_data("QSQLITE"); }
- void sqlite_enable_cache_mode();
-
-private:
- void createTestTables(QSqlDatabase db);
- void dropTestTables(QSqlDatabase db);
- void populateTestTables(QSqlDatabase db);
- void generic_data(const QString &engine=QString());
-
- void testRecord(const FieldDef fieldDefs[], const QSqlRecord& inf, QSqlDatabase db);
- void commonFieldTest(const FieldDef fieldDefs[], QSqlDatabase, const int);
-
- tst_Databases dbs;
-};
-
-// number of records to be inserted per testfunction
-static const int ITERATION_COUNT = 2;
-
-//helper class for database specific tests
-struct FieldDef {
- FieldDef(QString tn = QString(),
- QVariant::Type t = QVariant::Invalid,
- QVariant v = QVariant(),
- bool nl = true):
- typeName(tn), type(t), val(v), nullable(nl) {}
-
- QString fieldName() const
- {
- QString rt = typeName;
- rt.replace(QRegExp("\\s"), QString("_"));
- int i = rt.indexOf("(");
- if (i == -1)
- i = rt.length();
- if (i > 20)
- i = 20;
- return "t_" + rt.left(i);
- }
- QString typeName;
- QVariant::Type type;
- QVariant val;
- bool nullable;
-};
-
-// creates a table out of the FieldDefs and returns the number of fields
-// excluding the primary key field
-static int createFieldTable(const FieldDef fieldDefs[], QSqlDatabase db)
-{
- tst_Databases::safeDropTable(db, qTableName("qtestfields", __FILE__));
- QSqlQuery q(db);
- // construct a create table statement consisting of all fieldtypes
- QString qs = "create table " + qTableName("qtestfields", __FILE__);
- QString autoName = tst_Databases::autoFieldName(db);
- if (tst_Databases::isMSAccess(db))
- qs.append(" (id int not null");
- else if (tst_Databases::isPostgreSQL(db))
- qs.append(" (id serial not null");
- else
- qs.append(QString("(id integer not null %1 primary key").arg(autoName));
-
- int i = 0;
- for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) {
- qs += QString(",\n %1 %2").arg(fieldDefs[ i ].fieldName()).arg(fieldDefs[ i ].typeName);
- if ((db.driverName().startsWith("QTDS") || tst_Databases::isSqlServer(db)) && fieldDefs[ i ].nullable) {
- qs += " null";
- }
- }
-
- if (tst_Databases::isMSAccess(db))
- qs.append(",\n primary key (id)");
-
- qs += ')';
- if (!q.exec(qs)) {
- qDebug() << "Creation of Table failed:" << tst_Databases::printError(q.lastError(), db);
- qDebug() << "Query: " << qs;
- return -1;
- }
- return i;
-}
-
-tst_QSqlDatabase::tst_QSqlDatabase()
-{
-}
-
-tst_QSqlDatabase::~tst_QSqlDatabase()
-{
-}
-
-void tst_QSqlDatabase::createTestTables(QSqlDatabase db)
-{
- if (!db.isValid())
- return;
- QSqlQuery q(db);
- if (db.driverName().startsWith("QMYSQL"))
- // ### stupid workaround until we find a way to hardcode this
- // in the MySQL server startup script
- q.exec("set table_type=innodb");
- else if (tst_Databases::isSqlServer(db)) {
- QVERIFY_SQL(q, exec("SET ANSI_DEFAULTS ON"));
- QVERIFY_SQL(q, exec("SET IMPLICIT_TRANSACTIONS OFF"));
- } else if(tst_Databases::isPostgreSQL(db))
- QVERIFY_SQL( q, exec("set client_min_messages='warning'"));
-
- // please never ever change this table; otherwise fix all tests ;)
- if (tst_Databases::isMSAccess(db)) {
- QVERIFY_SQL(q, exec("create table " + qTableName("qtest", __FILE__) +
- " (id int not null, t_varchar varchar(40) not null, t_char char(40), "
- "t_numeric number, primary key (id, t_varchar))"));
- } else {
- QVERIFY_SQL(q, exec("create table " + qTableName("qtest", __FILE__) +
- " (id integer not null, t_varchar varchar(40) not null, "
- "t_char char(40), t_numeric numeric(6, 3), primary key (id, t_varchar))"));
- }
-
- if (testWhiteSpaceNames(db.driverName())) {
- QString qry = "create table "
- + db.driver()->escapeIdentifier(qTableName("qtest", __FILE__) + " test", QSqlDriver::TableName)
- + '('
- + db.driver()->escapeIdentifier(QLatin1String("test test"), QSqlDriver::FieldName)
- + " int not null primary key)";
- QVERIFY_SQL(q, exec(qry));
- }
-}
-
-void tst_QSqlDatabase::dropTestTables(QSqlDatabase db)
-{
- if (!db.isValid())
- return;
-
- if(tst_Databases::isPostgreSQL(db)) {
- QSqlQuery q(db);
- QVERIFY_SQL( q, exec("set client_min_messages='warning'"));
- }
-
- // drop the view first, otherwise we'll get dependency problems
- tst_Databases::safeDropViews(db, QStringList() << qTableName("qtest_view", __FILE__) << qTableName("qtest_view2", __FILE__));
-
- QStringList tableNames;
- tableNames << qTableName("qtest", __FILE__)
- << qTableName("qtestfields", __FILE__)
- << qTableName("qtestalter", __FILE__)
- << qTableName("qtest_temp", __FILE__)
- << qTableName("qtest_bigint", __FILE__)
- << qTableName("qtest_xmltype", __FILE__)
- << qTableName("latin1table", __FILE__)
- << qTableName("qtest_sqlguid", __FILE__)
- << qTableName("batable", __FILE__)
- << qTableName("qtest_prec", __FILE__)
- << qTableName("uint", __FILE__)
- << qTableName("strings", __FILE__)
- << qTableName("numericfields", __FILE__)
- << qTableName("qtest_ibaseblobs", __FILE__)
- << qTableName("qtestBindBool", __FILE__)
- << qTableName("testqGetString", __FILE__)
- << qTableName("qtest_sqlguid", __FILE__)
- << qTableName("uint_table", __FILE__)
- << qTableName("uint_test", __FILE__)
- << qTableName("bug_249059", __FILE__);
-
- QSqlQuery q(0, db);
- if (db.driverName().startsWith("QPSQL")) {
- q.exec("drop schema " + qTableName("qtestschema", __FILE__) + " cascade");
- q.exec("drop schema " + qTableName("qtestScHeMa", __FILE__) + " cascade");
- }
-
- if (testWhiteSpaceNames(db.driverName()))
- tableNames << db.driver()->escapeIdentifier(qTableName("qtest", __FILE__) + " test", QSqlDriver::TableName);
-
- tst_Databases::safeDropTables(db, tableNames);
-
- if (db.driverName().startsWith("QOCI")) {
- q.exec("drop user "+qTableName("CREATOR", __FILE__)+" cascade");
- q.exec("drop user "+qTableName("APPUSER", __FILE__)+" cascade");
- q.exec("DROP TABLE system."+qTableName("mypassword", __FILE__));
-
- }
-}
-
-void tst_QSqlDatabase::populateTestTables(QSqlDatabase db)
-{
- if (!db.isValid())
- return;
- QSqlQuery q(db);
- const QString qtest(qTableName("qtest", __FILE__));
-
- q.exec("delete from " + qtest); //non-fatal
- QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (0, 'VarChar0', 'Char0', 1.1)"));
- QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (1, 'VarChar1', 'Char1', 2.2)"));
- QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (2, 'VarChar2', 'Char2', 3.3)"));
- QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (3, 'VarChar3', 'Char3', 4.4)"));
- QVERIFY_SQL(q, exec("insert into " + qtest + " (id, t_varchar, t_char, t_numeric) values (4, 'VarChar4', NULL, NULL)"));
-}
-
-void tst_QSqlDatabase::initTestCase()
-{
- dbs.open();
-
- for (QStringList::ConstIterator it = dbs.dbNames.begin(); it != dbs.dbNames.end(); ++it) {
- QSqlDatabase db = QSqlDatabase::database((*it));
- CHECK_DATABASE(db);
- dropTestTables(db); //in case of leftovers
- createTestTables(db);
- populateTestTables(db);
- }
-}
-
-void tst_QSqlDatabase::cleanupTestCase()
-{
- for (QStringList::ConstIterator it = dbs.dbNames.begin(); it != dbs.dbNames.end(); ++it) {
- QSqlDatabase db = QSqlDatabase::database((*it));
- CHECK_DATABASE(db);
- dropTestTables(db);
- }
-
- dbs.close();
-}
-
-void tst_QSqlDatabase::init()
-{
-}
-
-void tst_QSqlDatabase::cleanup()
-{
-}
-
-void tst_QSqlDatabase::generic_data(const QString& engine)
-{
- if ( dbs.fillTestTable(engine) == 0 ) {
- if(engine.isEmpty())
- QSKIP( "No database drivers are available in this Qt configuration", SkipAll );
- else
- QSKIP( (QString("No database drivers of type %1 are available in this Qt configuration").arg(engine)).toLocal8Bit(), SkipAll );
- }
-}
-
-void tst_QSqlDatabase::addDatabase()
-{
- QTest::ignoreMessage(QtWarningMsg, "QSqlDatabase: BLAH_FOO_NONEXISTENT_DRIVER driver not loaded");
- QTest::ignoreMessage(QtWarningMsg, qPrintable("QSqlDatabase: available drivers: " + QSqlDatabase::drivers().join(QLatin1String(" "))));
- {
- QSqlDatabase db = QSqlDatabase::addDatabase("BLAH_FOO_NONEXISTENT_DRIVER",
- "INVALID_CONNECTION");
- QVERIFY(!db.isValid());
- }
- QVERIFY(QSqlDatabase::contains("INVALID_CONNECTION"));
- QSqlDatabase::removeDatabase("INVALID_CONNECTION");
- QVERIFY(!QSqlDatabase::contains("INVALID_CONNECTION"));
-}
-
-void tst_QSqlDatabase::open()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- int i;
- for (i = 0; i < 10; ++i) {
- db.close();
- QVERIFY(!db.isOpen());
- QVERIFY_SQL(db, open());
- QVERIFY(db.isOpen());
- QVERIFY(!db.isOpenError());
- }
-
- if (db.driverName().startsWith("QSQLITE") && db.databaseName() == ":memory:") {
- // tables in in-memory databases don't survive an open/close
- createTestTables(db);
- populateTestTables(db);
- }
-}
-
-void tst_QSqlDatabase::tables()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const QString qtest(qTableName("qtest", __FILE__)), qtest_view(qTableName("qtest_view", __FILE__)), temp_tab(qTableName("test_tab", __FILE__));
-
- bool views = true;
- bool tempTables = false;
-
- QSqlQuery q(db);
- if ( db.driverName().startsWith( "QMYSQL" ) && tst_Databases::getMySqlVersion( db ).section( QChar('.'), 0, 0 ).toInt()<5 )
- QSKIP( "Test requires MySQL >= 5.0", SkipSingle );
-
-
- if (!q.exec("CREATE VIEW " + qtest_view + " as select * from " + qtest)) {
- qDebug("DBMS '%s' cannot handle VIEWs: %s",
- qPrintable(tst_Databases::dbToString(db)),
- qPrintable(tst_Databases::printError(q.lastError())));
- views = false;
- }
-
- if (db.driverName().startsWith("QSQLITE3")) {
- QVERIFY_SQL(q, exec("CREATE TEMPORARY TABLE " + temp_tab + " (id int)"));
- tempTables = true;
- }
-
- QStringList tables = db.tables(QSql::Tables);
- QVERIFY(tables.contains(qtest, Qt::CaseInsensitive));
- QVERIFY(!tables.contains("sql_features", Qt::CaseInsensitive)); //check for postgres 7.4 internal tables
- if (views) {
- QVERIFY(!tables.contains(qtest_view, Qt::CaseInsensitive));
- }
- if (tempTables)
- QVERIFY(tables.contains(temp_tab, Qt::CaseInsensitive));
-
- tables = db.tables(QSql::Views);
- if (views) {
- if(!tables.contains(qtest_view, Qt::CaseInsensitive))
- qDebug() << "failed to find" << qtest_view << "in" << tables;
- QVERIFY(tables.contains(qtest_view, Qt::CaseInsensitive));
- }
- if (tempTables)
- QVERIFY(!tables.contains(temp_tab, Qt::CaseInsensitive));
- QVERIFY(!tables.contains(qtest, Qt::CaseInsensitive));
-
- tables = db.tables(QSql::SystemTables);
- QVERIFY(!tables.contains(qtest, Qt::CaseInsensitive));
- QVERIFY(!tables.contains(qtest_view, Qt::CaseInsensitive));
- QVERIFY(!tables.contains(temp_tab, Qt::CaseInsensitive));
-
- tables = db.tables(QSql::AllTables);
- if (views)
- QVERIFY(tables.contains(qtest_view, Qt::CaseInsensitive));
- if (tempTables)
- QVERIFY(tables.contains(temp_tab, Qt::CaseInsensitive));
- QVERIFY(tables.contains(qtest, Qt::CaseInsensitive));
-
- if (db.driverName().startsWith("QPSQL")) {
- QVERIFY(tables.contains(qtest + " test"));
- }
-}
-
-void tst_QSqlDatabase::whitespaceInIdentifiers()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (testWhiteSpaceNames(db.driverName())) {
- const QString tableName(qTableName("qtest", __FILE__) + " test");
- QVERIFY(db.tables().contains(tableName, Qt::CaseInsensitive));
-
- QSqlRecord rec = db.record(db.driver()->escapeIdentifier(tableName, QSqlDriver::TableName));
- QCOMPARE(rec.count(), 1);
- QCOMPARE(rec.fieldName(0), QString("test test"));
- if(db.driverName().startsWith("QOCI"))
- QCOMPARE(rec.field(0).type(), QVariant::Double);
- else
- QCOMPARE(rec.field(0).type(), QVariant::Int);
-
- QSqlIndex idx = db.primaryIndex(db.driver()->escapeIdentifier(tableName, QSqlDriver::TableName));
- QCOMPARE(idx.count(), 1);
- QCOMPARE(idx.fieldName(0), QString("test test"));
- if(db.driverName().startsWith("QOCI"))
- QCOMPARE(idx.field(0).type(), QVariant::Double);
- else
- QCOMPARE(idx.field(0).type(), QVariant::Int);
- } else {
- QSKIP("DBMS does not support whitespaces in identifiers", SkipSingle);
- }
-}
-
-void tst_QSqlDatabase::alterTable()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- const QString qtestalter(qTableName("qtestalter", __FILE__));
-
- QSqlQuery q(db);
-
- QVERIFY_SQL(q, exec("create table " + qtestalter + " (F1 char(20), F2 char(20), F3 char(20))"));
- QSqlRecord rec = db.record(qtestalter);
- QCOMPARE((int)rec.count(), 3);
-
- int i;
- for (i = 0; i < 3; ++i) {
- QCOMPARE(rec.field(i).name().toUpper(), QString("F%1").arg(i + 1));
- }
-
- if (!q.exec("alter table " + qtestalter + " drop column F2")) {
- QSKIP("DBMS doesn't support dropping columns in ALTER TABLE statement", SkipSingle);
- }
-
- rec = db.record(qtestalter);
-
- QCOMPARE((int)rec.count(), 2);
-
- QCOMPARE(rec.field(0).name().toUpper(), QString("F1"));
- QCOMPARE(rec.field(1).name().toUpper(), QString("F3"));
-
- q.exec("select * from " + qtestalter);
-}
-
-#if 0
-// this is the general test that should work on all databases.
-// unfortunately no DBMS supports SQL 92/ 99 so the general
-// test is more or less a joke. Please write a test for each
-// database plugin (see recordOCI and so on). Use this test
-// as a template.
-void tst_QSqlDatabase::record()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- static const FieldDef fieldDefs[] = {
- FieldDef("char(20)", QVariant::String, QString("blah1"), false),
- FieldDef("varchar(20)", QVariant::String, QString("blah2"), false),
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-}
-#endif
-
-void tst_QSqlDatabase::testRecord(const FieldDef fieldDefs[], const QSqlRecord& inf, QSqlDatabase db)
-{
- int i = 0;
- if (!tst_Databases::autoFieldName(db).isEmpty()) // Currently only MySQL is tested
- QVERIFY2(inf.field(i).isAutoValue(), qPrintable(inf.field(i).name() + " should be reporting as an autovalue"));
- for (i = 0; !fieldDefs[ i ].typeName.isNull(); ++i) {
- QCOMPARE(inf.field(i+1).name().toUpper(), fieldDefs[ i ].fieldName().toUpper());
- if (inf.field(i+1).type() != fieldDefs[ i ].type) {
- QFAIL(qPrintable(QString(" Expected: '%1' Received: '%2' for field %3 in testRecord").arg(
- QVariant::typeToName(fieldDefs[ i ].type)).arg(
- QVariant::typeToName(inf.field(i+1).type())).arg(
- fieldDefs[ i ].fieldName())));
- }
- QVERIFY(!inf.field(i+1).isAutoValue());
-
-// 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())));
- }
-}
-
-// non-dbms specific tests
-void tst_QSqlDatabase::commonFieldTest(const FieldDef fieldDefs[], QSqlDatabase db, const int fieldCount)
-{
- CHECK_DATABASE(db);
-
- QSqlRecord rec = db.record(qTableName("qtestfields", __FILE__));
- QCOMPARE((int)rec.count(), fieldCount+1);
- testRecord(fieldDefs, rec, db);
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec("select * from " + qTableName("qtestfields", __FILE__)));
-}
-
-void tst_QSqlDatabase::recordTDS()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- static const FieldDef fieldDefs[] = {
- FieldDef("tinyint", QVariant::Int, 255),
- FieldDef("smallint", QVariant::Int, 32767),
- FieldDef("int", QVariant::Int, 2147483647),
- FieldDef("numeric(10,9)", QVariant::Double, 1.23456789),
- FieldDef("decimal(10,9)", QVariant::Double, 1.23456789),
- FieldDef("float(4)", QVariant::Double, 1.23456789),
- FieldDef("double precision", QVariant::Double, 1.23456789),
- FieldDef("real", QVariant::Double, 1.23456789),
- FieldDef("smallmoney", QVariant::Double, 100.42),
- FieldDef("money", QVariant::Double, 200.42),
- // accuracy is that of a minute
- FieldDef("smalldatetime", QVariant::DateTime, QDateTime(QDate::currentDate(), QTime(1, 2, 0, 0))),
- // accuracy is that of a second
- FieldDef("datetime", QVariant::DateTime, QDateTime(QDate::currentDate(), QTime(1, 2, 3, 0))),
- FieldDef("char(20)", QVariant::String, "blah1"),
- FieldDef("varchar(20)", QVariant::String, "blah2"),
- FieldDef("nchar(20)", QVariant::String, "blah3"),
- FieldDef("nvarchar(20)", QVariant::String, "blah4"),
- FieldDef("text", QVariant::String, "blah5"),
- FieldDef("bit", QVariant::Int, 1, false),
-
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-}
-
-void tst_QSqlDatabase::recordOCI()
-{
- bool hasTimeStamp = false;
-
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- // runtime check for Oracle version since V8 doesn't support TIMESTAMPs
- if (tst_Databases::getOraVersion(db) >= 9)
- hasTimeStamp = true;
-
- FieldDef tsdef;
- FieldDef tstzdef;
- FieldDef tsltzdef;
- FieldDef intytm;
- FieldDef intdts;
-
- static const QDateTime dt(QDate::currentDate(), QTime(1, 2, 3, 0));
-
- if (hasTimeStamp) {
- tsdef = FieldDef("timestamp", QVariant::DateTime, dt);
- tstzdef = FieldDef("timestamp with time zone", QVariant::DateTime, dt);
- tsltzdef = FieldDef("timestamp with local time zone", QVariant::DateTime, dt);
- intytm = FieldDef("interval year to month", QVariant::String, QString("+01-01"));
- intdts = FieldDef("interval day to second", QVariant::String, QString("+01 00:00:01.000000"));
- }
-
- const FieldDef fieldDefs[] = {
- FieldDef("char(20)", QVariant::String, QString("blah1")),
- FieldDef("varchar(20)", QVariant::String, QString("blah2")),
- FieldDef("nchar(20)", QVariant::String, QString("blah3")),
- FieldDef("nvarchar2(20)", QVariant::String, QString("blah4")),
- FieldDef("number(10,5)", QVariant::Double, 1.1234567),
- FieldDef("date", QVariant::DateTime, dt),
- FieldDef("long raw", QVariant::ByteArray, QByteArray("blah5")),
- FieldDef("raw(2000)", QVariant::ByteArray, QByteArray("blah6"), false),
- FieldDef("blob", QVariant::ByteArray, QByteArray("blah7")),
- FieldDef("clob", QVariant::String, QString("blah8")),
- FieldDef("nclob", QVariant::String, QString("blah9")),
-// FieldDef("bfile", QVariant::ByteArray, QByteArray("blah10")),
-
- intytm,
- intdts,
- tsdef,
- tstzdef,
- tsltzdef,
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-
- // some additional tests
- QSqlRecord rec = db.record(qTableName("qtestfields", __FILE__));
- QCOMPARE(rec.field("T_NUMBER").length(), 10);
- QCOMPARE(rec.field("T_NUMBER").precision(), 5);
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec("SELECT * FROM " + qTableName("qtestfields", __FILE__)));
- rec = q.record();
- QCOMPARE(rec.field("T_NUMBER").length(), 10);
- QCOMPARE(rec.field("T_NUMBER").precision(), 5);
-}
-
-void tst_QSqlDatabase::recordPSQL()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- FieldDef byteadef;
- if (db.driver()->hasFeature(QSqlDriver::BLOB))
- byteadef = FieldDef("bytea", QVariant::ByteArray, QByteArray("bl\\ah"));
- static FieldDef fieldDefs[] = {
- FieldDef("bigint", QVariant::LongLong, Q_INT64_C(9223372036854775807)),
- FieldDef("bigserial", QVariant::LongLong, 100, false),
- FieldDef("bit", QVariant::String, "1"), // a bit in postgres is a bit-string
- FieldDef("box", QVariant::String, "(5,6),(1,2)"),
- FieldDef("char(20)", QVariant::String, "blah5678901234567890"),
- FieldDef("varchar(20)", QVariant::String, "blah5678901234567890"),
- FieldDef("cidr", QVariant::String, "12.123.0.0/24"),
- FieldDef("circle", QVariant::String, "<(1,2),3>"),
- FieldDef("date", QVariant::Date, QDate::currentDate()),
- FieldDef("float8", QVariant::Double, 1.12345678912),
- FieldDef("inet", QVariant::String, "12.123.12.23"),
- FieldDef("integer", QVariant::Int, 2147483647),
- FieldDef("interval", QVariant::String, "1 day 12:59:10"),
-// LOL... you can create a "line" datatype in PostgreSQL <= 7.2.x but
-// as soon as you want to insert data you get a "not implemented yet" error
-// FieldDef("line", QVariant::Polygon, QPolygon(QRect(1, 2, 3, 4))),
- FieldDef("lseg", QVariant::String, "[(1,1),(2,2)]"),
- FieldDef("macaddr", QVariant::String, "08:00:2b:01:02:03"),
- FieldDef("money", QVariant::String, "$12.23"),
- FieldDef("numeric", QVariant::Double, 1.2345678912),
- FieldDef("path", QVariant::String, "((1,2),(3,2),(3,5),(1,5))"),
- FieldDef("point", QVariant::String, "(1,2)"),
- FieldDef("polygon", QVariant::String, "((1,2),(3,2),(3,5),(1,5))"),
- FieldDef("real", QVariant::Double, 1.1234),
- FieldDef("smallint", QVariant::Int, 32767),
- FieldDef("serial", QVariant::Int, 100, false),
- FieldDef("text", QVariant::String, "blah"),
- FieldDef("time(6)", QVariant::Time, QTime(1, 2, 3)),
- FieldDef("timetz", QVariant::Time, QTime(1, 2, 3)),
- FieldDef("timestamp(6)", QVariant::DateTime, QDateTime::currentDateTime()),
- FieldDef("timestamptz", QVariant::DateTime, QDateTime::currentDateTime()),
- byteadef,
-
- FieldDef()
- };
-
- QSqlQuery q(db);
-
- if(tst_Databases::isPostgreSQL(db))
- QVERIFY_SQL( q, exec("set client_min_messages='warning'"));
-
- q.exec("drop sequence " + qTableName("qtestfields", __FILE__) + "_t_bigserial_seq");
- q.exec("drop sequence " + qTableName("qtestfields", __FILE__) + "_t_serial_seq");
- // older psql cut off the table name
- q.exec("drop sequence " + qTableName("qtestfields", __FILE__).left(15) + "_t_bigserial_seq");
- q.exec("drop sequence " + qTableName("qtestfields", __FILE__).left(18) + "_t_serial_seq");
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
- for (int i = 0; i < ITERATION_COUNT; ++i) {
- // increase serial values
- for (int i2 = 0; !fieldDefs[ i2 ].typeName.isNull(); ++i2) {
- if (fieldDefs[ i2 ].typeName == "serial" ||
- fieldDefs[ i2 ].typeName == "bigserial") {
-
- FieldDef def = fieldDefs[ i2 ];
- def.val = def.val.toInt() + 1;
- fieldDefs[ i2 ] = def;
- }
- }
- }
-}
-
-void tst_QSqlDatabase::recordMySQL()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- FieldDef bin10, varbin10;
- int major = tst_Databases::getMySqlVersion( db ).section( QChar('.'), 0, 0 ).toInt();
- int minor = tst_Databases::getMySqlVersion( db ).section( QChar('.'), 1, 1 ).toInt();
- int revision = tst_Databases::getMySqlVersion( db ).section( QChar('.'), 2, 2 ).toInt();
- int vernum = (major << 16) + (minor << 8) + revision;
-
- /* The below is broken in mysql below 5.0.15
- see http://dev.mysql.com/doc/refman/5.0/en/binary-varbinary.html
- specifically: Before MySQL 5.0.15, the pad value is space. Values are right-padded
- with space on insert, and trailing spaces are removed on select.
- */
- if( vernum >= ((5 << 16) + 15) ) {
- bin10 = FieldDef("binary(10)", QVariant::ByteArray, QString("123abc "));
- varbin10 = FieldDef("varbinary(10)", QVariant::ByteArray, QString("123abcv "));
- }
-
- static QDateTime dt(QDate::currentDate(), QTime(1, 2, 3, 0));
- static const FieldDef fieldDefs[] = {
- FieldDef("tinyint", QVariant::Int, 127),
- FieldDef("tinyint unsigned", QVariant::UInt, 255),
- FieldDef("smallint", QVariant::Int, 32767),
- FieldDef("smallint unsigned", QVariant::UInt, 65535),
- FieldDef("mediumint", QVariant::Int, 8388607),
- FieldDef("mediumint unsigned", QVariant::UInt, 16777215),
- FieldDef("integer", QVariant::Int, 2147483647),
- FieldDef("integer unsigned", QVariant::UInt, 4294967295u),
- FieldDef("bigint", QVariant::LongLong, Q_INT64_C(9223372036854775807)),
- FieldDef("bigint unsigned", QVariant::ULongLong, Q_UINT64_C(18446744073709551615)),
- FieldDef("float", QVariant::Double, 1.12345),
- FieldDef("double", QVariant::Double, 1.123456789),
- FieldDef("decimal(10, 9)", QVariant::Double,1.123456789),
- FieldDef("numeric(5, 2)", QVariant::Double, 123.67),
- FieldDef("date", QVariant::Date, QDate::currentDate()),
- FieldDef("datetime", QVariant::DateTime, dt),
- FieldDef("timestamp", QVariant::DateTime, dt, false),
- FieldDef("time", QVariant::Time, dt.time()),
- FieldDef("year", QVariant::Int, 2003),
- FieldDef("char(20)", QVariant::String, "Blah"),
- FieldDef("varchar(20)", QVariant::String, "BlahBlah"),
- FieldDef("tinytext", QVariant::String, QString("blah5")),
- FieldDef("text", QVariant::String, QString("blah6")),
- FieldDef("mediumtext", QVariant::String, QString("blah7")),
- FieldDef("longtext", QVariant::String, QString("blah8")),
- // SET OF?
-
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec("SELECT DATE_SUB(CURDATE(), INTERVAL 2 DAY)"));
- QVERIFY(q.next());
- QCOMPARE(q.value(0).toDateTime().date(), QDate::currentDate().addDays(-2));
-}
-
-void tst_QSqlDatabase::recordDB2()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- static const FieldDef fieldDefs[] = {
- FieldDef("char(20)", QVariant::String, QString("Blah1")),
- FieldDef("varchar(20)", QVariant::String, QString("Blah2")),
- FieldDef("long varchar", QVariant::String, QString("Blah3")),
- // using BOOLEAN results in "SQL0486N The BOOLEAN data type is currently only supported internally."
-//X FieldDef("boolean" , QVariant::Bool, QVariant(true, 1)),
- FieldDef("smallint", QVariant::Int, 32767),
- FieldDef("integer", QVariant::Int, 2147483647),
- FieldDef("bigint", QVariant::LongLong, Q_INT64_C(9223372036854775807)),
- FieldDef("real", QVariant::Double, 1.12345),
- FieldDef("double", QVariant::Double, 1.23456789),
- FieldDef("float", QVariant::Double, 1.23456789),
- FieldDef("decimal(10,9)", QVariant::Double, 1.234567891),
- FieldDef("numeric(10,9)", QVariant::Double, 1.234567891),
- FieldDef("date", QVariant::Date, QDate::currentDate()),
- FieldDef("time", QVariant::Time, QTime(1, 2, 3)),
- FieldDef("timestamp", QVariant::DateTime, QDateTime::currentDateTime()),
-// FieldDef("graphic(20)", QVariant::String, QString("Blah4")),
-// FieldDef("vargraphic(20)", QVariant::String, QString("Blah5")),
-// FieldDef("long vargraphic", QVariant::String, QString("Blah6")),
- //X FieldDef("datalink", QVariant::String, QString("DLVALUE('Blah10')")),
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-}
-
-void tst_QSqlDatabase::recordIBase()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- static const FieldDef fieldDefs[] = {
- FieldDef("char(20)", QVariant::String, QString("Blah1"), false),
- FieldDef("varchar(20)", QVariant::String, QString("Blah2")),
- FieldDef("smallint", QVariant::Int, 32767),
- FieldDef("float", QVariant::Double, 1.2345),
- FieldDef("double precision", QVariant::Double, 1.2345678),
- FieldDef("timestamp", QVariant::DateTime, QDateTime::currentDateTime()),
- FieldDef("time", QVariant::Time, QTime::currentTime()),
- FieldDef("decimal(18)", QVariant::LongLong, Q_INT64_C(9223372036854775807)),
- FieldDef("numeric(5,2)", QVariant::Double, 123.45),
-
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-}
-
-void tst_QSqlDatabase::recordSQLite()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- static const FieldDef fieldDefs[] = {
- // The affinity of these fields are TEXT so SQLite should give us strings, not ints or doubles.
- FieldDef("char(20)", QVariant::String, QString("123")),
- FieldDef("varchar(20)", QVariant::String, QString("123.4")),
- FieldDef("clob", QVariant::String, QString("123.45")),
- FieldDef("text", QVariant::String, QString("123.456")),
-
- FieldDef("integer", QVariant::Int, QVariant(13)),
- FieldDef("int", QVariant::Int, QVariant(12)),
- FieldDef("real", QVariant::String, QVariant(1.234567890123456)),
-
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-}
-
-void tst_QSqlDatabase::recordSQLServer()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (!tst_Databases::isSqlServer(db)) {
- QSKIP("SQL server specific test", SkipSingle);
- return;
- }
-
- // ### TODO: Add the rest of the fields
- static const FieldDef fieldDefs[] = {
- FieldDef("varchar(20)", QVariant::String, QString("Blah1")),
- FieldDef("bigint", QVariant::LongLong, 12345),
- FieldDef("int", QVariant::Int, 123456),
- FieldDef("tinyint", QVariant::UInt, 255),
- FieldDef("float", QVariant::Double, 1.12345),
- FieldDef("numeric(5,2)", QVariant::Double, 123.45),
- FieldDef("uniqueidentifier", QVariant::String,
- QString("AA7DF450-F119-11CD-8465-00AA00425D90")),
-
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-}
-
-void tst_QSqlDatabase::recordAccess()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (!tst_Databases::isMSAccess(db)) {
- QSKIP("MS Access specific test", SkipSingle);
- return;
- }
-
- QString memo;
- for (int i = 0; i < 32; i++)
- memo.append("ABCDEFGH12345678abcdefgh12345678");
-
- // ### TODO: Add the rest of the fields
- static const FieldDef fieldDefs[] = {
- FieldDef("varchar(20)", QVariant::String, QString("Blah1")),
- FieldDef("single", QVariant::Double, 1.12345),
- FieldDef("double", QVariant::Double, 1.123456),
- FieldDef("byte", QVariant::UInt, 255),
- FieldDef("long", QVariant::Int, 2147483647),
- FieldDef("memo", QVariant::String, memo),
- FieldDef()
- };
-
- const int fieldCount = createFieldTable(fieldDefs, db);
- QVERIFY(fieldCount > 0);
-
- commonFieldTest(fieldDefs, db, fieldCount);
-}
-
-void tst_QSqlDatabase::transaction()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- const QString qtest(qTableName("qtest", __FILE__));
-
- if (!db.driver()->hasFeature(QSqlDriver::Transactions)) {
- QSKIP("DBMS not transaction capable", SkipSingle);
- }
-
- QVERIFY(db.transaction());
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec("insert into " + qtest + " values (40, 'VarChar40', 'Char40', 40.40)"));
- QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 40"));
- QVERIFY(q.next());
- QCOMPARE(q.value(0).toInt(), 40);
- q.clear();
-
- QVERIFY(db.commit());
-
- QVERIFY(db.transaction());
- QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 40"));
- QVERIFY(q.next());
- QCOMPARE(q.value(0).toInt(), 40);
- q.clear();
- QVERIFY(db.commit());
-
- QVERIFY(db.transaction());
- QVERIFY_SQL(q, exec("insert into " + qtest + " values (41, 'VarChar41', 'Char41', 41.41)"));
- QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 41"));
- QVERIFY(q.next());
- QCOMPARE(q.value(0).toInt(), 41);
- q.clear(); // for SQLite which does not allow any references on rows that shall be rolled back
- if (!db.rollback()) {
- if (db.driverName().startsWith("QMYSQL")) {
- qDebug("MySQL: %s", qPrintable(tst_Databases::printError(db.lastError())));
- QSKIP("MySQL transaction failed ", SkipSingle); //non-fatal
- } else {
- QFAIL("Could not rollback transaction: " + tst_Databases::printError(db.lastError()));
- }
- }
-
- QVERIFY_SQL(q, exec("select * from " + qtest + " where id = 41"));
- if(db.driverName().startsWith("QODBC") && dbName.contains("MySQL"))
- QEXPECT_FAIL("", "Some odbc drivers don't actually roll back despite telling us they do, especially the mysql driver", Continue);
- QVERIFY(!q.next());
-
- populateTestTables(db);
-}
-
-void tst_QSqlDatabase::bigIntField()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- QString drvName = db.driverName();
- const QString qtest_bigint(qTableName("qtest_bigint", __FILE__));
-
- QSqlQuery q(db);
- q.setForwardOnly(true);
- if (drvName.startsWith("QOCI"))
- q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64);
-
- if (drvName.startsWith("QMYSQL")) {
- QVERIFY_SQL(q, exec("create table " + qtest_bigint + " (id int, t_s64bit bigint, t_u64bit bigint unsigned)"));
- } else if (drvName.startsWith("QPSQL")
- || drvName.startsWith("QDB2")
- || tst_Databases::isSqlServer(db)) {
- QVERIFY_SQL(q, exec("create table " + qtest_bigint + "(id int, t_s64bit bigint, t_u64bit bigint)"));
- } else if (drvName.startsWith("QOCI")) {
- QVERIFY_SQL(q, exec("create table " + qtest_bigint + " (id int, t_s64bit int, t_u64bit int)"));
- //} else if (drvName.startsWith("QIBASE")) {
- // QVERIFY_SQL(q, exec("create table " + qtest_bigint + " (id int, t_s64bit int64, t_u64bit int64)"));
- } else {
- QSKIP("no 64 bit integer support", SkipAll);
- }
- QVERIFY(q.prepare("insert into " + qtest_bigint + " values (?, ?, ?)"));
- qlonglong ll = Q_INT64_C(9223372036854775807);
- qulonglong ull = Q_UINT64_C(18446744073709551615);
-
- if (drvName.startsWith("QMYSQL") || drvName.startsWith("QOCI")) {
- q.bindValue(0, 0);
- q.bindValue(1, ll);
- q.bindValue(2, ull);
- QVERIFY_SQL(q, exec());
- q.bindValue(0, 1);
- q.bindValue(1, -ll);
- q.bindValue(2, ull);
- QVERIFY_SQL(q, exec());
- } else {
- // usinged bigint fields not supported - a cast is necessary
- q.bindValue(0, 0);
- q.bindValue(1, ll);
- q.bindValue(2, (qlonglong) ull);
- QVERIFY_SQL(q, exec());
- q.bindValue(0, 1);
- q.bindValue(1, -ll);
- q.bindValue(2, (qlonglong) ull);
- QVERIFY_SQL(q, exec());
- }
- QVERIFY(q.exec("select * from " + qtest_bigint + " order by id"));
- QVERIFY(q.next());
- QCOMPARE(q.value(1).toDouble(), (double)ll);
- QCOMPARE(q.value(1).toLongLong(), ll);
- if(drvName.startsWith("QOCI"))
- QEXPECT_FAIL("", "Oracle driver lacks support for unsigned int64 types", Continue);
- QCOMPARE(q.value(2).toULongLong(), ull);
- QVERIFY(q.next());
- QCOMPARE(q.value(1).toLongLong(), -ll);
- if(drvName.startsWith("QOCI"))
- QEXPECT_FAIL("", "Oracle driver lacks support for unsigned int64 types", Continue);
- QCOMPARE(q.value(2).toULongLong(), ull);
-}
-
-void tst_QSqlDatabase::caseSensivity()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- bool cs = false;
- if (db.driverName().startsWith("QMYSQL")
- || db.driverName().startsWith("QSQLITE")
- || db.driverName().startsWith("QTDS")
- || db.driverName().startsWith("QODBC"))
- cs = true;
-
- QSqlRecord rec = db.record(qTableName("qtest", __FILE__));
- QVERIFY((int)rec.count() > 0);
- if (!cs) {
- rec = db.record(qTableName("QTEST", __FILE__).toUpper());
- QVERIFY((int)rec.count() > 0);
- rec = db.record(qTableName("qTesT", __FILE__));
- QVERIFY((int)rec.count() > 0);
- }
-
- rec = db.primaryIndex(qTableName("qtest", __FILE__));
- QVERIFY((int)rec.count() > 0);
- if (!cs) {
- rec = db.primaryIndex(qTableName("QTEST", __FILE__).toUpper());
- QVERIFY((int)rec.count() > 0);
- rec = db.primaryIndex(qTableName("qTesT", __FILE__));
- QVERIFY((int)rec.count() > 0);
- }
-}
-
-void tst_QSqlDatabase::noEscapedFieldNamesInRecord()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QString fieldname("t_varchar");
- if (db.driverName().startsWith("QOCI") || db.driverName().startsWith("QIBASE") || db.driverName().startsWith("QDB2"))
- fieldname = fieldname.toUpper();
-
- QSqlQuery q(db);
- QString query = "SELECT " + db.driver()->escapeIdentifier(fieldname, QSqlDriver::FieldName) + " FROM " + qTableName("qtest", __FILE__);
- QVERIFY_SQL(q, exec(query));
- QCOMPARE(q.record().fieldName(0), fieldname);
-}
-
-void tst_QSqlDatabase::psql_schemas()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (!db.tables(QSql::SystemTables).contains("pg_namespace"))
- QSKIP("server does not support schemas", SkipSingle);
-
- QSqlQuery q(db);
-
- if(tst_Databases::isPostgreSQL(db)) {
- QVERIFY_SQL( q, exec("set client_min_messages='warning'"));
- }
-
- QVERIFY_SQL(q, exec("CREATE SCHEMA " + qTableName("qtestschema", __FILE__)));
-
- QString table = qTableName("qtestschema", __FILE__) + '.' + qTableName("qtesttable", __FILE__);
- QVERIFY_SQL(q, exec("CREATE TABLE " + table + " (id int primary key, name varchar(20))"));
-
- QVERIFY(db.tables().contains(table));
-
- QSqlRecord rec = db.record(table);
- QCOMPARE(rec.count(), 2);
- QCOMPARE(rec.fieldName(0), QString("id"));
- QCOMPARE(rec.fieldName(1), QString("name"));
-
- QSqlIndex idx = db.primaryIndex(table);
- QCOMPARE(idx.count(), 1);
- QCOMPARE(idx.fieldName(0), QString("id"));
-}
-
-void tst_QSqlDatabase::psql_escapedIdentifiers()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- QSqlDriver* drv = db.driver();
- CHECK_DATABASE(db);
-
- if (!db.tables(QSql::SystemTables).contains("pg_namespace"))
- QSKIP("server does not support schemas", SkipSingle);
-
- QSqlQuery q(db);
-
- if(tst_Databases::isPostgreSQL(db))
- QVERIFY_SQL( q, exec("set client_min_messages='warning'"));
-
- const QString schemaName(qTableName("qtestScHeMa", __FILE__)),
- tableName(qTableName("qtest", __FILE__)),
- field1Name(QLatin1String("fIeLdNaMe")),
- field2Name(QLatin1String("ZuLu"));
-
- q.exec(QString("DROP SCHEMA \"%1\" CASCADE").arg(schemaName));
- QString createSchema = QString("CREATE SCHEMA \"%1\"").arg(schemaName);
- QVERIFY_SQL(q, exec(createSchema));
- QString createTable = QString("CREATE TABLE \"%1\".\"%2\" (\"%3\" int PRIMARY KEY, \"%4\" varchar(20))").arg(schemaName).arg(tableName).arg(field1Name).arg(field2Name);
- QVERIFY_SQL(q, exec(createTable));
-
- QVERIFY(db.tables().contains(schemaName + '.' + tableName, Qt::CaseSensitive));
-
- QSqlField fld1(field1Name, QVariant::Int);
- QSqlField fld2(field2Name, QVariant::String);
- QSqlRecord rec;
- rec.append(fld1);
- rec.append(fld2);
-
- QVERIFY_SQL(q, exec(drv->sqlStatement(QSqlDriver::SelectStatement, db.driver()->escapeIdentifier(schemaName, QSqlDriver::TableName) + '.' + db.driver()->escapeIdentifier(tableName, QSqlDriver::TableName), rec, false)));
-
- rec = q.record();
- QCOMPARE(rec.count(), 2);
- QCOMPARE(rec.fieldName(0), field1Name);
- QCOMPARE(rec.fieldName(1), field2Name);
- QCOMPARE(rec.field(0).type(), QVariant::Int);
-
- q.exec(QString("DROP SCHEMA \"%1\" CASCADE").arg(schemaName));
-}
-
-void tst_QSqlDatabase::psql_escapeBytea()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const char dta[4] = {'\x71', '\x14', '\x32', '\x81'};
- QByteArray ba(dta, 4);
-
- QSqlQuery q(db);
- const QString tableName(qTableName("batable", __FILE__));
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (ba bytea)").arg(tableName)));
-
- QSqlQuery iq(db);
- QVERIFY_SQL(iq, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName)));
- iq.bindValue(0, QVariant(ba));
- QVERIFY_SQL(iq, exec());
-
- QVERIFY_SQL(q, exec(QString("SELECT ba FROM %1").arg(tableName)));
- QVERIFY_SQL(q, next());
-
- QByteArray res = q.value(0).toByteArray();
- int i = 0;
- for (; i < ba.size(); ++i){
- if (ba[i] != res[i])
- break;
- }
-
- QCOMPARE(i, 4);
-}
-
-void tst_QSqlDatabase::bug_249059()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QString version=tst_Databases::getPSQLVersion( db );
- double ver=version.section(QChar::fromLatin1('.'),0,1).toDouble();
- if (ver < 7.3)
- QSKIP("Test requires PostgreSQL >= 7.3", SkipSingle);
-
- QSqlQuery q(db);
- const QString tableName(qTableName("bug_249059", __FILE__));
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (dt timestamp, t time)").arg(tableName)));
-
- QSqlQuery iq(db);
- QVERIFY_SQL(iq, prepare(QString("INSERT INTO %1 VALUES (?, ?)").arg(tableName)));
- iq.bindValue(0, QVariant(QString("2001-09-09 04:05:06.789 -5:00")));
- iq.bindValue(1, QVariant(QString("04:05:06.789 -5:00")));
- QVERIFY_SQL(iq, exec());
- iq.bindValue(0, QVariant(QString("2001-09-09 04:05:06.789 +5:00")));
- iq.bindValue(1, QVariant(QString("04:05:06.789 +5:00")));
- QVERIFY_SQL(iq, exec());
-
- QVERIFY_SQL(q, exec(QString("SELECT dt, t FROM %1").arg(tableName)));
- QVERIFY_SQL(q, next());
- QDateTime dt1=q.value(0).toDateTime();
- QTime t1=q.value(1).toTime();
- QVERIFY_SQL(q, next());
- QDateTime dt2=q.value(0).toDateTime();
- QTime t2=q.value(1).toTime();
-
- // 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
- QCOMPARE(dt1, dt2);
- QCOMPARE(t1, t2);
-}
-
-// This test should be rewritten to work with Oracle as well - or the Oracle driver
-// should be fixed to make this test pass (handle overflows)
-void tst_QSqlDatabase::precisionPolicy()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-// DBMS_SPECIFIC(db, "QPSQL");
-
- QSqlQuery q(db);
- const QString tableName(qTableName("qtest_prec", __FILE__));
- if(!db.driver()->hasFeature(QSqlDriver::LowPrecisionNumbers))
- QSKIP("Driver or database doesn't support setting precision policy", SkipSingle);
-
- // Create a test table with some data
- if(tst_Databases::isMSAccess(db))
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (id smallint, num number)").arg(tableName)));
- else
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (id smallint, num numeric(18,5))").arg(tableName)));
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?, ?)").arg(tableName)));
- q.bindValue(0, 1);
- q.bindValue(1, 123);
- QVERIFY_SQL(q, exec());
- q.bindValue(0, 2);
- q.bindValue(1, 1850000000000.0001);
- QVERIFY_SQL(q, exec());
-
- // These are expected to pass
- q.setNumericalPrecisionPolicy(QSql::HighPrecision);
- QString query = QString("SELECT num FROM %1 WHERE id = 1").arg(tableName);
- QVERIFY_SQL(q, exec(query));
- QVERIFY_SQL(q, next());
- if(db.driverName().startsWith("QSQLITE"))
- QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue);
- QCOMPARE(q.value(0).type(), QVariant::String);
-
- q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64);
- QVERIFY_SQL(q, exec(query));
- QVERIFY_SQL(q, next());
- if(q.value(0).type() != QVariant::LongLong)
- QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue);
- QCOMPARE(q.value(0).type(), QVariant::LongLong);
- QCOMPARE(q.value(0).toLongLong(), (qlonglong)123);
-
- q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt32);
- QVERIFY_SQL(q, exec(query));
- if(db.driverName().startsWith("QOCI"))
- QEXPECT_FAIL("", "Oracle fails to move to next when data columns are oversize", Abort);
- QVERIFY_SQL(q, next());
- if(db.driverName().startsWith("QSQLITE"))
- QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue);
- QCOMPARE(q.value(0).type(), QVariant::Int);
- QCOMPARE(q.value(0).toInt(), 123);
-
- q.setNumericalPrecisionPolicy(QSql::LowPrecisionDouble);
- QVERIFY_SQL(q, exec(query));
- QVERIFY_SQL(q, next());
- if(db.driverName().startsWith("QSQLITE"))
- QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue);
- QCOMPARE(q.value(0).type(), QVariant::Double);
- QCOMPARE(q.value(0).toDouble(), (double)123);
-
- query = QString("SELECT num FROM %1 WHERE id = 2").arg(tableName);
- QVERIFY_SQL(q, exec(query));
- QVERIFY_SQL(q, next());
- if(db.driverName().startsWith("QSQLITE"))
- QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue);
- QCOMPARE(q.value(0).type(), QVariant::Double);
- QCOMPARE(q.value(0).toDouble(), QString("1850000000000.0001").toDouble());
-
- // Postgres returns invalid QVariants on overflow
- q.setNumericalPrecisionPolicy(QSql::HighPrecision);
- QVERIFY_SQL(q, exec(query));
- QVERIFY_SQL(q, next());
- if(db.driverName().startsWith("QSQLITE"))
- QEXPECT_FAIL("", "SQLite returns this value as determined by contents of the field, not the declaration", Continue);
- QCOMPARE(q.value(0).type(), QVariant::String);
-
- q.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64);
- QEXPECT_FAIL("QOCI", "Oracle fails here, to retrieve next", Continue);
- QVERIFY_SQL(q, exec(query));
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).type(), QVariant::LongLong);
-
- QSql::NumericalPrecisionPolicy oldPrecision= db.numericalPrecisionPolicy();
- db.setNumericalPrecisionPolicy(QSql::LowPrecisionInt64);
- QSqlQuery q2(db);
- q2.exec(QString("SELECT num FROM %1 WHERE id = 2").arg(tableName));
- QVERIFY_SQL(q2, exec(query));
- QVERIFY_SQL(q2, next());
- QCOMPARE(q2.value(0).type(), QVariant::LongLong);
- db.setNumericalPrecisionPolicy(oldPrecision);
-}
-
-// This test needs a ODBC data source containing MYSQL in it's name
-void tst_QSqlDatabase::mysqlOdbc_unsignedIntegers()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (!db.driverName().startsWith("QODBC") || !dbName.toUpper().contains("MYSQL")) {
- QSKIP("MySQL through ODBC-driver specific test", SkipSingle);
- return;
- }
-
- QSqlQuery q(db);
- const QString tableName(qTableName("uint", __FILE__));
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (foo integer(10) unsigned, bar integer(10))").arg(tableName)));
- QVERIFY_SQL(q, exec(QString("INSERT INTO %1 VALUES (-4000000000, -4000000000)").arg(tableName)));
- QVERIFY_SQL(q, exec(QString("INSERT INTO %1 VALUES (4000000000, 4000000000)").arg(tableName)));
-
- QVERIFY_SQL(q, exec(QString("SELECT foo, bar FROM %1").arg(tableName)));
- QVERIFY(q.next());
- QCOMPARE(q.value(0).toString(), QString("0"));
- QCOMPARE(q.value(1).toString(), QString("-2147483648"));
- QVERIFY(q.next());
- QCOMPARE(q.value(0).toString(), QString("4000000000"));
- QCOMPARE(q.value(1).toString(), QString("2147483647"));
-}
-
-void tst_QSqlDatabase::accessOdbc_strings()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (!tst_Databases::isMSAccess(db)) {
- QSKIP("MS Access specific test", SkipSingle);
- return;
- }
-
- QSqlQuery q(db);
- const QString tableName(qTableName("strings", __FILE__));
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (aStr memo, bStr memo, cStr memo, dStr memo"
- ", eStr memo, fStr memo, gStr memo, hStr memo)").arg(tableName)));
-
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?, ?, ?, ?, ?, ?, ?, ?)").arg(tableName)));
- QString aStr, bStr, cStr, dStr, eStr, fStr, gStr, hStr;
-
- q.bindValue(0, aStr.fill('A', 32));
- q.bindValue(1, bStr.fill('B', 127));
- q.bindValue(2, cStr.fill('C', 128));
- q.bindValue(3, dStr.fill('D', 129));
- q.bindValue(4, eStr.fill('E', 254));
- q.bindValue(5, fStr.fill('F', 255));
- q.bindValue(6, gStr.fill('G', 256));
- q.bindValue(7, hStr.fill('H', 512));
-
- QVERIFY_SQL(q, exec());
-
- QVERIFY_SQL(q, exec(QString("SELECT aStr, bStr, cStr, dStr, eStr, fStr, gStr, hStr FROM %1").arg(tableName)));
- q.next();
- QCOMPARE(q.value(0).toString(), aStr);
- QCOMPARE(q.value(1).toString(), bStr);
- QCOMPARE(q.value(2).toString(), cStr);
- QCOMPARE(q.value(3).toString(), dStr);
- QCOMPARE(q.value(4).toString(), eStr);
- QCOMPARE(q.value(5).toString(), fStr);
- QCOMPARE(q.value(6).toString(), gStr);
- QCOMPARE(q.value(7).toString(), hStr);
-}
-
-// For task 125053
-void tst_QSqlDatabase::ibase_numericFields()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QSqlQuery q(db);
- const QString tableName(qTableName("numericfields", __FILE__));
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (id int not null, num1 NUMERIC(2,1), "
- "num2 NUMERIC(5,2), num3 NUMERIC(10,3), "
- "num4 NUMERIC(18,4))").arg(tableName)));
-
- QVERIFY_SQL(q, exec(QString("INSERT INTO %1 VALUES (1, 1.1, 123.45, 1234567.123, 10203040506070.8090)").arg(tableName)));
-
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?, ?, ?, ?, ?)").arg(tableName)));
-
- double num1 = 1.1;
- double num2 = 123.45;
- double num3 = 1234567.123;
- double num4 = 10203040506070.8090;
-
- q.bindValue(0, 2);
- q.bindValue(1, QVariant(num1));
- q.bindValue(2, QVariant(num2));
- q.bindValue(3, QVariant(num3));
- q.bindValue(4, QVariant(num4));
- QVERIFY_SQL(q, exec());
-
- QVERIFY_SQL(q, exec(QString("SELECT id, num1, num2, num3, num4 FROM %1").arg(tableName)));
-
- int id = 0;
- while (q.next()) {
- QCOMPARE(q.value(0).toInt(), ++id);
- QCOMPARE(q.value(1).toString(), QString("%1").arg(num1));
- QCOMPARE(q.value(2).toString(), QString("%1").arg(num2));
- QCOMPARE(QString("%1").arg(q.value(3).toDouble()), QString("%1").arg(num3));
- QCOMPARE(QString("%1").arg(q.value(4).toDouble()), QString("%1").arg(num4));
- QVERIFY(q.value(0).type() == QVariant::Int);
- QVERIFY(q.value(1).type() == QVariant::Double);
- QVERIFY(q.value(2).type() == QVariant::Double);
- QVERIFY(q.value(3).type() == QVariant::Double);
- QVERIFY(q.value(4).type() == QVariant::Double);
-
- QCOMPARE(q.record().field(1).length(), 2);
- QCOMPARE(q.record().field(1).precision(), 1);
- QCOMPARE(q.record().field(2).length(), 5);
- QCOMPARE(q.record().field(2).precision(), 2);
- QCOMPARE(q.record().field(3).length(), 10);
- QCOMPARE(q.record().field(3).precision(), 3);
- QCOMPARE(q.record().field(4).length(), 18);
- QCOMPARE(q.record().field(4).precision(), 4);
- QVERIFY(q.record().field(0).requiredStatus() == QSqlField::Required);
- QVERIFY(q.record().field(1).requiredStatus() == QSqlField::Optional);
- }
-
- QSqlRecord r = db.record(tableName);
- QVERIFY(r.field(0).type() == QVariant::Int);
- QVERIFY(r.field(1).type() == QVariant::Double);
- QVERIFY(r.field(2).type() == QVariant::Double);
- QVERIFY(r.field(3).type() == QVariant::Double);
- QVERIFY(r.field(4).type() == QVariant::Double);
- QCOMPARE(r.field(1).length(), 2);
- QCOMPARE(r.field(1).precision(), 1);
- QCOMPARE(r.field(2).length(), 5);
- QCOMPARE(r.field(2).precision(), 2);
- QCOMPARE(r.field(3).length(), 10);
- QCOMPARE(r.field(3).precision(), 3);
- QCOMPARE(r.field(4).length(), 18);
- QCOMPARE(r.field(4).precision(), 4);
- QVERIFY(r.field(0).requiredStatus() == QSqlField::Required);
- QVERIFY(r.field(1).requiredStatus() == QSqlField::Optional);
-}
-
-void tst_QSqlDatabase::ibase_fetchBlobs()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const QString tableName(qTableName("qtest_ibaseblobs", __FILE__));
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1 (blob1 BLOB segment size 256)").arg(tableName)));
-
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName)));
- q.bindValue(0, QByteArray().fill('x', 1024));
- QVERIFY_SQL(q, exec());
-
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName)));
- q.bindValue(0, QByteArray().fill('x', 16383));
- QVERIFY_SQL(q, exec());
-
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES (?)").arg(tableName)));
- q.bindValue(0, QByteArray().fill('x', 17408));
- QVERIFY_SQL(q, exec());
-
- QVERIFY_SQL(q, exec(QString("SELECT * FROM %1").arg(tableName)));
-
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toByteArray().size(), 1024);
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toByteArray().size(), 16383);
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toByteArray().size(), 17408);
-}
-
-void tst_QSqlDatabase::ibase_procWithoutReturnValues()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QSqlQuery q(db);
- const QString procName(qTableName("qtest_proc1", __FILE__));
- q.exec(QString("drop procedure %1").arg(procName));
- QVERIFY_SQL(q, exec("CREATE PROCEDURE " + procName + " (str VARCHAR(10))\nAS BEGIN\nstr='test';\nEND;"));
- QVERIFY_SQL(q, exec(QString("execute procedure %1('qtest')").arg(procName)));
- q.exec(QString("drop procedure %1").arg(procName));
-}
-
-void tst_QSqlDatabase::ibase_procWithReturnValues()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (!db.driverName().startsWith("QIBASE")) {
- QSKIP("InterBase specific test", SkipSingle);
- return;
- }
-
- const QString procName(qTableName("qtest_proc2", __FILE__));
-
- QSqlQuery q(db);
- q.exec(QString("drop procedure %1").arg(procName));
- QVERIFY_SQL(q, exec("CREATE PROCEDURE " + procName + " ("
- "\nABC INTEGER)"
- "\nRETURNS ("
- "\nRESULT INTEGER)"
- "\nAS"
- "\nbegin"
- "\nRESULT = 10 * ABC;"
- "\nsuspend;"
- "\nend"));
-
- // Interbase procedures can be executed in two ways: EXECUTE PROCEDURE or SELECT
- QVERIFY_SQL(q, exec(QString("execute procedure %1(123)").arg(procName)));
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 1230);
- QVERIFY_SQL(q, exec(QString("select result from %1(456)").arg(procName)));
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 4560);
- QVERIFY_SQL(q, prepare(QLatin1String("execute procedure ")+procName+QLatin1String("(?)")));
- q.bindValue(0, 123);
- QVERIFY_SQL(q, exec());
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 1230);
- q.bindValue(0, 456);
- QVERIFY_SQL(q, exec());
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 4560);
-
- q.exec(QString("drop procedure %1").arg(procName));
-}
-
-void tst_QSqlDatabase::formatValueTrimStrings()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QSqlQuery q(db);
-
- QVERIFY_SQL(q, exec(QString("INSERT INTO %1 (id, t_varchar, t_char) values (50, 'Trim Test ', 'Trim Test 2 ')").arg(qTableName("qtest", __FILE__))));
- QVERIFY_SQL(q, exec(QString("INSERT INTO %1 (id, t_varchar, t_char) values (51, 'TrimTest', 'Trim Test 2')").arg(qTableName("qtest", __FILE__))));
- QVERIFY_SQL(q, exec(QString("INSERT INTO %1 (id, t_varchar, t_char) values (52, ' ', ' ')").arg(qTableName("qtest", __FILE__))));
-
- 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__))));
-
- QVERIFY_SQL(q, next());
-
- QCOMPARE(db.driver()->formatValue(q.record().field(0), true), QString("'Trim Test'"));
- QCOMPARE(db.driver()->formatValue(q.record().field(1), true), QString("'Trim Test 2'"));
-
- QVERIFY_SQL(q, next());
- QCOMPARE(db.driver()->formatValue(q.record().field(0), true), QString("'TrimTest'"));
- QCOMPARE(db.driver()->formatValue(q.record().field(1), true), QString("'Trim Test 2'"));
-
- QVERIFY_SQL(q, next());
- QCOMPARE(db.driver()->formatValue(q.record().field(0), true), QString("''"));
- QCOMPARE(db.driver()->formatValue(q.record().field(1), true), QString("''"));
-
-}
-
-void tst_QSqlDatabase::odbc_reopenDatabase()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec("SELECT * from " + qTableName("qtest", __FILE__)));
- QVERIFY_SQL(q, next());
- db.open();
- QVERIFY_SQL(q, exec("SELECT * from " + qTableName("qtest", __FILE__)));
- QVERIFY_SQL(q, next());
- db.open();
-}
-
-void tst_QSqlDatabase::odbc_bindBoolean()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- if (tst_Databases::isMySQL(db)) {
- QSKIP("MySql has inconsistent behaviour of bit field type across versions.", SkipSingle);
- return;
- }
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec("CREATE TABLE " + qTableName("qtestBindBool", __FILE__) + "(id int, boolvalue bit)"));
-
- // Bind and insert
- QVERIFY_SQL(q, prepare("INSERT INTO " + qTableName("qtestBindBool", __FILE__) + " VALUES(?, ?)"));
- q.bindValue(0, 1);
- q.bindValue(1, true);
- QVERIFY_SQL(q, exec());
- q.bindValue(0, 2);
- q.bindValue(1, false);
- QVERIFY_SQL(q, exec());
-
- // Retrive
- QVERIFY_SQL(q, exec("SELECT id, boolvalue FROM " + qTableName("qtestBindBool", __FILE__) + " ORDER BY id"));
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 1);
- QCOMPARE(q.value(1).toBool(), true);
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 2);
- QCOMPARE(q.value(1).toBool(), false);
-}
-
-void tst_QSqlDatabase::odbc_testqGetString()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- const QString testqGetString(qTableName("testqGetString", __FILE__));
-
- QSqlQuery q(db);
- if (tst_Databases::isSqlServer(db))
- QVERIFY_SQL(q, exec("CREATE TABLE " + testqGetString + "(id int, vcvalue varchar(MAX))"));
- else if(tst_Databases::isMSAccess(db))
- QVERIFY_SQL(q, exec("CREATE TABLE " + testqGetString + "(id int, vcvalue memo)"));
- else
- QVERIFY_SQL(q, exec("CREATE TABLE " + testqGetString + "(id int, vcvalue varchar(65538))"));
-
- QString largeString;
- largeString.fill('A', 65536);
-
- // Bind and insert
- QVERIFY_SQL(q, prepare("INSERT INTO " + testqGetString + " VALUES(?, ?)"));
- q.bindValue(0, 1);
- q.bindValue(1, largeString);
- QVERIFY_SQL(q, exec());
- q.bindValue(0, 2);
- q.bindValue(1, largeString+QLatin1Char('B'));
- QVERIFY_SQL(q, exec());
- q.bindValue(0, 3);
- q.bindValue(1, largeString+QLatin1Char('B')+QLatin1Char('C'));
- QVERIFY_SQL(q, exec());
-
- // Retrive
- QVERIFY_SQL(q, exec("SELECT id, vcvalue FROM " + testqGetString + " ORDER BY id"));
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 1);
- QCOMPARE(q.value(1).toString().length(), 65536);
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 2);
- QCOMPARE(q.value(1).toString().length(), 65537);
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toInt(), 3);
- QCOMPARE(q.value(1).toString().length(), 65538);
-}
-
-
-void tst_QSqlDatabase::mysql_multiselect()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- const QString qtest(qTableName("qtest", __FILE__));
-
- QSqlQuery q(db);
- QString version=tst_Databases::getMySqlVersion( db );
- double ver=version.section(QChar::fromLatin1('.'),0,1).toDouble();
- if (ver < 4.1)
- QSKIP("Test requires MySQL >= 4.1", SkipSingle);
-
- QVERIFY_SQL(q, exec("SELECT * FROM " + qtest + "; SELECT * FROM " + qtest));
- QVERIFY_SQL(q, next());
- QVERIFY_SQL(q, exec("SELECT * FROM " + qtest + "; SELECT * FROM " + qtest));
- QVERIFY_SQL(q, next());
- QVERIFY_SQL(q, exec("SELECT * FROM " + qtest));
-}
-
-void tst_QSqlDatabase::ibase_useCustomCharset()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- QString nonlatin1string("��");
-
- db.close();
- db.setConnectOptions("ISC_DPB_LC_CTYPE=Latin1");
- db.open();
-
- const QString tableName(qTableName("latin1table", __FILE__));
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(text VARCHAR(6) CHARACTER SET Latin1)").arg(tableName)));
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName)));
- q.addBindValue(nonlatin1string);
- QVERIFY_SQL(q, exec());
- QVERIFY_SQL(q, exec(QString("SELECT text FROM %1").arg(tableName)));
- QVERIFY_SQL(q, next());
- QCOMPARE(toHex(q.value(0).toString()), toHex(nonlatin1string));
-}
-
-void tst_QSqlDatabase::oci_serverDetach()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- for (int i = 0; i < 2; i++) {
- db.close();
- if (db.open()) {
- QSqlQuery query(db);
- query.exec("SELECT 1 FROM DUAL");
- db.close();
- } else {
- QFAIL(tst_Databases::printError(db.lastError(), db));
- }
- }
- if(!db.open())
- qFatal("%s", qPrintable(tst_Databases::printError(db.lastError(), db)));
-}
-
-void tst_QSqlDatabase::oci_xmltypeSupport()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const QString tableName(qTableName("qtest_xmltype", __FILE__));
- QString xml("<?xml version=\"1.0\"?><TABLE_NAME>MY_TABLE</TABLE_NAME>");
- QSqlQuery q(db);
-
- // Embedding the XML in the statement
- if(!q.exec(QString("CREATE TABLE %1(xmldata xmltype)").arg(tableName)))
- QSKIP("This test requries xml type support", SkipSingle);
- QVERIFY_SQL(q, exec(QString("INSERT INTO %1 values('%2')").arg(tableName).arg(xml)));
- QVERIFY_SQL(q, exec(QString("SELECT a.xmldata.getStringVal() FROM %1 a").arg(tableName)));
- QVERIFY_SQL(q, last());
- QCOMPARE(q.value(0).toString(), xml);
-
- // Binding the XML with a prepared statement
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 values(?)").arg(tableName)));
- q.addBindValue(xml);
- QVERIFY_SQL(q, exec());
- QVERIFY_SQL(q, exec(QString("SELECT a.xmldata.getStringVal() FROM %1 a").arg(tableName)));
- QVERIFY_SQL(q, last());
- QCOMPARE(q.value(0).toString(), xml);
-}
-
-
-void tst_QSqlDatabase::oci_fieldLength()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const QString tableName(qTableName("qtest", __FILE__));
- QSqlQuery q(db);
-
- QVERIFY_SQL(q, exec(QString("SELECT t_varchar, t_char FROM %1").arg(tableName)));
- QVERIFY_SQL(q, next());
- QCOMPARE(q.record().field(0).length(), 40);
- QCOMPARE(q.record().field(1).length(), 40);
-}
-
-void tst_QSqlDatabase::oci_synonymstest()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QSqlQuery q(db);
- const QString creator(qTableName("CREATOR", __FILE__)), appuser(qTableName("APPUSER", __FILE__)), table1(qTableName("TABLE1", __FILE__));
-// QVERIFY_SQL(q, exec("drop public synonym "+table1));
- QVERIFY_SQL(q, exec(QString("create user %1 identified by %2 default tablespace users temporary tablespace temp").arg(creator).arg(creator)));
- QVERIFY_SQL(q, exec(QString("grant CONNECT to %1").arg(creator)));
- QVERIFY_SQL(q, exec(QString("grant RESOURCE to %1").arg(creator)));
- QSqlDatabase db2=db.cloneDatabase(db, QLatin1String("oci_synonymstest"));
- db2.close();
- QVERIFY_SQL(db2, open(creator,creator));
- QSqlQuery q2(db2);
- QVERIFY_SQL(q2, exec(QString("create table %1(id int primary key)").arg(table1)));
- QVERIFY_SQL(q, exec(QString("create user %1 identified by %2 default tablespace users temporary tablespace temp").arg(appuser).arg(appuser)));
- QVERIFY_SQL(q, exec(QString("grant CREATE ANY SYNONYM to %1").arg(appuser)));
- QVERIFY_SQL(q, exec(QString("grant CONNECT to %1").arg(appuser)));
- QVERIFY_SQL(q2, exec(QString("grant select, insert, update, delete on %1 to %2").arg(table1).arg(appuser)));
- QSqlDatabase db3=db.cloneDatabase(db, QLatin1String("oci_synonymstest2"));
- db3.close();
- QVERIFY_SQL(db3, open(appuser,appuser));
- QSqlQuery q3(db3);
- QVERIFY_SQL(q3, exec("create synonym "+appuser+'.'+qTableName("synonyms", __FILE__)+" for "+creator+'.'+table1));
- QVERIFY_SQL(db3, tables().filter(qTableName("synonyms", __FILE__), Qt::CaseInsensitive).count() >= 1);
-}
-
-
-// This test isn't really necessary as SQL_GUID / uniqueidentifier is
-// already tested in recordSQLServer().
-void tst_QSqlDatabase::odbc_uniqueidentifier()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- if (!tst_Databases::isSqlServer(db)) {
- QSKIP("SQL Server (ODBC) specific test", SkipSingle);
- return;
- }
-
- const QString tableName(qTableName("qtest_sqlguid", __FILE__));
- QString guid = QString("AAAAAAAA-BBBB-CCCC-DDDD-EEEEEEEEEEEE");
- QString invalidGuid = QString("GAAAAAAA-BBBB-CCCC-DDDD-EEEEEEEEEEEE");
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(id uniqueidentifier)").arg(tableName)));
-
- q.prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName));;
- q.addBindValue(guid);
- QVERIFY_SQL(q, exec());
-
- q.addBindValue(invalidGuid);
- QEXPECT_FAIL("", "The GUID string is required to be correctly formated!",
- Continue);
- QVERIFY_SQL(q, exec());
-
- QVERIFY_SQL(q, exec(QString("SELECT id FROM %1").arg(tableName)));
- QVERIFY_SQL(q, next());
- QCOMPARE(q.value(0).toString(), guid);
-}
-
-void tst_QSqlDatabase::getConnectionName()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QCOMPARE(db.connectionName(), dbName);
- QSqlDatabase clone = QSqlDatabase::cloneDatabase(db, "clonedDatabase");
- QCOMPARE(clone.connectionName(), QString("clonedDatabase"));
- QTest::ignoreMessage(QtWarningMsg, "QSqlDatabasePrivate::removeDatabase: "
- "connection 'clonedDatabase' is still in use, all queries will cease to work.");
- QSqlDatabase::removeDatabase("clonedDatabase");
- QCOMPARE(clone.connectionName(), QString());
- QCOMPARE(db.connectionName(), dbName);
-}
-
-void tst_QSqlDatabase::odbc_uintfield()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const QString tableName(qTableName("uint_table", __FILE__));
- unsigned int val = 4294967295U;
-
- QSqlQuery q(db);
- if ( tst_Databases::isMSAccess( db ) )
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(num number)").arg(tableName)));
- else
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(num numeric(10))").arg(tableName)));
- q.prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName));
- q.addBindValue(val);
- QVERIFY_SQL(q, exec());
-
- q.exec(QString("SELECT num FROM %1").arg(tableName));
- if (q.next())
- QCOMPARE(q.value(0).toUInt(), val);
-}
-
-void tst_QSqlDatabase::eventNotification()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- QSqlDriver *driver = db.driver();
- if (!driver->hasFeature(QSqlDriver::EventNotifications))
- QSKIP("DBMS doesn't support event notifications", SkipSingle);
-
- // Not subscribed to any events yet
- QCOMPARE(driver->subscribedToNotifications().size(), 0);
-
- // Subscribe to "event_foo"
- QVERIFY_SQL(*driver, subscribeToNotification(QLatin1String("event_foo")));
- QCOMPARE(driver->subscribedToNotifications().size(), 1);
- QVERIFY(driver->subscribedToNotifications().contains("event_foo"));
-
- // Can't subscribe to the same event multiple times
- QVERIFY2(!driver->subscribeToNotification(QLatin1String("event_foo")), "Shouldn't be able to subscribe to event_foo twice");
- QCOMPARE(driver->subscribedToNotifications().size(), 1);
-
- // Unsubscribe from "event_foo"
- QVERIFY_SQL(*driver, unsubscribeFromNotification(QLatin1String("event_foo")));
- QCOMPARE(driver->subscribedToNotifications().size(), 0);
-
- // Re-subscribing to "event_foo" now is allowed
- QVERIFY_SQL(*driver, subscribeToNotification(QLatin1String("event_foo")));
- QCOMPARE(driver->subscribedToNotifications().size(), 1);
-
- // closing the connection causes automatically unsubscription from all events
- db.close();
- QCOMPARE(driver->subscribedToNotifications().size(), 0);
-
- // Can't subscribe to anything while database is closed
- QVERIFY2(!driver->subscribeToNotification(QLatin1String("event_foo")), "Shouldn't be able to subscribe to event_foo");
- QCOMPARE(driver->subscribedToNotifications().size(), 0);
-
- db.open();
-}
-
-void tst_QSqlDatabase::eventNotificationIBase()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const QString procedureName(qTableName("posteventProc", __FILE__));
- QSqlDriver *driver=db.driver();
- QVERIFY_SQL(*driver, subscribeToNotification(procedureName));
- QTest::qWait(300); // Interbase needs some time to call the driver callback.
-
- db.transaction(); // InterBase events are posted from within transactions.
- QSqlQuery q(db);
- q.exec(QString("DROP PROCEDURE %1").arg(procedureName));
- q.exec(QString("CREATE PROCEDURE %1\nAS BEGIN\nPOST_EVENT '%1';\nEND;").arg(procedureName));
- q.exec(QString("EXECUTE PROCEDURE %1").arg(procedureName));
- QSignalSpy spy(driver, SIGNAL(notification(const QString&)));
- db.commit(); // No notifications are posted until the transaction is committed.
- QTest::qWait(300); // Interbase needs some time to post the notification and call the driver callback.
- // This happends from another thread, and we have to process events in order for the
- // event handler in the driver to be executed and emit the notification signal.
-
- QCOMPARE(spy.count(), 1);
- QList<QVariant> arguments = spy.takeFirst();
- QVERIFY(arguments.at(0).toString() == procedureName);
- QVERIFY_SQL(*driver, unsubscribeFromNotification(procedureName));
- q.exec(QString("DROP PROCEDURE %1").arg(procedureName));
-}
-
-void tst_QSqlDatabase::eventNotificationPSQL()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
-#if defined(Q_OS_LINUX)
- QSKIP( "Event support doesn't work on linux", SkipAll );
-#endif
-
- QSqlQuery query(db);
- QString procedureName = qTableName("posteventProc", __FILE__);
-
- QSqlDriver &driver=*(db.driver());
- QVERIFY_SQL(driver, subscribeToNotification(procedureName));
- QSignalSpy spy(db.driver(), SIGNAL(notification(const QString&)));
- query.exec(QString("NOTIFY \"%1\"").arg(procedureName));
- QCoreApplication::processEvents();
- QCOMPARE(spy.count(), 1);
- QList<QVariant> arguments = spy.takeFirst();
- QVERIFY(arguments.at(0).toString() == procedureName);
- QVERIFY_SQL(driver, unsubscribeFromNotification(procedureName));
-}
-
-void tst_QSqlDatabase::sqlite_bindAndFetchUInt()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- if (db.driverName().startsWith("QSQLITE2")) {
- QSKIP("SQLite3 specific test", SkipSingle);
- return;
- }
-
- QSqlQuery q(db);
- const QString tableName(qTableName("uint_test", __FILE__));
- QVERIFY_SQL(q, exec(QString("CREATE TABLE %1(uint_field UNSIGNED INTEGER)").arg(tableName)));
- QVERIFY_SQL(q, prepare(QString("INSERT INTO %1 VALUES(?)").arg(tableName)));
- q.addBindValue(4000000000U);
- QVERIFY_SQL(q, exec());
- QVERIFY_SQL(q, exec(QString("SELECT uint_field FROM %1").arg(tableName)));
- QVERIFY_SQL(q, next());
-
- // All integers in SQLite are signed, so even though we bound the value
- // as an UInt it will come back as a LongLong
- QCOMPARE(q.value(0).type(), QVariant::LongLong);
- QCOMPARE(q.value(0).toUInt(), 4000000000U);
-}
-
-void tst_QSqlDatabase::db2_valueCacheUpdate()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- const QString tableName(qTableName("qtest", __FILE__));
- QSqlQuery q(db);
- q.exec(QString("SELECT id, t_varchar, t_char, t_numeric FROM %1").arg(tableName));
- q.next();
- QVariant c4 = q.value(3);
- QVariant c3 = q.value(2);
- QVariant c2 = q.value(1);
- QVariant c1 = q.value(0);
- QCOMPARE(c4.toString(), q.value(3).toString());
- QCOMPARE(c3.toString(), q.value(2).toString());
- QCOMPARE(c2.toString(), q.value(1).toString());
- QCOMPARE(c1.toString(), q.value(0).toString());
-}
-
-void tst_QSqlDatabase::sqlStatementUseIsNull_189093()
-{
- // NULL = NULL is unknown, the sqlStatment must use IS NULL
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
-
- // select a record with NULL value
- QSqlQuery q(QString::null, db);
- QVERIFY_SQL(q, exec("select * from " + qTableName("qtest", __FILE__) + " where id = 4"));
- QVERIFY_SQL(q, next());
-
- QSqlDriver *driver = db.driver();
- QVERIFY(driver);
-
- QString preparedStatment = driver->sqlStatement(QSqlDriver::WhereStatement, QString("qtest"), q.record(), true);
- QCOMPARE(preparedStatment.count("IS NULL", Qt::CaseInsensitive), 2);
-
- QString statment = driver->sqlStatement(QSqlDriver::WhereStatement, QString("qtest"), q.record(), false);
- QCOMPARE(statment.count("IS NULL", Qt::CaseInsensitive), 2);
-}
-
-void tst_QSqlDatabase::mysql_savepointtest()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- if ( db.driverName().startsWith( "QMYSQL" ) && tst_Databases::getMySqlVersion( db ).section( QChar('.'), 0, 1 ).toDouble()<4.1 )
- QSKIP( "Test requires MySQL >= 4.1", SkipSingle );
-
- QSqlQuery q(db);
- QVERIFY_SQL(q, exec("begin"));
- QVERIFY_SQL(q, exec("insert into "+qTableName("qtest", __FILE__)+" VALUES (54, 'foo', 'foo', 54.54)"));
- QVERIFY_SQL(q, exec("savepoint foo"));
-}
-
-void tst_QSqlDatabase::oci_tables()
-{
- QFETCH(QString, dbName);
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- QSqlQuery q(db);
- const QString systemTableName("system."+qTableName("mypassword", __FILE__));
- QVERIFY_SQL(q, exec("CREATE TABLE "+systemTableName+"(name VARCHAR(20))"));
- QVERIFY(!db.tables().contains(systemTableName.toUpper()));
- QVERIFY(db.tables(QSql::SystemTables).contains(systemTableName.toUpper()));
-}
-
-void tst_QSqlDatabase::sqlite_enable_cache_mode()
-{
- QFETCH(QString, dbName);
- if(dbName.endsWith(":memory:"))
- QSKIP( "cache mode is meaningless for :memory: databases", SkipSingle );
- QSqlDatabase db = QSqlDatabase::database(dbName);
- CHECK_DATABASE(db);
- db.close();
- db.setConnectOptions("QSQLITE_ENABLE_SHARED_CACHE");
- QVERIFY_SQL(db, open());
- QSqlDatabase db2 = QSqlDatabase::cloneDatabase(db, dbName+":cachemodeconn2");
- db2.setConnectOptions("QSQLITE_ENABLE_SHARED_CACHE");
- QVERIFY_SQL(db2, open());
- QSqlQuery q(db), q2(db2);
- QVERIFY_SQL(q, exec("select * from "+qTableName("qtest", __FILE__)));
- QVERIFY_SQL(q2, exec("select * from "+qTableName("qtest", __FILE__)));
-}
-
-QTEST_MAIN(tst_QSqlDatabase)
-#include "tst_qsqldatabase.moc"