// 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:

//

// 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

#include <d32dbms.h>

#include <s32file.h>

#include <e32test.h>

#include <e32math.h>

#include <hal.h>

class TTimer

	{

public:

	void Start(const TDesC& aDes);

	void Stop();

private:

	TUint iTicks;

	};

LOCAL_D RTest test(_L("t_dbbig - Test Large DBMS objects"));

LOCAL_D CTrapCleanup* TheTrapCleanup;

LOCAL_D CFileStore* TheStore;

LOCAL_D RDbStoreDatabase TheDatabase;

LOCAL_D RDbTable TheTable;

LOCAL_D RFs TheFs;

const TInt KTestCleanupStack=0x20;

const TPtrC KTestDir=_L("C:\\DBMS-TST\\");

const TPtrC KTestFile=_L("T_BIG.DB");

const TPtrC KTableName(_S("table"));

const TPtrC KIndexText=_S("text");

const TPtrC KIndexInt=_S("int");

const TPtrC KColumnText=_S("text");

const TPtrC KColumnInt=_S("int");

const TPtrC KIncFormat=_S("%5d\r");

const TInt KRecords=1000;

const TPtrC KOtherTable=_S("extra");

static TTimer TheTimer;

void TTimer::Start(const TDesC& aDes)

	{

	test.Printf(_L("  %S: "),&aDes);

	iTicks=User::FastCounter();

	}

