// 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 <e32math.h>

#include <s32file.h>

#include <e32test.h>

#include "t_fail.h"

#include "crccheck.h"

#undef __UHEAP_MARK

#define __UHEAP_MARK

#undef __UHEAP_MARKEND

#define __UHEAP_MARKEND

#undef __UHEAP_CHECK

#define __UHEAP_CHECK(a)

LOCAL_D TDBMS_CRCChecks TheCrcChecker;

#ifndef __linux__ //No CRC test on LINUX

#ifdef __TOOLS2__

const TPtrC	KCrcRecord=_L("\\epoc32\\winscw\\c\\dbms-tst\\T_FAIL.CRC");

#else

const TPtrC	KCrcRecord=_L("C:\\dbms-tst\\T_FAIL.CRC");

#endif

#endif

#define CRCCHECK  (TheCrcChecker.GenerateCrcL(KTestDatabase))

_LIT(KTestTitle,"T_FAIL: DBMS Failure mode test");

GLDEF_D RTest test(KTestTitle);

GLDEF_D RDbs TheDbs;

GLDEF_D RDbNamedDatabase TheDatabase;

GLDEF_D TClientHeap KClientHeap;

GLDEF_D TServerHeap KServerHeap;

LOCAL_D CTrapCleanup* TheTrapCleanup;

LOCAL_D RFs TheFs;

LOCAL_D RDbView TheView;

LOCAL_D RDbTable TheTable;

LOCAL_D RDbRowSet::TAccess Access;

LOCAL_D CDbColSet* TheColSet;

LOCAL_D CDbKey* TheKey;

LOCAL_D const TDesC* TheSql;

LOCAL_D TBuf<64> TheFormat;

const TInt KTestCleanupStack=0x20;

#ifndef __TOOLS2__

const TPtrC KTestDatabase=_L("C:\\dbms-tst\\t_fail.db");

#else

const TPtrC KTestDatabase=_L(".\\dbms-tst\\t_fail.db");

#endif

_LIT(TableName,"Table1");

_LIT(TableName2,"Table_two");

_LIT(TableNameX,"Bad Table Name");

_LIT(IndexName,"Index1");

_LIT(IndexName2,"Index2");

_LIT(Column1,"column_one");

_LIT(Column1Fold,"COLUMN_ONE");

_LIT(Column2,"column_2");

_LIT(Column2X,"column_2%");

_LIT(SimpleSql,"select * from Table1");

_LIT(UpdateSql,"update Table1 SET column_2='hello'");

//const TPtrC ComplexSql(_S("select * from Table1 where column_one<0 and not column_one is null or column_2 not like '*fred*' and column_2>'m' order by column_one desc"));

const TPtrC ComplexSql[]=

	{

	_S("select * from Table1 where column_one<0 and column_one is null"),

	_S("select * from Table1 where column_one<0 and (column_one is null and column_2 like '')"),

	_S("select * from Table1 where (column_one<0 and column_one is null) and column_2 like ''"),

	_S("select * from Table1 where (column_one<0 and column_one is null) and (column_2 like '' and column_one>0)"),

	_S("select * from Table1 where (column_one<0 and column_one is null) and (column_2 like '' and column_one>0 and column_one is null)"),

	_S("select * from Table1 where (column_one<0 and column_one is null and column_one = 10) and (column_2 like '' and column_one>0 and column_one is null)"),

	_S("select * from Table1 where column_one<0 and column_one is null and column_one = 10 and column_2 like '' and column_one>0 and column_one is null")

	};

struct SSqlErrors

	{

	const TText* iSql;

	TInt iError;

	};

