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 <hal.h>
sl@0: #include "D32DBAS.H"
sl@0: 
sl@0: LOCAL_D RTest test(_L("t_dbsrv: Test DBMS server"));
sl@0: LOCAL_D CTrapCleanup* TheTrapCleanup;
sl@0: LOCAL_D RFs TheFs;
sl@0: LOCAL_D RDbs TheDbs;
sl@0: LOCAL_D RDbNamedDatabase TheDatabase;
sl@0: LOCAL_D RDbTable TheTable;
sl@0: LOCAL_D RDbView TheView;
sl@0: 
sl@0: const TInt KTestCleanupStack=0x40;
sl@0: const TPtrC KTestDatabase(_S("c:\\dbms-tst\\share.db"));
sl@0: const TPtrC KTestFormat(_S(""));
sl@0: const TPtrC KTable1(_S("Table1"));
sl@0: const TPtrC KTable2(_S("Table2"));
sl@0: const TInt KRowCount=1000;
sl@0: const TUint KExitDelay=6*0x100000;	// ~6 seconds
sl@0: 
sl@0: const TPtrC KCreateTable1=_S("CREATE TABLE Table1 (Id INTEGER,Name CHAR(200),Memo LONG VARCHAR,Memo2 LONG VARBINARY)");
sl@0: const TPtrC KCreateTable2=_S("CREATE TABLE Table2 (Id INTEGER,Name CHAR(200),Memo LONG VARCHAR)");
sl@0: const TPtrC KDropTable1=_S("DROP TABLE Table1");
sl@0: const TPtrC KDropTable2=_S("DROP TABLE Table2");
sl@0: 
sl@0: _LIT(KTestSpdFile1, "c:\\dbms-tst\\11335577.spd");
sl@0: _LIT(KTestSpdFile2, "c:\\dbms-tst\\11335578.spd");
sl@0: _LIT(KTestSpdFile3, "c:\\dbms-tst\\11335579.spd");
sl@0: _LIT(KTestSpdFile4, "c:\\dbms-tst\\1133557A.spd");
sl@0: 
sl@0: const TInt KReturnValueForCompare = 10;
sl@0: const TInt KReturnValueForFind = 20;
sl@0: 
sl@0: class TTimer
sl@0: 	{
sl@0: public:
sl@0: 	void Start(const TDesC& aDes);
sl@0: 	void Stop();
sl@0: private:
sl@0: 	TUint iTicks;
sl@0: 	};
sl@0: 
sl@0: static TTimer TheTimer;
sl@0: 
sl@0: void TTimer::Start(const TDesC& aDes)
sl@0: 	{
sl@0: 	test.Printf(_L("  %S: "),&aDes);
sl@0: 	iTicks=User::FastCounter();
sl@0: 	}
sl@0: 
sl@0: void TTimer::Stop()
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: 	test.Printf(_L("%d ms\r\n"),v2/KMsIn1Sec);
sl@0: 	}
sl@0: 
sl@0: void DeleteTestFiles()
sl@0: 	{
sl@0: 	(void)TheFs.Delete(KTestDatabase);
sl@0: 	(void)TheFs.Delete(KTestSpdFile1); 
sl@0: 	(void)TheFs.Delete(KTestSpdFile2); 
sl@0: 	(void)TheFs.Delete(KTestSpdFile3); 
sl@0: 	(void)TheFs.Delete(KTestSpdFile4); 
sl@0: 	}
sl@0: 
sl@0: void Check(TInt aValue,TInt aExpected,TInt aLine)
sl@0: 	{
sl@0: 	if (aValue!=aExpected)
sl@0: 		{
sl@0: 		DeleteTestFiles();
sl@0: 		test.Printf(_L("*** Expected %d: got %d\r\n"),aExpected,aValue);
sl@0: 		test.operator()(EFalse,aLine);
sl@0: 		}
sl@0: 	}
sl@0: #define test2(a,b) Check(a,b,__LINE__)
sl@0: 
sl@0: LOCAL_C void Connect()
sl@0: 	{
sl@0: 	test2(TheDbs.Connect(),KErrNone);
sl@0: 	TheDbs.ResourceMark();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void Disconnect()
sl@0: 	{
sl@0: 	TheDbs.ResourceCheck();
sl@0: 	TheDbs.Close();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void Execute(const TDesC& aSql)
sl@0: 	{
sl@0: 	test2 (TheDatabase.Execute(aSql),KErrNone);
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void WriteRecordsL(TInt aCount)
sl@0: 	{
sl@0: 	TheTimer.Start(_L("writing"));
sl@0: 	TheDatabase.Begin();
sl@0: 	TBuf<10> text;
sl@0: 	TInt jj=0;
sl@0: 	for (TInt ii=0;ii<aCount;++ii)
sl@0: 		{
sl@0: 		TheTable.InsertL();
sl@0: 		jj=(jj+23);
sl@0: 		if (jj>=aCount)
sl@0: 			jj-=aCount;
sl@0: 		TheTable.SetColL(1,jj);
sl@0: 		text.Num(jj);
sl@0: 		TheTable.SetColL(2,text);
sl@0: 		TheTable.PutL();
sl@0: 		}
sl@0: 	test2 (TheDatabase.Commit(),KErrNone);
sl@0: 	TheTimer.Stop();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void Ipc(TInt aCount)
sl@0: 	{
sl@0: 	TheTimer.Start(_L("ipc"));
sl@0: 	while (--aCount>=0)
sl@0: 		TheDatabase.InTransaction();
sl@0: 	TheTimer.Stop();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void LoopL(RDbTable::TPosition aDirection)
sl@0: 	{
sl@0: 	TheTimer.Start(_L("loop"));
sl@0: 	TInt cc=0;
sl@0: 	while (TheTable.GotoL(aDirection))
sl@0: 		++cc;
sl@0: 	test2 (cc,TheTable.CountL());
sl@0: 	TheTimer.Stop();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void IterateL(RDbTable::TPosition aDirection)
sl@0: 	{
sl@0: 	TheTimer.Start(_L("iterate"));
sl@0: 	TInt cc=0;
sl@0: 	while (TheTable.GotoL(aDirection))
sl@0: 		{
sl@0: 		++cc;
sl@0: 		TheTable.GetL();
sl@0: 		TBuf<10> text;
sl@0: 		text.Num(TheTable.ColInt(1));
sl@0: 		test (text==TheTable.ColDes(2));
sl@0: 		}
sl@0: 	test2 (cc,TheTable.CountL());
sl@0: 	TheTimer.Stop();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void LocateL(const TDesC& aSql)
sl@0: 	{
sl@0: 	test2 (TheView.Prepare(TheDatabase,aSql),KErrNone);
sl@0: 	test2 (TheView.EvaluateAll(),KErrNone);
sl@0: 	TheTimer.Start(_L("locate"));
sl@0: 	test (!TheView.NextL());
sl@0: 	TheTimer.Stop();
sl@0: 	TheView.Close();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void Locate1L()
sl@0: 	{
sl@0: 	LocateL(_L("select * from Table1 where id is null"));
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void Locate2L()
sl@0: 	{
sl@0: 	LocateL(_L("select * from Table1 where id = -12345"));
sl@0: 	}
sl@0: 
sl@0: LOCAL_C TInt DeleteL()
sl@0: 	{
sl@0: 	TheTimer.Start(_L("deleting"));
sl@0: 	TheDatabase.Begin();
sl@0: 	TInt cc=0;
sl@0: 	TheTable.BeginningL();
sl@0: 	while (TheTable.NextL())
sl@0: 		{
sl@0: 		++cc;
sl@0: 		TheTable.DeleteL();
sl@0: 		}
sl@0: 	test (TheTable.CountL()==0);
sl@0: 	test (TheDatabase.Commit()==KErrNone);
sl@0: 	TheTimer.Stop();
sl@0: 	return cc;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C TInt DeleteSQL()
sl@0: 	{
sl@0: 	TheTimer.Start(_L("deleting [SQL]"));
sl@0: 	TInt cc=TheDatabase.Execute(_L("delete from Table1"));
sl@0: 	test (cc>=KErrNone);
sl@0: 	test (TheTable.CountL()==0);
sl@0: 	TheTimer.Stop();
sl@0: 	return cc;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void BenchmarkL()
sl@0: 	{
sl@0: 	TInt r=TheTable.Open(TheDatabase,KTable1);
sl@0: 	TheTable.LastL();
sl@0: 	test (r==KErrNone);
sl@0: 	Ipc(KRowCount);
sl@0: 	TheTable.Reset();
sl@0: 	LoopL(TheTable.ENext);
sl@0: 	TheTable.Reset();
sl@0: 	IterateL(TheTable.ENext);
sl@0: 	Locate1L();
sl@0: 	Locate2L();
sl@0: 	TheTable.Close();
sl@0: 	}
sl@0: 
sl@0: const TPtrC KSemaphore(_S("Connect-test"));
sl@0: 
sl@0: LOCAL_C TInt ConnectThread(TAny*)
sl@0: 	{
sl@0: 	RSemaphore s;
sl@0: 	s.OpenGlobal(KSemaphore,EOwnerThread);
sl@0: 	RDbs dbs;
sl@0: 	dbs.Connect();
sl@0: 	s.Signal();
sl@0: 	User::After(0x100000);
sl@0: 	s.Wait();
sl@0: 	dbs.Close();
sl@0: 	s.Signal();
sl@0: 	s.Close();
sl@0: 	return KErrNone;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0605
sl@0: @SYMTestCaseDesc        Single and multiple database connection tests
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Setup a DBMS server session Search the server for pattern matching
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestConnect()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0605 Single connection "));
sl@0: 	test (TheDbs.Connect()==KErrNone);
sl@0: 	TheDbs.Close();
sl@0: 	test.Next(_L("Deferred exit"));
sl@0: 	TFindServer find(_L("!DBMS server"));
sl@0: 	TFullName result;
sl@0: 	test2 (find.Next(result),KErrNone);
sl@0: 	test.Next(_L("Multiple connection"));
sl@0: 	Connect();
sl@0: 	RDbs dbs;
sl@0: 	test2 (dbs.Connect(),KErrNone);
sl@0: 	Disconnect();
sl@0: 	dbs.Close();
sl@0: 	test.Next(_L("Deferred exit"));
sl@0: 	find.Find(_L("!DBMS server"));
sl@0: 	test2 (find.Next(result),KErrNone);
sl@0: 	User::After(KExitDelay);
sl@0: 	find.Find(_L("!DBMS server"));
sl@0: 	test2 (find.Next(result),KErrNotFound);
sl@0: 	test.Next(_L("multiple thread connections"));
sl@0: 	RSemaphore s;
sl@0: 	test2 (s.CreateGlobal(KSemaphore,0,EOwnerThread),KErrNone);
sl@0: 	RThread t;
sl@0: 	test2 (t.Create(KSemaphore,ConnectThread,0x2000,0x1000,0x10000,0,EOwnerThread),KErrNone);
sl@0: 	t.Resume();
sl@0: 	TRequestStatus st;
sl@0: 	t.Logon(st);
sl@0: 	t.Close();
sl@0: 	s.Wait();
sl@0: 	Connect();
sl@0: 	s.Signal();
sl@0: 	s.Close();
sl@0: 	User::WaitForRequest(st);
sl@0: 	test2 (TheDbs.ResourceCount(),0);
sl@0: 	Disconnect();
sl@0: 	test.Next(_L("Deferred exit"));
sl@0: 	find.Find(_L("!DBMS server"));
sl@0: 	test2 (find.Next(result),KErrNone);
sl@0: 	User::After(KExitDelay);
sl@0: 	find.Find(_L("!DBMS server"));
sl@0: 	test2 (find.Next(result),KErrNotFound);
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0606
sl@0: @SYMTestCaseDesc        Tests for benchmark
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for creating database and writing a table.Test for no error conditions.
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestBenchL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0606 Create database "));
sl@0: 	TInt r=TheDatabase.Replace(TheFs,KTestDatabase,KTestFormat);
sl@0: 	test (r==KErrNone);
sl@0: 	Execute(KCreateTable1);
sl@0: 	test.Next(_L("write table"));
sl@0: 	r=TheTable.Open(TheDatabase,KTable1);
sl@0: 	test (r==KErrNone);
sl@0: 	WriteRecordsL(KRowCount);
sl@0: 	TheTable.Close();
sl@0: 	test.Next(_L("BenchmarkL"));
sl@0: 	TRAPD(errCode, BenchmarkL());
sl@0: 	test(errCode == KErrNone);
sl@0: 	test.Next(_L("Open server-side"));
sl@0: 	TheDatabase.Close();
sl@0: 	Connect();
sl@0: 	r=TheDatabase.Open(TheDbs,KTestDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	test.Next(_L("BenchmarkL"));
sl@0: 	TRAP(errCode, BenchmarkL());
sl@0: 	test(errCode == KErrNone);
sl@0: 	test.Next(_L("Wrap up"));
sl@0: 	TheDatabase.Close();
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0607
sl@0: @SYMTestCaseDesc        Tests for opening a shared database
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for database open,column type,write and drop table
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestOpenL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0607 Create database "));
sl@0: 	test2 (TheDatabase.Replace(TheFs,KTestDatabase,KTestFormat),KErrNone);
sl@0: 	TheDatabase.Close();
sl@0: 	test.Next(_L("Open as shared"));
sl@0: 	Connect();
sl@0: 	test2 (TheDatabase.Open(TheDbs,KTestDatabase),KErrNone);
sl@0: 	Execute(KCreateTable1);
sl@0: 	test2 (TheTable.Open(TheDatabase,KTable1),KErrNone);
sl@0: 	test2 (TheTable.ColCount(),4);
sl@0: 	test2 (TheTable.ColType(1),EDbColInt32);
sl@0: 	test2 (TheTable.ColType(2),EDbColText);
sl@0: 	test2 (TheTable.ColType(3),EDbColLongText);
sl@0: 	test2 (TheTable.ColType(4),EDbColLongBinary);
sl@0: 	delete TheTable.ColSetL();
sl@0: 	test.Next(_L("write table"));
sl@0: 	WriteRecordsL(KRowCount);
sl@0: 	test.Next(_L("Check table"));
sl@0: 	TheTable.Reset();
sl@0: 	test (TheTable.AtBeginning());
sl@0: 	test (!TheTable.AtRow());
sl@0: 	test (!TheTable.AtEnd());
sl@0: 	test2 (TheTable.CountL(),KRowCount);
sl@0: 	IterateL(TheTable.ENext);
sl@0: 	test (!TheTable.AtBeginning());
sl@0: 	test (!TheTable.AtRow());
sl@0: 	test (TheTable.AtEnd());
sl@0: 	test.Next(_L("Delete rows"));
sl@0: 	test2 (DeleteL(),KRowCount);
sl@0: 	TheTable.Close();
sl@0: 	test.Next(_L("Drop table"));
sl@0: 	Execute(KDropTable1);
sl@0: 	TheDatabase.Close();
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0608
sl@0: @SYMTestCaseDesc        Tests for database locking
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for shared,exclusive locks on database
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestLocking()
sl@0: 	{
sl@0: 	TInt r;
sl@0: 	RDbNamedDatabase db;
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0608 Open databases "));
sl@0: 	Connect();
sl@0: 	test2 (TheDatabase.Open(TheDbs,KTestDatabase),KErrNone);
sl@0: 	test2 (db.Open(TheDbs,KTestDatabase,KTestFormat),KErrNone);
sl@0: 	RDbNotifier ob;
sl@0: 	test2 (ob.Open(TheDatabase),KErrNone);
sl@0: //
sl@0: 	test.Next(_L("Shared locks"));
sl@0: 	TRequestStatus stat;
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	test2 (db.Begin(),KErrNone);
sl@0: 	test2 (TheDatabase.Commit(),KErrNone);
sl@0: 	User::After(1);
sl@0: 	test2 (stat.Int(),KRequestPending);		// should not report yet
sl@0: 	test2 (db.Commit(),KErrNone);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test2 (stat.Int(),ob.EUnlock);
sl@0: //
sl@0: 	test.Next(_L("Exclusive locks"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	test2 (db.Begin(),KErrNone);
sl@0: 	test2 (TheDatabase.Execute(KCreateTable1),KErrLocked);	// cannot acquire
sl@0: 	test2 (db.Commit(),KErrNone);	// release lock
sl@0: 	test2 (TheDatabase.Execute(KCreateTable1),KErrNone);	// upgrade to X-lock
sl@0: 	test2 (db.Begin(),KErrLocked);	// cannot share
sl@0: 	test2 (TheTable.Open(db,KTable1),KErrNone);
sl@0: 	TRAP(r,TheTable.InsertL());		// cannot lock
sl@0: 	test2 (r,KErrLocked);
sl@0: 	TheTable.Close();
sl@0: 	test2 (db.Execute(KDropTable1),KErrLocked);	// cannot lock
sl@0: 	test2 (TheTable.Open(TheDatabase,KTable1),KErrNone);
sl@0: 	TRAP(r,TheTable.InsertL());		// we own the lock
sl@0: 	test2 (r,KErrNone);
sl@0: 	TheTable.Cancel();
sl@0: 	TheTable.Close();
sl@0: 	test2 (TheDatabase.Execute(KDropTable1),KErrNone);
sl@0: 	test2 (stat.Int(),KRequestPending);	// no NotifyUnlock yet
sl@0: 	test2 (TheDatabase.Commit(),KErrNone);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test2 (stat.Int(),ob.ECommit);
sl@0: //
sl@0: 	ob.Close();
sl@0: 	db.Close();
sl@0: 	TheDatabase.Close();
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0609
sl@0: @SYMTestCaseDesc        Tests for sharing a database
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for opening a database more than once.
sl@0:                         Tests the integrity of the table data
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestShareL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0609 Open database "));
sl@0: 	Connect();
sl@0: 	TInt r=TheDatabase.Open(TheDbs,KTestDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	Execute(KCreateTable1);
sl@0: 	test.Next(_L("Open it again"));
sl@0: 	RDbNamedDatabase db;
sl@0: 	test (db.Open(TheDbs,KTestDatabase,KTestFormat)==KErrNone);
sl@0: 	test (TheTable.Open(db,KTable1)==KErrNone);
sl@0: 	test2 (TheTable.ColCount(),4);
sl@0: 	test2 (TheTable.ColType(1),EDbColInt32);
sl@0: 	test2 (TheTable.ColType(2),EDbColText);
sl@0: 	test2 (TheTable.ColType(3),EDbColLongText);
sl@0: 	test2 (TheTable.ColType(4),EDbColLongBinary);
sl@0: 	delete TheTable.ColSetL();
sl@0: 	TheTable.Close();
sl@0: //
sl@0: 	test.Next(_L("write table"));
sl@0: 	test (TheTable.Open(TheDatabase,KTable1)==KErrNone);
sl@0: 	WriteRecordsL(KRowCount);
sl@0: 	TheTable.Close();
sl@0: 	test.Next(_L("Check table"));
sl@0: 	TheDatabase.Close();
sl@0: 	TheDatabase=db;
sl@0: 	test (TheTable.Open(TheDatabase,KTable1)==KErrNone);
sl@0: 	test (TheTable.AtBeginning());
sl@0: 	test (!TheTable.AtRow());
sl@0: 	test (!TheTable.AtEnd());
sl@0: 	test (TheTable.CountL()==KRowCount);
sl@0: 	IterateL(TheTable.ENext);
sl@0: 	test (!TheTable.AtBeginning());
sl@0: 	test (!TheTable.AtRow());
sl@0: 	test (TheTable.AtEnd());
sl@0: 	test.Next(_L("Delete rows"));
sl@0: 	test (DeleteSQL()==KRowCount);
sl@0: 	TheTable.Close();
sl@0: 	test.Next(_L("Drop table"));
sl@0: 	Execute(KDropTable1);
sl@0: 	TheDatabase.Close();
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario1L()
sl@0: 	{
sl@0: 	test.Start(_L("Take stream-lock on client 2"));
sl@0: 	test (TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	RDbColReadStream rcol;
sl@0: 	rcol.OpenLC(TheView,3);
sl@0: 	test2 (rcol.ReadUint16L(),0);
sl@0: 	test.Next(_L("Take a [shared] transaction-lock on client 1"));
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	test.Next(_L("Attempt a write-lock on client 1"));
sl@0: 	TRAPD(r,TheTable.InsertL());
sl@0: 	test2 (r,KErrLocked);
sl@0: 	test2 (rcol.ReadUint16L(),1);
sl@0: 	test.Next(_L("Release locks on client 1 and then 2"));
sl@0: 	TheDatabase.Rollback();
sl@0: 	CleanupStack::PopAndDestroy();	// rcol
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario2L()
sl@0: 	{
sl@0: 	test.Start(_L("Take stream-lock on client 2"));
sl@0: 	test (TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	RDbColReadStream rcol;
sl@0: 	rcol.OpenLC(TheView,3);
sl@0: 	test2 (rcol.ReadUint16L(),0);
sl@0: 	test.Next(_L("Take a [shared] transaction-lock on client 1"));
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	test.Next(_L("Attempt a write-lock on client 1"));
sl@0: 	TRAPD(r,TheTable.InsertL());
sl@0: 	test2 (r,KErrLocked);
sl@0: 	test2 (rcol.ReadUint16L(),1);
sl@0: 	test.Next(_L("Release client 2 stream-lock"));
sl@0: 	CleanupStack::PopAndDestroy();	// rcol
sl@0: 	test.Next(_L("Take write-lock on client 1"));
sl@0: 	TheTable.InsertL();				// read-lock removed
sl@0: 	test.Next(_L("release client 1 locks"));
sl@0: 	TheTable.Cancel();
sl@0: 	TheDatabase.Rollback();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario3L(RDbDatabase& aClient2)
sl@0: 	{
sl@0: 	test.Start(_L("Take transaction-lock on client 1"));
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	test.Next(_L("Take stream-lock on client 2"));
sl@0: 	test (TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	RDbColReadStream rcol;
sl@0: 	rcol.OpenLC(TheView,3);
sl@0: 	test2 (rcol.ReadUint16L(),0);
sl@0: 	test.Next(_L("Release client 1 lock"));
sl@0: 	TheDatabase.Rollback();
sl@0: 	test.Next(_L("Take write-lock on client 2"));
sl@0: 	RDbTable table2;			// need a second cursor (cannot do insert with open streams)
sl@0: 	test2 (table2.Open(aClient2,KTable1,table2.EInsertOnly),KErrNone);
sl@0: 	TRAPD(r,table2.InsertL());
sl@0: 	test2 (r,KErrNone);
sl@0: 	test.Next(_L("Release stream-lock"));
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	test.Next(_L("Release write-lock"));
sl@0: 	table2.PutL();
sl@0: 	table2.Close();
sl@0: 	test.Next(_L("check the system is unlocked"));
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	test2 (TheDatabase.Commit(),KErrNone);
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario4L()
sl@0: 	{
sl@0: 	test.Start(_L("Take transaction-lock on client 1"));
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	test.Next(_L("Take stream-lock on client 1"));
sl@0: 	test (TheTable.FirstL());
sl@0: 	TheTable.GetL();
sl@0: 	RDbColReadStream rcol;
sl@0: 	rcol.OpenLC(TheTable,3);
sl@0: 	test2 (rcol.ReadUint16L(),0);
sl@0: 	test.Next(_L("Take write-lock on client 1"));
sl@0: 	RDbTable table2;			// need a second cursor (cannot do insert with open streams)
sl@0: 	test2 (table2.Open(TheDatabase,KTable1,table2.EInsertOnly),KErrNone);
sl@0: 	TRAPD(r,table2.InsertL());
sl@0: 	test2 (r,KErrNone);
sl@0: 	test.Next(_L("Release write-lock"));
sl@0: 	table2.PutL();
sl@0: 	table2.Close();
sl@0: 	test.Next(_L("Release stream-lock"));
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	test.Next(_L("release transaction-lock"));
sl@0: 	test2 (TheDatabase.Commit(),KErrNone);
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario5L()
sl@0: 	{
sl@0: 	test.Start(_L("Begin compaction on client 1"));
sl@0: 	RDbIncremental inc;
sl@0: 	TInt s;
sl@0: 	test2 (inc.Compact(TheDatabase,s),KErrNone);
sl@0: 	test.Next(_L("Attempt a stream-lock on client 2"));
sl@0: 	test (TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	RDbColReadStream rcol;
sl@0: 	TRAPD(r,rcol.OpenL(TheView,3));
sl@0: 	test (r==KErrLocked);
sl@0: 	test.Next(_L("Attempt a stream-lock on client 1"));
sl@0: 	TRAP(r,rcol.OpenL(TheTable,3));
sl@0: 	test (r==KErrAccessDenied);
sl@0: 	test.Next(_L("Release compaction lock"));
sl@0: 	inc.Close();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario6L()
sl@0: 	{
sl@0: 	test.Start(_L("Begin compaction on client 1 - open and read columns"));
sl@0: 	TheTable.Close();
sl@0: 
sl@0: 	RDbIncremental inc;
sl@0: 	TInt s;
sl@0: 	test2 (inc.Compact(TheDatabase,s),KErrNone);
sl@0: 
sl@0: 	test.Next(_L("Attempt to open a table on client 1"));
sl@0: 	TInt r=TheTable.Open(TheDatabase,KTable1);
sl@0: 	test (r==KErrNone);
sl@0: 
sl@0: 	//read short column data
sl@0: 	TheTable.FirstL();
sl@0: 	TheTable.GetL();
sl@0: 	TheTable.ColInt32(1);
sl@0: 
sl@0: 	// We cant write to tables
sl@0: 	TRAP(r,TheTable.InsertL());
sl@0: 	test (r==KErrAccessDenied);
sl@0: 
sl@0: 	RDbColReadStream rcol;
sl@0: 	// We can't read long columns
sl@0: 	TheTable.FirstL();
sl@0: 	TheTable.GetL();
sl@0: 	TRAP(r, rcol.OpenL(TheTable,3));
sl@0: 	test2 (r,KErrAccessDenied);
sl@0: 
sl@0: 	// can read other columns
sl@0: 	TRAP(r, rcol.OpenL(TheTable,4));
sl@0: 	test2 (r,KErrNone);
sl@0: 	rcol.Close();
sl@0: 
sl@0: 	test.Next(_L("Release compaction lock"));
sl@0: 	inc.Close();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario7L()
sl@0: 	{
sl@0: 	test.Start(_L("Open tables on client 1 - Begin compaction on client 1"));
sl@0: 
sl@0: 	TheTable.Close();
sl@0: 	test.Next(_L("Attempt to open a table on client 1"));
sl@0: 	TInt r=TheTable.Open(TheDatabase,KTable1);
sl@0: 	test (r==KErrNone);
sl@0: 
sl@0: 	test.Next(_L("Begin compaction on client 1"));
sl@0: 	RDbIncremental inc;
sl@0: 	TInt s;
sl@0: 	test2 (inc.Compact(TheDatabase,s),KErrNone);
sl@0: 
sl@0: 	//read short column data
sl@0: 	TheTable.FirstL();
sl@0: 	TheTable.GetL();
sl@0: 	TheTable.ColInt32(1);
sl@0: 
sl@0: 	// We cant write to tables
sl@0: 	TRAP(r,TheTable.InsertL());
sl@0: 	test (r==KErrAccessDenied);
sl@0: 
sl@0: 	RDbColReadStream rcol;
sl@0: 	// cant read 4K text
sl@0: 	TheTable.FirstL();
sl@0: 	TheTable.GetL();
sl@0: 	TRAP(r, rcol.OpenL(TheTable,3));
sl@0: 	test2 (r,KErrAccessDenied);
sl@0: 
sl@0: 	// can read 1K blob
sl@0: 	TRAP(r, rcol.OpenL(TheTable,4));
sl@0: 	test2 (r,KErrNone);
sl@0: 	rcol.Close();
sl@0: 
sl@0: 	test.Next(_L("Release compaction lock"));
sl@0: 	inc.Close();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void TestScenario8L()
sl@0: 	{
sl@0: 	test.Start(_L("Take update-lock on client 1"));
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	TheTable.InsertL();
sl@0: 	test.Next(_L("Read blob without locking on client 2"));
sl@0: 	test (TheView.FirstL());
sl@0: 	TheView.GetL();
sl@0: 	RDbColReadStream rcol;
sl@0: 	rcol.OpenLC(TheView,4);			// 1K blob
sl@0: 	test2 (rcol.ReadInt32L(),0);
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	TRAPD(r,rcol.OpenL(TheView,3));			// 4K text blob
sl@0: 	test2 (r,KErrLocked);
sl@0: 	test.Next(_L("Release client 1 lock"));
sl@0: 	TheTable.Cancel();
sl@0: 	TheDatabase.Rollback();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0610
sl@0: @SYMTestCaseDesc        Tests for a defect on database
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for database connection
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestDefectL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0610 Build test database "));
sl@0: 	Connect();
sl@0: 	TInt r=TheDatabase.Open(TheDbs,KTestDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	Execute(KCreateTable1);
sl@0: 	test2 (TheTable.Open(TheDatabase,KTable1),KErrNone);
sl@0: 	TheTable.InsertL();
sl@0: 	RDbColWriteStream wcol;
sl@0: 	wcol.OpenLC(TheTable,3);
sl@0: 	TInt ii;
sl@0: 	for (ii=0;ii<2048;++ii)
sl@0: 		wcol.WriteUint16L(ii);
sl@0: 	wcol.CommitL();
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	wcol.OpenLC(TheTable,4);
sl@0: 	for (ii=0;ii<256;++ii)
sl@0: 		wcol.WriteInt32L(ii);
sl@0: 	wcol.CommitL();
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	TheTable.PutL();
sl@0: //
sl@0: 	test.Next(_L("open client 2 connection"));
sl@0: 	RDbNamedDatabase db;
sl@0: 	test2 (db.Open(TheDbs,KTestDatabase,KTestFormat),KErrNone);
sl@0: 	test2 (TheView.Prepare(db,_L("select * from Table1")),KErrNone);
sl@0: 	test2 (TheView.EvaluateAll(),KErrNone);
sl@0: //
sl@0: 	test.Next(_L("Scenario 1"));
sl@0: 	TestScenario1L();
sl@0: //
sl@0: 	test.Next(_L("Scenario 2"));
sl@0: 	TestScenario2L();
sl@0: //
sl@0: 	test.Next(_L("Scenario 3"));
sl@0: 	TestScenario3L(db);
sl@0: //
sl@0: 	test.Next(_L("Scenario 4"));
sl@0: 	TestScenario4L();
sl@0: //
sl@0: 	test.Next(_L("Scenario 5"));
sl@0: 	TestScenario5L();
sl@0: //
sl@0: 	test.Next(_L("Scenario 6"));
sl@0: 	TestScenario6L();
sl@0: //
sl@0: 	test.Next(_L("Scenario 7"));
sl@0: 	TestScenario7L();
sl@0: //
sl@0: 	test.Next(_L("Scenario 8"));
sl@0: 	TestScenario8L();
sl@0: //
sl@0: 	
sl@0: 	test.Next(_L("tidy up"));
sl@0: 	test2 (TheDatabase.Begin(),KErrNone);
sl@0: 	TheView.Close();
sl@0: 	TheTable.Close();
sl@0: 	db.Close();
sl@0: 	Execute(KDropTable1);
sl@0: 	test2 (TheDatabase.Commit(),KErrNone);
sl@0: 	TheDatabase.Close();
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          PDS-DBMS-CT-4002
sl@0: @SYMTestCaseDesc	    Testing RDbIncremental API
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Executing SQL using RDbIncremental, Altering tables, creating and droping indexes
sl@0: @SYMTestExpectedResults After execution Table should exist in DB, after altering, table colums should change,
sl@0: 						creation of index should create index column in table, dropping index should remove
sl@0: 						it from table
sl@0: @SYMDEF                 DEF135710
sl@0: */
sl@0: LOCAL_C void TestRDbIncrementalAPIL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:PDS-DBMS-CT-4002 Testing RDbIncremental API"));
sl@0: 	
sl@0: 	Connect();
sl@0: 	TInt err = TheDatabase.Open(TheDbs,KTestDatabase);
sl@0: 	test2(err, KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("RDbIncremental API"));
sl@0: 	RDbIncremental inc;
sl@0: 	TInt step;
sl@0: 	
sl@0: 	test2(TheDatabase.Begin(), KErrNone);
sl@0: 	err = inc.Execute(TheDatabase, KCreateTable2, step);
sl@0: 	test2(err, KErrNone);	
sl@0: 	while(step > 0)
sl@0: 		{
sl@0: 		err = inc.Next(step);
sl@0: 		test2(err, KErrNone);
sl@0: 		}
sl@0: 	inc.Close();
sl@0: 	
sl@0: 	test.Next(_L("AlterTable"));
sl@0: 	CDbColSet* colSet = CDbColSet::NewLC();
sl@0: 	colSet->AddL(TDbCol(_L("Id2"), EDbColUint32));
sl@0: 	colSet->AddL(TDbCol(_L("Memo2"), EDbColText));
sl@0: 	test2(colSet->Count(), 2);
sl@0: 	err = inc.AlterTable(TheDatabase, KTable2, *colSet, step);
sl@0: 	test2(err, KErrNone);
sl@0: 	while(step > 0)
sl@0: 		{
sl@0: 		err = inc.Next(step);
sl@0: 		test2(err, KErrNone);
sl@0: 		}
sl@0: 	inc.Close();
sl@0: 	err = TheDatabase.Commit();
sl@0: 	test2(err, KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("CreateIndex"));
sl@0: 	TDbKeyCol kcol(_L("Id2"), TDbKeyCol::EAsc);
sl@0: 	CDbKey* key = CDbKey::NewLC();
sl@0: 	test2(TheDatabase.Begin(), KErrNone);
sl@0: 	key->AddL(kcol);
sl@0: 	err = inc.CreateIndex(TheDatabase, _L("Id2"), KTable2, *key, step);
sl@0: 	test2(err, KErrNone);
sl@0: 	while(step > 0)
sl@0: 		{
sl@0: 		err = inc.Next(step);
sl@0: 		test2(err, KErrNone);
sl@0: 		}
sl@0: 	inc.Close();
sl@0: 	
sl@0: 	test.Next(_L("DropIndex"));
sl@0: 	err = inc.DropIndex(TheDatabase, _L("Id2"), KTable2, step);
sl@0: 	test2(err, KErrNone);
sl@0: 	while(step > 0)
sl@0: 		{
sl@0: 		err = inc.Next(step);
sl@0: 		test2(err, KErrNone);
sl@0: 		} 
sl@0: 	inc.Close();
sl@0: 	err = inc.Execute(TheDatabase, KDropTable2, step);
sl@0: 	test2(err, KErrNone);
sl@0: 	while(step > 0)
sl@0: 		{
sl@0: 		err = inc.Next(step);
sl@0: 		test2(err, KErrNone);
sl@0: 		}
sl@0: 	err = TheDatabase.Commit();
sl@0: 	test2(err, KErrNone);
sl@0: 	inc.Close();
sl@0: 	
sl@0: 	CleanupStack::PopAndDestroy(2);
sl@0: 	
sl@0: 	TheDatabase.Close();
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          PDS-DBMS-CT-4003
sl@0: @SYMTestCaseDesc	    Testing RDbUpdate API
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Executing DML command using RDbUpdate, checking if rowCount working properly
sl@0: @SYMTestExpectedResults After DML execution, rowCount should return proper number of afected rows. 
sl@0: @SYMDEF                 DEF135710
sl@0: */
sl@0: LOCAL_C void TestRDbUpdate()
sl@0: {
sl@0: 	test.Start(_L(" @SYMTestCaseID:PDS-DBMS-CT-4003 Testing RDbUpdate API"));
sl@0: 	_LIT(DMLinsert, "INSERT INTO Table2 VALUES (2,'Mietek', 'Mietek ma kota')");
sl@0: 	
sl@0: 	Connect();
sl@0: 	TInt err = TheDatabase.Open(TheDbs,KTestDatabase);
sl@0: 	test2(err, KErrNone);
sl@0: 	
sl@0: 	err = TheDatabase.Begin();
sl@0: 	test2(err, KErrNone);
sl@0: 	
sl@0: 	err = TheDatabase.Execute(KCreateTable2, EDbCompareNormal);
sl@0: 	test(err >= KErrNone);
sl@0: 	
sl@0: 	RDbUpdate update;
sl@0: 	err = update.Execute(TheDatabase, DMLinsert, EDbCompareNormal );
sl@0: 	if(err != KErrNone)
sl@0: 		RDebug::Printf("Error on Execute %d",err);
sl@0: 	test2(err, KErrNone);	
sl@0: 	
sl@0: 	TInt rows = update.RowCount();
sl@0: 	RDebug::Printf("Afected rows %d",rows);
sl@0: 	test2(rows, 1);	
sl@0: 	update.Close();
sl@0: 	
sl@0: 	err = TheDatabase.Commit();
sl@0: 	test2(err, KErrNone);
sl@0: 	
sl@0: 	TheDatabase.Close();
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: }
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          PDS-DBMS-CT-4004 
sl@0: @SYMTestCaseDesc	    Testing RDbRow API
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Test for construction functions for RDbRow
sl@0: @SYMTestExpectedResults After Creation/Opening row should be a valid object.
sl@0: @SYMDEF                 DEF135710
sl@0: */
sl@0: LOCAL_C void TestRDbRowL()
sl@0: {
sl@0: 	test.Start(_L(" @SYMTestCaseID:PDS-DBMS-CT-4004 Testing RDbRow API"));
sl@0: 	const TInt KRowSize = 300;
sl@0: 	const TInt KRealRowSize = 512;
sl@0: 
sl@0: 	RDbRow row;
sl@0: 	row.CreateL(KRowSize);
sl@0: 	RDebug::Printf("Rows %d %d",row.Size(), row.MaxSize() );
sl@0: 	test2(row.MaxSize(), KRealRowSize);
sl@0: 	TAny* rptr = row.First();
sl@0: 	
sl@0: 	RDbRow row2;
sl@0: 	row2.Open(rptr, KRowSize, 2*KRowSize);
sl@0: 	RDebug::Printf("Row2s %d %d", KRowSize, row2.MaxSize());
sl@0: 	test2(row2.Size(), KRowSize);
sl@0: 	test2(row2.MaxSize(), 2*KRowSize);
sl@0: 	
sl@0: 	row.Close();
sl@0: 	row2.Close();
sl@0: 	test.End();
sl@0: }
sl@0: /*
sl@0:  * Helper function for SYSLIB-DBMS-CT-4005 Testing TTextOps API
sl@0:  */
sl@0: LOCAL_C TInt HelperCompareForTestTTextOps(const TText8*,TInt,const TText8*,TInt)
sl@0: 	{
sl@0: 	return KReturnValueForCompare;
sl@0: 	}
sl@0: /*
sl@0:  * Helper function for SYSLIB-DBMS-CT-4005 Testing TTextOps API
sl@0:  */
sl@0: LOCAL_C TInt HelperFindForTestTTextOps(const TDesC8&,const TText8*,TInt)
sl@0: 	{
sl@0: 	return KReturnValueForFind;
sl@0: 	}
sl@0: /**
sl@0: @SYMTestCaseID          PDS-DBMS-CT-4005
sl@0: @SYMTestCaseDesc	    Testing TTextOps API
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Test for Compare and Find functions for TTextOps
sl@0: @SYMTestExpectedResults Test if those functions really calling proper targets.
sl@0: @SYMDEF                 DEF135710
sl@0: */
sl@0: LOCAL_C void TestTTextOps()
sl@0: {
sl@0: 	test.Start(_L(" @SYMTestCaseID:PDS-DBMS-CT-4005 Testing TTextOps API"));
sl@0: 	TTextOps text;
sl@0: 	
sl@0: 	text.iCompare8 = HelperCompareForTestTTextOps;
sl@0: 	text.iFind8 = HelperFindForTestTTextOps;
sl@0: 	TInt ret = text.Compare(_L8("Ala ma kota"), _L8("Ala ma konia"));
sl@0: 	test2(ret, KReturnValueForCompare);
sl@0: 	ret = text.Find(_L8("Ala ma kota"), _L8("ma ko"));
sl@0: 	test2(ret, KReturnValueForFind);
sl@0: 	
sl@0: 	test.End();
sl@0: }
sl@0: 
sl@0: #if defined __WINS__ ||	defined __WINSCW__
sl@0: 
sl@0: LOCAL_C TInt ExecuteRemoteL(const TDesC& aCommand, const TDesC& aCommandLineArg)
sl@0: 	{
sl@0: 	RProcess process;
sl@0: 	User::LeaveIfError(process.Create(aCommand, aCommandLineArg));
sl@0: 	
sl@0: 	TRequestStatus status;
sl@0: 	process.Logon(status);
sl@0: 	process.Resume();
sl@0: 
sl@0: 	User::WaitForRequest(status);
sl@0: 	TInt exitReason = process.ExitReason();
sl@0: 	
sl@0: 	process.Close();
sl@0: 	User::LeaveIfError(exitReason);
sl@0: 	
sl@0: 	return exitReason;
sl@0: 	}
sl@0: 
sl@0: #endif //defined __WINS__ ||	defined __WINSCW__
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          PDS-DBMS-CT-4007
sl@0: @SYMTestCaseDesc	    Testing SPConv - This test case uses the Edbsconv tool 
sl@0: 						so therefore only runs on WINSCW builds
sl@0: @SYMTestPriority 	    High
sl@0: @SYMTestActions  	    Launch the external tool to generate SPD files
sl@0: @SYMTestExpectedResults Should produce SPD files and report no errors
sl@0: @SYMDEF                 DEF135710
sl@0: */
sl@0: LOCAL_C void TestSPConvL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:PDS-DBMS-CT-4007 Testing SPConv"));
sl@0: 	
sl@0: #if defined __WINS__ ||	defined __WINSCW__
sl@0: 	
sl@0: 	_LIT(KRomTxtFile1, "z:\\test\\11335577.txt");
sl@0: 	_LIT(KRomTxtFile2, "z:\\test\\11335578.txt");
sl@0: 	_LIT(KRomTxtFile3, "z:\\test\\11335579.txt");
sl@0: 	_LIT(KRomTxtFile4, "z:\\test\\1133557A.txt");
sl@0: 	_LIT(KCommand,"Edbspconv");
sl@0: 	_LIT(KCommandParameter, " /f=%S /b=%S /s");
sl@0: 	
sl@0: 	TBuf<200> commandParameter;
sl@0: 	
sl@0: 	test.Next(_L("Create SPD File from \"11335577.txt\""));
sl@0: 	commandParameter.Format(KCommandParameter, &KRomTxtFile1, &KTestSpdFile1);
sl@0: 	ExecuteRemoteL(KCommand, commandParameter);
sl@0: 		
sl@0: 	test.Next(_L("Create SPD File from \"11335578.txt\""));
sl@0: 	commandParameter.Format(KCommandParameter, &KRomTxtFile2, &KTestSpdFile2);
sl@0: 	ExecuteRemoteL(KCommand, commandParameter);
sl@0: 	
sl@0: 	test.Next(_L("Create SPD File from \"11335579.txt\""));
sl@0: 	commandParameter.Format(KCommandParameter, &KRomTxtFile3, &KTestSpdFile3);
sl@0: 	ExecuteRemoteL(KCommand, commandParameter);
sl@0: 	
sl@0: 	test.Next(_L("Create SPD File from \"1133557A.txt\""));
sl@0: 	commandParameter.Format(KCommandParameter, &KRomTxtFile4, &KTestSpdFile4);
sl@0: 	ExecuteRemoteL(KCommand, commandParameter);
sl@0: 	
sl@0: #else
sl@0: 	RDebug::Print(_L("Testing SPConv - This test case cannot run on hardware"));
sl@0: #endif	
sl@0: 	
sl@0: 	test.Next(_L("End"));
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: 
sl@0: /**
sl@0: @SYMTestCaseID          SYSLIB-DBMS-CT-0611
sl@0: @SYMTestCaseDesc        Tests the behaviour of observers
sl@0: @SYMTestPriority        Medium
sl@0: @SYMTestActions         Tests for DDL,DML
sl@0: @SYMTestExpectedResults Test must not fail
sl@0: @SYMREQ                 REQ0000
sl@0: */
sl@0: LOCAL_C void TestObserverL()
sl@0: 	{
sl@0: 	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0611 Single connection/observer "));
sl@0: 	Connect();
sl@0: 	TInt r=TheDatabase.Open(TheDbs,KTestDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	RDbNotifier ob;
sl@0: 	r=ob.Open(TheDatabase);
sl@0: 	test (r==KErrNone);
sl@0: //
sl@0: 	test.Next(_L("Cancel"));
sl@0: 	TRequestStatus stat;
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	test (stat==KRequestPending);
sl@0: 	ob.Cancel();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==KErrCancel);
sl@0: //
sl@0: 	test.Next(_L("Close"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	test (stat==KRequestPending);
sl@0: 	ob.Close();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==KErrCancel);
sl@0: //
sl@0: 	test.Next(_L("DDL"));
sl@0: 	r=ob.Open(TheDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	test (stat==KRequestPending);
sl@0: 	Execute(KCreateTable1);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.ECommit);
sl@0: //
sl@0: 	test.Next(_L("DML"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	test (stat==KRequestPending);
sl@0: 	r=TheTable.Open(TheDatabase,KTable1);
sl@0: 	test (r==KErrNone);
sl@0: 	WriteRecordsL(50);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.ECommit);
sl@0: //
sl@0: 	test.Next(_L("Locked read"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	TheDatabase.Begin();
sl@0: 	test (stat==KRequestPending);
sl@0: 	TheDatabase.Commit();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EUnlock);
sl@0: //
sl@0: 	test.Next(_L("Database closed"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	TheTable.Close();
sl@0: 	TheDatabase.Close();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EClose);
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EClose);
sl@0: //
sl@0: 	test.Next(_L("Re-open database"));
sl@0: 	r=TheDatabase.Open(TheDbs,KTestDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EClose);
sl@0: 	ob.Close();
sl@0: //
sl@0: 	test.Next(_L("Multiple connections and observers"));
sl@0: 	r=ob.Open(TheDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	RDbNamedDatabase db2;
sl@0: 	r=db2.Open(TheDbs,KTestDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	RDbNotifier ob2;
sl@0: 	r=ob2.Open(db2);
sl@0: 	test (r==KErrNone);
sl@0: //
sl@0: 	test.Next(_L("Cancel"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	TRequestStatus stat2;
sl@0: 	ob2.NotifyUnlock(stat2);
sl@0: 	test (stat==KRequestPending);
sl@0: 	ob.Cancel();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==KErrCancel);
sl@0: 	test (stat2==KRequestPending);
sl@0: 	ob2.Cancel();
sl@0: 	User::WaitForRequest(stat2);
sl@0: 	test (stat2==KErrCancel);
sl@0: //
sl@0: 	test.Next(_L("Close"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	ob2.NotifyUnlock(stat2);
sl@0: 	test (stat2==KRequestPending);
sl@0: 	ob2.Close();
sl@0: 	User::WaitForRequest(stat2);
sl@0: 	test (stat2==KErrCancel);
sl@0: 	test (stat==KRequestPending);
sl@0: 	ob.Close();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==KErrCancel);
sl@0: //
sl@0: 	test.Next(_L("NotifyChange"));
sl@0: 	r=ob.Open(TheDatabase);
sl@0: 	test (r==KErrNone);
sl@0: 	r=ob2.Open(db2);
sl@0: 	test (r==KErrNone);
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	ob2.NotifyChange(stat2);
sl@0: 	TheDatabase.Begin();
sl@0: 	r=TheDatabase.Commit();
sl@0: 	test (r==KErrNone);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EUnlock);
sl@0: 	test (stat2==KRequestPending);
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	db2.Begin();
sl@0: 	r=db2.Commit();
sl@0: 	test (r==KErrNone);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EUnlock);
sl@0: 	test (stat2==KRequestPending);
sl@0: 	Execute(KDropTable1);
sl@0: 	User::WaitForRequest(stat2);
sl@0: 	test (stat2==ob.ECommit);
sl@0: //
sl@0: 	test.Next(_L("missed event"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.ECommit);
sl@0: //
sl@0: 	test.Next(_L("database close"));
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	test (stat==KRequestPending);
sl@0: 	ob2.NotifyUnlock(stat2);
sl@0: 	test (stat2==KRequestPending);
sl@0: 	TheDatabase.Close();
sl@0: 	User::After(0x20000);	// ~.1s
sl@0: 	test (stat==KRequestPending);
sl@0: 	test (stat2==KRequestPending);
sl@0: 	db2.Close();
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EClose);
sl@0: 	User::WaitForRequest(stat2);
sl@0: 	test (stat2==ob.EClose);
sl@0: 	ob.NotifyUnlock(stat);
sl@0: 	User::WaitForRequest(stat);
sl@0: 	test (stat==ob.EClose);
sl@0: 	ob.Cancel();
sl@0: 	ob.Close();
sl@0: 	ob2.NotifyUnlock(stat2);
sl@0: 	User::WaitForRequest(stat2);
sl@0: 	test (stat2==ob.EClose);
sl@0: 	ob2.Cancel();
sl@0: 	ob2.Close();
sl@0: //
sl@0: 	Disconnect();
sl@0: 	test.End();
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void setupTestDirectory()
sl@0: //
sl@0: // Prepare the test directory.
sl@0: //
sl@0:     {
sl@0: 	TInt r=TheFs.Connect();
sl@0: 	test(r==KErrNone);
sl@0: //
sl@0: 	r=TheFs.MkDir(KTestDatabase);
sl@0: 	test(r==KErrNone || r==KErrAlreadyExists);
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void setupCleanup()
sl@0: //
sl@0: // Initialise the cleanup stack.
sl@0: //
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  KillDbmsServer()
sl@0:     {
sl@0:     _LIT(KDbmsServer,"edbsrv.exe");
sl@0:      TFullName name;
sl@0:     TBuf<64> pattern(KDbmsServer);
sl@0:     TInt length = pattern.Length();
sl@0:     pattern += _L("*");
sl@0:     TFindProcess procFinder(pattern);
sl@0: 
sl@0:     while (procFinder.Next(name) == KErrNone)
sl@0:         {
sl@0:         if (name.Length() > length)
sl@0:             {//If found name is a string containing aProcessName string.
sl@0:             TChar c(name[length]);
sl@0:             if (c.IsAlphaDigit() ||
sl@0:                 c == TChar('_') ||
sl@0:                 c == TChar('-'))
sl@0:                 {
sl@0:                 // If the found name is other valid application name
sl@0:                 // starting with aProcessName string.
sl@0:                 //RDebug::Print(_L(":: Process name: \"%S\".\n"), &name);
sl@0:                 continue;
sl@0:                 }
sl@0:             }
sl@0:         RProcess proc;
sl@0:         if (proc.Open(name) == KErrNone)
sl@0:             {
sl@0:             proc.Kill(0);
sl@0:             //RDebug::Print(_L("\"%S\" process killed.\n"), &name);
sl@0:             }
sl@0:         proc.Close();
sl@0:         }
sl@0:     }
sl@0: void DoTests()
sl@0: 	{
sl@0: 	TVersionName n=RDbs::Version().Name();
sl@0: 	test.Printf(_L("DBMS server v%S\n"),&n);
sl@0: 	TInt r;
sl@0: 	test.Start(_L("Connection"));
sl@0: 	TestConnect();
sl@0: 	
sl@0: 	test.Next(_L("Open Database"));
sl@0: 	TRAP(r,TestOpenL());
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("test defect"));
sl@0: 	TRAP(r,TestDefectL());
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("Share Database"));
sl@0: 	TRAP(r,TestShareL());
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("Locking"));
sl@0: 	TRAP(r,TestLocking());
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("Observers"));
sl@0: 	TRAP(r,TestObserverL());
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("Benchmarks"));
sl@0: 	TRAP(r,TestBenchL());
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("RDbIncremental"));
sl@0: 	TRAP(r, TestRDbIncrementalAPIL() );
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("RDbUpdate"));
sl@0: 	TestRDbUpdate();
sl@0: 
sl@0: 	test.Next(_L("RDbRow"));
sl@0: 	TRAP(r, TestRDbRowL() );
sl@0: 	test2 (r,KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("TTextOpsL"));
sl@0: 	TestTTextOps();
sl@0: 	
sl@0: 	test.Next(_L("TestSPConvL"));
sl@0: 	TRAP(r, TestSPConvL() );
sl@0: 	test2 (r, KErrNone);
sl@0: 	
sl@0: 	test.Next(_L("Waiting for server exit"));
sl@0: 	}
sl@0: 
sl@0: 
sl@0: GLDEF_C TInt E32Main()
sl@0: //
sl@0: // Test streaming conversions.
sl@0: //
sl@0:     {
sl@0: 	__UHEAP_MARK;
sl@0: 	
sl@0: 	test.Title();
sl@0: 	setupTestDirectory();
sl@0: 	DeleteTestFiles();
sl@0: 	setupCleanup();
sl@0: 	KillDbmsServer();
sl@0: 	DoTests();
sl@0: 	delete TheTrapCleanup;
sl@0: 	DeleteTestFiles();
sl@0: 	
sl@0: 	test.End();
sl@0: 	TheFs.Close();
sl@0: 	test.Close();
sl@0: 	__UHEAP_MARKEND;
sl@0: 	return 0;
sl@0:     }