sl@0: // Copyright (c) 1998-2009 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: #include <d32dbms.h>
sl@0: #include <s32file.h>
sl@0: #include <e32test.h>
sl@0: #include <e32math.h>
sl@0: #include <hal.h>
sl@0: 
sl@0: static RTest TheTest(_L("t_dbtrans: Test DBMS transactions"));
sl@0: static RDbTable TheTable;
sl@0: static RFs TheFs;
sl@0: static RDbs TheDbs;
sl@0: static RDbNamedDatabase TheDatabase;
sl@0: 
sl@0: static TFileName TheTestDbFileName;
sl@0: 
sl@0: const TPtrC KTableName(_S("table"));
sl@0: const TPtrC KIndexInt=_S("int");
sl@0: const TPtrC KIndexText=_S("text");
sl@0: const TPtrC KColumnInt=_S("int");
sl@0: const TPtrC KColumnText=_S("text");
sl@0: const TPtrC KColumnComment=_S("comment");
sl@0: const TPtrC KCommentValue=_S("abcdefghijklmnopqrstuvwxyz");
sl@0: const TInt KRecords=2000;
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: static void CloseAll()
sl@0: 	{
sl@0: 	TheTable.Close();
sl@0: 	TheDatabase.Close();
sl@0: 	TheDbs.Close();
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: //Delete "aFullName" file.
sl@0: static void DeleteFile(const TDesC& aFullName)
sl@0: 	{
sl@0: 	RFs fsSession;
sl@0: 	TInt err = fsSession.Connect();
sl@0: 	if(err == KErrNone)
sl@0: 		{
sl@0: 		TEntry entry;
sl@0: 		if(fsSession.Entry(aFullName, entry) == KErrNone)
sl@0: 			{
sl@0: 			err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
sl@0: 			if(err != KErrNone) 
sl@0: 				{
sl@0: 				TheTest.Printf(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);
sl@0: 				}
sl@0: 			err = fsSession.Delete(aFullName);
sl@0: 			if(err != KErrNone) 
sl@0: 				{
sl@0: 				TheTest.Printf(_L("Error %d deleting \"%S\" file.\n"), err, &aFullName);
sl@0: 				}
sl@0: 			}
sl@0: 		fsSession.Close();
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		TheTest.Printf(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: static void DestroyTestEnv()
sl@0: 	{
sl@0: 	CloseAll();
sl@0: 	DeleteFile(TheTestDbFileName);
sl@0: 	TheFs.Close();
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: //Tests macros and functions.
sl@0: //If (!aValue) then the test will be panicked, the test data files will be deleted.
sl@0: static void Check(TInt aValue, TInt aLine)
sl@0: 	{
sl@0: 	if(!aValue)
sl@0: 		{
sl@0: 		TheTest.Printf(_L("*** Boolean expression evaluated to false!\r\n"));
sl@0: 		DestroyTestEnv();
sl@0: 		TheTest(EFalse, aLine);
sl@0: 		}
sl@0: 	}
sl@0: //If (aValue != aExpected) then the test will be panicked, the test data files will be deleted.
sl@0: static void Check(TInt aValue, TInt aExpected, TInt aLine)
sl@0: 	{
sl@0: 	if(aValue != aExpected)
sl@0: 		{
sl@0: 		TheTest.Printf(_L("*** Expected error: %d, got: %d\r\n"), aExpected, aValue);
sl@0: 		DestroyTestEnv();
sl@0: 		TheTest(EFalse, aLine);
sl@0: 		}
sl@0: 	}
sl@0: //Use these to test conditions.
sl@0: #define TEST(arg) ::Check((arg), __LINE__)
sl@0: #define TEST2(aValue, aExpected) ::Check(aValue, aExpected, __LINE__)
sl@0: 
sl@0: //////////////////////////////////////////////////////
sl@0: 
sl@0: static TInt TheCounterFreq = -10000000;
sl@0: const TInt KMicroSecIn1Sec = 1000000;
sl@0: 
sl@0: TUint32 CalcTickDiff(TUint32 aStartTicks, TUint32 aEndTicks)
sl@0: 	{
sl@0: 	TInt64 diffTicks = (TInt64)aEndTicks - (TInt64)aStartTicks;
sl@0: 	if(diffTicks < 0)
sl@0: 		{
sl@0: 		diffTicks = KMaxTUint32 + diffTicks + 1;
sl@0: 		}
sl@0: 	return (TUint32)diffTicks;
sl@0: 	}
sl@0: 
sl@0: //Prints aFastCount parameter (converted to us)
sl@0: void PrintFcDiffAsUs(const TDesC& aFormatStr, TUint32 aFastCount)
sl@0: 	{
sl@0: 	if(TheCounterFreq <= 0)
sl@0: 		{
sl@0: 		TEST2(HAL::Get(HAL::EFastCounterFrequency, TheCounterFreq), KErrNone);
sl@0: 		TheTest.Printf(_L("Counter frequency=%d Hz\r\n"), TheCounterFreq);
sl@0: 		}
sl@0: 	double v = ((double)aFastCount * KMicroSecIn1Sec) / (double)TheCounterFreq;
sl@0: 	TInt v2 = (TInt)v;
sl@0: 	TheTest.Printf(aFormatStr, v2);
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: //
sl@0: // Prepare the test directory.
sl@0: //
sl@0: void CreateTestEnv()
sl@0:     {
sl@0: 	TInt err = TheFs.Connect();
sl@0: 	TheTest(err == KErrNone);
sl@0: 
sl@0: 	err = TheFs.MkDirAll(TheTestDbFileName);
sl@0: 	TEST(err == KErrNone || err == KErrAlreadyExists);
sl@0: 	}
sl@0: 
sl@0: ///////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: class Progress
sl@0: 	{
sl@0: 	enum {ETotal=32};
sl@0: public:
sl@0: 	Progress(TInt aCount);
sl@0: 	void Next(TInt aStep);
sl@0: private:
sl@0: 	TInt iCount;
sl@0: 	TInt iPos;
sl@0: 	};
sl@0: 
sl@0: Progress::Progress(TInt aCount)
sl@0: 	: iCount(aCount),iPos(0)
sl@0: 	{}
sl@0: 
sl@0: void Progress::Next(TInt aStep)
sl@0: 	{
sl@0: 	TInt next=(ETotal*(iCount-aStep))/iCount;
sl@0: 	if (next!=iPos)
sl@0: 		{
sl@0: 		iPos=next;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: static void ProgressInc(RDbIncremental& inc,TInt aCount)
sl@0: 	{
sl@0: 	Progress progress(aCount);
sl@0: 	while (aCount)
sl@0: 		{
sl@0: 		inc.Next(aCount);
sl@0: 		progress.Next(aCount);
sl@0: 		}
sl@0: 	inc.Close();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Create the database
sl@0: //
sl@0: static void CreateDatabase()
sl@0: 	{
sl@0: 	TInt err = TheDatabase.Replace(TheFs, TheTestDbFileName);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Create the database
sl@0: //
sl@0: static void OpenDatabase()
sl@0: 	{
sl@0: 	TInt err = TheDatabase.Open(TheFs, TheTestDbFileName);
sl@0: 	TEST2(err, KErrNone);
sl@0: 	}
sl@0: 
sl@0: static void CloseDatabase()
sl@0: 	{
sl@0: 	TheDatabase.Close();
sl@0: 	}
sl@0: 
sl@0: static void CreateTable()
sl@0: 	{
sl@0: 	TInt err = TheDatabase.Execute(_L("create table table (int integer,text varchar(8),comment varchar)"));
sl@0: 	TEST2(err, KErrNone);
sl@0: 	}
sl@0: 
sl@0: static void WriteRecordsL(TInt aCount)
sl@0: 	{
sl@0: 	Progress write(aCount);
sl@0: 	TDbColNo cInt,cText,cComment;
sl@0: 	CDbColSet* set=TheTable.ColSetL();
sl@0: 	cInt=set->ColNo(KColumnInt);
sl@0: 	cText=set->ColNo(KColumnText);
sl@0: 	cComment=set->ColNo(KColumnComment);
sl@0: 	delete set;
sl@0: 	TBuf<10> text;
sl@0: 	TInt jj=0;
sl@0: 	for (TInt ii=0;ii<aCount;++ii)
sl@0: 		{
sl@0: 		TheTable.InsertL();
sl@0: 		jj=(jj+23);
sl@0: 		if (jj>=aCount)
sl@0: 			jj-=aCount;
sl@0: 		TheTable.SetColL(cInt,jj);
sl@0: 		text.Num(jj);
sl@0: 		TheTable.SetColL(cText,text);
sl@0: 		TheTable.SetColL(cComment,KCommentValue);
sl@0: 		TheTable.PutL();
sl@0: 		write.Next(aCount-ii-1);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: static TUint FileSize()
sl@0: 	{
sl@0: 	TEntry entry;
sl@0: 	TEST2(TheFs.Entry(TheTestDbFileName, entry), KErrNone);
sl@0: 	return entry.iSize;
sl@0: 	}
sl@0: 
sl@0: static void BuildTableL(TInt aCount, TBool aTransactions, TUint32& aTicks, TUint& aSize)
sl@0: 	{
sl@0: 	TUint size = FileSize();
sl@0: 	TUint fc = User::FastCounter();
sl@0: 	CreateTable();
sl@0: 	if(aTransactions)
sl@0: 		{
sl@0: 		TheDatabase.Begin();
sl@0: 		}
sl@0: 	TEST2(TheTable.Open(TheDatabase, KTableName), KErrNone);
sl@0: 	WriteRecordsL(aCount);
sl@0: 	if(aTransactions)
sl@0: 		{
sl@0: 		TEST2(TheDatabase.Commit(), KErrNone);
sl@0: 		}
sl@0: 	TheTable.Close();
sl@0: 	aTicks = CalcTickDiff(fc, User::FastCounter());
sl@0: 	aSize = FileSize() - size;
sl@0: 	}
sl@0: 
sl@0: static void Execute(const TDesC& aSql)
sl@0: 	{
sl@0: 	RDbIncremental inc;
sl@0: 	TInt step;
sl@0: 	TEST2(inc.Execute(TheDatabase,aSql,step), KErrNone);
sl@0: 	ProgressInc(inc,step);
sl@0: 	}
sl@0: 
sl@0: static void BreakIndexL()
sl@0: 	{
sl@0: 	TheDatabase.Begin();
sl@0: 	TEST2(TheTable.Open(TheDatabase,KTableName), KErrNone);
sl@0: 	TheTable.InsertL();
sl@0: 	TheTable.SetColL(1,-1);
sl@0: 	TheTable.PutL();
sl@0: 	TheTable.Close();
sl@0: 	TheDatabase.Rollback();
sl@0: 	TEST(TheDatabase.IsDamaged());
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void Recover()
sl@0: 	{
sl@0: 	RDbIncremental rec;
sl@0: 	TInt step;
sl@0: 	TEST2(rec.Recover(TheDatabase,step), KErrNone);
sl@0: 	ProgressInc(rec,step);
sl@0: 	TEST(!TheDatabase.IsDamaged());
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0637
sl@0: @SYMTestCaseDesc        Streaming conversions test
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Test the database definition and enquiry functions
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: static void TestL()
sl@0: 	{
sl@0: 	TheTest.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0637 Build without transactions "));
sl@0: 	CreateDatabase();
sl@0: 	TUint32 ticks1;
sl@0: 	TUint size1;
sl@0: 	BuildTableL(KRecords, EFalse, ticks1, size1);
sl@0: 	CloseDatabase();
sl@0: 	
sl@0: 	TheTest.Next(_L("Build with transactions"));
sl@0: 	CreateDatabase();
sl@0: 	TUint32 ticks2;
sl@0: 	TUint size2;
sl@0: 	BuildTableL(KRecords, ETrue, ticks2, size2);
sl@0: 	
sl@0: 	PrintFcDiffAsUs(_L("#### Without transactions, time=%d us\n"), ticks1);
sl@0: 	PrintFcDiffAsUs(_L("#### With    transactions, time=%d us\n"), ticks2);
sl@0: 	TheTest.Printf(_L("Transaction performance ratio (without trn:with trn): time %4.2f, size %4.2f\n"), TReal(ticks1) / TReal(ticks2), TReal(size1) / TReal(size2));
sl@0: 	
sl@0: 	TheTest.Next(_L("Build Int index"));
sl@0: 	Execute(_L("create unique index int on table (int)"));
sl@0: 	
sl@0: 	TheTest.Next(_L("Break index"));
sl@0: 	BreakIndexL();
sl@0: 	
sl@0: 	TheTest.Next(_L("Build Text index"));
sl@0: 	Execute(_L("create unique index text on table (text)"));
sl@0: 	
sl@0: 	TheTest.Next(_L("Recover"));
sl@0: 	TEST(TheDatabase.IsDamaged());
sl@0: 	
sl@0: 	CloseDatabase();
sl@0: 	OpenDatabase();
sl@0: 	TEST(TheDatabase.IsDamaged());
sl@0: 	Recover();
sl@0: 	
sl@0: 	TheTest.Next(_L("Drop table"));
sl@0: 	Execute(_L("drop table table"));
sl@0: 	CloseDatabase();
sl@0: 	}
sl@0: 
sl@0: //Usage: "t_trans [<drive letter>:]]"
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: 	TBuf<256> cmdline;
sl@0: 	User::CommandLine(cmdline);
sl@0: 
sl@0: 	TParse parse;
sl@0: 
sl@0: 	_LIT(KTestDatabase, "C:\\DBMS-TST\\T_TRANS.DB");
sl@0: 	parse.Set(cmdline, &KTestDatabase, 0);
sl@0: 	TheTestDbFileName.Copy(parse.FullName());
sl@0: 	
sl@0: 	__UHEAP_MARK;
sl@0: 	
sl@0: 	CreateTestEnv();
sl@0: 	TRAPD(err, TestL());
sl@0: 	TEST2(err, KErrNone);
sl@0: 	DestroyTestEnv();
sl@0: 
sl@0: 	delete tc;
sl@0: 
sl@0: 	__UHEAP_MARKEND;
sl@0: 	
sl@0: 	TheTest.End();
sl@0: 	TheTest.Close();
sl@0: 	
sl@0: 	return 0;
sl@0:     }