sl@0: // Copyright (c) 2008-2010 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include <e32test.h>
sl@0: #include <bautils.h>
sl@0: #include <sqldb.h>
sl@0: #include "t_sqlcmdlineutil.h"
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: RTest			TheTest(_L("t_sqlperformance2 test"));
sl@0: RSqlDatabase 	TheDb;
sl@0: TFileName		TheDbFileName;
sl@0: RFs				TheFs;
sl@0: 
sl@0: TBuf<200> 		TheTestTitle;
sl@0: TCmdLineParams 	TheCmdLineParams;
sl@0: TBuf8<200> 		TheSqlConfigString;
sl@0: 
sl@0: _LIT(KUtf8,  "UTF8 ");
sl@0: _LIT(KUtf16, "UTF16");
sl@0: 
sl@0: TInt TheBlobSize = 1024 * 256;
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: void TestEnvDestroy()
sl@0: 	{
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	TheFs.Close();
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: //Test macros and functions
sl@0: void Check1(TInt aValue, TInt aLine)
sl@0: 	{
sl@0: 	if(!aValue)
sl@0: 		{
sl@0: 		TestEnvDestroy();
sl@0: 		TheTest.Printf(_L("*** Line %d\r\n"), aLine);
sl@0: 		TheTest(EFalse, aLine);
sl@0: 		}
sl@0: 	}
sl@0: void Check2(TInt aValue, TInt aExpected, TInt aLine)
sl@0: 	{
sl@0: 	if(aValue != aExpected)
sl@0: 		{
sl@0: 		TestEnvDestroy();
sl@0: 		TheTest.Printf(_L("*** Line %d, Expected error: %d, got: %d\r\n"), aLine, aExpected, aValue);
sl@0: 		TheTest(EFalse, aLine);
sl@0: 		}
sl@0: 	}
sl@0: #define TEST(arg) ::Check1((arg), __LINE__)
sl@0: #define TEST2(aValue, aExpected) ::Check2(aValue, aExpected, __LINE__)
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: void TestEnvInit()
sl@0:     {
sl@0:     TInt err = TheFs.Connect();
sl@0:     TEST2(err, KErrNone);
sl@0:     //
sl@0:     TInt driveNumber = -1;
sl@0: 	err = RFs::CharToDrive(TheCmdLineParams.iDriveName[0], driveNumber);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TDriveNumber driveNo = static_cast <TDriveNumber> (driveNumber);
sl@0: 	TDriveInfo driveInfo;
sl@0: 	err = TheFs.Drive(driveInfo, driveNo);
sl@0: 	TEST2(err, KErrNone);
sl@0:     //Create the test directory
sl@0: 	err = TheFs.MkDirAll(TheDbFileName);
sl@0: 	TEST(err == KErrNone || err == KErrAlreadyExists);
sl@0:     //Print drive info and the database name 
sl@0: 	_LIT(KType1, "Not present");
sl@0: 	_LIT(KType2, "Unknown");
sl@0: 	_LIT(KType3, "Floppy");
sl@0: 	_LIT(KType4, "Hard disk");
sl@0: 	_LIT(KType5, "CD ROM");
sl@0: 	_LIT(KType6, "RAM disk");
sl@0: 	_LIT(KType7, "Flash");
sl@0: 	_LIT(KType8, "ROM drive");
sl@0: 	_LIT(KType9, "Remote drive");
sl@0: 	_LIT(KType10,"NAND flash");
sl@0: 	_LIT(KType11,"Rotating media");
sl@0: 	TPtrC KMediaTypeNames[] = {KType1(), KType2(), KType3(), KType4(), KType5(), KType6(), KType7(), KType8(), KType9(), KType10(), KType11()};
sl@0: 	TheTest.Printf(_L("Drive %C: %S. File: \"%S\"\r\n"), 'A' + driveNo, &KMediaTypeNames[driveInfo.iType], &TheDbFileName);
sl@0: 	}
sl@0: 	
sl@0: void PrintWriteTime(TTimeIntervalMicroSeconds aTime, TTimeIntervalMicroSeconds aWriteTime, TTimeIntervalMicroSeconds aCommitTime)
sl@0: 	{
sl@0: 	TheTest.Printf(_L("####Execution time: %d ms, Write: %d ms, Commit: %d ms\r\n"), 
sl@0: 		(TInt)(aTime.Int64() / 1000), (TInt)(aWriteTime.Int64() / 1000), (TInt)(aCommitTime.Int64() / 1000));
sl@0: 	}
sl@0: 
sl@0: void PrintReadTime(TTimeIntervalMicroSeconds aPrepareTime, TTimeIntervalMicroSeconds aNextTime, TTimeIntervalMicroSeconds aReadTime)
sl@0: 	{
sl@0: 	TInt executionTime = (TInt)(aPrepareTime.Int64() / 1000) + (TInt)(aNextTime.Int64() / 1000) + (TInt)(aReadTime.Int64() / 1000);
sl@0: 	TheTest.Printf(_L("####Execution time: %d ms, Prepare: %d ms, Next: %d ms, Read: %d ms\r\n"), 
sl@0: 		executionTime, (TInt)(aPrepareTime.Int64() / 1000), (TInt)(aNextTime.Int64() / 1000), (TInt)(aReadTime.Int64() / 1000));
sl@0: 	}
sl@0: 
sl@0: void PrintReadTime(TTimeIntervalMicroSeconds aOpenTime, TTimeIntervalMicroSeconds aReadTime)
sl@0: 	{
sl@0: 	TInt executionTime = (TInt)(aOpenTime.Int64() / 1000) + (TInt)(aReadTime.Int64() / 1000);
sl@0: 	TheTest.Printf(_L("####Execution time: %d ms, Open: %d ms, Read: %d ms\r\n"), 
sl@0: 		executionTime, (TInt)(aOpenTime.Int64() / 1000), (TInt)(aReadTime.Int64() / 1000));
sl@0: 	}
sl@0: 	
sl@0: void PrintFileSize(RSqlDatabase& aDb)
sl@0: 	{
sl@0: 	TheTest.Printf(_L("####FileSize: %d\r\n"), aDb.Size());
sl@0: 	}
sl@0: 		
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 	
sl@0: void CreateTestDb()
sl@0: 	{
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	TInt err = TheDb.Create(TheDbFileName, &TheSqlConfigString);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	err = TheDb.Exec(_L8("CREATE TABLE A(B BLOB)"));
sl@0: 	TEST2(err, 1);
sl@0: 	}
sl@0: 
sl@0: void DoWriteBlobIncrL(const TDesC8& aData, 
sl@0: 					  TTime& aT1, 
sl@0: 					  TTime& aT2,
sl@0: 					  TTime& aT3,
sl@0: 					  TTime& aT4)
sl@0: 	{
sl@0: 	
sl@0: 	RSqlBlobWriteStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	
sl@0: 	aT1.HomeTime();
sl@0: 	strm.OpenL(TheDb, _L("A"), _L("B"));	
sl@0: 	strm.WriteL(aData);
sl@0: 	aT2.HomeTime();
sl@0: 	
sl@0: 	aT3.HomeTime();
sl@0: 	strm.CommitL();
sl@0: 	aT4.HomeTime();
sl@0: 	
sl@0: 	CleanupStack::PopAndDestroy(&strm);
sl@0: 	}
sl@0: 	
sl@0: void InsertZeroBlob(TBool aDoPrintTime = EFalse)
sl@0: 	{
sl@0: 	TBuf<100> sql;
sl@0: 	sql.Format(_L("INSERT INTO A VALUES(zeroblob(%d))"), TheBlobSize);
sl@0: 	
sl@0: 	TTime t1, t2;
sl@0: 	t1.HomeTime();
sl@0: 	TInt err = TheDb.Exec(sql);
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, 1);
sl@0: 	TTimeIntervalMicroSeconds insertTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	if(aDoPrintTime)
sl@0: 		{
sl@0: 		PrintWriteTime(insertTime, TTimeIntervalMicroSeconds(0), TTimeIntervalMicroSeconds(0));
sl@0: 		}
sl@0: 	}
sl@0: 	
sl@0: void InsertRealBlob()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	dataptr.SetLength(TheBlobSize);
sl@0: 	dataptr.Fill(TChar('A'));
sl@0: 		
sl@0: 	RSqlStatement stmt;
sl@0: 	TInt err = stmt.Prepare(TheDb, _L8("INSERT INTO A VALUES(:Prm)"));
sl@0: 	TEST2(err, KErrNone);
sl@0: 
sl@0: 	RSqlParamWriteStream strm;
sl@0: 	err = strm.BindBinary(stmt, 0);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	TRAP(err, strm.WriteL(dataptr));
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TRAP(err, strm.CommitL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	strm.Close();
sl@0: 
sl@0: 	err = stmt.Exec();	
sl@0: 	TEST2(err, 1);			
sl@0: 	stmt.Close();	
sl@0: 	
sl@0: 	delete data;
sl@0: 	}
sl@0: 	
sl@0: void InsertBlobIncr()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	dataptr.SetLength(TheBlobSize);
sl@0: 	dataptr.Fill(TChar('B'));
sl@0: 	
sl@0: 	TTimeIntervalMicroSeconds totalTime, writeTime, commitTime;
sl@0: 
sl@0: 	TBuf<100> sql;
sl@0: 	sql.Format(_L("INSERT INTO A VALUES(zeroblob(%d))"), TheBlobSize);
sl@0: 
sl@0: 	TTime t1, t2, subt1, subt2, subt3, subt4;
sl@0: 	t1.HomeTime();
sl@0: 	
sl@0: 	TInt err = TheDb.Exec(_L8("BEGIN"));
sl@0: 	TEST(err >= 0);
sl@0: 	
sl@0: 	err = TheDb.Exec(sql);
sl@0: 	TEST2(err, 1);
sl@0: 	
sl@0: 	TRAP(err, DoWriteBlobIncrL(dataptr, subt1, subt2, subt3, subt4));
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	err = TheDb.Exec(_L8("COMMIT"));
sl@0: 	TEST(err >= 0);
sl@0: 		
sl@0: 	t2.HomeTime();
sl@0: 	totalTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	writeTime = subt2.MicroSecondsFrom(subt1);
sl@0: 	commitTime = subt4.MicroSecondsFrom(subt3);
sl@0: 	
sl@0: 	PrintWriteTime(totalTime, writeTime, commitTime);
sl@0: 	
sl@0: 	delete data;
sl@0: 	}
sl@0: 	
sl@0: void InsertBlobExec()
sl@0: 	{
sl@0: 	HBufC8* buf = HBufC8::New(TheBlobSize * 2 + 100);
sl@0: 	TEST(buf != NULL);
sl@0: 	TPtr8 sql = buf->Des();
sl@0: 	_LIT8(KStr, "INSERT INTO A VALUES(x'");
sl@0: 	sql.SetLength(TheBlobSize * 2 + KStr().Length());
sl@0: 	sql.Fill(TChar('A'));
sl@0: 	sql.Replace(0, KStr().Length(), KStr);
sl@0: 	sql.Append(_L8("')"));
sl@0: 
sl@0: 	TTime t1, t2;
sl@0: 	
sl@0: 	t1.HomeTime();		
sl@0: 	TInt err = TheDb.Exec(sql);
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, 1);
sl@0: 
sl@0: 	TTimeIntervalMicroSeconds totalTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	PrintWriteTime(totalTime, TTimeIntervalMicroSeconds(0), TTimeIntervalMicroSeconds(0));
sl@0: 	
sl@0: 	delete buf;	
sl@0: 	}
sl@0: 
sl@0: void InsertBlobBindStreamPrm()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	dataptr.SetLength(TheBlobSize);
sl@0: 	dataptr.Fill(TChar('A'));
sl@0: 	
sl@0: 	TTimeIntervalMicroSeconds totalTime, writeTime, commitTime;
sl@0: 
sl@0: 	TTime t1, t2, t3, t4, t5, t6;
sl@0: 	t1.HomeTime();
sl@0: 				
sl@0: 	RSqlStatement stmt;
sl@0: 	TInt err = stmt.Prepare(TheDb, _L8("INSERT INTO A VALUES(:Prm)"));
sl@0: 	TEST2(err, KErrNone);
sl@0: 
sl@0: 	RSqlParamWriteStream strm;
sl@0: 	err = strm.BindBinary(stmt, 0);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	t3.HomeTime();
sl@0: 	TRAP(err, strm.WriteL(dataptr));
sl@0: 	t4.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	t5.HomeTime();
sl@0: 	TRAP(err, strm.CommitL());
sl@0: 	t6.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	err = stmt.Exec();	
sl@0: 	
sl@0: 	strm.Close();
sl@0: 	stmt.Close();	
sl@0: 	
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, 1);
sl@0: 					
sl@0: 	totalTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	writeTime = t4.MicroSecondsFrom(t3);
sl@0: 	commitTime = t6.MicroSecondsFrom(t5);
sl@0: 	
sl@0: 	PrintWriteTime(totalTime, writeTime, commitTime);
sl@0: 			
sl@0: 	delete data;	
sl@0: 	}
sl@0: 	
sl@0: void UpdateBlobIncr()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	dataptr.SetLength(TheBlobSize);
sl@0: 	dataptr.Fill(TChar('A'));
sl@0: 	
sl@0: 	TTimeIntervalMicroSeconds totalTime, writeTime, commitTime;
sl@0: 
sl@0: 	TTime t1, t2, subt1, subt2, subt3, subt4;
sl@0: 	t1.HomeTime();
sl@0: 	
sl@0: 	TInt err = TheDb.Exec(_L8("BEGIN"));
sl@0: 	TEST(err >= 0);
sl@0: 		
sl@0: 	TRAP(err, DoWriteBlobIncrL(dataptr, subt1, subt2, subt3, subt4));
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	err = TheDb.Exec(_L8("COMMIT"));
sl@0: 	TEST(err >= 0);
sl@0: 		
sl@0: 	t2.HomeTime();
sl@0: 	totalTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	writeTime = subt2.MicroSecondsFrom(subt1);
sl@0: 	commitTime = subt4.MicroSecondsFrom(subt3);
sl@0: 	
sl@0: 	PrintWriteTime(totalTime, writeTime, commitTime);
sl@0: 	
sl@0: 	delete data;
sl@0: 	}
sl@0: 	
sl@0: void UpdateBlobExec()
sl@0: 	{
sl@0: 	HBufC8* buf = HBufC8::New(TheBlobSize * 2 + 100);
sl@0: 	TEST(buf != NULL);
sl@0: 	TPtr8 sql = buf->Des();
sl@0: 	_LIT8(KStr, "UPDATE A SET B=x'");
sl@0: 	sql.SetLength(TheBlobSize * 2 + KStr().Length());
sl@0: 	sql.Fill(TChar('B'));
sl@0: 	sql.Replace(0, KStr().Length(), KStr);
sl@0: 	sql.Append(_L8("'"));
sl@0: 
sl@0: 	TTime t1, t2;
sl@0: 	t1.HomeTime();			
sl@0: 	TInt err = TheDb.Exec(sql);	
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, 1);
sl@0: 
sl@0: 	TTimeIntervalMicroSeconds totalTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	PrintWriteTime(totalTime, TTimeIntervalMicroSeconds(0), TTimeIntervalMicroSeconds(0));
sl@0: 	
sl@0: 	delete buf;	
sl@0: 	}
sl@0: 
sl@0: void UpdateBlobBindStreamPrm()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	dataptr.SetLength(TheBlobSize);
sl@0: 	dataptr.Fill(TChar('B'));
sl@0: 	
sl@0: 	TTimeIntervalMicroSeconds totalTime, writeTime, commitTime;
sl@0: 
sl@0: 	TTime t1, t2, t3, t4, t5, t6;
sl@0: 	t1.HomeTime();
sl@0: 				
sl@0: 	RSqlStatement stmt;
sl@0: 	TInt err = stmt.Prepare(TheDb, _L8("UPDATE A SET B=(:Prm)"));
sl@0: 	TEST2(err, KErrNone);
sl@0: 
sl@0: 	RSqlParamWriteStream strm;
sl@0: 	err = strm.BindBinary(stmt, 0);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	t3.HomeTime();;
sl@0: 	TRAP(err, strm.WriteL(dataptr));
sl@0: 	t4.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	t5.HomeTime();
sl@0: 	TRAP(err, strm.CommitL());
sl@0: 	t6.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	err = stmt.Exec();	
sl@0: 
sl@0: 	strm.Close();		
sl@0: 	stmt.Close();	
sl@0: 
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, 1);
sl@0: 	
sl@0: 	totalTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	writeTime = t4.MicroSecondsFrom(t3);
sl@0: 	commitTime = t6.MicroSecondsFrom(t5);
sl@0: 	
sl@0: 	PrintWriteTime(totalTime, writeTime, commitTime);
sl@0: 			
sl@0: 	delete data;	
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID			SYSLIB-SQL-UT-4084
sl@0: @SYMTestCaseDesc		SQL, BLOB write, performance tests.
sl@0: 						Tests insertion and updates of BLOBs using the old
sl@0: 						APIs and the new RSqlBlobWriteStream APIs.
sl@0: @SYMTestPriority		Medium
sl@0: @SYMTestActions			Insertion and updates of blobs using the old and new APIs.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ					REQ5912
sl@0: */
sl@0: void BlobWriteTest()
sl@0: 	{	
sl@0: 	TheTest.Printf(_L("Blob size=%d Kb\r\n"), TheBlobSize / 1024);
sl@0: 	
sl@0: 	//Insert a blob
sl@0: 	TheTest.Printf(_L("==================================================================\r\n"));
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("INSERT zeroblob - RSqlDatabase::Exec()\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertZeroBlob(ETrue);
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 				
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("INSERT blob - RSqlParamWriteStream\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertBlobBindStreamPrm();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("INSERT blob - RSqlDatabase::Exec()\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertBlobExec();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("INSERT blob - RSqlBlobWriteStream + transaction\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertBlobIncr();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 						
sl@0: 	// Update a blob 
sl@0: 	TheTest.Printf(_L("==================================================================\r\n"));
sl@0: 		
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("UPDATE zeroblob - RSqlParamWriteStream\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertZeroBlob();
sl@0: 	UpdateBlobBindStreamPrm();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("UPDATE blob - RSqlParamWriteStream\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertRealBlob();
sl@0: 	UpdateBlobBindStreamPrm();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 			
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("UPDATE zeroblob - RSqlDatabase::Exec()\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertZeroBlob();
sl@0: 	UpdateBlobExec();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("UPDATE blob - RSqlDatabase::Exec()\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertRealBlob();
sl@0: 	UpdateBlobExec();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("UPDATE zeroblob - RSqlBlobWriteStream + transaction\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertZeroBlob();
sl@0: 	UpdateBlobIncr();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	CreateTestDb();
sl@0: 	TheTest.Printf(_L("UPDATE blob - RSqlBlobWriteStream + transaction\r\n"));
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertRealBlob();
sl@0: 	UpdateBlobIncr();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);	
sl@0: 	}
sl@0: 
sl@0: void DoReadBlobIncrL(TDes8& aDes, TInt aMaxLength)
sl@0: 	{
sl@0: 	TTime t1, t2, t3, t4;
sl@0: 	
sl@0: 	TTimeIntervalMicroSeconds openTime, readTime; 
sl@0: 	
sl@0: 	RSqlBlobReadStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	
sl@0: 	t1.HomeTime();
sl@0: 	strm.OpenL(TheDb, _L("A"), _L("B"), 1);
sl@0: 	t2.HomeTime();
sl@0: 	
sl@0: 	openTime = t2.MicroSecondsFrom(t1);
sl@0: 		
sl@0: 	t3.HomeTime();
sl@0: 	strm.ReadL(aDes, aMaxLength);
sl@0: 	t4.HomeTime();
sl@0: 
sl@0: 	readTime = t4.MicroSecondsFrom(t3);
sl@0: 	
sl@0: 	PrintReadTime(openTime, readTime);
sl@0: 
sl@0: 	CleanupStack::PopAndDestroy(&strm);
sl@0: 	}
sl@0: 
sl@0: void ReadBlobIncr()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	
sl@0: 	TRAPD(err, DoReadBlobIncrL(dataptr, TheBlobSize));
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TEST2(dataptr.Length(), TheBlobSize);
sl@0: 	
sl@0: 	delete data;
sl@0: 	}
sl@0: 
sl@0: void ReadBlobColDes()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	
sl@0: 	TTime t1, t2, t3, t4, t5, t6;
sl@0: 	TTimeIntervalMicroSeconds prepareTime, nextTime, readTime;
sl@0: 	
sl@0: 	RSqlStatement stmt;
sl@0: 	t1.HomeTime();
sl@0: 	TInt err = stmt.Prepare(TheDb, _L8("SELECT B FROM A WHERE ROWID=1"));
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	prepareTime = t2.MicroSecondsFrom(t1);
sl@0: 
sl@0: 	t3.HomeTime();
sl@0: 	err = stmt.Next();
sl@0: 	t4.HomeTime();
sl@0: 	TEST2(err, KSqlAtRow);
sl@0: 	nextTime = t4.MicroSecondsFrom(t3);
sl@0: 	
sl@0: 	t5.HomeTime();
sl@0: 	err = stmt.ColumnBinary(0, dataptr);
sl@0: 	t6.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TEST2(dataptr.Length(), TheBlobSize);
sl@0: 	readTime = t6.MicroSecondsFrom(t5);
sl@0: 		
sl@0: 	PrintReadTime(prepareTime, nextTime, readTime);
sl@0: 	stmt.Close();
sl@0: 	
sl@0: 	delete data;
sl@0: 	}
sl@0: 
sl@0: void ReadBlobColPtr()
sl@0: 	{
sl@0: 	TTime t1, t2, t3, t4, t5, t6;
sl@0: 	TTimeIntervalMicroSeconds prepareTime, nextTime, readTime;
sl@0: 	
sl@0: 	RSqlStatement stmt;
sl@0: 	t1.HomeTime();
sl@0: 	TInt err = stmt.Prepare(TheDb, _L8("SELECT B FROM A WHERE ROWID=1"));
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	prepareTime = t2.MicroSecondsFrom(t1);
sl@0: 	
sl@0: 	t3.HomeTime();
sl@0: 	err = stmt.Next();
sl@0: 	t4.HomeTime();
sl@0: 	TEST2(err, KSqlAtRow);
sl@0: 	nextTime = t4.MicroSecondsFrom(t3);
sl@0: 	
sl@0: 	TPtrC8 data;
sl@0: 	t5.HomeTime();
sl@0: 	err = stmt.ColumnBinary(0, data);
sl@0: 	t6.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TEST2(data.Length(), TheBlobSize);
sl@0: 	readTime = t6.MicroSecondsFrom(t5);
sl@0: 
sl@0: 	PrintReadTime(prepareTime, nextTime, readTime);
sl@0: 	stmt.Close();
sl@0: 	}
sl@0: 
sl@0: void ReadBlobStreamCol()
sl@0: 	{
sl@0: 	HBufC8* data = HBufC8::New(TheBlobSize);
sl@0: 	TEST(data != NULL);
sl@0: 	TPtr8 dataptr = data->Des();
sl@0: 	
sl@0: 	TTime t1, t2, t3, t4, t5, t6;
sl@0: 	TTimeIntervalMicroSeconds prepareTime, nextTime, readTime;
sl@0: 	
sl@0: 	RSqlStatement stmt;
sl@0: 	t1.HomeTime();
sl@0: 	TInt err = stmt.Prepare(TheDb, _L8("SELECT B FROM A WHERE ROWID=1"));
sl@0: 	t2.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	prepareTime = t2.MicroSecondsFrom(t1);
sl@0: 
sl@0: 	t3.HomeTime();
sl@0: 	err = stmt.Next();
sl@0: 	t4.HomeTime();
sl@0: 	TEST2(err, KSqlAtRow);
sl@0: 	nextTime = t4.MicroSecondsFrom(t3);
sl@0: 
sl@0: 	RSqlColumnReadStream strm;
sl@0: 	t5.HomeTime();
sl@0: 	err = strm.ColumnBinary(stmt, 0);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TRAP(err, strm.ReadL(dataptr, TheBlobSize));
sl@0: 	t6.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TEST2(dataptr.Length(), TheBlobSize);
sl@0: 	readTime = t6.MicroSecondsFrom(t5);
sl@0: 
sl@0: 	strm.Close();
sl@0: 	stmt.Close();
sl@0: 	
sl@0: 	PrintReadTime(prepareTime, nextTime, readTime);
sl@0: 		
sl@0: 	delete data;
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: @SYMTestCaseID			SYSLIB-SQL-UT-4085
sl@0: @SYMTestCaseDesc		SQL, BLOB read, performance tests.
sl@0: 						Tests retrieval of BLOBs using the old
sl@0: 						APIs and the new RSqlBlobReadStream APIs.
sl@0: @SYMTestPriority		Medium
sl@0: @SYMTestActions			Retrieval of blobs using the old and new APIs.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ					REQ5912
sl@0: */
sl@0: void BlobReadTest()
sl@0: 	{
sl@0: 	TheTest.Printf(_L("Blob size=%d Kb\r\n"), TheBlobSize / 1024);
sl@0: 	
sl@0: 	// Insert a blob
sl@0: 	TheTest.Printf(_L("==================================================================\r\n"));
sl@0: 	TheTest.Printf(_L("Insert blob\r\n"));
sl@0: 		
sl@0: 	CreateTestDb();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	InsertBlobExec();
sl@0: 	PrintFileSize(TheDb);
sl@0: 	TheDb.Close();
sl@0: 		
sl@0: 	// Read the blob
sl@0: 	TheTest.Printf(_L("==================================================================\r\n"));
sl@0: 		
sl@0: 	TheTest.Printf(_L("Read blob - RSqlBlobReadStream\r\n"));	
sl@0: 	TInt err = TheDb.Open(TheDbFileName);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	ReadBlobIncr();
sl@0: 	TheDb.Close();
sl@0: 
sl@0: 	TheTest.Printf(_L("Read blob - RSqlStatement::ColumnBinary(TInt, TDes8&)\r\n"));	
sl@0: 	err = TheDb.Open(TheDbFileName);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	ReadBlobColDes();
sl@0: 	TheDb.Close();
sl@0: 		
sl@0: 	TheTest.Printf(_L("Read blob - RSqlStatement::ColumnBinary(TInt, TPtrC8&)\r\n"));	
sl@0: 	err = TheDb.Open(TheDbFileName);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	ReadBlobColPtr();
sl@0: 	TheDb.Close();
sl@0: 		
sl@0: 	TheTest.Printf(_L("Read blob - RSqlColumnReadStream\r\n"));	
sl@0: 	err = TheDb.Open(TheDbFileName);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	ReadBlobStreamCol();
sl@0: 	TheDb.Close();
sl@0: 		
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: @SYMTestCaseID			SYSLIB-SQL-UT-4115
sl@0: @SYMTestCaseDesc		SQL, sequential BLOB writes, performance tests.
sl@0: 						Tests sequentially writing 32Kb blocks to a 1.125Mb blob
sl@0: 						using the new RSqlBlobWriteStream APIs to examine
sl@0: 					    the write performance at different stages in the 
sl@0: 						sequence.
sl@0: @SYMTestPriority		Medium
sl@0: @SYMTestActions			Sequential writing of a blob using the new RSqlBlobWriteStream APIs.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ					REQ5912
sl@0: */
sl@0: void SequentialWriteTestL()
sl@0: 	{
sl@0: 	const TInt KBufLen = 32768; // 32Kb
sl@0: 	HBufC8* buf = HBufC8::NewL(KBufLen);
sl@0: 	TPtr8 dataPtr =	buf->Des();
sl@0: 	dataPtr.SetLength(KBufLen);
sl@0: 	dataPtr.Fill('A', KBufLen);	
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	InsertZeroBlob(); // insert zeroblob of "TheBlobSize" size
sl@0: 		
sl@0: 	RSqlBlobWriteStream strm;
sl@0: 	strm.OpenL(TheDb, _L("A"), _L("B"));	
sl@0: 								
sl@0: 	// Sequentially write 32Kb blocks of data to the 
sl@0: 	// blob until the 1Mb cache is full and writes to the disk begin.
sl@0: 	// 32 * 32Kb = 1Mb = soft heap limit
sl@0: 	const TInt KItCount = TheBlobSize / KBufLen - 1;
sl@0: 	for(TInt i = 1; i <= KItCount; ++i)
sl@0: 		{
sl@0: 		TheTest.Printf(_L("***Iteration %d\r\n"), i);
sl@0: 		
sl@0: 		PrintFileSize(TheDb);
sl@0: 	
sl@0: 		TTimeIntervalMicroSeconds writeTime;
sl@0: 		TTime t1, t2;
sl@0: 
sl@0: 		t1.HomeTime();
sl@0: 		strm.WriteL(dataPtr);
sl@0: 		t2.HomeTime();		
sl@0: 
sl@0: 		writeTime = t2.MicroSecondsFrom(t1);
sl@0: 							
sl@0: 		PrintWriteTime(TTimeIntervalMicroSeconds(0), writeTime, TTimeIntervalMicroSeconds(0));		
sl@0: 		PrintFileSize(TheDb);		
sl@0: 		}	
sl@0: 			
sl@0: 	TTimeIntervalMicroSeconds commitTime;
sl@0: 	TTime t3, t4;
sl@0: 	t3.HomeTime();
sl@0: 	strm.CommitL();
sl@0: 	t4.HomeTime();	
sl@0: 	commitTime = t4.MicroSecondsFrom(t3);
sl@0: 		
sl@0: 	PrintWriteTime(TTimeIntervalMicroSeconds(0), TTimeIntervalMicroSeconds(0), commitTime);		
sl@0: 	PrintFileSize(TheDb);		
sl@0: 			
sl@0: 	strm.Close();		
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	delete buf;
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: @SYMTestCaseID			SYSLIB-SQL-UT-4116
sl@0: @SYMTestCaseDesc		SQL, transaction sequential BLOB writes, performance tests.
sl@0: 						Tests sequentially writing 32Kb blocks to a 1.125Mb blob
sl@0: 						within a transaction, using the new RSqlBlobWriteStream APIs,
sl@0: 						to examine the write performance at different stages in the 
sl@0: 						sequence.
sl@0: @SYMTestPriority		Medium
sl@0: @SYMTestActions			Sequential writing of a blob within a transactions, using the 
sl@0: 						new RSqlBlobWriteStream APIs.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ					REQ5912
sl@0: */
sl@0: void TransSequentialWriteTestL()
sl@0: 	{
sl@0: 	const TInt KBufLen = 32768; // 32Kb
sl@0: 	HBufC8* buf = HBufC8::NewL(KBufLen);
sl@0: 	TPtr8 dataPtr =	buf->Des();
sl@0: 	dataPtr.SetLength(KBufLen);
sl@0: 	dataPtr.Fill('A', KBufLen);	
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	InsertZeroBlob(); // insert zeroblob of "TheBlobSize" size
sl@0: 		
sl@0: 	RSqlBlobWriteStream strm;
sl@0: 	strm.OpenL(TheDb, _L("A"), _L("B"));
sl@0: 	
sl@0: 	TInt err = TheDb.Exec(_L8("BEGIN"));
sl@0: 	TEST(err >= 0);	
sl@0: 								
sl@0: 	// Sequentially write 32Kb blocks of data to the 
sl@0: 	// blob until the 1Mb cache is full and writes to the disk begin.
sl@0: 	// 32 * 32Kb = 1Mb = soft heap limit
sl@0: 	const TInt KItCount = TheBlobSize / KBufLen - 1;
sl@0: 	for(TInt i = 1; i <= KItCount; ++i)
sl@0: 		{
sl@0: 		TheTest.Printf(_L("***Iteration %d\r\n"), i);
sl@0: 		
sl@0: 		PrintFileSize(TheDb);
sl@0: 	
sl@0: 		TTimeIntervalMicroSeconds writeTime;
sl@0: 		TTime t1, t2;
sl@0: 		
sl@0: 		t1.HomeTime();
sl@0: 		strm.WriteL(dataPtr);
sl@0: 		t2.HomeTime();	
sl@0: 
sl@0: 		writeTime = t2.MicroSecondsFrom(t1);
sl@0: 							
sl@0: 		PrintWriteTime(TTimeIntervalMicroSeconds(0), writeTime, TTimeIntervalMicroSeconds(0));		
sl@0: 		PrintFileSize(TheDb);		
sl@0: 		}	
sl@0: 		
sl@0: 	TTimeIntervalMicroSeconds commitTime;
sl@0: 	TTime t3, t4;
sl@0: 	
sl@0: 	t3.HomeTime();
sl@0: 	strm.CommitL();
sl@0: 	t4.HomeTime();	
sl@0: 	commitTime = t4.MicroSecondsFrom(t3);
sl@0: 
sl@0: 	PrintWriteTime(TTimeIntervalMicroSeconds(0), TTimeIntervalMicroSeconds(0), commitTime);		
sl@0: 	PrintFileSize(TheDb);		
sl@0: 		
sl@0: 	TTime t5, t6;
sl@0: 	t5.HomeTime();	
sl@0: 	err = TheDb.Exec(_L8("COMMIT"));
sl@0: 	t6.HomeTime();	
sl@0: 	TEST(err >= 0);
sl@0: 	
sl@0: 	TTimeIntervalMicroSeconds transCommitTime = t6.MicroSecondsFrom(t5);		
sl@0: 	PrintWriteTime(TTimeIntervalMicroSeconds(0), TTimeIntervalMicroSeconds(0), transCommitTime);		
sl@0: 	PrintFileSize(TheDb);	
sl@0: 			
sl@0: 	strm.Close();		
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	delete buf;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID			SYSLIB-SQL-UT-4117
sl@0: @SYMTestCaseDesc		SQL, whole BLOB write, performance tests.
sl@0: 						Tests writing a 256Kb data block to a 256Kb blob to examine the
sl@0: 						relative performance of the TSqlBlob and RSqlBlobWriteStream APIs.
sl@0: @SYMTestPriority		Medium
sl@0: @SYMTestActions			Whole update of a blob using the new TSqlBlob and RSqlBlobWriteStream APIs.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ					REQ5912
sl@0: */
sl@0: void WholeWriteTestL()
sl@0: 	{
sl@0: 	TInt bufLen = TheBlobSize; 
sl@0: 	HBufC8* buf = HBufC8::NewL(bufLen);
sl@0: 	TPtr8 dataPtr =	buf->Des();
sl@0: 	dataPtr.SetLength(bufLen);
sl@0: 	dataPtr.Fill('Z', bufLen);	
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	InsertRealBlob(); // insert blob of "TheBlobSize" size
sl@0: 			
sl@0: 	TheTest.Printf(_L("***WholeWriteTestL - %dKb blob \r\n"), TheBlobSize / 1024);		
sl@0: 	PrintFileSize(TheDb);
sl@0: 	
sl@0: 	// TSqlBlob::Set
sl@0: 	TTimeIntervalMicroSeconds writeTime;
sl@0: 	TTime t1, t2, t3, t4;
sl@0: 
sl@0: 	t1.HomeTime();
sl@0: 	TSqlBlob::SetL(TheDb, _L("A"), _L("B"), dataPtr);	
sl@0: 	t2.HomeTime();	
sl@0: 		
sl@0: 	writeTime = t2.MicroSecondsFrom(t1);
sl@0: 								
sl@0: 	PrintWriteTime(TTimeIntervalMicroSeconds(0), writeTime, TTimeIntervalMicroSeconds(0));		
sl@0: 	PrintFileSize(TheDb);
sl@0: 	
sl@0: 	// to avoid caching issues, close and re-create the database for the next part
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);		
sl@0: 	CreateTestDb();
sl@0: 	InsertRealBlob(); // insert blob of "TheBlobSize" size
sl@0: 	PrintFileSize(TheDb);
sl@0: 
sl@0: 	// RSqlBlobWriteStream::WriteL
sl@0: 	t3.HomeTime();
sl@0: 	RSqlBlobWriteStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	strm.OpenL(TheDb, _L("A"), _L("B"));	
sl@0: 	strm.WriteL(dataPtr);
sl@0: 	CleanupStack::PopAndDestroy(&strm);
sl@0: 	t4.HomeTime();	
sl@0: 		
sl@0: 	writeTime = t4.MicroSecondsFrom(t3);
sl@0: 							
sl@0: 	PrintWriteTime(TTimeIntervalMicroSeconds(0), writeTime, TTimeIntervalMicroSeconds(0));		
sl@0: 	PrintFileSize(TheDb);				
sl@0: 				
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	delete buf;
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: @SYMTestCaseID			SYSLIB-SQL-UT-4118
sl@0: @SYMTestCaseDesc		SQL, transaction whole BLOB write, performance tests.
sl@0: 						Tests writing a 256Kb data block to a 256Kb blob, within a transaction,
sl@0: 						to examine the relative performance of the TSqlBlob and RSqlBlobWriteStream APIs.
sl@0: @SYMTestPriority		Medium
sl@0: @SYMTestActions			Whole update of a blob, within a transaction, using the new TSqlBlob and 
sl@0: 						RSqlBlobWriteStream APIs.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ					REQ5912
sl@0: */
sl@0: void TransWholeWriteTestL()
sl@0: 	{
sl@0: 	TInt bufLen = TheBlobSize;
sl@0: 	HBufC8* buf = HBufC8::NewL(bufLen);
sl@0: 	TPtr8 dataPtr =	buf->Des();
sl@0: 	dataPtr.SetLength(bufLen);
sl@0: 	dataPtr.Fill('Z', bufLen);	
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	InsertRealBlob(); // insert blob of "TheBlobSize" size
sl@0: 	
sl@0: 	TheTest.Printf(_L("***TransWholeWriteTestL - %dKb blob\r\n"), TheBlobSize / 1024);	
sl@0: 	PrintFileSize(TheDb);
sl@0: 		
sl@0: 	// TSqlBlob::Set
sl@0: 	TTimeIntervalMicroSeconds writeTime;
sl@0: 	TTime t1, t2, t3, t4;
sl@0: 
sl@0: 	t1.HomeTime();
sl@0: 	TInt err = TheDb.Exec(_L8("BEGIN"));
sl@0: 	TEST(err >= 0);		
sl@0: 	TSqlBlob::SetL(TheDb, _L("A"), _L("B"), dataPtr);			
sl@0: 	err = TheDb.Exec(_L8("COMMIT"));
sl@0: 	t2.HomeTime();	
sl@0: 	TEST(err >= 0);	
sl@0: 
sl@0: 	writeTime = t2.MicroSecondsFrom(t1);
sl@0: 							
sl@0: 	PrintWriteTime(TTimeIntervalMicroSeconds(0), writeTime, TTimeIntervalMicroSeconds(0));		
sl@0: 	PrintFileSize(TheDb);	
sl@0: 	
sl@0: 	// to avoid caching issues, close and re-create the database for the next part
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	CreateTestDb();
sl@0: 	InsertRealBlob(); // insert blob of "TheBlobSize" size
sl@0: 	PrintFileSize(TheDb);
sl@0: 	
sl@0: 	// RSqlBlobWriteStream::WriteL
sl@0: 	t3.HomeTime();
sl@0: 	err = TheDb.Exec(_L8("BEGIN"));
sl@0: 	TEST(err >= 0);	
sl@0: 	RSqlBlobWriteStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	strm.OpenL(TheDb, _L("A"), _L("B"));	
sl@0: 	strm.WriteL(dataPtr);
sl@0: 	CleanupStack::PopAndDestroy(&strm);
sl@0: 	err = TheDb.Exec(_L8("COMMIT"));
sl@0: 	t4.HomeTime();
sl@0: 	TEST(err >= 0);	
sl@0: 
sl@0: 	writeTime = t4.MicroSecondsFrom(t3);
sl@0: 							
sl@0: 	PrintWriteTime(TTimeIntervalMicroSeconds(0), writeTime, TTimeIntervalMicroSeconds(0));		
sl@0: 	PrintFileSize(TheDb);				
sl@0: 				
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	delete buf;
sl@0: 	}	
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID			SYSLIB-SQL-UT-4119
sl@0: @SYMTestCaseDesc		SQL, whole BLOB read, performance tests.
sl@0: 						Tests reading a 256Kb blob in one block to examine the
sl@0: 						relative performance of the TSqlBlob and RSqlBlobReadStream APIs.
sl@0: @SYMTestPriority		Medium
sl@0: @SYMTestActions			Whole retrieval of a blob using the new TSqlBlob and RSqlBlobReadStream APIs.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ					REQ5912
sl@0: */	
sl@0: void WholeReadTestL()
sl@0: 	{
sl@0: 	TInt bufLen = TheBlobSize; 
sl@0: 	HBufC8* buf = HBufC8::NewL(bufLen);
sl@0: 	TPtr8 dataPtr =	buf->Des();
sl@0: 	dataPtr.SetLength(bufLen);
sl@0: 	dataPtr.Fill('A', bufLen);	
sl@0: 	
sl@0: 	CreateTestDb();
sl@0: 	InsertRealBlob(); // insert blob of "TheBlobSize" size
sl@0: 	
sl@0: 	TheTest.Printf(_L("***WholeReadTestL - %dKb blob \r\n"), TheBlobSize / 1024);
sl@0: 	PrintFileSize(TheDb);
sl@0: 	
sl@0: 	// TSqlBlob::GetLC
sl@0: 	TTimeIntervalMicroSeconds readTime;
sl@0: 	TTime t1, t2, t3, t4, t5, t6;
sl@0: 
sl@0: 	t1.HomeTime();
sl@0: 	HBufC8* readBuf = TSqlBlob::GetLC(TheDb, _L("A"), _L("B"));
sl@0: 	t2.HomeTime();
sl@0: 	TEST(readBuf->Des().Compare(buf->Des()) == 0);
sl@0: 	
sl@0: 	readTime = t2.MicroSecondsFrom(t1);
sl@0: 							
sl@0: 	PrintReadTime(TTimeIntervalMicroSeconds(0), readTime);
sl@0: 	PrintFileSize(TheDb);				
sl@0: 	CleanupStack::PopAndDestroy(readBuf);
sl@0: 	
sl@0: 	// to avoid caching issues, close and re-create the database for the next part
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	CreateTestDb();
sl@0: 	InsertRealBlob(); // insert blob of "TheBlobSize" size
sl@0: 	PrintFileSize(TheDb);
sl@0: 	
sl@0: 	// TSqlBlob::Get
sl@0: 	HBufC8* preBuf = HBufC8::NewLC(bufLen);
sl@0: 	TPtr8 preBufPtr(preBuf->Des());
sl@0: 	t3.HomeTime();
sl@0: 	TInt err = TSqlBlob::Get(TheDb, _L("A"), _L("B"), preBufPtr);	
sl@0: 	t4.HomeTime();
sl@0: 	TEST2(err, KErrNone);
sl@0: 	TEST(preBufPtr.Compare(buf->Des()) == 0);
sl@0: 
sl@0: 	readTime = t4.MicroSecondsFrom(t3);
sl@0: 							
sl@0: 	PrintReadTime(TTimeIntervalMicroSeconds(0), readTime);
sl@0: 	PrintFileSize(TheDb);				
sl@0: 	CleanupStack::PopAndDestroy(preBuf);
sl@0: 	
sl@0: 	// to avoid caching issues, close and re-create the database for the next part
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 	CreateTestDb();
sl@0: 	InsertRealBlob(); // insert blob of "TheBlobSize" size
sl@0: 	PrintFileSize(TheDb);
sl@0: 	
sl@0: 	// RSqlBlobReadStream::ReadL
sl@0: 	preBuf = HBufC8::NewLC(bufLen);	
sl@0: 	TPtr8 preBufP(preBuf->Des());
sl@0: 	t5.HomeTime();
sl@0: 	RSqlBlobReadStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	strm.OpenL(TheDb, _L("A"), _L("B"));
sl@0: 	strm.ReadL(preBufP, bufLen);
sl@0: 	CleanupStack::PopAndDestroy(&strm);
sl@0: 	t6.HomeTime();
sl@0: 	TEST(preBufP.Compare(buf->Des()) == 0);
sl@0: 		
sl@0: 	readTime = t6.MicroSecondsFrom(t5);
sl@0: 							
sl@0: 	PrintReadTime(TTimeIntervalMicroSeconds(0), readTime);
sl@0: 	PrintFileSize(TheDb);	
sl@0: 	CleanupStack::PopAndDestroy(preBuf);
sl@0: 			
sl@0: 	TheDb.Close();
sl@0: 	(void)RSqlDatabase::Delete(TheDbFileName);
sl@0: 		
sl@0: 	delete buf;
sl@0: 	}
sl@0: ///////////////////////////////////////////////////////////////////////////////////
sl@0: ///////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: void DoTests()
sl@0: 	{
sl@0: 	TheTestTitle.Format(_L("@SYMTestCaseID:SYSLIB-SQL-UT-4084 SQL, BLOB write, performance tests, encoding: \"%S\", page size: %d\r\n"), 
sl@0: 			TheCmdLineParams.iDbEncoding == TCmdLineParams::EDbUtf16 ? &KUtf16 : &KUtf8, TheCmdLineParams.iPageSize);
sl@0: 	TheTest.Start(TheTestTitle);
sl@0: 	BlobWriteTest();
sl@0: 	
sl@0: 	TheTestTitle.Format(_L("@SYMTestCaseID:SYSLIB-SQL-UT-4085 SQL, BLOB read, performance tests, encoding: \"%S\", page size: %d\r\n"), 
sl@0: 			TheCmdLineParams.iDbEncoding == TCmdLineParams::EDbUtf16 ? &KUtf16 : &KUtf8, TheCmdLineParams.iPageSize);
sl@0: 	TheTest.Next(TheTestTitle);
sl@0: 	BlobReadTest();
sl@0: 
sl@0: 	TheTest.Printf(_L("==================================================================\r\n"));
sl@0: 	
sl@0: 	// Bigger blob tests - only on hardware, release mode
sl@0: #if !defined __WINS__ && !defined __WINSCW__ && !defined _DEBUG
sl@0: 	
sl@0: 	TheBlobSize = 1024 * 1024 + 128 * 1024;//1.125Mb 
sl@0: 
sl@0: 	TheTestTitle.Format(_L("@SYMTestCaseID:SYSLIB-SQL-UT-4115 SQL, sequential BLOB writes, performance tests, encoding: \"%S\", page size: %d\r\n"), 
sl@0: 			TheCmdLineParams.iDbEncoding == TCmdLineParams::EDbUtf16 ? &KUtf16 : &KUtf8, TheCmdLineParams.iPageSize);
sl@0: 	TheTest.Next(TheTestTitle);
sl@0: 	TRAPD(err, SequentialWriteTestL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	TheTestTitle.Format(_L("@SYMTestCaseID:SYSLIB-SQL-UT-4116 SQL, transaction sequential BLOB writes, performance tests, encoding: \"%S\", page size: %d\r\n"), 
sl@0: 			TheCmdLineParams.iDbEncoding == TCmdLineParams::EDbUtf16 ? &KUtf16 : &KUtf8, TheCmdLineParams.iPageSize);
sl@0: 	TheTest.Next(TheTestTitle);
sl@0: 	TRAP(err, TransSequentialWriteTestL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 		
sl@0: 	TheBlobSize = 256 * 1024 ; // 256Kb
sl@0: 		
sl@0: 	TheTestTitle.Format(_L("@SYMTestCaseID:SYSLIB-SQL-UT-4117 SQL, whole BLOB write, performance tests, encoding: \"%S\", page size: %d\r\n"), 
sl@0: 			TheCmdLineParams.iDbEncoding == TCmdLineParams::EDbUtf16 ? &KUtf16 : &KUtf8, TheCmdLineParams.iPageSize);
sl@0: 	TheTest.Next(TheTestTitle);
sl@0: 	TRAP(err, WholeWriteTestL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	TheTestTitle.Format(_L("@SYMTestCaseID:SYSLIB-SQL-UT-4118 SQL, transaction whole BLOB write, performance tests, encoding: \"%S\", page size: %d\r\n"), 
sl@0: 			TheCmdLineParams.iDbEncoding == TCmdLineParams::EDbUtf16 ? &KUtf16 : &KUtf8, TheCmdLineParams.iPageSize);
sl@0: 	TheTest.Next(TheTestTitle);
sl@0: 	TRAP(err, TransWholeWriteTestL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: 	TheTestTitle.Format(_L("@SYMTestCaseID:SYSLIB-SQL-UT-4119 SQL, whole BLOB read, performance tests, encoding: \"%S\", page size: %d\r\n"), 
sl@0: 			TheCmdLineParams.iDbEncoding == TCmdLineParams::EDbUtf16 ? &KUtf16 : &KUtf8, TheCmdLineParams.iPageSize);
sl@0: 	TheTest.Next(TheTestTitle);
sl@0: 	TRAP(err, WholeReadTestL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	
sl@0: #endif//!defined __WINS__ && !defined __WINSCW__ && !defined _DEBUG
sl@0: 	}
sl@0: 
sl@0: TInt E32Main()
sl@0: 	{
sl@0: 	TheTest.Title();
sl@0: 
sl@0: 	CTrapCleanup* tc = CTrapCleanup::New();
sl@0: 	TheTest(tc != NULL);
sl@0: 
sl@0: 	__UHEAP_MARK;
sl@0: 
sl@0: 	GetCmdLineParamsAndSqlConfigString(TheTest, _L("t_sqlperformance2"), TheCmdLineParams, TheSqlConfigString);
sl@0: 	_LIT(KDbName, "c:\\test\\t_sqlperformance2.db");
sl@0: 	PrepareDbName(KDbName, TheCmdLineParams.iDriveName, TheDbFileName);
sl@0: 
sl@0: 	TheTest.Printf(_L("==Databases: %S\r\n"), &TheDbFileName); 
sl@0: 	
sl@0: 	TestEnvInit();
sl@0: 	DoTests();
sl@0: 	TestEnvDestroy();
sl@0: 
sl@0: 	__UHEAP_MARKEND;
sl@0: 	
sl@0: 	TheTest.End();
sl@0: 	TheTest.Close();
sl@0: 	
sl@0: 	delete tc;
sl@0: 
sl@0: 	User::Heap().Check();
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 	
sl@0: