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

LOCAL_D RTest test(_L("t_dbwindow: Testing the 'window' stage"));

LOCAL_D CTrapCleanup* TheTrapCleanup;

LOCAL_D CFileStore* TheStore;

LOCAL_D RDbStoreDatabase TheDatabase;

LOCAL_D RDbView TheView;

LOCAL_D RFs TheFs;

const TInt KTestCleanupStack=0x20;

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

const TPtrC KTestFile=_S("T_WINDOW.DB");

const TPtrC KTableName=_S("TestTable");

const TPtrC KColumnID=_S("id");

const TPtrC KIndexName=_S("TestIndex");

const TInt KRecords=10;

const TPtrC KCreateTable=_L("CREATE TABLE TestTable (id INTEGER NOT NULL)");

const TPtrC KCreateIndex=_L("CREATE UNIQUE INDEX TestIndex ON TestTable (id)");

const TPtrC KEmptyQuery=_L("select * from TestTable where id is null");

const TPtrC KOrderQuery=_L("select * from TestTable order by id");

const TDbWindow KSingleSlotWindow(0,0);

const TDbWindow KSmallWindow(2,2);

const TDbWindow KLargeWindow(20,0);

//

// Create the database-in-a-store

//

LOCAL_C void CreateDatabaseL()

	{

	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;

	}

LOCAL_C void CloseDatabaseL()

	{

	// cannot evaluate size info for store database

	RDbDatabase::TSize size=TheDatabase.Size();

	test (size.iSize<0);

	test (size.iUsage<0);

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

	size=TheDatabase.Size();

	test (size.iSize<0);

	test (size.iUsage<0);

	TheDatabase.Close();

	delete TheStore;

	}

LOCAL_C void CreateTableL()

	{

	TheDatabase.Begin();

	test(TheDatabase.Execute(KCreateTable)==KErrNone);

	RDbTable table;

	test(table.Open(TheDatabase,KTableName,table.EInsertOnly)==KErrNone);

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

		{

		table.InsertL();

		table.SetColL(1,ii);

		table.PutL();

		}

	table.Close();

	test(TheDatabase.Execute(KCreateIndex)==KErrNone);

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

	}

LOCAL_C void InitL()

	{

	CreateDatabaseL();

	CreateTableL();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0638

@SYMTestCaseDesc        Tests for navigation

@SYMTestPriority        Medium

@SYMTestActions         Tests for navigation in an empty window

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestEmptyL()

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0638 Unevaluated "));

	test(TheView.Prepare(TheDatabase,KEmptyQuery,TDbWindow::EUnlimited)==KErrNone);

	test(TheView.CountL(TheView.EQuick)==0);

	test(!TheView.FirstL());

	test(TheView.AtEnd());

	test(!TheView.PreviousL());

	test(TheView.AtBeginning());

	test(!TheView.LastL());

	test(TheView.AtBeginning());

	test(!TheView.NextL());

	test(TheView.AtEnd());

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

	test(TheView.EvaluateAll()==KErrNone);

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

	test(!TheView.FirstL());

	test(TheView.AtEnd());

	test(!TheView.PreviousL());

	test(TheView.AtBeginning());

	test(!TheView.LastL());

	test(TheView.AtBeginning());

	test(!TheView.NextL());

	test(TheView.AtEnd());

	test.End();

	TheView.Close();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0639

@SYMTestCaseDesc        Tests for navigation

@SYMTestPriority        Medium

@SYMTestActions         Tests for the unlimited (dynaset) window

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestUnlimitedL()

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0639 EvaluateAll "));

	test(TheView.Prepare(TheDatabase,KOrderQuery,TDbWindow::EUnlimited)==KErrNone);

	test(TheView.EvaluateAll()==KErrNone);

	test(!TheView.Unevaluated());

	test(TheView.CountL()==KRecords);

	TInt cc=0;

	for (TheView.BeginningL();TheView.NextL();)

		++cc;

	test(cc==KRecords);

	for (TheView.EndL();TheView.PreviousL();)

		--cc;

	test(cc==0);

	test(!TheView.Unevaluated());

	test.Next(_L("Incremental evaluate"));

	TheView.Reset();

	cc=TheView.CountL(TheView.EQuick);

	test(cc==0);

	test(!TheView.FirstL());

	while (TheView.Unevaluated())

		{

		test(TheView.Evaluate()>=KErrNone);

		TInt ii=TheView.CountL()-cc;

		test(ii>=0);

		cc+=ii;

		while (--ii>=0)

			{

			test(TheView.AtRow());

			TheView.NextL();

			}

		test(!TheView.AtRow());

		}

	test(cc==KRecords);

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

// The new records should go on the end of the set

	TheView.InsertL();

	TheView.SetColL(1,TInt(-1));

	TheView.PutL();

	test(TheView.CountL()==KRecords+1);

	test(TheView.LastL());

	TheView.GetL();

	test(TheView.ColInt(1)==-1);

// because of order, it should appear at beginning on re-evaluation

	TheView.Reset();

	test(TheView.EvaluateAll()==KErrNone);

	test(TheView.CountL()==KRecords+1);

	test(TheView.FirstL());

	TheView.GetL();

	test(TheView.ColInt(1)==-1);

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

// updated records should not move (or disappear) in the set

	TheView.UpdateL();

	TheView.SetColL(1,KRecords);

	TheView.PutL();

	test(TheView.CountL()==KRecords+1);

	test(TheView.FirstL());

	TheView.GetL();

	test(TheView.ColInt(1)==KRecords);

// because of order, it should appear at end on re-evaluation

	TheView.Reset();

	test(TheView.EvaluateAll()==KErrNone);

	test(TheView.CountL()==KRecords+1);

	test(TheView.LastL());

	TheView.GetL();

	test(TheView.ColInt(1)==KRecords);

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

	TDbBookmark mark=TheView.Bookmark();

	TheView.BeginningL();

	TRAPD(r,TheView.GotoL(mark));

	test(r==KErrNone);

	TheView.GetL();

	test(TheView.ColInt(1)==KRecords);

	test(!TheView.NextL());

	test(TheView.PreviousL());

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

// should disappear from the set

	TheView.DeleteL();

	test(TheView.CountL()==KRecords);

	for (TheView.BeginningL();TheView.NextL();)

		{

		TheView.GetL();

		test(TheView.ColInt(1)!=KRecords);

		}

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

	test(r!=KErrNone);

	TheView.Reset();

	test(TheView.EvaluateAll()==KErrNone);

	test(TheView.CountL()==KRecords);

	for (TheView.BeginningL();TheView.NextL();)

		{

		TheView.GetL();

		test(TheView.ColInt(1)!=KRecords);

		}

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

	test(r!=KErrNone);

	test.End();

	TheView.Close();

	}