void TTimer::Stop()

	{

	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;

	test.Printf(_L("%d ms\r\n"),v2/KMsIn1Sec);

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1309

@SYMTestCaseDesc        Create the database-in-a-store

@SYMTestPriority        Medium

@SYMTestActions        	Calls up RDbStoreDatabase::CreateL() function

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void CreateDatabaseL()

	{

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

	CFileStore* store=CPermanentFileStore::ReplaceLC(TheFs,KTestFile,EFileRead|EFileWrite);

	store->SetTypeL(KPermanentFileStoreLayoutUid);

	TStreamId id;

		id=TheDatabase.CreateL(store);

	store->SetRootL(id);

	store->CommitL();

	CleanupStack::Pop();

	TheStore=store;

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1310

@SYMTestCaseDesc        Open the database-in-a-store

@SYMTestPriority        Medium

@SYMTestActions        	Call up RDbStoreDatabase::OpenL()

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void OpenDatabaseL()

	{

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

	CFileStore* store=CPermanentFileStore::OpenLC(TheFs,KTestFile,EFileRead|EFileWrite);

		TheDatabase.OpenL(store,store->Root());

	CleanupStack::Pop();

	TheStore=store;

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1311

@SYMTestCaseDesc        Close the database in store

@SYMTestPriority        Medium

@SYMTestActions        	Test for RDbStoreDatabase::Close() function

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void CloseDatabase()

	{

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

	TheDatabase.Close();

	delete TheStore;

	}

LOCAL_C void CreateTableL()

	{

	CDbColSet *cs=CDbColSet::NewLC();

	TDbCol col1(KColumnInt,EDbColInt32);

	col1.iAttributes=TDbCol::ENotNull;

	cs->AddL(col1);

	TDbCol col2(KColumnText,EDbColText,200/sizeof(TText));

	col2.iAttributes=TDbCol::ENotNull;

	cs->AddL(col2);

	test(TheDatabase.CreateTable(KTableName,*cs)==KErrNone);

	CleanupStack::PopAndDestroy();

	}

LOCAL_C void WriteRecordsL(TInt aCount)

	{

	TBuf<10> text;

	TInt jj=0;

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

		{

		TheTable.InsertL();

		jj=(jj+23);

		if (jj>=aCount)

			jj-=aCount;

		TheTable.SetColL(1,jj);

		text.Num(jj);

		TheTable.SetColL(2,text);

		TheTable.PutL();

		}

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1312

@SYMTestCaseDesc        Create a table in database

@SYMTestPriority        Medium

@SYMTestActions        	Build a table and write records into the table.Test for commiting the transactions.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void BuildTableL(TInt aCount)

	{

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

	TheTimer.Start(_L("build"));

	CreateTableL();

	TheDatabase.Begin();

	test(TheTable.Open(TheDatabase,KTableName)==KErrNone);

	WriteRecordsL(aCount);

	test(TheDatabase.Commit()==KErrNone);

	TheTable.Close();

	TheTimer.Stop();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1313

@SYMTestCaseDesc        Tests for total rows in the rowset

@SYMTestPriority        Medium

@SYMTestActions        	Iterate through the table.Test for the total numbers of rows available

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void IterateL(RDbTable::TPosition aDirection)

	{

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

	TheTimer.Start(_L("iterate"));

	TInt cc=0;

	while (TheTable.GotoL(aDirection))

		{

		++cc;

		TheTable.GetL();

		}

	TheTimer.Stop();

	test(cc=TheTable.CountL());

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0580

@SYMTestCaseDesc        Tests the database definition and enquiry functions

@SYMTestPriority        Medium

@SYMTestActions        	Tests by setting an active index for the table.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestIndexL(const TDesC& aName,const CDbKey& aKey)

	{

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

	TheTimer.Start(_L("build"));

	test(TheDatabase.CreateIndex(aName,KTableName,aKey)==KErrNone);

	TheTimer.Stop();

	test(TheTable.Open(TheDatabase,KTableName)==KErrNone);

	test(TheTable.SetIndex(aName)==KErrNone);

	IterateL(TheTable.ENext);

	TheTable.Close();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0581

@SYMTestCaseDesc        Tests the database definition and enquiry functions

@SYMTestPriority        Medium

@SYMTestActions        	Tests for bookmark which saves the current location of a rowset.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestBookmarkL()

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0581 creating alien bookmark "));

	CDbColSet* cs=CDbColSet::NewLC();

	TDbCol col(_L("column"),EDbColUint8);

	col.iAttributes=TDbCol::ENotNull+TDbCol::EAutoIncrement;

	cs->AddL(col);

	test (TheDatabase.CreateTable(KOtherTable,*cs)==KErrNone);

	CleanupStack::PopAndDestroy();

	RDbTable extra;

	test (extra.Open(TheDatabase,KOtherTable)==KErrNone);

	extra.InsertL();

	extra.PutL();

	TDbBookmark alien=extra.Bookmark();

	extra.Close();

//

	test.Next(_L("Alien bookmark"));

	test (TheTable.Open(TheDatabase,KTableName)==KErrNone);

	TRAPD(r,TheTable.GotoL(alien));

	test (r==KErrNotFound);

	test (TheTable.SetIndex(KIndexInt)==KErrNone);

	TRAP(r,TheTable.GotoL(alien));

	test (r==KErrNotFound);

	test (TheTable.SetIndex(KIndexText)==KErrNone);

	TRAP(r,TheTable.GotoL(alien));

	test (r==KErrNotFound);

//

	test.Next(_L("Cross-view bookmarks"));

	TheTable.LastL();	// indexed view

	TheTable.PreviousL();

	TDbBookmark mark=TheTable.Bookmark();

	test (extra.Open(TheDatabase,KTableName)==KErrNone);

	TRAP(r,extra.GotoL(mark));

	test (r==KErrNone);

	test (extra.PreviousL());

	TRAP(r,TheTable.GotoL(extra.Bookmark()));

	test (r==KErrNone);

	extra.Close();

//

	test.Next(_L("Bookmark persistence"));

	TheTable.Close();

	test (TheTable.Open(TheDatabase,KTableName)==KErrNone);

	TRAP(r,TheTable.GotoL(mark));

	test (r==KErrNone);

	TheTable.Close();

//

	test.Next(_L("Delete alien record"));

	test (extra.Open(TheDatabase,KOtherTable)==KErrNone);

	TRAP(r, extra.GotoL(mark));

	test (r==KErrNotFound);

	TRAP(r,extra.GotoL(alien));

	test (r==KErrNone);

	extra.DeleteL();

	TRAP(r,extra.GotoL(alien));

	test (r==KErrNotFound);

	extra.Close();

//

	test.Next(_L("Delete extra table"));

	test (TheDatabase.DropTable(KOtherTable)==KErrNone);

	test (TheTable.Open(TheDatabase,KTableName)==KErrNone);

	TRAP(r,TheTable.GotoL(alien));

	test (r==KErrNotFound);

	TheTable.Close();

//

	test.End();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1314

@SYMTestCaseDesc        Discarding indexes belonging to the table on database

@SYMTestPriority        Medium

@SYMTestActions        	Tests for RDbIncremental::DropTable(),RDbIncremental::Next() function.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void BreakIndex()

	{

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

	TheTimer.Start(_L("break"));

	TInt step;

	RDbIncremental drop;

	test(drop.DropTable(TheDatabase,KTableName,step)==KErrNone);

	test(drop.Next(step)==KErrNone);

	test(step>0);

	drop.Close();	// abort the drop

	test(TheDatabase.IsDamaged());

	TheTimer.Stop();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1315

@SYMTestCaseDesc        Database recovery test

@SYMTestPriority        Medium

@SYMTestActions        	Calls up RDbStoreDatabase::Recover() function

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void Recover()

	{

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

	TheTimer.Start(_L("recover"));

	test(TheDatabase.Recover()==KErrNone);

	TheTimer.Stop();

	test(!TheDatabase.IsDamaged());

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1316

@SYMTestCaseDesc        Tests for dropping an index

@SYMTestPriority        Medium

@SYMTestActions        	Drop an integer and text index from the table. Test for damage of database

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void DropIndexes()

	{

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

	TheTimer.Start(_L("drop Int[32]"));

	test(TheDatabase.DropIndex(KIndexInt,KTableName)==KErrNone);

	TheTimer.Stop();

	TheTimer.Start(_L("drop Text[200]"));

	test(TheDatabase.DropIndex(KIndexText,KTableName)==KErrNone);

	TheTimer.Stop();

	test(!TheDatabase.IsDamaged());

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-1317

@SYMTestCaseDesc        Deleting a table from the database

@SYMTestPriority        Medium

@SYMTestActions        	Delete the rows from the rowset.Check for empty rows in the rowset.

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void DeleteTableL()

	{

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

	const TInt KTenthRecords=KRecords/10;

	test (TheTable.Open(TheDatabase,KTableName)==KErrNone);

	TheDatabase.Begin();

	TInt ii;

	for (ii=0;ii<15;++ii)

		{

		TheTable.NextL();

		TheTable.DeleteL();

		}

	TheTable.NextL();

	TDbBookmark mark=TheTable.Bookmark();

	TheTable.Close();

	TheDatabase.Commit();

	CloseDatabase();

	OpenDatabaseL();

	TheTimer.Start(_L("delete table"));

	test (TheTable.Open(TheDatabase,KTableName)==KErrNone);

	TheDatabase.Begin();

	TheTable.GotoL(mark);

	TheTable.DeleteL();

	for (ii=0;ii<KTenthRecords*2-16;++ii)

		{

		TheTable.NextL();

		TheTable.DeleteL();

		}

	TheTable.EndL();

	for (ii=0;ii<KTenthRecords*2;++ii)

		{

		TheTable.PreviousL();

		TheTable.DeleteL();

		}

	TheTable.BeginningL();

	for (ii=0;ii<KTenthRecords*3;++ii)

		TheTable.NextL();

	for (ii=0;ii<KTenthRecords*2;++ii)

		{

		TheTable.NextL();

		TheTable.DeleteL();

		}

	for (ii=0;ii<KTenthRecords*2;++ii)

		{

		TheTable.PreviousL();

		TheTable.DeleteL();

		}

	for (ii=0;ii<KTenthRecords;++ii)

		{

		TheTable.NextL();

		TheTable.DeleteL();

		}

	for (ii=0;ii<KTenthRecords;++ii)

		{

		TheTable.PreviousL();

		TheTable.DeleteL();

		}

	test (TheTable.CountL()==0);

	test (!TheTable.NextL());

	test (!TheTable.PreviousL());

	test (TheDatabase.Commit()==KErrNone);

	TheTable.Close();

	TheTimer.Stop();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0579

@SYMTestCaseDesc        Tests the database definition and enquiry functions

@SYMTestPriority        Medium

@SYMTestActions        	Executes the index and bookmark tests

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void BigTestL()

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0579 Table "));

	CreateDatabaseL();

	BuildTableL(KRecords);

	test(TheTable.Open(TheDatabase,KTableName)==KErrNone);

	TheTable.EndL();

	IterateL(TheTable.EPrevious);

	TheTable.BeginningL();

	IterateL(TheTable.ENext);

	TheTable.EndL();

	IterateL(TheTable.EPrevious);

	TheTable.Close();

	test.Next(_L("Int32 Index"));

	CDbKey *key=CDbKey::NewLC();

	key->AddL(KColumnInt);

	key->MakeUnique();

	TestIndexL(KIndexInt,*key);

	test.Next(_L("Text[200] Index"));

	key->Clear();

	key->AddL(KColumnText);

	key->MakeUnique();

	TestIndexL(KIndexText,*key);

	test.Next(_L("Bookmarks"));

	TestBookmarkL();

	test.Next(_L("Int32 Index"));

	TheTimer.Start(_L("drop"));

	test(TheDatabase.DropIndex(KIndexInt,KTableName)==KErrNone);

	TheTimer.Stop();

	key->Clear();

	key->AddL(KColumnInt);

	key->MakeUnique();

	TestIndexL(KIndexInt,*key);

	CleanupStack::PopAndDestroy();

	test.Next(_L("Break & Recover"));

	BreakIndex();

	Recover();

	test.Next(_L("Drop Indexes"));

	DropIndexes();

	test.Next(_L("Delete all records"));

	DeleteTableL();

	CloseDatabase();

	test.End();

	}

//

// Prepare the test directory.

//

LOCAL_C void setupTestDirectory()

    {

	TInt r=TheFs.Connect();

	test(r==KErrNone);

	r=TheFs.MkDir(KTestDir);

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

	r=TheFs.SetSessionPath(KTestDir);

	test(r==KErrNone);

	}

//

// 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);

	}

LOCAL_C void DeleteDataFile(const TDesC& aFullName)

	{

	RFs fsSession;

	TInt err = fsSession.Connect();

	if(err == KErrNone)

		{

		TEntry entry;

		if(fsSession.Entry(aFullName, entry) == KErrNone)

			{

			RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);

			err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);

			if(err != KErrNone)

				{

				RDebug::Print(_L("Error %d changing \"%S\" file attributes.\n"), err, &aFullName);

				}

			err = fsSession.Delete(aFullName);

			if(err != KErrNone)

				{