LOCAL_D SSqlErrors const BadSql[]=

	{

		{_S("sponge"),KErrArgument},

		{_S("select * from widget"),KErrNotFound},

		{_S("select * from Table1 where x = 0"),KErrNotFound},

		{_S("select * from Table1 where x 0 like"),KErrArgument},

		{_S("select * from Table1 where column_2>'a' and column_one<'z'"),KErrGeneral},

		{_S("select from Table1"),KErrArgument},

		{_S("select x, from Table1"),KErrArgument},

		{_S("select x from Table1"),KErrNotFound},

		{_S("select column_2 column_one from Table1"),KErrArgument},

		{_S("select * from Table1 order by x"),KErrNotFound},

		{_S("select * from Table1 order column_one"),KErrArgument},

		{_S("select * from Table1 order by column_one down"),KErrArgument}

	};

GLDEF_C void Connect()

	{

#ifndef __TOOLS2__

	TInt r=TheDbs.Connect();

	test (r==KErrNone);

	TheDbs.ResourceMark();

#endif

	}

GLDEF_C void Disconnect()

	{

#ifndef __TOOLS2__

	TheDbs.ResourceCheck();

	TheDbs.Close();

#endif

	}

//SYMBIAN_REMOVE_TRIVIAL_ENCRYPTION version

LOCAL_C void DbCreateL()

	{

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

	}

//SYMBIAN_REMOVE_TRIVIAL_ENCRYPTION version

LOCAL_C void DbOpenL()

	{

	User::LeaveIfError(TheDatabase.Open(TheFs,KTestDatabase,TheFormat));

	CleanupClosePushL(TheDatabase);

	delete TheDatabase.TableNamesL();	// force a schema load

	CleanupStack::Pop();

	}

//SYMBIAN_REMOVE_TRIVIAL_ENCRYPTION version

