// Copyright (c) 1998-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 <d32dbms.h>

 #include <s32file.h>

 #include <e32test.h>

 #include <e32math.h>

 #include <e32svr.h>

 #include <hal.h>

 #include <d32dbmsconstants.h>

 // MSVC++ up to 5.0 has problems with expanding inline functions

 // This disables the mad warnings for the whole project

 #if defined(NDEBUG) && defined(__VC32__) && _MSC_VER<=1100

 #pragma warning(disable : 4710)			// function not expanded. MSVC 5.0 is stupid

 #endif

 class TTimer

 	{

 public:

 	void Start();

 	TReal Stop() const;

 private:

 	TUint iTicks;

 	};

 LOCAL_D RTest test(_L("t_dbbench"));

 LOCAL_D CTrapCleanup* TheTrapCleanup;

 LOCAL_D RDbNamedDatabase TheDatabase;

 LOCAL_D RDbView TheView;

 LOCAL_D RFs TheFs;

 const TInt KTestCleanupStack=0x20;

 //T_BENCH file shall not be deleted at the end of the test! It will be used by T_COMP test.

 const TPtrC KTestDatabase=_S("\\DBMS-TST\\T_BENCH.DB");

 const TPtrC KTableName=_S("Test");

 const TPtrC KColCluster=_S("Cluster");

 const TPtrC KColXcluster=_S("xCluster");

 const TPtrC KColRandom=_S("Random");

 const TPtrC KColXrandom=_S("xRandom");

 const TInt KRecords=2000;

 static TTimer TheTimer;

 void TTimer::Start()

 	{

 	iTicks=User::FastCounter();

 	}

 TReal TTimer::Stop() const

 	{

 	TUint ticks = User::FastCounter() - iTicks;

 	TInt freq = 0;

 	test(HAL::Get(HAL::EFastCounterFrequency, freq) == KErrNone);

 	const TInt KMicroSecIn1Sec = 1000000;

 	const TInt KMsIn1Sec = 1000;

 	double v = ((double)ticks * KMicroSecIn1Sec) / (double)freq; TInt v2 = (TInt)v;

 	return v2 / KMsIn1Sec;

 	}

 LOCAL_C void CloseDatabase()

 	{

 	TheDatabase.Close();

 	}

 /**

 Create the database: keep the code 050 compatible

 @SYMTestCaseID          SYSLIB-DBMS-CT-0577

 @SYMTestCaseDesc        Benchmark Tests. Creation of a local Database test

 @SYMTestPriority        Medium

 @SYMTestActions        	Attempt to test RDbNamedDatabase::CreateTable(),RDbNamedDatabase::CreateIndex(),

 						RDbNamedDatabase::Compact(),RDbView::Prepare() functions

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */

 LOCAL_C void CreateDatabaseL()

 	{

 	test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0577 "));

 	User::LeaveIfError(TheDatabase.Replace(TheFs,KTestDatabase));

 	CDbColSet& set=*CDbColSet::NewLC();

 	TDbCol col(KColCluster,EDbColInt32);

 	col.iAttributes=col.ENotNull;

 	set.AddL(col);

 	col.iName=KColXcluster;

 	set.AddL(col);

 	col.iName=KColRandom;

 	set.AddL(col);

 	col.iName=KColXrandom;

 	set.AddL(col);

 	TInt r=TheDatabase.CreateTable(KTableName,set);

 	test (r==KErrNone);

 	CleanupStack::PopAndDestroy();

 	TheTimer.Start();

 	r=TheView.Prepare(TheDatabase,_L("select * from test"),TheView.EInsertOnly);

 	TheDatabase.Begin();

 	test (r==KErrNone);

 	TInt jj=0;

 	for (TInt ii=0;ii<KRecords;++ii)

 		{

 		TheView.InsertL();

 		jj=(jj+23);

 		if (jj>=KRecords)

 			jj-=KRecords;

 		TheView.SetColL(1,ii);

 		TheView.SetColL(2,ii);

 		TheView.SetColL(3,jj);

 		TheView.SetColL(4,jj);

 		TheView.PutL();

 		}

 	r=TheDatabase.Commit();

 	test (r==KErrNone);

 	TheView.Close();

 	test.Printf(_L("Build table: %7.1f ms\n"),TheTimer.Stop());

 	TheTimer.Start();

 	CDbKey& key=*CDbKey::NewLC();

 	key.AddL(KColXcluster);

 	key.MakeUnique();

 	r=TheDatabase.CreateIndex(KColXcluster,KTableName,key);

 	test (r==KErrNone);

 	test.Printf(_L("Cluster index: %7.1f ms\n"),TheTimer.Stop());

 	TheTimer.Start();

 	key.Clear();

 	key.AddL(KColXrandom);

 	r=TheDatabase.CreateIndex(KColXrandom,KTableName,key);

 	test (r==KErrNone);

 	CleanupStack::PopAndDestroy();

 	test.Printf(_L("Random index: %7.1f ms\n"),TheTimer.Stop());

 	TheTimer.Start();

 	r = TheDatabase.Compact();

 	test.Printf(_L("Compact: %7.1f ms\n"),TheTimer.Stop());

 	test (r == KErrNone);

 	}

 LOCAL_C TReal Evaluate(const TDesC& aSql)

 	{

 	TInt m=1;

 	for (;;)

 		{

 		TheTimer.Start();

 		for (TInt ii=0;ii<m;++ii)

 			{

 			TInt r=TheView.Prepare(TheDatabase,aSql,KDbUnlimitedWindow,TheView.EReadOnly);

 			if (r<0)

 				return r;

 			r=TheView.EvaluateAll();

 			test (r==KErrNone);

 			TheView.Close();

 			}

 		TReal t=TheTimer.Stop();

 		if (t>=100.0)

 			return t/m;

 		m*=4;

 		}

 	}

 struct TTest

 	{

 	const TText* iName;

 	const TText* iQuery;

 	};

 const TTest KQuery[]=

 	{

 	{_S("project"),_S("select cluster,xcluster,random,xrandom from test")},

 	{_S("restrict 1"),_S("select * from test where cluster=0")},

 	{_S("restrict 2"),_S("select * from test where xrandom=0")},

 	{_S("restrict 3"),_S("select * from test where xcluster<500 and xrandom <500")},

 	{_S("order 1"),_S("select * from test order by xrandom")},

 	{_S("order 2"),_S("select * from test order by cluster")},

 	{_S("all 1"),_S("select * from test where random<500 order by xrandom")},

 	{_S("all 2"),_S("select * from test where xcluster<500 order by xrandom")},

 	{_S("all 3"),_S("select * from test where xcluster<500 order by xcluster")},

 	{_S("all 4"),_S("select * from test where xcluster<500 and xrandom<200 order by xcluster")}

 	};

 /**

 @SYMTestCaseID          SYSLIB-DBMS-CT-0578

 @SYMTestCaseDesc        Benchmark Test.Querying a local Database Test

 @SYMTestPriority        Medium

 @SYMTestActions        	Evaluate SELECT queries on the created database

 @SYMTestExpectedResults Test must not fail

 @SYMREQ                 REQ0000

 */

 LOCAL_C void Queries()

 	{

 	test.Next(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0578 "));

 	for (TUint ii=0;ii<sizeof(KQuery)/sizeof(KQuery[0]);++ii)

 		{

 		test.Printf(_L("%15s: "),KQuery[ii].iName);

 		TReal t=Evaluate(TPtrC(KQuery[ii].iQuery));

 		if (t<0.0)

 			test.Printf(_L("-\n"));

 		else

 			test.Printf(_L("%7.1f ms\n"),t);

 		}

 	}

 //

 // Benchmark tests

 //

 LOCAL_C void BenchTestL()

 	{

 	CreateDatabaseL();

 	Queries();

 	CloseDatabase();

 	}

 //

 // Prepare the test directory.

 //

 LOCAL_C void setupTestDirectory()

     {

 	TInt r=TheFs.Connect();

 	test(r==KErrNone);

 //

 #if 0

 	TDriveList drives;

 	TheFs.DriveList(drives);

 	if (drives[EDriveK] == KDriveAbsent)

 		{

 		TInt r = TheFs.AddFileSystem(_L("ELFFS"));

 		test (r == KErrNone);

 		r = TheFs.MountFileSystem(_L("Lffs"),EDriveK);

 		if (r == KErrCorrupt || r == KErrNotReady)

 			{

 			RFormat format;

 			TInt    count;

 			r = format.Open(TheFs, _L("K:\\"), EHighDensity, count);

 			test (r == KErrNone);

 			while (count)

 				format.Next(count);

 			format.Close();

     		}

 		else

 			test (r == KErrNone);

 		}

 #endif

 //

 	r=TheFs.MkDir(KTestDatabase);

 	test(r==KErrNone || r==KErrAlreadyExists);

 	}

 //

 // Initialise the cleanup stack.

 //

 LOCAL_C void setupCleanup()

     {

 	TheTrapCleanup=CTrapCleanup::New();

 	test(TheTrapCleanup!=NULL);

 	TRAPD(r,\

 		{\

 		for (TInt i=KTestCleanupStack;i>0;i--)\

 			CleanupStack::PushL((TAny*)0);\

 		CleanupStack::Pop(KTestCleanupStack);\

 		});

 	test(r==KErrNone);

 	}

 //

 // entry point

 //

 GLDEF_C TInt E32Main()

     {

 	test.Title();

 	setupTestDirectory();

 	setupCleanup();

 	__UHEAP_MARK;

 //

 	test.Start(_L("Benchmarking..."));

 	TRAPD(r,BenchTestL());

 	test(r==KErrNone);

 	test.End();

 //

 	__UHEAP_MARKEND;

 	delete TheTrapCleanup;

 	//T_BENCH.DB cannot be deleted here, because it is used by T_COMP test!

 	TheFs.Close();

 	test.Close();

 	return 0;

     }