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: 
sl@0: LOCAL_D RTest test(_L("t_dbwindow: Testing the 'window' stage"));
sl@0: LOCAL_D CTrapCleanup* TheTrapCleanup;
sl@0: LOCAL_D CFileStore* TheStore;
sl@0: LOCAL_D RDbStoreDatabase TheDatabase;
sl@0: LOCAL_D RDbView TheView;
sl@0: LOCAL_D RFs TheFs;
sl@0: 
sl@0: const TInt KTestCleanupStack=0x20;
sl@0: const TPtrC KTestDir=_S("C:\\DBMS-TST\\");
sl@0: const TPtrC KTestFile=_S("T_WINDOW.DB");
sl@0: const TPtrC KTableName=_S("TestTable");
sl@0: const TPtrC KColumnID=_S("id");
sl@0: const TPtrC KIndexName=_S("TestIndex");
sl@0: const TInt KRecords=10;
sl@0: const TPtrC KCreateTable=_L("CREATE TABLE TestTable (id INTEGER NOT NULL)");
sl@0: const TPtrC KCreateIndex=_L("CREATE UNIQUE INDEX TestIndex ON TestTable (id)");
sl@0: const TPtrC KEmptyQuery=_L("select * from TestTable where id is null");
sl@0: const TPtrC KOrderQuery=_L("select * from TestTable order by id");
sl@0: const TDbWindow KSingleSlotWindow(0,0);
sl@0: const TDbWindow KSmallWindow(2,2);
sl@0: const TDbWindow KLargeWindow(20,0);
sl@0: 
sl@0: //
sl@0: // Create the database-in-a-store
sl@0: //
sl@0: LOCAL_C void CreateDatabaseL()
sl@0: 	{
sl@0: 	CFileStore* store=CPermanentFileStore::ReplaceLC(TheFs,KTestFile,EFileRead|EFileWrite);
sl@0: 	store->SetTypeL(KPermanentFileStoreLayoutUid);
sl@0: 	TStreamId id;
sl@0: 		id=TheDatabase.CreateL(store);
sl@0: 	store->SetRootL(id);
sl@0: 	store->CommitL();
sl@0: 	CleanupStack::Pop();
sl@0: 	TheStore=store;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void CloseDatabaseL()
sl@0: 	{
sl@0: 	// cannot evaluate size info for store database
sl@0: 	RDbDatabase::TSize size=TheDatabase.Size();
sl@0: 	test (size.iSize<0);
sl@0: 	test (size.iUsage<0);
sl@0: 	test (TheDatabase.UpdateStats()==KErrNone);
sl@0: 	size=TheDatabase.Size();
sl@0: 	test (size.iSize<0);
sl@0: 	test (size.iUsage<0);
sl@0: 	TheDatabase.Close();
sl@0: 	delete TheStore;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void CreateTableL()
sl@0: 	{
sl@0: 	TheDatabase.Begin();
sl@0: 	test(TheDatabase.Execute(KCreateTable)==KErrNone);
sl@0: 	RDbTable table;
sl@0: 	test(table.Open(TheDatabase,KTableName,table.EInsertOnly)==KErrNone);
sl@0: 	for (TInt ii=0;ii<KRecords;++ii)
sl@0: 		{
sl@0: 		table.InsertL();
sl@0: 		table.SetColL(1,ii);
sl@0: 		table.PutL();
sl@0: 		}
sl@0: 	table.Close();
sl@0: 	test(TheDatabase.Execute(KCreateIndex)==KErrNone);
sl@0: 	test (TheDatabase.Commit()==KErrNone);
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void InitL()
sl@0: 	{
sl@0: 	CreateDatabaseL();
sl@0: 	CreateTableL();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0638
sl@0: @SYMTestCaseDesc        Tests for navigation
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for navigation in an empty window
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestEmptyL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0638 Unevaluated "));
sl@0: 	test(TheView.Prepare(TheDatabase,KEmptyQuery,TDbWindow::EUnlimited)==KErrNone);
sl@0: 	test(TheView.CountL(TheView.EQuick)==0);
sl@0: 	test(!TheView.FirstL());
sl@0: 	test(TheView.AtEnd());
sl@0: 	test(!TheView.PreviousL());
sl@0: 	test(TheView.AtBeginning());
sl@0: 	test(!TheView.LastL());
sl@0: 	test(TheView.AtBeginning());
sl@0: 	test(!TheView.NextL());
sl@0: 	test(TheView.AtEnd());
sl@0: 	test.Next(_L("Evaluated"));
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(TheView.CountL()==0);
sl@0: 	test(!TheView.FirstL());
sl@0: 	test(TheView.AtEnd());
sl@0: 	test(!TheView.PreviousL());
sl@0: 	test(TheView.AtBeginning());
sl@0: 	test(!TheView.LastL());
sl@0: 	test(TheView.AtBeginning());
sl@0: 	test(!TheView.NextL());
sl@0: 	test(TheView.AtEnd());
sl@0: 	test.End();
sl@0: 	TheView.Close();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0639
sl@0: @SYMTestCaseDesc        Tests for navigation
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for the unlimited (dynaset) window
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestUnlimitedL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0639 EvaluateAll "));
sl@0: 	test(TheView.Prepare(TheDatabase,KOrderQuery,TDbWindow::EUnlimited)==KErrNone);
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	test(TheView.CountL()==KRecords);
sl@0: 	TInt cc=0;
sl@0: 	for (TheView.BeginningL();TheView.NextL();)
sl@0: 		++cc;
sl@0: 	test(cc==KRecords);
sl@0: 	for (TheView.EndL();TheView.PreviousL();)
sl@0: 		--cc;
sl@0: 	test(cc==0);
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	test.Next(_L("Incremental evaluate"));
sl@0: 	TheView.Reset();
sl@0: 	cc=TheView.CountL(TheView.EQuick);
sl@0: 	test(cc==0);
sl@0: 	test(!TheView.FirstL());
sl@0: 	while (TheView.Unevaluated())
sl@0: 		{
sl@0: 		test(TheView.Evaluate()>=KErrNone);
sl@0: 		TInt ii=TheView.CountL()-cc;
sl@0: 		test(ii>=0);
sl@0: 		cc+=ii;
sl@0: 		while (--ii>=0)
sl@0: 			{
sl@0: 			test(TheView.AtRow());
sl@0: 			TheView.NextL();
sl@0: 			}
sl@0: 		test(!TheView.AtRow());
sl@0: 		}
sl@0: 	test(cc==KRecords);
sl@0: 	test.Next(_L("Insert"));
sl@0: // The new records should go on the end of the set
sl@0: 	TheView.InsertL();
sl@0: 	TheView.SetColL(1,TInt(-1));
sl@0: 	TheView.PutL();
sl@0: 	test(TheView.CountL()==KRecords+1);
sl@0: 	test(TheView.LastL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==-1);
sl@0: // because of order, it should appear at beginning on re-evaluation
sl@0: 	TheView.Reset();
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(TheView.CountL()==KRecords+1);
sl@0: 	test(TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==-1);
sl@0: 	test.Next(_L("Update"));
sl@0: // updated records should not move (or disappear) in the set
sl@0: 	TheView.UpdateL();
sl@0: 	TheView.SetColL(1,KRecords);
sl@0: 	TheView.PutL();
sl@0: 	test(TheView.CountL()==KRecords+1);
sl@0: 	test(TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==KRecords);
sl@0: // because of order, it should appear at end on re-evaluation
sl@0: 	TheView.Reset();
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(TheView.CountL()==KRecords+1);
sl@0: 	test(TheView.LastL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==KRecords);
sl@0: 	test.Next(_L("Bookmarks"));
sl@0: 	TDbBookmark mark=TheView.Bookmark();
sl@0: 	TheView.BeginningL();
sl@0: 	TRAPD(r,TheView.GotoL(mark));
sl@0: 	test(r==KErrNone);
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==KRecords);
sl@0: 	test(!TheView.NextL());
sl@0: 	test(TheView.PreviousL());
sl@0: 	test.Next(_L("Delete"));
sl@0: // should disappear from the set
sl@0: 	TheView.DeleteL();
sl@0: 	test(TheView.CountL()==KRecords);
sl@0: 	for (TheView.BeginningL();TheView.NextL();)
sl@0: 		{
sl@0: 		TheView.GetL();
sl@0: 		test(TheView.ColInt(1)!=KRecords);
sl@0: 		}
sl@0: 	TRAP(r,TheView.GotoL(mark));
sl@0: 	test(r!=KErrNone);
sl@0: 	TheView.Reset();
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(TheView.CountL()==KRecords);
sl@0: 	for (TheView.BeginningL();TheView.NextL();)
sl@0: 		{
sl@0: 		TheView.GetL();
sl@0: 		test(TheView.ColInt(1)!=KRecords);
sl@0: 		}
sl@0: 	TRAP(r,TheView.GotoL(mark));
sl@0: 	test(r!=KErrNone);
sl@0: 	test.End();
sl@0: 	TheView.Close();
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // do as much incremental evaluation as possible
sl@0: //
sl@0: LOCAL_C void Evaluate()
sl@0: 	{
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // get to the true end of set
sl@0: //
sl@0: LOCAL_C void GotoEndL()
sl@0: 	{
sl@0: 	for (;;)
sl@0: 		{
sl@0: 		while (TheView.AtRow())
sl@0: 			TheView.NextL();
sl@0: 		if (!TheView.Unevaluated())
sl@0: 			break;
sl@0: 		Evaluate();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void CheckWindowL(TInt forward,TInt back)
sl@0: 	{
sl@0: 	TInt ii;
sl@0: 	for (ii=0;ii<forward;++ii)
sl@0: 		test(TheView.NextL());
sl@0: 	test(!TheView.NextL());
sl@0: 	for (ii=0;ii<forward+back+1;++ii)
sl@0: 		test(TheView.PreviousL());
sl@0: 	test(!TheView.PreviousL());
sl@0: 	for (ii=0;ii<back+1;++ii)
sl@0: 		test(TheView.NextL());
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0640
sl@0: @SYMTestCaseDesc        Tests for RDbView
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for a restricted sized window
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestRestrictedL()
sl@0: 	{
sl@0: 	test.Start(_L("	@SYMTestCaseID:SYSLIB-DBMS-CT-0640 Behaviour at start of set "));
sl@0: 	test(TheView.Prepare(TheDatabase,KOrderQuery,KSingleSlotWindow)==KErrNone);
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(TheView.CountL()==1);
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	test(TheView.NextL());
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	TheView.GetL();
sl@0: 	TInt id=TheView.ColInt(1);
sl@0: 	test(!TheView.NextL());
sl@0: 	test(TheView.Unevaluated());
sl@0: 	Evaluate();
sl@0: 	test(TheView.CountL()==1);
sl@0: 	test(TheView.AtRow());
sl@0: 	test(!TheView.PreviousL());
sl@0: 	test(TheView.Unevaluated());
sl@0: 	Evaluate();
sl@0: 	test(TheView.CountL()==1);
sl@0: 	test(TheView.AtRow());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==id);
sl@0: 	test(!TheView.PreviousL());
sl@0: 	test(TheView.Unevaluated());
sl@0: 	Evaluate();
sl@0: 	test(TheView.CountL()==1);
sl@0: 	test(TheView.AtBeginning());
sl@0: 	test(TheView.NextL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==id);
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	test.Next(_L("Behaviour at end of set"));
sl@0: 	GotoEndL();
sl@0: 	test(TheView.LastL());
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	TheView.GetL();
sl@0: 	id=TheView.ColInt(1);
sl@0: 	test(!TheView.PreviousL());
sl@0: 	test(TheView.Unevaluated());
sl@0: 	Evaluate();
sl@0: 	test(TheView.CountL()==1);
sl@0: 	test(TheView.AtRow());
sl@0: 	test(!TheView.NextL());
sl@0: 	test(TheView.Unevaluated());
sl@0: 	Evaluate();
sl@0: 	test(TheView.CountL()==1);
sl@0: 	test(TheView.AtRow());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==id);
sl@0: 	test(!TheView.NextL());
sl@0: 	test(TheView.Unevaluated());
sl@0: 	Evaluate();
sl@0: 	test(TheView.CountL()==1);
sl@0: 	test(TheView.AtEnd());
sl@0: 	test(TheView.PreviousL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==id);
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	TheView.Close();
sl@0: //
sl@0: 	test.Next(_L("Forward and backwards slots"));
sl@0: 	test(TheView.Prepare(TheDatabase,KOrderQuery,KSmallWindow)==KErrNone);
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(TheView.CountL()==5);
sl@0: 	test(TheView.FirstL());
sl@0: 	CheckWindowL(4,0);
sl@0: 	test(TheView.NextL());
sl@0: 	test(TheView.NextL());		// now on preferred slot (id=2)
sl@0: 	test(!TheView.Unevaluated());
sl@0: 	test(TheView.NextL());
sl@0: 	test(TheView.Unevaluated());
sl@0: 	Evaluate();
sl@0: 	CheckWindowL(2,2);
sl@0: 	test(TheView.LastL());		// id=5
sl@0: 	Evaluate();
sl@0: 	test(TheView.LastL());		// id=7
sl@0: 	Evaluate();					// should now have last five rows
sl@0: 	CheckWindowL(2,2);
sl@0: 	test(TheView.LastL());		// id=9
sl@0: 	Evaluate();					// no more rows
sl@0: 	CheckWindowL(0,4);			// all behind us now
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==9);
sl@0: 	TheView.FirstL();			// id=5
sl@0: 	Evaluate();
sl@0: 	TheView.FirstL();			// id=3
sl@0: 	Evaluate();
sl@0: 	TheView.FirstL();			// id=1
sl@0: 	Evaluate();
sl@0: 	CheckWindowL(3,1);
sl@0: //
sl@0: 	test.Next(_L("Bookmarks"));
sl@0: 	TDbBookmark mark=TheView.Bookmark();
sl@0: 	test(TheView.NextL());
sl@0: 	test(TheView.NextL());
sl@0: 	test(TheView.NextL());
sl@0: 	Evaluate();
sl@0: 	TRAPD(r,TheView.GotoL(mark));
sl@0: 	test(r!=KErrNone);
sl@0: 	TheView.FirstL();
sl@0: 	Evaluate();
sl@0: 	TRAP(r,TheView.GotoL(mark));
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Delete"));
sl@0: 	test(TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==0);
sl@0: 	TheView.DeleteL();
sl@0: 	test(TheView.CountL()==4);
sl@0: 	TheView.FirstL();
sl@0: 	CheckWindowL(3,0);
sl@0: 	test.Next(_L("Insert"));
sl@0: 	TheView.InsertL();
sl@0: 	TheView.SetColL(1,TInt(0));
sl@0: 	TheView.PutL();
sl@0: 	test(TheView.CountL()==4);
sl@0: 	TheView.FirstL();
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==1);
sl@0: 	TheView.Reset();
sl@0: 	test(TheView.EvaluateAll()==KErrNone);
sl@0: 	test(TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	test(TheView.ColInt(1)==0);
sl@0: //
sl@0: 	test.End();
sl@0: 	TheView.Close();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestL()
sl@0: 	{
sl@0: 	__UHEAP_MARK;
sl@0: 	test.Start(_L("Setting up test table"));
sl@0: 	TRAPD(r,InitL();)
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Empty Window"));
sl@0: 	TRAP(r,TestEmptyL();)
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Unlimited Window"));
sl@0: 	TRAP(r,TestUnlimitedL();)
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Sized window"));
sl@0: 	TRAP(r,TestRestrictedL();)
sl@0: 	test(r==KErrNone);
sl@0: 	test.Next(_L("Cleanup"));
sl@0: 	TRAP(r,CloseDatabaseL();)
sl@0: 	test(r==KErrNone);
sl@0: 	test.End();
sl@0: 	__UHEAP_MARKEND;
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: 	r=TheFs.MkDir(KTestDir);
sl@0: 	test(r==KErrNone || r==KErrAlreadyExists);
sl@0: 	r=TheFs.SetSessionPath(KTestDir);
sl@0: 	test(r==KErrNone);
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: LOCAL_C void DeleteDataFile(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: 			RDebug::Print(_L("Deleting \"%S\" file.\n"), &aFullName);
sl@0: 			err = fsSession.SetAtt(aFullName, 0, KEntryAttReadOnly);
sl@0: 			if(err != KErrNone)
sl@0: 				{
sl@0: 				RDebug::Print(_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: 				RDebug::Print(_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: 		RDebug::Print(_L("Error %d connecting file session. File: %S.\n"), err, &aFullName);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: //
sl@0: // Test streaming conversions.
sl@0: //
sl@0: GLDEF_C TInt E32Main()
sl@0:     {
sl@0: 	test.Title();
sl@0: 	setupTestDirectory();
sl@0: 	setupCleanup();
sl@0: //
sl@0: 	test.Start(_L("TDbWindow - database test"));
sl@0: 	TRAPD(err, TestL());
sl@0: 	test(err == KErrNone);
sl@0: 
sl@0: 	//deletion of data files must be done before call to end - DEF047652
sl@0: 	_LIT(KTestDbName, "C:\\DBMS-TST\\T_WINDOW.DB");
sl@0: 	::DeleteDataFile(KTestDbName);
sl@0: 	test.End();
sl@0: //
sl@0: 
sl@0: 	delete TheTrapCleanup;
sl@0: 	TheFs.Close();
sl@0: 	test.Close();
sl@0: 	return 0;
sl@0:     }