LOCAL_C void DbShareL()

	{

	User::LeaveIfError(TheDatabase.Open(TheDbs,KTestDatabase,TheFormat));

	CleanupClosePushL(TheDatabase);

	delete TheDatabase.TableNamesL();	// force a schema load

	CleanupStack::Pop();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0612

@SYMTestCaseDesc        Database validity test

@SYMTestPriority        Medium

@SYMTestActions         Tests for opening and closing of database

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestOpen()

	{

	_LIT(KFileNotFound,"not a database");

	TInt r=TheDatabase.Open(TheFs,KFileNotFound);

	test (r==KErrNotFound || r==KErrPathNotFound);

//

	_LIT(KPathNotFound,"C:\\not a path\\database.db");

	r=TheDatabase.Open(TheFs,KPathNotFound);

#ifndef __TOOLS2__

	test (r==KErrPathNotFound);

#else

	// Tools2 f32 does not return KErrPathNotFound

	test( (r==KErrPathNotFound) || (r==KErrNotFound));

#endif

//

	_LIT(KNotFormat,"not.a.dbx");

	r=TheDatabase.Open(TheFs,KFileNotFound,KNotFormat);

	test (r==KErrNotFound || r==KErrPathNotFound);

//

	DbCreateL();

	TheDatabase.Close();

	TInt err = CRCCHECK;

	test(err == KErrNone);

	r=TheDatabase.Open(TheFs,KTestDatabase,TUid::Uid(0x01234567).Name());

	test (r==KErrNone); // New code has no loadable drivers, it is irrelevant to expect error here

	TheDatabase.Close(); // We have added it here because previous statement does not return error anymore

	err = CRCCHECK;

	test(err == KErrNone);

//

	RFile f;

	r=f.Replace(TheFs,KTestDatabase,EFileWrite);

	test (r==KErrNone);

	TCheckedUid type(KDirectFileStoreLayoutUid);

	r=f.Write(type.Des());

	test (r==KErrNone);

	f.Close();

	r=TheDatabase.Open(TheFs,KTestDatabase);

	test (r==KErrNotSupported);

//

	_LIT(KDefaultFormat,"epoc");

	r=TheDatabase.Open(TheFs,KTestDatabase,KDefaultFormat);

	test (r==KErrNotSupported); // We expect not supported db here

	}

class TClient : public TContext

	{

public:

	TClient() {}

private:

	void OpenDbL() const

		{DbOpenL();}

	};

class TServer : public TContext

	{

public:

	TServer() {}

private:

	void OpenDbL() const

		{DbShareL();}

	};

const TClient KClient;

const TServer KServer;

void TFail::Test(const THeapFail& aHeap,const TContext* aContext)

	{

	TInt ii;

	TInt errCode;

	for (ii=1;;++ii)

		{

		if (aContext)

			{

			TRAP(errCode, aContext->OpenDbL());

			if(errCode != KErrNone)

				return;

			}

		aHeap.Fail(ii);

		aHeap.Mark();

		TRAPD(r,RunL());

		aHeap.Reset();

		if (r==KErrNone)

			break;

		test(r==KErrNoMemory);

		if (aContext)

			{

			TheDatabase.Close();

			TRAPD(lc, errCode = CRCCHECK);

			test(errCode == KErrNone);

			test(lc == KErrNone);

			}

		aHeap.Check();

		}

	End();

	if (aContext)

		{

		TheDatabase.Close();

		TRAPD(lc, errCode = CRCCHECK);

		test(errCode == KErrNone);

		test(lc == KErrNone);

		}

	aHeap.Check();

	}

class TFailCreateDatabase : public TFail

	{

	void RunL()

		{DbCreateL();}

	void End()

		{

		TheDatabase.Close();

		TInt err;

		TRAPD(lc, err = CRCCHECK);

		test(err == KErrNone);

		test(lc == KErrNone);

		}

	};

class TFailOpenDatabase : public TFail

	{

	void RunL()

		{DbOpenL();}

	void End()

		{

		TheDatabase.Close();

		TInt err;

		TRAPD(lc, err = CRCCHECK);

		test(err == KErrNone);

		test(lc == KErrNone);

	   	}

	};

class TFailShareDatabase : public TFail

	{

	void RunL()

		{DbShareL();}

	void End()

		{

		TheDatabase.Close();

// Unfortunately it is not possible to generate CRC checks here. The

// database on a number of occasions is still open by another instance.

// This causes a KErrInUse in the CRC check code for Symbian, but

// works on TOOLS2, thus giving probably spurious mismatches.

//		TInt err;

//		TRAPD(lc, err = CRCCHECK);

//		RDebug::Print(_L("ERROR %d\n"), err);

//		test(err == KErrNone);

//		test(lc == KErrNone);

	   	}

	};

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0613

@SYMTestCaseDesc        Tests for allocation failures on creating a database

@SYMTestPriority        Medium

@SYMTestActions         Tests for allocation failure for differently sourced databases

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void Origins()

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0613 Allocation failures on Creating a database "));

	TFailCreateDatabase t1;

	t1.Test(KClientHeap);

//

	test.Next(_L("Fail to create existing database"));

#ifndef __TOOLS2__

	TUint att;

	TInt r=TheFs.Att(KTestDatabase,att);

	test (r==KErrNone);

#else

	TInt r;

#endif

	r=TheDatabase.Create(TheFs,KTestDatabase,TheFormat);

	test (r==KErrAlreadyExists);

#ifndef __TOOLS2__

	r=TheFs.Att(KTestDatabase,att);

	test (r==KErrNone);

#endif

//

	test.Next(_L("Allocation failures on Open"));

	TFailOpenDatabase t2;

	t2.Test(KClientHeap);

//

	test.Next(_L("Allocation failures on 1st Share"));

	Connect();

	TFailShareDatabase t3;

	t3.Test(KClientHeap);

	t3.Test(KServerHeap);

//

	test.Next(_L("Allocation failures on 2nd Share"));

	DbShareL();

	RDbNamedDatabase temp=TheDatabase;TheDatabase=RDbNamedDatabase();

	t3.Test(KClientHeap);

	t3.Test(KServerHeap);

	temp.Close();

	Disconnect();

	test.End();

	}

class TFailCreateTable : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheDatabase.CreateTable(TableName,*TheColSet));}

	};

class TFailAlterTable : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheDatabase.AlterTable(TableName,*TheColSet));}

	};

class TFailDropTable : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheDatabase.DropTable(TableName));}

	};