//

// do as much incremental evaluation as possible

//

LOCAL_C void Evaluate()

	{

	test(TheView.EvaluateAll()==KErrNone);

	}

//

// get to the true end of set

//

LOCAL_C void GotoEndL()

	{

	for (;;)

		{

		while (TheView.AtRow())

			TheView.NextL();

		if (!TheView.Unevaluated())

			break;

		Evaluate();

		}

	}

LOCAL_C void CheckWindowL(TInt forward,TInt back)

	{

	TInt ii;

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

		test(TheView.NextL());

	test(!TheView.NextL());

	for (ii=0;ii<forward+back+1;++ii)

		test(TheView.PreviousL());

	test(!TheView.PreviousL());

	for (ii=0;ii<back+1;++ii)

		test(TheView.NextL());

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0640

@SYMTestCaseDesc        Tests for RDbView

@SYMTestPriority        Medium

@SYMTestActions         Tests for a restricted sized window

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestRestrictedL()

	{

	test.Start(_L("	@SYMTestCaseID:SYSLIB-DBMS-CT-0640 Behaviour at start of set "));

	test(TheView.Prepare(TheDatabase,KOrderQuery,KSingleSlotWindow)==KErrNone);

	test(TheView.EvaluateAll()==KErrNone);

	test(TheView.CountL()==1);

	test(!TheView.Unevaluated());

	test(TheView.NextL());

	test(!TheView.Unevaluated());

	TheView.GetL();

	TInt id=TheView.ColInt(1);

	test(!TheView.NextL());

	test(TheView.Unevaluated());

	Evaluate();

	test(TheView.CountL()==1);

	test(TheView.AtRow());

	test(!TheView.PreviousL());

	test(TheView.Unevaluated());

	Evaluate();

	test(TheView.CountL()==1);

	test(TheView.AtRow());

	TheView.GetL();

	test(TheView.ColInt(1)==id);

	test(!TheView.PreviousL());

	test(TheView.Unevaluated());

	Evaluate();

	test(TheView.CountL()==1);

	test(TheView.AtBeginning());

	test(TheView.NextL());

	TheView.GetL();

	test(TheView.ColInt(1)==id);

	test(!TheView.Unevaluated());

	test.Next(_L("Behaviour at end of set"));

	GotoEndL();

	test(TheView.LastL());

	test(!TheView.Unevaluated());

	TheView.GetL();

	id=TheView.ColInt(1);

	test(!TheView.PreviousL());

	test(TheView.Unevaluated());

	Evaluate();

	test(TheView.CountL()==1);

	test(TheView.AtRow());

	test(!TheView.NextL());

	test(TheView.Unevaluated());

	Evaluate();

	test(TheView.CountL()==1);

	test(TheView.AtRow());

	TheView.GetL();

	test(TheView.ColInt(1)==id);

	test(!TheView.NextL());

	test(TheView.Unevaluated());

	Evaluate();

	test(TheView.CountL()==1);

	test(TheView.AtEnd());

	test(TheView.PreviousL());

	TheView.GetL();

	test(TheView.ColInt(1)==id);

	test(!TheView.Unevaluated());

	TheView.Close();

//

	test.Next(_L("Forward and backwards slots"));

	test(TheView.Prepare(TheDatabase,KOrderQuery,KSmallWindow)==KErrNone);

	test(TheView.EvaluateAll()==KErrNone);

	test(TheView.CountL()==5);

	test(TheView.FirstL());

	CheckWindowL(4,0);

	test(TheView.NextL());

	test(TheView.NextL());		// now on preferred slot (id=2)

	test(!TheView.Unevaluated());

	test(TheView.NextL());

	test(TheView.Unevaluated());

	Evaluate();

	CheckWindowL(2,2);

	test(TheView.LastL());		// id=5

	Evaluate();

	test(TheView.LastL());		// id=7

	Evaluate();					// should now have last five rows

	CheckWindowL(2,2);

	test(TheView.LastL());		// id=9

	Evaluate();					// no more rows

	CheckWindowL(0,4);			// all behind us now

	TheView.GetL();

	test(TheView.ColInt(1)==9);

	TheView.FirstL();			// id=5

	Evaluate();

	TheView.FirstL();			// id=3

	Evaluate();

	TheView.FirstL();			// id=1

	Evaluate();

	CheckWindowL(3,1);

//

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

	TDbBookmark mark=TheView.Bookmark();

	test(TheView.NextL());

	test(TheView.NextL());

	test(TheView.NextL());

	Evaluate();

	TRAPD(r,TheView.GotoL(mark));

	test(r!=KErrNone);

	TheView.FirstL();

	Evaluate();

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

	test(r==KErrNone);

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

	test(TheView.FirstL());

	TheView.GetL();

	test(TheView.ColInt(1)==0);

	TheView.DeleteL();

	test(TheView.CountL()==4);

	TheView.FirstL();

	CheckWindowL(3,0);

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

	TheView.InsertL();

	TheView.SetColL(1,TInt(0));

	TheView.PutL();

	test(TheView.CountL()==4);

	TheView.FirstL();

	TheView.GetL();

	test(TheView.ColInt(1)==1);

	TheView.Reset();

	test(TheView.EvaluateAll()==KErrNone);

	test(TheView.FirstL());

	TheView.GetL();

	test(TheView.ColInt(1)==0);

//

	test.End();

	TheView.Close();

	}

LOCAL_C void TestL()

	{

	__UHEAP_MARK;

	test.Start(_L("Setting up test table"));

	TRAPD(r,InitL();)

	test(r==KErrNone);

	test.Next(_L("Empty Window"));

	TRAP(r,TestEmptyL();)

	test(r==KErrNone);

	test.Next(_L("Unlimited Window"));

	TRAP(r,TestUnlimitedL();)

	test(r==KErrNone);

	test.Next(_L("Sized window"));

	TRAP(r,TestRestrictedL();)

	test(r==KErrNone);

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

	TRAP(r,CloseDatabaseL();)

	test(r==KErrNone);

	test.End();

	__UHEAP_MARKEND;

	}

//

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

				{

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

				}

			}

		fsSession.Close();

		}

	else

		{

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

		}

	}

//

// Test streaming conversions.

//

GLDEF_C TInt E32Main()

    {

	test.Title();

	setupTestDirectory();

	setupCleanup();

//

	test.Start(_L("TDbWindow - database test"));

	TRAPD(err, TestL());

	test(err == KErrNone);

	//deletion of data files must be done before call to end - DEF047652

	_LIT(KTestDbName, "C:\\DBMS-TST\\T_WINDOW.DB");

	::DeleteDataFile(KTestDbName);

	test.End();

//

	delete TheTrapCleanup;

	TheFs.Close();

	test.Close();

	return 0;

    }