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: 
sl@0: #include <d32dbms.h>
sl@0: #include <s32file.h>
sl@0: #include <e32test.h>
sl@0: #include <e32math.h>
sl@0: #include <e32svr.h>
sl@0: #include <hal.h>
sl@0: #include <d32dbmsconstants.h>
sl@0: 
sl@0: // MSVC++ up to 5.0 has problems with expanding inline functions
sl@0: // This disables the mad warnings for the whole project
sl@0: #if defined(NDEBUG) && defined(__VC32__) && _MSC_VER<=1100
sl@0: #pragma warning(disable : 4710)			// function not expanded. MSVC 5.0 is stupid
sl@0: #endif
sl@0: 
sl@0: class TTimer
sl@0: 	{
sl@0: public:
sl@0: 	void Start();
sl@0: 	TReal Stop() const;
sl@0: private:
sl@0: 	TUint iTicks;
sl@0: 	};
sl@0: 
sl@0: LOCAL_D RTest test(_L("t_dbbench"));
sl@0: LOCAL_D CTrapCleanup* TheTrapCleanup;
sl@0: LOCAL_D RDbNamedDatabase TheDatabase;
sl@0: LOCAL_D RDbView TheView;
sl@0: LOCAL_D RFs TheFs;
sl@0: 
sl@0: const TInt KTestCleanupStack=0x20;
sl@0: //T_BENCH file shall not be deleted at the end of the test! It will be used by T_COMP test.
sl@0: const TPtrC KTestDatabase=_S("\\DBMS-TST\\T_BENCH.DB");
sl@0: const TPtrC KTableName=_S("Test");
sl@0: const TPtrC KColCluster=_S("Cluster");
sl@0: const TPtrC KColXcluster=_S("xCluster");
sl@0: const TPtrC KColRandom=_S("Random");
sl@0: const TPtrC KColXrandom=_S("xRandom");
sl@0: const TInt KRecords=2000;
sl@0: 
sl@0: static TTimer TheTimer;
sl@0: 
sl@0: void TTimer::Start()
sl@0: 	{
sl@0: 	iTicks=User::FastCounter();
sl@0: 	}
sl@0: 
sl@0: TReal TTimer::Stop() const
sl@0: 	{
sl@0: 	TUint ticks = User::FastCounter() - iTicks;
sl@0: 	TInt freq = 0;
sl@0: 	test(HAL::Get(HAL::EFastCounterFrequency, freq) == KErrNone);
sl@0: 	const TInt KMicroSecIn1Sec = 1000000;
sl@0: 	const TInt KMsIn1Sec = 1000;
sl@0: 	double v = ((double)ticks * KMicroSecIn1Sec) / (double)freq; TInt v2 = (TInt)v;
sl@0: 	return v2 / KMsIn1Sec;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void CloseDatabase()
sl@0: 	{
sl@0: 	TheDatabase.Close();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Create the database: keep the code 050 compatible
sl@0: 
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0577
sl@0: @SYMTestCaseDesc        Benchmark Tests. Creation of a local Database test
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions        	Attempt to test RDbNamedDatabase::CreateTable(),RDbNamedDatabase::CreateIndex(),
sl@0: 						RDbNamedDatabase::Compact(),RDbView::Prepare() functions
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void CreateDatabaseL()
sl@0: 	{
sl@0: 	test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0577 "));
sl@0: 	User::LeaveIfError(TheDatabase.Replace(TheFs,KTestDatabase));
sl@0: 	CDbColSet& set=*CDbColSet::NewLC();
sl@0: 	TDbCol col(KColCluster,EDbColInt32);
sl@0: 	col.iAttributes=col.ENotNull;
sl@0: 	set.AddL(col);
sl@0: 	col.iName=KColXcluster;
sl@0: 	set.AddL(col);
sl@0: 	col.iName=KColRandom;
sl@0: 	set.AddL(col);
sl@0: 	col.iName=KColXrandom;
sl@0: 	set.AddL(col);
sl@0: 	TInt r=TheDatabase.CreateTable(KTableName,set);
sl@0: 	test (r==KErrNone);
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	TheTimer.Start();
sl@0: 	r=TheView.Prepare(TheDatabase,_L("select * from test"),TheView.EInsertOnly);
sl@0: 	TheDatabase.Begin();
sl@0: 	test (r==KErrNone);
sl@0: 	TInt jj=0;
sl@0: 	for (TInt ii=0;ii<KRecords;++ii)
sl@0: 		{
sl@0: 		TheView.InsertL();
sl@0: 		jj=(jj+23);
sl@0: 		if (jj>=KRecords)
sl@0: 			jj-=KRecords;
sl@0: 		TheView.SetColL(1,ii);
sl@0: 		TheView.SetColL(2,ii);
sl@0: 		TheView.SetColL(3,jj);
sl@0: 		TheView.SetColL(4,jj);
sl@0: 		TheView.PutL();
sl@0: 		}
sl@0: 	r=TheDatabase.Commit();
sl@0: 	test (r==KErrNone);
sl@0: 	TheView.Close();
sl@0: 	test.Printf(_L("Build table: %7.1f ms\n"),TheTimer.Stop());
sl@0: 	TheTimer.Start();
sl@0: 	CDbKey& key=*CDbKey::NewLC();
sl@0: 	key.AddL(KColXcluster);
sl@0: 	key.MakeUnique();
sl@0: 	r=TheDatabase.CreateIndex(KColXcluster,KTableName,key);
sl@0: 	test (r==KErrNone);
sl@0: 	test.Printf(_L("Cluster index: %7.1f ms\n"),TheTimer.Stop());
sl@0: 	TheTimer.Start();
sl@0: 	key.Clear();
sl@0: 	key.AddL(KColXrandom);
sl@0: 	r=TheDatabase.CreateIndex(KColXrandom,KTableName,key);
sl@0: 	test (r==KErrNone);
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	test.Printf(_L("Random index: %7.1f ms\n"),TheTimer.Stop());
sl@0: 	TheTimer.Start();
sl@0: 	r = TheDatabase.Compact();
sl@0: 	test.Printf(_L("Compact: %7.1f ms\n"),TheTimer.Stop());
sl@0: 	test (r == KErrNone);
sl@0: 	}
sl@0: 
sl@0: LOCAL_C TReal Evaluate(const TDesC& aSql)
sl@0: 	{
sl@0: 	TInt m=1;
sl@0: 	for (;;)
sl@0: 		{
sl@0: 		TheTimer.Start();
sl@0: 		for (TInt ii=0;ii<m;++ii)
sl@0: 			{
sl@0: 			TInt r=TheView.Prepare(TheDatabase,aSql,KDbUnlimitedWindow,TheView.EReadOnly);
sl@0: 			if (r<0)
sl@0: 				return r;
sl@0: 			r=TheView.EvaluateAll();
sl@0: 			test (r==KErrNone);
sl@0: 			TheView.Close();
sl@0: 			}
sl@0: 		TReal t=TheTimer.Stop();
sl@0: 		if (t>=100.0)
sl@0: 			return t/m;
sl@0: 		m*=4;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: struct TTest
sl@0: 	{
sl@0: 	const TText* iName;
sl@0: 	const TText* iQuery;
sl@0: 	};
sl@0: const TTest KQuery[]=
sl@0: 	{
sl@0: 	{_S("project"),_S("select cluster,xcluster,random,xrandom from test")},
sl@0: 	{_S("restrict 1"),_S("select * from test where cluster=0")},
sl@0: 	{_S("restrict 2"),_S("select * from test where xrandom=0")},
sl@0: 	{_S("restrict 3"),_S("select * from test where xcluster<500 and xrandom <500")},
sl@0: 	{_S("order 1"),_S("select * from test order by xrandom")},
sl@0: 	{_S("order 2"),_S("select * from test order by cluster")},
sl@0: 	{_S("all 1"),_S("select * from test where random<500 order by xrandom")},
sl@0: 	{_S("all 2"),_S("select * from test where xcluster<500 order by xrandom")},
sl@0: 	{_S("all 3"),_S("select * from test where xcluster<500 order by xcluster")},
sl@0: 	{_S("all 4"),_S("select * from test where xcluster<500 and xrandom<200 order by xcluster")}
sl@0: 	};
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0578
sl@0: @SYMTestCaseDesc        Benchmark Test.Querying a local Database Test
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions        	Evaluate SELECT queries on the created database
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void Queries()
sl@0: 	{
sl@0: 	test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0578 "));
sl@0: 	for (TUint ii=0;ii<sizeof(KQuery)/sizeof(KQuery[0]);++ii)
sl@0: 		{
sl@0: 		test.Printf(_L("%15s: "),KQuery[ii].iName);
sl@0: 		TReal t=Evaluate(TPtrC(KQuery[ii].iQuery));
sl@0: 		if (t<0.0)
sl@0: 			test.Printf(_L("-\n"));
sl@0: 		else
sl@0: 			test.Printf(_L("%7.1f ms\n"),t);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Benchmark tests
sl@0: //
sl@0: LOCAL_C void BenchTestL()
sl@0: 	{
sl@0: 	CreateDatabaseL();
sl@0: 	Queries();
sl@0: 	CloseDatabase();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Prepare the test directory.
sl@0: //
sl@0: LOCAL_C void setupTestDirectory()
sl@0:     {
sl@0: 	TInt r=TheFs.Connect();
sl@0: 	test(r==KErrNone);
sl@0: //
sl@0: #if 0
sl@0: 	TDriveList drives;
sl@0: 	TheFs.DriveList(drives);
sl@0: 	if (drives[EDriveK] == KDriveAbsent)
sl@0: 		{
sl@0: 		TInt r = TheFs.AddFileSystem(_L("ELFFS"));
sl@0: 		test (r == KErrNone);
sl@0: 		r = TheFs.MountFileSystem(_L("Lffs"),EDriveK);
sl@0: 		if (r == KErrCorrupt || r == KErrNotReady)
sl@0: 			{
sl@0: 			RFormat format;
sl@0: 			TInt    count;
sl@0: 			r = format.Open(TheFs, _L("K:\\"), EHighDensity, count);
sl@0: 			test (r == KErrNone);
sl@0: 			while (count)
sl@0: 				format.Next(count);
sl@0: 			format.Close();
sl@0:     		}
sl@0: 		else
sl@0: 			test (r == KErrNone);
sl@0: 		}
sl@0: #endif
sl@0: //
sl@0: 	r=TheFs.MkDir(KTestDatabase);
sl@0: 	test(r==KErrNone || r==KErrAlreadyExists);
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Initialise the cleanup stack.
sl@0: //
sl@0: LOCAL_C void setupCleanup()
sl@0:     {
sl@0: 	TheTrapCleanup=CTrapCleanup::New();
sl@0: 	test(TheTrapCleanup!=NULL);
sl@0: 	TRAPD(r,\
sl@0: 		{\
sl@0: 		for (TInt i=KTestCleanupStack;i>0;i--)\
sl@0: 			CleanupStack::PushL((TAny*)0);\
sl@0: 		CleanupStack::Pop(KTestCleanupStack);\
sl@0: 		});
sl@0: 	test(r==KErrNone);
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // entry point
sl@0: //
sl@0: GLDEF_C TInt E32Main()
sl@0:     {
sl@0: 	test.Title();
sl@0: 	setupTestDirectory();
sl@0: 	setupCleanup();
sl@0: 	__UHEAP_MARK;
sl@0: //
sl@0: 	test.Start(_L("Benchmarking..."));
sl@0: 	TRAPD(r,BenchTestL());
sl@0: 	test(r==KErrNone);
sl@0: 	test.End();
sl@0: //
sl@0: 	__UHEAP_MARKEND;
sl@0: 	delete TheTrapCleanup;
sl@0: 
sl@0: 	//T_BENCH.DB cannot be deleted here, because it is used by T_COMP test!
sl@0: 
sl@0: 	TheFs.Close();
sl@0: 	test.Close();
sl@0: 	return 0;
sl@0:     }