class TFailCreateIndex : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheDatabase.CreateIndex(IndexName,TableName,*TheKey));}

	};

class TFailDropIndex : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheDatabase.DropIndex(IndexName,TableName));}

	};

class TFailGetObject : public TFail

	{

protected:

	void End()

		{delete iObject;}

protected:

	CBase* iObject;

	};

class TFailDatabaseTables : public TFailGetObject

	{

	void RunL()

		{iObject=TheDatabase.TableNamesL();}

	};

class TFailDatabaseColSet : public TFailGetObject

	{

	void RunL()

		{iObject=TheDatabase.ColSetL(TableName);}

	};

class TFailDatabaseIndexes : public TFailGetObject

	{

	void RunL()

		{iObject=TheDatabase.IndexNamesL(TableName);}

	};

class TFailDatabaseKeys : public TFailGetObject

	{

	void RunL()

		{iObject=TheDatabase.KeyL(IndexName,TableName);}

	};

const TInt KRowCount=60;

LOCAL_C void WriteTableL()

	{

	DbOpenL();

	TInt r=TheTable.Open(TheDatabase,TableName);

	test (r==KErrNone);

	TheDatabase.Begin();

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

		{

		TheTable.InsertL();

		TheTable.SetColL(1,TUint((ii*17)%KRowCount));

		TheTable.PutL();

		}

	r=TheDatabase.Commit();

	test (r==KErrNone);

	TheTable.Close();

	TheDatabase.Close();

	TInt err = CRCCHECK;

	test(err == KErrNone);

	}

LOCAL_C void Database()

	{

	test.Start(_L("Adding and dropping tables"));

	DbCreateL();

// ensure the database locking list has been allocated

	TheDatabase.Begin();

	TheDatabase.Commit();

//

	CDbColSet *col=CDbColSet::NewLC();

//

	test.Next(_L("Empty Column Set"));

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableName,*col)!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Invalid table name"));

	col->AddL(TDbCol(Column1,EDbColInt32));

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableNameX,*col)!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Invalid column name"));

	col->AddL(TDbCol(Column2X,EDbColBit));

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableName,*col)!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Duplicate column name"));

	col->Remove(Column2X);

	col->AddL(TDbCol(Column1Fold,EDbColBit));

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableName,*col)!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Invalid column type"));

	col->Remove(Column1);

	col->AddL(TDbCol(Column2,TDbColType(-1)));

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableName,*col)!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Invalid maximum length"));

	col->Remove(Column2);

	col->AddL(TDbCol(Column2,EDbColInt32,0));

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableName,*col)!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Invalid attributes"));

	col->Remove(Column2);

	TDbCol cc(Column2,EDbColInt32);

	cc.iAttributes=13;

	col->AddL(cc);

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableName,*col)!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Adding/dropping a table name twice"));

	col->Remove(Column2);

	col->AddL(TDbCol(Column2,EDbColText8));

	__UHEAP_MARK;

	test(TheDatabase.CreateTable(TableName,*col)==KErrNone);

	test(TheDatabase.CreateTable(TableName,*col)==KErrAlreadyExists);

	test(TheDatabase.DropTable(TableNameX)!=KErrNone);

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

	test(TheDatabase.DropTable(TableName)==KErrNotFound);

	__UHEAP_MARKEND;

