--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/persistentstorage/sqlite3api/TEST/t_sqlitedb64.cpp	Fri Jan 22 11:06:30 2010 +0200
@@ -0,0 +1,452 @@
+// Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).
+// All rights reserved.
+// This component and the accompanying materials are made available
+// under the terms of "Eclipse Public License v1.0"
+// which accompanies this distribution, and is available
+// at the URL "http://www.eclipse.org/legal/epl-v10.html".
+//
+// Initial Contributors:
+// Nokia Corporation - initial contribution.
+//
+// Contributors:
+//
+// Description:
+//
+#include <e32test.h>
+#include <bautils.h>
+#include <f32file64.h>
+#include <e32math.h>
+#include <hal.h>
+#include <sqlite3.h>
+#include <string.h>
+#include <stdio.h>
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+RTest TheTest(_L("t_sqlitedb64 test"));
+
+_LIT(KTestDbName,	"\\test\\t_sqlitedb64.db");
+
+RFs TheFs;
+
+sqlite3* TheDb = 0;
+sqlite3_stmt* TheStmt = 0;
+
+const TInt64 K1Mb = 1024LL * 1024LL;
+const TInt64 K1Gb = 1024LL * K1Mb;
+const TInt64 K4Gb = 4LL * K1Gb;
+
+TInt64 TheLastInsertedRowid = -1LL;
+
+struct TTestDriveInfo
+	{
+	TInt	iSizeMb;	
+	TBool	iWritable;	
+	};
+	
+TTestDriveInfo TheDriveInfo[KMaxDrives];
+TInt   		   TheBiggestDriveNo = -1;
+TFileName 	   TheDbName;
+char		   TheDbName8[KMaxFileName];
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+static void DeleteTestFiles()
+	{
+	if(TheStmt)
+		{
+		sqlite3_finalize(TheStmt);	
+		TheStmt = 0;
+		}
+	if(TheDb)
+		{
+		(void)sqlite3_close(TheDb);
+		TheDb = 0;
+		}
+	(void)TheFs.Delete(TheDbName);
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+static void PrintSqliteErrMsg()
+	{
+	if(TheDb)
+		{
+		const char* msg = sqlite3_errmsg(TheDb);
+		TBuf<200> buf;
+		buf.Copy(TPtrC8((const TUint8*)msg));
+		TheTest.Printf(_L("*** SQLite error message: \"%S\"\r\n"), &buf);
+		}
+	}
+
+//Test macros and functions
+static void Check(TInt aValue, TInt aLine)
+	{
+	if(!aValue)
+		{
+		DeleteTestFiles();
+		PrintSqliteErrMsg();
+		TheTest(EFalse, aLine);
+		}
+	}
+static void Check(TInt aValue, TInt aExpected, TInt aLine)
+	{
+	if(aValue != aExpected)
+		{
+		DeleteTestFiles();
+		RDebug::Print(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
+		PrintSqliteErrMsg();
+		TheTest(EFalse, aLine);
+		}
+	}
+#define TEST(arg) ::Check((arg), __LINE__)
+#define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+void SqlTimerPrint(const TDesC& aText, TUint32 aStartTicks, TUint32 aEndTicks)
+	{
+	static TInt freq = 0;
+	if(freq == 0)
+		{
+		TEST2(HAL::Get(HAL::EFastCounterFrequency, freq), KErrNone);
+		}
+	TInt64 diffTicks = (TInt64)aEndTicks - (TInt64)aStartTicks;
+	if(diffTicks < 0)
+		{
+		diffTicks = KMaxTUint32 + diffTicks + 1;
+		}
+	const TInt KMicroSecIn1Sec = 1000000;
+	TInt32 us = (diffTicks * KMicroSecIn1Sec) / freq;
+	TheTest.Printf(_L("#### %S. Execution time: %d us\r\n"), &aText, us);
+	}
+
+TUint32 SqlTimerTicks()
+	{
+	return User::FastCounter();
+	}
+
+void CollectDriveInfo()
+	{
+	TheTest.Printf(_L("==================\r\n"));
+	_LIT(KType1, "Not present");
+	_LIT(KType2, "Unknown");
+	_LIT(KType3, "Floppy");
+	_LIT(KType4, "Hard disk");
+	_LIT(KType5, "CD ROM");
+	_LIT(KType6, "RAM disk");
+	_LIT(KType7, "Flash");
+	_LIT(KType8, "ROM drive");
+	_LIT(KType9, "Remote drive");
+	_LIT(KType10,"NAND flash");
+	_LIT(KType11,"Rotating media");
+	
+	Mem::FillZ(TheDriveInfo, sizeof(TheDriveInfo));
+	TheBiggestDriveNo = 0;
+	
+	for(TInt drive=EDriveA;drive<=EDriveZ;++drive)
+		{
+		TDriveInfo driveInfo;
+		TInt err = TheFs.Drive(driveInfo, drive);
+		if(err == KErrNone)
+			{
+			TVolumeInfo vinfo;
+			err = TheFs.Volume(vinfo, drive);
+			if(err == KErrNone)
+				{
+				TVolumeIOParamInfo vparam;
+				err = TheFs.VolumeIOParam(drive, vparam);
+				TEST2(err, KErrNone);
+				TBuf8<128> vinfoex8;
+				err = TheFs.QueryVolumeInfoExt(drive, EFileSystemSubType, vinfoex8);
+				TEST2(err, KErrNone);
+				TPtrC vinfoex((const TUint16*)(vinfoex8.Ptr() + 8), vinfoex8[0]);
+				TPtrC KMediaTypeNames[] = {KType1(), KType2(), KType3(), KType4(), KType5(), KType6(), KType7(), KType8(), KType9(), KType10(), KType11()};
+				TInt sizeMb = vinfo.iSize / K1Mb;
+				TheTest.Printf(_L("Drive: %C:, Type: %16.16S, File System: %8.8S, Size: %d Mb.\r\n"), 'A' + drive, &KMediaTypeNames[driveInfo.iType], &vinfoex, sizeMb);
+				TheTest.Printf(_L("       Block size=%d, Cluster size=%d, Read buffer size=%d.\r\n"), vparam.iBlockSize, vparam.iClusterSize, vparam.iRecReadBufSize);
+				TheDriveInfo[drive].iSizeMb = sizeMb;
+				if(driveInfo.iType == EMediaRam || driveInfo.iType == EMediaHardDisk || driveInfo.iType == EMediaFlash || driveInfo.iType == EMediaNANDFlash)
+				  	{
+					TheDriveInfo[drive].iWritable = ETrue;
+					if(sizeMb > TheDriveInfo[TheBiggestDriveNo].iSizeMb)
+						{
+						TheBiggestDriveNo = drive;
+						}
+					}
+				}
+			else
+				{
+				TheTest.Printf(_L("Drive %C. RFs::Volume() has failed with err=%d.\r\n"), 'A' + drive, err);	
+				}
+			}
+		else
+			{
+			TheTest.Printf(_L("Drive %C. RFs::Drive() has failed with err=%d.\r\n"), 'A' + drive, err);	
+			}
+		}
+		
+	TheTest.Printf(_L("The biggest R/W drive is: %C, Size: %d Mb\r\n"), 'A' + TheBiggestDriveNo, TheDriveInfo[TheBiggestDriveNo].iSizeMb);
+	TDriveUnit drvUnit(TheBiggestDriveNo);
+	TDriveName drvName = drvUnit.Name();
+	TParse parse;
+	parse.Set(KTestDbName, &drvName, NULL);
+	TheDbName.Copy(parse.FullName());
+	TPtr8 p((TUint8*)TheDbName8, 0, KMaxFileName);
+	p.Copy(TheDbName);
+	p.Append(TChar(0));
+
+	TRAPD(err, BaflUtils::EnsurePathExistsL(TheFs, TheDbName));
+	TEST(err == KErrNone || err == KErrAlreadyExists);
+
+	TheTest.Printf(_L("==================\r\n"));
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+/**
+@SYMTestCaseID			PDS-SQLITE3-CT-4041
+@SYMTestCaseDesc		Creation of a database bigger than 4Gb (KMaxTUint).
+						The test creates a test database with a table and inserts records into the table
+						until the database size gets bigger than 4Gb (KMaxTUint). The purpose of the test is to verify
+						that it is possible to create and manipulate 64-bit SQLite databases.
+@SYMTestActions			Creation of a database bigger than 4Gb (KMaxTUint).
+@SYMTestExpectedResults Test must not fail
+@SYMTestPriority 	    High
+@SYMREQ					REQ12107
+                        REQ12108
+*/
+void CreateBigDbTest(TInt64 aDbSize)
+	{
+	__ASSERT_ALWAYS(aDbSize > 0LL, User::Invariant());
+	(void)TheFs.Delete(TheDbName);
+
+	const char* ver = sqlite3_libversion();
+	TBuf<20> buf;
+	buf.Copy(TPtrC8((const TUint8*)ver));
+	TheTest.Printf(_L("*** SQLite library version: \"%S\"\r\n"), &buf);
+	
+	TInt err = sqlite3_open(TheDbName8, &TheDb);
+	TEST2(err, SQLITE_OK);
+	
+	//
+	err = sqlite3_exec(TheDb, "CREATE TABLE A(Id INTEGER PRIMARY KEY AUTOINCREMENT, Data BLOB)", 0, 0, 0);
+	TEST2(err, SQLITE_OK);
+	TInt64 fsize = 0;
+	TheTest.Printf(_L("==File size:"));
+	while(fsize < aDbSize)
+		{
+		const TInt KRecCnt = 1000;
+		//Insert KRecCnt records in a transaction
+		err = sqlite3_exec(TheDb, "BEGIN", 0, 0, 0);	
+		if(err != SQLITE_OK)
+			{
+			TheTest.Printf(_L("==='BEGIN' has failed with err %d\r\n"), err);
+			}
+		TEST2(err, SQLITE_OK);
+		err = sqlite3_prepare(TheDb, "INSERT INTO A(Data) VALUES(zeroblob(32768))", -1, &TheStmt, 0);//32Kb big blob
+		TEST2(err, SQLITE_OK);
+		for(TInt i=0;i<KRecCnt;++i)
+			{
+			err = sqlite3_step(TheStmt);
+			TEST2(err, SQLITE_DONE);
+			err = sqlite3_reset(TheStmt);
+			TEST2(err, SQLITE_OK);
+			}
+		err = sqlite3_finalize(TheStmt);
+		TEST2(err, SQLITE_OK);
+		TheStmt = 0;
+		err = sqlite3_exec(TheDb, "COMMIT", 0, 0, 0);	
+		if(err != SQLITE_OK)
+			{
+			TheTest.Printf(_L("==='COMMIT' has failed with err %d\r\n"), err);	
+			}
+		TEST2(err, SQLITE_OK);
+		TheLastInsertedRowid = sqlite3_last_insert_rowid(TheDb);
+		TEST(TheLastInsertedRowid > 0LL);
+		//Check and print the file size
+		sqlite3_close(TheDb);
+		TheDb = 0;
+		RFile64 file;
+		err = file.Open(TheFs, TheDbName, EFileRead | EFileWrite);
+		TEST2(err, KErrNone);
+		err = file.Size(fsize);
+		TEST2(err, KErrNone);
+		file.Close();
+		TheTest.Printf(_L(" %ldMb"), fsize / K1Mb);
+		err = sqlite3_open(TheDbName8, &TheDb);
+		TEST2(err, SQLITE_OK);
+		}
+	TheTest.Printf(_L("\r\n"));
+	//
+	sqlite3_close(TheDb);
+	TheDb = 0;
+	}
+
+/**
+@SYMTestCaseID			PDS-SQLITE3-CT-4042
+@SYMTestCaseDesc		SQLite operations on a 64-bit database.
+						The test uses the database created in test case PDS-SQLITE3-UT-4041.
+						Simple INSERT, UPDATE, DELETE and SELECT statements are executed on the database.
+						The data in the test SQL statements is such that the manipulated records are beyond the 4Gb
+						file offset. Some other of the test SQL statements will perform sequential scan of the whole
+						database from offset 0 to the end of the database file.
+						The purpose of the test is to verify that there are no problem if the database offset is 64-bit.
+@SYMTestActions			SQLite operations on a 64-bit database.
+@SYMTestExpectedResults Test must not fail
+@SYMTestPriority 	    High
+@SYMREQ					REQ12107
+                        REQ12108
+*/
+void SimpleDbOperationsTest()
+	{
+	__ASSERT_ALWAYS(TheLastInsertedRowid > 0LL, User::Invariant());
+	TInt err = sqlite3_open(TheDbName8, &TheDb);
+	TEST2(err, SQLITE_OK);
+
+	//SELECT-1
+	TUint32 start = SqlTimerTicks();
+	err = sqlite3_prepare(TheDb, "SELECT Id FROM A WHERE ROWID = :Prm", -1, &TheStmt, 0);
+	TEST2(err, SQLITE_OK);
+	err = sqlite3_bind_int64(TheStmt, 1, TheLastInsertedRowid - 1LL);
+	TEST2(err, SQLITE_OK);
+	err = sqlite3_step(TheStmt);
+	TEST2(err, SQLITE_ROW);
+	TInt64 id = sqlite3_column_int64(TheStmt, 0);
+	TheTest.Printf(_L("==Id=%ld\r\n"), id);
+	sqlite3_finalize(TheStmt);
+	TheStmt = 0;
+	TUint32 end = SqlTimerTicks();
+	SqlTimerPrint(_L("SELECT-1"), start, end);
+
+	//INSERT
+	start = SqlTimerTicks();
+	err = sqlite3_exec(TheDb, "INSERT INTO A(Data) VALUES('123456')", 0, 0, 0);
+	TEST2(err, SQLITE_OK);
+	end = SqlTimerTicks();
+	TInt cnt = sqlite3_changes(TheDb);
+	TEST2(cnt, 1);
+	SqlTimerPrint(_L("INSERT"), start, end);
+	
+	//UPDATE
+	start = SqlTimerTicks();
+	TBuf<100> sql;
+	sql.Format(_L("UPDATE A SET Data='56789' WHERE Id=%ld"), id);
+	TBuf8<100> sql8;
+	sql8.Copy(sql);
+	err = sqlite3_exec(TheDb, (const char*)sql8.PtrZ(), 0, 0, 0);
+	TEST2(err, SQLITE_OK);
+	end = SqlTimerTicks();
+	cnt = sqlite3_changes(TheDb);
+	TEST2(cnt, 1);
+	SqlTimerPrint(_L("UPDATE"), start, end);
+	
+	//SELECT-2
+	start = SqlTimerTicks();
+	sql.Format(_L("SELECT Data FROM A WHERE ID = %ld"), id);
+	sql8.Copy(sql);
+	err = sqlite3_prepare(TheDb, (const char*)sql8.PtrZ(), -1, &TheStmt, 0);
+	TEST2(err, SQLITE_OK);
+	err = sqlite3_step(TheStmt);
+	TEST2(err, SQLITE_ROW);
+	const char* data = (const char*)sqlite3_column_text(TheStmt, 0);
+	TEST(data != 0);
+	err = strcmp(data, "56789");
+	TEST2(err, 0);
+	sqlite3_finalize(TheStmt);
+	TheStmt = 0;
+	end = SqlTimerTicks();
+	SqlTimerPrint(_L("SELECT-2"), start, end);
+	
+	//SELECT-3
+	start = SqlTimerTicks();
+	err = sqlite3_prepare(TheDb, "SELECT COUNT(*) FROM A", -1, &TheStmt, 0);
+	TEST2(err, SQLITE_OK);
+	err = sqlite3_step(TheStmt);
+	TEST2(err, SQLITE_ROW);
+	TInt recCnt = sqlite3_column_int(TheStmt, 0);
+	TheTest.Printf(_L("==Records count: %d\r\n"), recCnt);
+	sqlite3_finalize(TheStmt);
+	TheStmt = 0;
+	end = SqlTimerTicks();
+	SqlTimerPrint(_L("SELECT-3"), start, end);
+	TEST(recCnt > 0);
+
+	//SELECT-4
+	start = SqlTimerTicks();
+	err = sqlite3_prepare(TheDb, "SELECT MAX(ROWID) FROM A", -1, &TheStmt, 0);
+	TEST2(err, SQLITE_OK);
+	err = sqlite3_step(TheStmt);
+	TEST2(err, SQLITE_ROW);
+	TInt rowid = sqlite3_column_int(TheStmt, 0);
+	TheTest.Printf(_L("==MAX(ROWID): %d\r\n"), recCnt);
+	sqlite3_finalize(TheStmt);
+	TheStmt = 0;
+	end = SqlTimerTicks();
+	SqlTimerPrint(_L("SELECT-4"), start, end);
+	TEST(rowid > 0);
+	
+	//DELETE
+	start = SqlTimerTicks();
+	sql.Format(_L("DELETE FROM A WHERE ID = %ld"), id);
+	sql8.Copy(sql);
+	err = sqlite3_exec(TheDb, (const char*)sql8.PtrZ(), 0, 0, 0);
+	TEST2(err, SQLITE_OK);
+	end = SqlTimerTicks();
+	cnt = sqlite3_changes(TheDb);
+	TEST2(cnt, 1);
+	SqlTimerPrint(_L("DELETE"), start, end);
+	
+	sqlite3_close(TheDb);
+	TheDb = 0;
+	}
+
+///////////////////////////////////////////////////////////////////////////////////////
+
+static void DoTests()
+	{
+	TheTest.Start(_L("Collect drive information"));
+	CollectDriveInfo();
+	
+	TInt64 maxDrvSize = TheDriveInfo[TheBiggestDriveNo].iSizeMb * K1Mb;
+	if(maxDrvSize <= K4Gb)
+		{
+		TheTest.Printf(_L("There is no drive bigger than 4Gb. The tests won't be executed.\r\n"));
+		return;	
+		}
+	
+	TheTest.Next(_L(" @SYMTestCaseID:PDS-SQLITE3-CT-4041 Create database, bigger than 4Gb"));
+	CreateBigDbTest(K4Gb + 64 * K1Mb);
+
+	TheTest.Next (_L("  @SYMTestCaseID:PDS-SQLITE3-CT-4042 64-bit database - simple operations test"));
+	SimpleDbOperationsTest();
+
+	(void)TheFs.Delete(TheDbName);
+	}
+
+TInt E32Main()
+	{
+	TheTest.Title();
+
+	CTrapCleanup* tc = CTrapCleanup::New();
+	TheTest(tc != NULL);
+
+	__UHEAP_MARK;
+
+	TInt err = TheFs.Connect();
+	TheTest(err == KErrNone);
+
+	DeleteTestFiles();
+	DoTests();
+	DeleteTestFiles();
+
+	__UHEAP_MARKEND;
+
+	TheFs.Close();
+	TheTest.End();
+	TheTest.Close();
+
+	delete tc;
+
+	User::Heap().Check();
+	return KErrNone;
+	}