//

	test.Next(_L("Adding and dropping indexes"));

	test(TheDatabase.CreateTable(TableName,*col)==KErrNone);

	TheDatabase.Close();

	TInt err = CRCCHECK;

	test(err == KErrNone);

	CDbKey *key=CDbKey::NewLC();

	__UHEAP_MARK;

	DbOpenL();

	test(TheDatabase.CreateIndex(IndexName,TableName,*key)!=KErrNone);

	TheDatabase.Close();

	err = CRCCHECK;

	test(err == KErrNone);

	__UHEAP_MARKEND;

	key->AddL(Column2X());

	__UHEAP_MARK;

	DbOpenL();

	test(TheDatabase.CreateIndex(IndexName,TableName,*key)!=KErrNone);

	TheDatabase.Close();

	err = CRCCHECK;

	test(err == KErrNone);

	__UHEAP_MARKEND;

	key->Clear();

	key->AddL(Column1());

	__UHEAP_MARK;

	DbOpenL();

	test(TheDatabase.CreateIndex(TableNameX,TableName,*key)!=KErrNone);

	TheDatabase.Close();

	err = CRCCHECK;

	test(err == KErrNone);

	__UHEAP_CHECK(0);

	DbOpenL();

	test(TheDatabase.CreateIndex(IndexName,TableNameX,*key)!=KErrNone);

	TheDatabase.Close();

	err = CRCCHECK;

	test(err == KErrNone);

	__UHEAP_MARKEND;

	__UHEAP_MARK;

	DbOpenL();

	test(TheDatabase.CreateIndex(IndexName,TableName,*key)==KErrNone);

	test(TheDatabase.CreateIndex(IndexName,TableName,*key)==KErrAlreadyExists);

	test(TheDatabase.DropIndex(TableNameX,TableName)!=KErrNone);

	test(TheDatabase.DropIndex(IndexName,TableNameX)!=KErrNone);

	test(TheDatabase.DropIndex(IndexName,TableName)==KErrNone);

	test(TheDatabase.DropIndex(IndexName,TableName)==KErrNotFound);

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

	test(TheDatabase.DropIndex(IndexName,TableName)==KErrNotFound);

	TheDatabase.Close();

	err = CRCCHECK;

	test(err == KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Allocation failure during DDL"));

	TFailCreateTable fct;

	TFailAlterTable fat;

	TFailDropTable fdt;

	TFailCreateIndex fci;

	TFailDropIndex fdi;

	TheColSet=CDbColSet::NewL();

	TheColSet->AddL(TDbCol(Column1,EDbColUint16));

	TheKey=CDbKey::NewL();

	TheKey->AddL(Column1());

	fct.Test(KClientHeap,KClient);

	WriteTableL();

	TheColSet->AddL(TDbCol(Column2,EDbColText));

	fat.Test(KClientHeap,KClient);

	fci.Test(KClientHeap,KClient);

	fdi.Test(KClientHeap,KClient);

	fdt.Test(KClientHeap,KClient);

//

	test.Next(_L("Allocation failure during server DDL"));

	Connect();

	TheColSet->Remove(Column2);

	fct.Test(KClientHeap,KServer);

	WriteTableL();

	TheColSet->AddL(TDbCol(Column2,EDbColText));

	fat.Test(KClientHeap,KServer);

	fci.Test(KClientHeap,KServer);

	fdi.Test(KClientHeap,KServer);

	fdt.Test(KClientHeap,KServer);

//

	TheColSet->Remove(Column2);

	fct.Test(KServerHeap,KServer);

	WriteTableL();

	TheColSet->AddL(TDbCol(Column2,EDbColText));

	fat.Test(KServerHeap,KServer);

	fci.Test(KServerHeap,KServer);

	fdi.Test(KServerHeap,KServer);

	fdt.Test(KServerHeap,KServer);

	Disconnect();

//

	delete TheColSet;

	delete TheKey;

//

	test.Next(_L("Allocation failure on schema enquiry"));

	DbCreateL();

	test(TheDatabase.CreateTable(TableName,*col)==KErrNone);

	test(TheDatabase.CreateIndex(IndexName,TableName,*key)==KErrNone);

	CleanupStack::PopAndDestroy(2);	// columns set and key

	TheDatabase.Close();

	err = CRCCHECK;

	test(err == KErrNone);

	TFailDatabaseTables t4;

	TFailDatabaseColSet t5;

	TFailDatabaseIndexes t6;

	TFailDatabaseKeys t7;

	t4.Test(KClientHeap,KClient);

	t5.Test(KClientHeap,KClient);

	t6.Test(KClientHeap,KClient);

	t7.Test(KClientHeap,KClient);

//

	test.Next(_L("Allocation failure on server schema enquiry"));

	Connect();

	t4.Test(KClientHeap,KServer);

	t4.Test(KServerHeap,KServer);

	t5.Test(KClientHeap,KServer);

	t5.Test(KServerHeap,KServer);

	t6.Test(KClientHeap,KServer);

	t6.Test(KServerHeap,KServer);

	t7.Test(KClientHeap,KServer);

	t7.Test(KServerHeap,KServer);

	Disconnect();

	test.End();

	}

class TFailOpenTable : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheTable.Open(TheDatabase,TableName,Access));}

	void End()

		{TheTable.Close();}

	};

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0614

@SYMTestCaseDesc        Tests for allocation failure on opening and closing of database

@SYMTestPriority        Medium

@SYMTestActions         Tests for opening and closing of database

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestTable(const THeapFail& aHeap,const TContext& aContext)

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0614 Allocation failure on Open "));

	TFailOpenTable fot;

	Access=RDbRowSet::EUpdatable;

	fot.Test(aHeap,aContext);

	Access=RDbRowSet::EReadOnly;

	fot.Test(aHeap,aContext);

	Access=RDbRowSet::EInsertOnly;

	fot.Test(aHeap,aContext);

//

	test.Next(_L("Open invalid table"));

	aContext.OpenDbL();

	__UHEAP_MARK;

	TInt r=TheTable.Open(TheDatabase,TableNameX);

	test (r!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Set invalid index"));

	r=TheTable.Open(TheDatabase,TableName);

	test (r==KErrNone);

	__UHEAP_MARK;

	r=TheTable.SetIndex(IndexName2);

	test (r!=KErrNone);

	__UHEAP_MARKEND;

//

	test.Next(_L("Allocation failure on 2nd Open"));

	RDbTable table(TheTable);

	Access=RDbRowSet::EUpdatable;

	fot.Test(aHeap);

	Access=RDbRowSet::EReadOnly;

	fot.Test(aHeap);

	Access=RDbRowSet::EInsertOnly;

	fot.Test(aHeap);

	table.Close();

	TheDatabase.Close();

	r = CRCCHECK;

	test(r == KErrNone);

	test.End();

	}

LOCAL_C void TestTableDDL(const TContext& aContext)

	{

	test.Start(_L("DDL while open"));

	aContext.OpenDbL();

	TInt r=TheTable.Open(TheDatabase,TableName);

	test (r==KErrNone);

	CDbColSet* set=CDbColSet::NewLC();

	set->AddL(TDbCol(Column1,EDbColText));

	r=TheDatabase.CreateTable(TableName2,*set);

	test (r==KErrNone);

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrNone);

	TheTable.Close();

	r=TheTable.Open(TheDatabase,TableName2);

	test (r==KErrNone);

//

	set->AddL(TDbCol(Column2,EDbColUint32));

	r=TheDatabase.AlterTable(TableName2,*set);

	test (r==KErrNone);

	CleanupStack::PopAndDestroy();		// set

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrDisconnected);

	TheTable.Reset();

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrDisconnected);

	TheTable.Close();

	r=TheTable.Open(TheDatabase,TableName2);

	test (r==KErrNone);

//

	CDbKey* key=CDbKey::NewLC();

	key->AddL(Column2());

	r=TheDatabase.CreateIndex(IndexName2,TableName,*key);

	test (r==KErrNone);

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrNone);

	r=TheDatabase.DropIndex(IndexName2,TableName);

	test (r==KErrNone);

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrNone);

//

	r=TheDatabase.CreateIndex(IndexName,TableName2,*key);

	test (r==KErrNone);

	CleanupStack::PopAndDestroy();	// key

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrDisconnected);

	TheTable.Close();

	r=TheTable.Open(TheDatabase,TableName2);

	test (r==KErrNone);

//

	r=TheDatabase.DropIndex(IndexName,TableName2);

	test (r==KErrNone);

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrDisconnected);

	TheTable.Close();

	r=TheTable.Open(TheDatabase,TableName2);

	test (r==KErrNone);

//

	r=TheDatabase.DropTable(TableName2);

	test (r==KErrNone);

	TRAP(r,TheTable.CountL(TheTable.EQuick));

	test (r==KErrDisconnected);

	TheTable.Close();

	TheDatabase.Close();

	r = CRCCHECK;

	test(r == KErrNone);

	test.End();

	}

LOCAL_C void Table()

	{

	test.Start(_L("Testing Client-side"));

	TestTable(KClientHeap,KClient);

	TestTableDDL(KClient);

	test.Next(_L("Testing Client-Server"));

	Connect();

	TestTable(KClientHeap,KServer);

	TestTable(KServerHeap,KServer);

	TestTableDDL(KServer);

	Disconnect();

	test.End();

	}

class TFailExecuteSQL : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheDatabase.Execute(*TheSql));}

	void End()

		{}

	};

class TFailPrepareView : public TFail

	{

	void RunL()

		{User::LeaveIfError(TheView.Prepare(TheDatabase,*TheSql,Access));}

	void End()

		{TheView.Close();}

	};

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0615

@SYMTestCaseDesc        Tests for allocation failure on prepare

@SYMTestPriority        Medium

@SYMTestActions         Tests for error on updating a row set data

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestView(const THeapFail& aHeap,const TContext& aContext)

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0615 Allocation failure on Prepare "));

	TFailPrepareView fpv;

	TheSql=&SimpleSql;

	Access=RDbRowSet::EUpdatable;

	fpv.Test(aHeap,aContext);

	Access=RDbRowSet::EReadOnly;

	fpv.Test(aHeap,aContext);

	Access=RDbRowSet::EInsertOnly;

	fpv.Test(aHeap,aContext);

//

	test.Next(_L("Allocation failure on Prepare (complex SQL)"));

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

		{

		TheSql=&ComplexSql[ii];

		Access=RDbRowSet::EUpdatable;

		fpv.Test(aHeap,aContext);

		}

	test.End();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0616

@SYMTestCaseDesc        Bad SQL query test 

@SYMTestPriority        Medium

@SYMTestActions         Test for bad query

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestSQL(const TContext& aContext)

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0616 Bad SQL "));

	aContext.OpenDbL();

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

		test(TheView.Prepare(TheDatabase,TPtrC(BadSql[ii].iSql))==BadSql[ii].iError);

	TheDatabase.Close();

	TInt err = CRCCHECK;

	test(err == KErrNone);

	test.End();

	}

/**

@SYMTestCaseID          SYSLIB-DBMS-CT-0617

@SYMTestCaseDesc        Tests for updation of an SQL statement

@SYMTestPriority        Medium

@SYMTestActions         Tests for update SQL statement

@SYMTestExpectedResults Test must not fail

@SYMREQ                 REQ0000

*/

LOCAL_C void TestUpdateSQL(const THeapFail& aHeap,const TContext& aContext)

	{

	test.Start(_L(" @SYMTestCaseID:SYSLIB-DBMS-CT-0617 Test for UPDATE SQL statement "));

	TFailExecuteSQL fsql;

	TheSql=&UpdateSql;

	fsql.Test(aHeap,aContext);

	test.End();

	}

LOCAL_C void View()

	{

	test.Start(_L("Client side"));

	TestView(KClientHeap,KClient);

	TestSQL(KClient);

	test.Next(_L("Client-Server"));

	Connect();

	TestView(KClientHeap,KServer);

	TestView(KServerHeap,KServer);

	TestSQL(KServer);

	TestUpdateSQL(KClientHeap,KClient);

	TestUpdateSQL(KServerHeap,KClient);

	Disconnect();

	test.End();

	}

//TFailIncrementalUpdate implements the base class' virtual methods - RunL() and End().

//TFailIncrementalUpdate::RunL() is called by the base class' Test() method, which simulates

//OOM failures and checks the behaviour of the "incremental update" statement used by RunL().

class TFailIncrementalUpdate : public TFail

	{

	virtual void RunL()

		{

		RDbUpdate dbUpdate;

		CleanupClosePushL(dbUpdate);

		User::LeaveIfError(dbUpdate.Execute(TheDatabase, _L("UPDATE A SET Name = 'ModifiedNameString' WHERE Id2 > 10")));

		TInt step = 0;

		for(TInt err=1;err>0;++step)

			{

			err = dbUpdate.Next();

			User::LeaveIfError(err);

			}

		test(step > 1);//just to be sure that the test executes dbUpdate.Next() more than once

		CleanupStack::PopAndDestroy(&dbUpdate);

		}

	virtual void End()

		{

		TheDatabase.Close();

		TInt err;

		TRAPD( lc, err = CRCCHECK);

		test(err == KErrNone);

		test(lc == KErrNone);

		}

	};	

/**

@SYMTestCaseID          SYSLIB-DBMS-UT-3414

@SYMTestCaseDesc        "Incremental update" operations - OOM test.

@SYMTestPriority        High

@SYMTestActions         Create a test database with one table and insert some records there (> 100).

						Run an "incremental update" operation in OOM loop.

@SYMTestExpectedResults The test should not fail or panic.

@SYMDEF INC101720

*/

LOCAL_C void IncrementalUpdateTest(const THeapFail& aHeap)

	{

	//Create a test shared database with a table

	TheDatabase.Close();

	TInt err, lc;

#ifndef __TOOLS2__

	TheDbs.Close();

#endif

	TRAP(lc, err = CRCCHECK);

	test(err == KErrNone);

	test(lc == KErrNone);

#ifndef __TOOLS2__

	err = TheDbs.Connect();

	test(err == KErrNone);

#endif

	err = TheDatabase.Replace(TheFs, KTestDatabase);

	test(err == KErrNone);

	TheDatabase.Close();

	TRAP(lc, err = CRCCHECK);

	test(err == KErrNone);

	test(lc == KErrNone);

	err = TheDatabase.Open(TheDbs, KTestDatabase);

	test(err == KErrNone);

	//Create a test table and fill the table with enough test records (> 100)

	err = TheDatabase.Execute(_L("CREATE TABLE A(Id COUNTER, Id2 INTEGER, Name LONG VARCHAR)"));	

	test(err == KErrNone);

	const TInt KTestRecCount = 110;

	err = TheDatabase.Begin();	

	test(err == KErrNone);

	for(TInt i=0;i<KTestRecCount;++i)

		{

		_LIT(KSqlFmtStr, "INSERT INTO A(Id2, Name) VALUES(%d, 'TestNameString')");

		TBuf<100> sql;

//		TUint32 id = Math::Random() % KTestRecCount;

		TUint32 id = (i^0x55555555) % KTestRecCount;

		sql.Format(KSqlFmtStr, id + 1);

		err = TheDatabase.Execute(sql);

		test(err == 1);

		}

	err = TheDatabase.Commit();	

	test(err == KErrNone);

	//The OOM test

	TFailIncrementalUpdate testObj;

	testObj.Test(aHeap);

	//Cleanup

	TheDatabase.Close();

#ifndef __TOOLS2__

	TheDbs.Close();

#endif

	TRAP(lc, err = CRCCHECK);

	test(err == KErrNone);

	test(lc == KErrNone);

	}

//

// Testing the DBMS for failure modes

//

LOCAL_C void doMain()

	{

	test.Start(_L("Class RDbNamedDatabase"));

	__UHEAP_MARK;

	Origins();

	__UHEAP_CHECK(0);

	__UHEAP_MARK;

//  secure shared, not supported on tools2.

//	Origins2();

	__UHEAP_CHECK(0);

	test.Next(_L("Class RDbDatabase"));

	Database();

	__UHEAP_CHECK(0);

	test.Next(_L("Class RDbTable"));

	Table();

	__UHEAP_CHECK(0);