// Copyright (c) 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: MDS harvesting performance test

//

#include <e32test.h>

#include <e32math.h>

#include <bautils.h>

#include <hal.h>

#include <sqldb.h>

RTest 			TheTest(_L("t_sqlperformance3 test"));

RSqlDatabase 	TheDb;

_LIT(KDbName, 	"c:\\test\\t_sqlperformance3.db");

TFileName		TheDbFileName;

TBuf<256>  		TheCmd;

TDriveName 		TheDriveName;

TParse     		TheParse;

TInt TheFastCounterFreq = 0;

const TInt KItemCnt = 1000;

const TInt KItemBlockSize = 100;

TInt TheIterations[100];

TInt TheIterationsCount = -1;

void CalcIterationsCount()

	{

	TheIterationsCount = KItemCnt / KItemBlockSize;

	TInt r = KItemCnt % KItemBlockSize;

	if(r > 0)

		{

		++TheIterationsCount;		

		}

	else

		{

		r = KItemBlockSize;

		}

	for(TInt i=0;i<(TheIterationsCount-1);++i)

		{

		TheIterations[i] = KItemBlockSize;

		}

	TheIterations[TheIterationsCount - 1] = r;

	}

////////////////////////////////////////////////////////////////////////////////////////////////////

void TestEnvDestroy()

	{

	TheDb.Close();

	(void)RSqlDatabase::Delete(TheDbFileName);

	}

///////////////////////////////////////////////////////////////////////////////////////

///////////////////////////////////////////////////////////////////////////////////////

//Test macros and functions

void Check1(TInt aValue, TInt aLine)

	{

	if(!aValue)

		{

		TestEnvDestroy();

		TheTest.Printf(_L("*** Line %d\r\n"), aLine);

		TheTest(EFalse, aLine);

		}

	}

void Check2(TInt aValue, TInt aExpected, TInt aLine)

	{

	if(aValue != aExpected)

		{

		TSqlRetCodeClass cl = SqlRetCodeClass(aValue);

		if(cl == ESqlDbError)

			{

			TPtrC errmsg = TheDb.LastErrorMessage();

			TheTest.Printf(_L("*** SQLite err=\"%S\"\r\n"), &errmsg);

			}

		TestEnvDestroy();

		TheTest.Printf(_L("*** Line %d, Expected error: %d, got: %d\r\n"), aLine, aExpected, aValue);

		TheTest(EFalse, aLine);

		}

	}

#define TEST(arg) ::Check1((arg), __LINE__)

#define TEST2(aValue, aExpected) ::Check2(aValue, aExpected, __LINE__)

///////////////////////////////////////////////////////////////////////////////////////

void TestEnvInit()

	{

	RFs fs;

	TInt err = fs.Connect();

	TEST2(err, KErrNone);

	err = fs.MkDirAll(TheDbFileName);

	TEST(err == KErrNone || err == KErrAlreadyExists);

	fs.Close();

	}

TInt TimeDiffUs(TUint32 aStartTicks, TUint32 aEndTicks)

	{

	if(TheFastCounterFreq == 0)

		{

		TEST2(HAL::Get(HAL::EFastCounterFrequency, TheFastCounterFreq), KErrNone);

		}

	TInt64 diffTicks = (TInt64)aEndTicks - (TInt64)aStartTicks;

	if(diffTicks < 0)

		{

		diffTicks = KMaxTUint32 + diffTicks + 1;

		}

	const TInt KMicroSecIn1Sec = 1000000;

	TInt us = (diffTicks * KMicroSecIn1Sec) / TheFastCounterFreq;

	return us;

	}

void PrintTime(const TDesC& aFmt, TUint32 aStartTicks, TUint32 aEndTicks)

	{

	TInt us = TimeDiffUs(aStartTicks, aEndTicks);

	TheTest.Printf(aFmt, us);

	}

//=============================================================================

TInt TheCreateDbCreateConnTime = 0;

TInt TheCreateDbOpenConnTime = 0;

TInt TheLastItemIdTime = 0;

TInt TheTableExistsTime = 0;

TInt TheMdeTablesCreationTime = 0;

TInt TheLastInsertedRowIdTime = 0;

TInt TheCreateTables1Time = 0;

TInt TheCreateTables2Time = 0;

TInt TheCreateTables3Time = 0;

TInt TheTransactionTime = 0;

TInt TheDbCreateTime = 0;

TInt TheCreateTriggersTime = 0;

TInt TheInsertEventRelationTime = 0;

TInt TheDeleteObjPropertyTime = 0;

TInt TheInsertCol2PropTime = 0;

TInt TheHarvestTime = 0;

TInt TheHarvestSelectTime = 0;

TInt TheHarvestInsertObjImageTime = 0;

TInt TheHarvestSelect2Time = 0;

TInt TheHarvestInsertEventTime = 0;

TInt TheHarvestUpdateObjImageTime = 0;

TInt TheHarvestSelect3Time = 0;

TInt TheHarvestSelect4Time = 0;

TInt TheHarvestUpdateObjTime = 0;

//=============================================================================

void DoCreateDbFile()

	{

	_LIT8(KConfig, "page_size=4096;cache_size=10000;");

	TUint32 fc1 = User::FastCounter();

    TInt err = TheDb.Create(TheDbFileName, &KConfig);

    if(err != KErrNone)

    	{

    	if(err == KErrAlreadyExists)

    		{

    		err = TheDb.Open(TheDbFileName, &KConfig);

    		if(err == KErrNone)

    			{

    			TUint32 fc2 = User::FastCounter();

    			TheCreateDbCreateConnTime += TimeDiffUs(fc1, fc2);

    			}

    		}

    	}

    else

    	{

    	TUint32 fc2 = User::FastCounter();

		TheCreateDbOpenConnTime += TimeDiffUs(fc1, fc2);

    	}

    TEST2(err, KErrNone);

	}

void DoGetlastItemId()

	{

	_LIT(KGetLastMaxId, "SELECT max(seq) FROM SQLITE_SEQUENCE WHERE name!='symbian_security';");

	TUint32 fc1 = User::FastCounter();

	RSqlStatement stmt;

	TInt err = stmt.Prepare(TheDb, KGetLastMaxId);

	if(err == KErrNone)

		{

		(void)stmt.Next();

		}

	stmt.Close();

	TUint32 fc2 = User::FastCounter();

	TheLastItemIdTime += TimeDiffUs(fc1, fc2);

	}

TBool MdePreferencesCheck()

	{

	_LIT(KCheck, "SELECT COUNT(*) FROM MdE_Preferences;");

	TUint32 fc1 = User::FastCounter();

	RSqlStatement stmt;

	TInt err = stmt.Prepare(TheDb, KCheck);

	if(err == KErrNone)

		{

		err = stmt.Next();

		}

	stmt.Close();

	TUint32 fc2 = User::FastCounter();

	TheTableExistsTime += TimeDiffUs(fc1, fc2);

	return err == KSqlAtRow;

	}

void CreateMdeTables()

	{

	_LIT(KSql1, "CREATE TABLE MdE_Preferences(Key TEXT,Value NONE,ExtraValue LARGEINT,UNIQUE(Key,Value))");

	_LIT(KSql2, "CREATE TABLE MdS_Medias(MediaId INTEGER PRIMARY KEY,Drive INTEGER,PresentState INTEGER,Time LARGEINT)");

	_LIT(KSql3, "INSERT INTO MdE_Preferences(Key, Value, ExtraValue) VALUES(?, ?, ?)");

	TUint32 fc1 = User::FastCounter();

	TInt rc = TheDb.Exec(KSql1);

	TEST(rc >= 0);

	rc = TheDb.Exec(KSql2);

	TEST(rc >= 0);

	RSqlStatement stmt;

	rc = stmt.Prepare(TheDb, KSql3);

	TEST2(rc, KErrNone);

	rc = stmt.BindInt(0, 1);

	TEST2(rc, KErrNone);

	rc = stmt.BindInt(1, 2);

	TEST2(rc, KErrNone);

	rc = stmt.BindInt(2, 3);

	TEST2(rc, KErrNone);

	rc = stmt.Exec();

	TEST2(rc, 1);

	stmt.Close();

	TUint32 fc2 = User::FastCounter();

	TheMdeTablesCreationTime += TimeDiffUs(fc1, fc2);

	}

TInt64 LastInsertedRowId()

	{

	_LIT(KSql, "SELECT last_insert_rowid();");

	TUint32 fc1 = User::FastCounter();

	RSqlStatement stmt;

	TInt err = stmt.Prepare(TheDb, KSql);

	TEST2(err, KErrNone);

	err = stmt.Next();

	TEST2(err, KSqlAtRow);

	TInt64 rowid = stmt.ColumnInt64(0); 

	stmt.Close();

	TUint32 fc2 = User::FastCounter();

	TheLastInsertedRowIdTime += TimeDiffUs(fc1, fc2);

	return rowid;

	}

void DoCreateTables1()

	{

	_LIT(KSql1, "CREATE TABLE IF NOT EXISTS NamespaceDef(NamespaceDefId INTEGER PRIMARY KEY,ReadOnly INTEGER,VendorId INTEGER,Name TEXT)");

	_LIT(KSql2, "CREATE TABLE IF NOT EXISTS ObjectDef(ObjectDefId INTEGER PRIMARY KEY,NamespaceDefId INTEGER NOT NULL,ParentDefId INTEGER NOT NULL,Flags INTEGER,Name TEXT)");

	_LIT(KSql3, "CREATE TABLE IF NOT EXISTS PropertyDef(PropertyDefId INTEGER PRIMARY KEY,ObjectDefId INTEGER NOT NULL,Flags INTEGER,Type INTEGER,MinValue NUMERIC,MaxValue NUMERIC,Name TEXT)");

	_LIT(KSql4, "CREATE TABLE IF NOT EXISTS RelationDef(RelationDefId INTEGER PRIMARY KEY,NamespaceDefId INTEGER NOT NULL,Name TEXT)");

	_LIT(KSql5, "CREATE TABLE IF NOT EXISTS EventDef(EventDefId INTEGER PRIMARY KEY,NamespaceDefId INTEGER NOT NULL,Priority INTEGER,Name TEXT)");

	TUint32 fc1 = User::FastCounter();

	TInt rc = TheDb.Exec(KSql1);

	TEST(rc >= 0);

	rc = TheDb.Exec(KSql2);

	TEST(rc >= 0);

	rc = TheDb.Exec(KSql3);

	TEST(rc >= 0);

	rc = TheDb.Exec(KSql4);

	TEST(rc >= 0);

	rc = TheDb.Exec(KSql5);

	TEST(rc >= 0);

	_LIT(KSql6, "INSERT INTO NamespaceDef(ReadOnly,VendorId,Name) Values(?,?,?);");

	RSqlStatement stmt;

	rc = stmt.Prepare(TheDb, KSql6);

	TEST2(rc, KErrNone);

	rc = stmt.BindInt(0, 1);

	TEST2(rc, KErrNone);

	rc = stmt.BindInt(1, 2);

	TEST2(rc, KErrNone);

	rc = stmt.BindText(2, _L("Nokia"));

	TEST2(rc, KErrNone);

	rc = stmt.Exec();

	TEST2(rc, 1);

	stmt.Close();

	TUint32 fc2 = User::FastCounter();

	TheCreateTables1Time += TimeDiffUs(fc1, fc2);

	}

void BeginTransaction()

	{

	TInt err = TheDb.Exec(_L("BEGIN"));

	TEST(err >= 0);

	}

void CommitTransaction()

	{

	TInt err = TheDb.Exec(_L("COMMIT"));

	TEST(err >= 0);

	}

void DoCreateTables2()

	{

	_LIT(KSql1, "CREATE TABLE IF NOT EXISTS Object1(ObjectId INTEGER PRIMARY KEY AUTOINCREMENT,ObjectDefId INTEGER NOT NULL,Flags INTEGER,MediaId LARGEINT,UsageCount LARGEINT DEFAULT 0,GuidHigh LARGEINT,GuidLow LARGEINT,URI TEXT NOT NULL COLLATE NOCASE,Origin INTEGER,Size LARGEINT,TimeOffset INTEGER,CreationDate LARGEINT,LastModifiedDate LARGEINT,ItemType TEXT,Title TEXT,UNIQUE(GuidHigh,GuidLow),UNIQUE(MediaId,URI))");

	_LIT(KSql2, "CREATE TABLE IF NOT EXISTS Relations1(RelationId INTEGER PRIMARY KEY AUTOINCREMENT,Flags INTEGER,RelationDefId INTEGER NOT NULL,LeftObjectId INTEGER NOT NULL,RightObjectId INTEGER NOT NULL,Parameter INTEGER,GuidHigh LARGEINT,GuidLow LARGEINT,LastModifiedDate LARGEINT)");

	_LIT(KSql3, "CREATE TRIGGER DeleteRelations1 BEFORE DELETE ON Object1 BEGIN DELETE FROM Relations1 WHERE LeftObjectId=OLD.ObjectId OR RightObjectId=OLD.ObjectId; END");

	_LIT(KSql4, "CREATE TABLE IF NOT EXISTS Event1(EventId INTEGER PRIMARY KEY AUTOINCREMENT,ObjectId INTEGER NOT NULL, EventDefId INTEGER NOT NULL, Timestamp INTEGER NOT NULL, Source TEXT, Participant TEXT)");

	_LIT(KSql5, "CREATE TRIGGER DeleteEvent1 BEFORE DELETE ON Object1 BEGIN DELETE FROM Event1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql6, "CREATE TABLE IF NOT EXISTS TextSearch1(WordId INTEGER NOT NULL,ObjectId INTEGER NOT NULL,Position INTEGER)");

	_LIT(KSql7, "CREATE TRIGGER DeleteTextSearch1 BEFORE DELETE ON Object1 BEGIN DELETE FROM TextSearch1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql8, "CREATE INDEX FreetextWordIdIndex1 ON TextSearch1(WordId)");

	_LIT(KSql9, "CREATE INDEX FreetextObjectIdIndex1 ON TextSearch1(ObjectId)");

	_LIT(KSql10, "CREATE TABLE IF NOT EXISTS TextSearchDictionary1(WordId INTEGER PRIMARY KEY,Word TEXT NOT NULL)");

	_LIT(KSql11, "CREATE TRIGGER InsertRelations1 INSERT ON Relations1 BEGIN UPDATE Object1 SET UsageCount = UsageCount + 1 WHERE ObjectId=NEW.LeftObjectId OR ObjectId=NEW.RightObjectId; END");

	_LIT(KSql12, "CREATE TRIGGER UpdateRelations1 UPDATE OF LeftObjectId, RightObjectId ON Relations1 WHEN OLD.Flags=NEW.Flags BEGIN UPDATE Object1 SET UsageCount = UsageCount - 1 WHERE ObjectId=OLD.LeftObjectId OR ObjectId=OLD.RightObjectId; UPDATE Object1 SET UsageCount = UsageCount + 1 WHERE ObjectId=NEW.LeftObjectId OR ObjectId=NEW.RightObjectId; END");

	_LIT(KSql13, "CREATE TRIGGER UpdateNotRemovedRelations1 UPDATE OF Flags ON Relations1 WHEN OLD.Flags!=NEW.Flags AND NOT NEW.Flags&3 BEGIN UPDATE Object1 SET UsageCount = UsageCount + 1 WHERE ObjectId=NEW.LeftObjectId OR ObjectId=NEW.RightObjectId; END");

	_LIT(KSql14, "CREATE TRIGGER UpdateRemovedRelations1 UPDATE OF Flags ON Relations1 WHEN OLD.Flags!=NEW.Flags AND NEW.Flags&3 AND NOT OLD.Flags&3 BEGIN UPDATE Object1 SET UsageCount = UsageCount - 1 WHERE ObjectId=OLD.LeftObjectId OR ObjectId=OLD.RightObjectId; END");

	_LIT(KSql15, "CREATE INDEX RelationsLeftObjectIdIndex1 ON Relations1(LeftObjectId)");

	_LIT(KSql16, "CREATE INDEX RelationsRightObjectIdIndex1 ON Relations1(RightObjectId)");

	_LIT(KSql17, "CREATE INDEX ObjectDefIndex1 ON Object1(ObjectDefId)");

	_LIT(KSql18, "CREATE TABLE IF NOT EXISTS Location1(ObjectId INTEGER NOT NULL,CellID LARGEINT,LocationAreaCode LARGEINT,Speed REAL,Direction REAL,Quality REAL,Latitude REAL,Longitude REAL,Altitude REAL,CountryCodeStr TEXT,NetworkCodeStr TEXT,Satellites TEXT,Country TEXT,CellName TEXT, UNIQUE(ObjectId))");

	_LIT(KSql19, "CREATE TABLE IF NOT EXISTS Calendar1(ObjectId INTEGER NOT NULL,CalendarType INTEGER,LocalUid LARGEINT,StartTime LARGEINT,EndTime LARGEINT,Location TEXT,vCalendar TEXT, UNIQUE(ObjectId))");

	_LIT(KSql20, "CREATE TABLE IF NOT EXISTS Contact1(ObjectId INTEGER NOT NULL,Number TEXT,EmailAddress TEXT,Company TEXT,JobTitle TEXT,Address TEXT,ContactURL TEXT,vCard TEXT, UNIQUE(ObjectId))");

	_LIT(KSql21, "CREATE TABLE IF NOT EXISTS Message1(ObjectId INTEGER NOT NULL,Received INTEGER,ToWhom TEXT,Sender TEXT, UNIQUE(ObjectId))");

	_LIT(KSql22, "CREATE TABLE IF NOT EXISTS Album1(ObjectId INTEGER NOT NULL,Ordered INTEGER,Type INTEGER, UNIQUE(ObjectId))");

	_LIT(KSql23, "CREATE TABLE IF NOT EXISTS Tag1(ObjectId INTEGER NOT NULL, UNIQUE(ObjectId))");

	_LIT(KSql24, "CREATE TABLE IF NOT EXISTS MediaObject1(ObjectId INTEGER NOT NULL,Protected INTEGER,DRM INTEGER,ThumbnailPresent INTEGER,Resized INTEGER,Sample INTEGER,Rating INTEGER,Privacy INTEGER,ResolutionUnit INTEGER,Bitrate INTEGER,Width INTEGER,Height INTEGER,Preinstalled INTEGER,AccessCount LARGEINT,DownloadID LARGEINT,Duration REAL,ReleaseDate LARGEINT,CaptureDate LARGEINT,Artist TEXT,Author TEXT,Copyright TEXT,Legal TEXT,Description TEXT,Comment TEXT,Genre TEXT, UNIQUE(ObjectId))");

	_LIT(KSql25, "CREATE TABLE IF NOT EXISTS Video1(ObjectId INTEGER NOT NULL,Protected INTEGER,DRM INTEGER,ThumbnailPresent INTEGER,Resized INTEGER,Sample INTEGER,Rating INTEGER,Privacy INTEGER,ResolutionUnit INTEGER,Bitrate INTEGER,Width INTEGER,Height INTEGER,Preinstalled INTEGER,AccessCount LARGEINT,DownloadID LARGEINT,Duration REAL,ReleaseDate LARGEINT,CaptureDate LARGEINT,AgeProfile INTEGER,AudioFourCC LARGEINT,RecordingFlags LARGEINT,LastPlayPosition REAL,Framerate REAL,Artist TEXT,Author TEXT,Copyright TEXT,Legal TEXT,Description TEXT,Comment TEXT,Genre TEXT,AudioLanguage TEXT, UNIQUE(ObjectId))");

	_LIT(KSql26, "CREATE TABLE IF NOT EXISTS Image1(ObjectId INTEGER NOT NULL,Protected INTEGER,DRM INTEGER,ThumbnailPresent INTEGER,Resized INTEGER,Sample INTEGER,Rating INTEGER,Privacy INTEGER,ResolutionUnit INTEGER,Bitrate INTEGER,Width INTEGER,Height INTEGER,Preinstalled INTEGER,AccessCount LARGEINT,DownloadID LARGEINT,Duration REAL,ReleaseDate LARGEINT,CaptureDate LARGEINT,FocalPlaneResolutionUnit INTEGER,ExposureProgram INTEGER,FocalLengthIn35mmFilm INTEGER,ISOSpeedRatings INTEGER,MeteringMode INTEGER,WhiteBalance INTEGER,Flash INTEGER,ColourSpace INTEGER,Orientation INTEGER,SamplesPerPixel INTEGER,BitsPerSample INTEGER,YCbCrPositioning INTEGER,ThumbCompression INTEGER,ThumbResolutionUnit INTEGER,ThumbOrientation INTEGER,FrameCount INTEGER,PixelXDimension LARGEINT,PixelYDimension LARGEINT,ExifVersion LARGEINT,ComponentsConfiguration LARGEINT,FlashPixVersion LARGEINT,ThumbXResolution LARGEINT,ThumbYResolution LARGEINT,FocalPlaneXResolution REAL,FocalPlaneYResolution REAL,ExposureTime REAL,ExposureBiasValue REAL,FNumber REAL,FocalLength REAL,ApertureValue REAL,MaxAperture REAL,ShutterSpeedValue REAL,XResolution REAL,YResolution REAL,DateTime LARGEINT,DateTimeDigitized LARGEINT,DateTimeOriginal LARGEINT,Artist TEXT,Author TEXT,Copyright TEXT,Legal TEXT,Description TEXT,Comment TEXT,Genre TEXT,Model TEXT,Make TEXT,RelatedSoundFile TEXT, UNIQUE(ObjectId))");

	_LIT(KSql27, "CREATE TABLE IF NOT EXISTS Audio1(ObjectId INTEGER NOT NULL,Protected INTEGER,DRM INTEGER,ThumbnailPresent INTEGER,Resized INTEGER,Sample INTEGER,Rating INTEGER,Privacy INTEGER,ResolutionUnit INTEGER,Bitrate INTEGER,Width INTEGER,Height INTEGER,Preinstalled INTEGER,AccessCount LARGEINT,DownloadID LARGEINT,Duration REAL,ReleaseDate LARGEINT,CaptureDate LARGEINT,Track INTEGER,SamplingFrequency REAL,Artist TEXT,Author TEXT,Copyright TEXT,Legal TEXT,Description TEXT,Comment TEXT,Genre TEXT,Album TEXT,Composer TEXT,OriginalArtist TEXT,AlbumArtist TEXT, UNIQUE(ObjectId))");

	_LIT(KSql28, "CREATE TABLE IF NOT EXISTS TrackLog1(ObjectId INTEGER NOT NULL,Length LARGEINT,StartTime LARGEINT,StopTime LARGEINT, UNIQUE(ObjectId))");

	const TPtrC KSql[] = 

		{

		KSql1(), KSql2(), KSql3(), KSql4(), KSql5(), KSql6(), KSql7(), KSql8(), KSql9(), KSql10(), 

		KSql11(), KSql12(), KSql13(), KSql14(), KSql15(), KSql16(), KSql17(), KSql18(), KSql19(), KSql20(), 

		KSql21(), KSql22(), KSql23(), KSql24(), KSql25(), KSql26(), KSql27(), KSql28() 

		};

	TUint32 fc1 = User::FastCounter();	

	for(TInt i=0;i<(sizeof(KSql)/sizeof(KSql[0]));++i)

		{

		TInt err = TheDb.Exec(KSql[i]);

		TEST(err >= 0);

		}

	TUint32 fc2 = User::FastCounter();

	TheCreateTables2Time += TimeDiffUs(fc1, fc2);

	}

void DoCreateTables3()

	{

	const TInt KInsObjDefRecCnt = 12;

	const TInt KInsPropDefRecCnt[KInsObjDefRecCnt] = {7, 11, 6, 7, 3, 2, 0, 24, 6, 40, 6, 3};

	TUint32 fc1 = User::FastCounter();	

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

		{

		TBuf<10> objDefName;

		RSqlStatement stmt1;

		TInt err = stmt1.Prepare(TheDb, _L("INSERT INTO ObjectDef(NamespaceDefId, ParentDefId, Flags, Name) Values(?,?,?,?)"));

		TEST2(err, KErrNone);

		err = stmt1.BindInt(0, 1);

		TEST2(err, KErrNone);

		err = stmt1.BindInt(1, 2);

		TEST2(err, KErrNone);

		err = stmt1.BindInt(2, 3);

		TEST2(err, KErrNone);

		objDefName.Copy(_L("ObjDef"));

		objDefName.AppendNum(i + 1);

		err = stmt1.BindText(3, objDefName);

		TEST2(err, KErrNone);

		err = stmt1.Exec();

		TEST2(err, 1);

		stmt1.Close();

		TInt64 objdefid = LastInsertedRowId();

		for(TInt j=0;j<KInsPropDefRecCnt[i];++j)

			{

			TBuf<10> propDefName;

			RSqlStatement stmt2;

			err = stmt2.Prepare(TheDb, _L("INSERT INTO PropertyDef(ObjectDefId,Flags,Type,MinValue,MaxValue,Name) Values(?,?,?,?,?,?);"));

			TEST2(err, KErrNone);

			err = stmt2.BindInt64(0, objdefid);

			TEST2(err, KErrNone);

			err = stmt2.BindInt(1, 2);

			TEST2(err, KErrNone);

			err = stmt2.BindInt(2, 3);

			TEST2(err, KErrNone);

			err = stmt2.BindInt(3, 100);

			TEST2(err, KErrNone);

			err = stmt2.BindInt(4, 200);

			TEST2(err, KErrNone);

			propDefName.Copy(_L("PropDef"));

			propDefName.AppendNum(j + 1);

			err = stmt2.BindText(5, propDefName);

			TEST2(err, KErrNone);

			err = stmt2.Exec();

			TEST2(err, 1);

			stmt2.Close();

			LastInsertedRowId();

			}

		}

	TUint32 fc2 = User::FastCounter();

	TheCreateTables3Time += TimeDiffUs(fc1, fc2);

	}

void DoCreateTriggers()

	{

	_LIT(KSql1, "CREATE TRIGGER DeleteLocation1 DELETE ON Object1 BEGIN DELETE FROM Location1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql2, "CREATE TRIGGER DeleteCalendar1 DELETE ON Object1 BEGIN DELETE FROM Calendar1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql3, "CREATE TRIGGER DeleteContact1 DELETE ON Object1 BEGIN DELETE FROM Contact1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql4, "CREATE TRIGGER DeleteMessage1 DELETE ON Object1 BEGIN DELETE FROM Message1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql5, "CREATE TRIGGER DeleteAlbum1 DELETE ON Object1 BEGIN DELETE FROM Album1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql6, "CREATE TRIGGER DeleteTag1 DELETE ON Object1 BEGIN DELETE FROM Tag1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql7, "CREATE TRIGGER DeleteMediaObject1 DELETE ON Object1 BEGIN DELETE FROM MediaObject1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql8, "CREATE TRIGGER DeleteVideo1 DELETE ON Object1 BEGIN DELETE FROM Video1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql9, "CREATE TRIGGER DeleteImage1 DELETE ON Object1 BEGIN DELETE FROM Image1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql10, "CREATE TRIGGER DeleteAudio1 DELETE ON Object1 BEGIN DELETE FROM Audio1 WHERE ObjectId=OLD.ObjectId; END");

	_LIT(KSql11, "CREATE TRIGGER DeleteTrackLog1 DELETE ON Object1 BEGIN DELETE FROM TrackLog1 WHERE ObjectId=OLD.ObjectId; END");

	const TPtrC KSql[] = 

		{

		KSql1(), KSql2(), KSql3(), KSql4(), KSql5(), KSql6(), KSql7(), KSql8(), KSql9(), KSql10(), KSql11() 

		};

	TUint32 fc1 = User::FastCounter();	

	for(TInt i=0;i<(sizeof(KSql)/sizeof(KSql[0]));++i)

		{

		TInt err = TheDb.Exec(KSql[i]);

		TEST(err >= 0);

		}

	TUint32 fc2 = User::FastCounter();

	TheCreateTriggersTime += TimeDiffUs(fc1, fc2);

	}

void DoInsertEventRelationDefs()

	{

	_LIT(KSql1, "INSERT INTO EventDef (NamespaceDefId, Priority, Name ) Values(?, ?, ?);");

	const TInt KSql1Cnt = 7;

	_LIT(KSql2, "INSERT INTO RelationDef (NamespaceDefId,Name) Values(?,?);");

	const TInt KSql2Cnt = 8;

	TUint32 fc1 = User::FastCounter();	

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

		{

		TBuf<10> eventDefName;

		RSqlStatement stmt;

		TInt err = stmt.Prepare(TheDb, KSql1);

		TEST2(err, KErrNone);

		err = stmt.BindInt(0, 1);

		TEST2(err, KErrNone);

		err = stmt.BindInt(1, 2);

		TEST2(err, KErrNone);

		eventDefName.Copy(_L("EvtDef"));

		eventDefName.AppendNum(i + 1);

		err = stmt.BindText(2, eventDefName);

		TEST2(err, KErrNone);

		err = stmt.Exec();

		TEST2(err, 1);

		stmt.Close();

		LastInsertedRowId();

		}

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

		{

		TBuf<10> relDefName;

		RSqlStatement stmt;

		TInt err = stmt.Prepare(TheDb, KSql2);

		TEST2(err, KErrNone);

		err = stmt.BindInt(0, 1);

		TEST2(err, KErrNone);

		relDefName.Copy(_L("RelDef"));

		relDefName.AppendNum(i + 1);

		err = stmt.BindText(1, relDefName);

		TEST2(err, KErrNone);

		err = stmt.Exec();

		TEST2(err, 1);

		stmt.Close();

		LastInsertedRowId();

		}

	TUint32 fc2 = User::FastCounter();

	TheInsertEventRelationTime += TimeDiffUs(fc1, fc2);

	}

void DoDeleteObjPropertyDef()

	{

	_LIT(KSql1, "DELETE FROM ObjectDef WHERE ObjectDefId=?;");

	_LIT(KSql2, "DELETE FROM PropertyDef WHERE ObjectDefId=?;");

	TUint32 fc1 = User::FastCounter();

	RSqlStatement stmt1;

	TInt err = stmt1.Prepare(TheDb, KSql1);

	TEST2(err, KErrNone);

	err = stmt1.BindInt(0, 0);

	TEST2(err, KErrNone);

	err = stmt1.Exec();

	TEST(err >= 0);

	stmt1.Close();

	RSqlStatement stmt2;

	err = stmt2.Prepare(TheDb, KSql2);

	TEST2(err, KErrNone);

	err = stmt2.BindInt(0, 0);

	TEST2(err, KErrNone);

	err = stmt2.Exec();

	TEST(err >= 0);

	stmt2.Close();

	TUint32 fc2 = User::FastCounter();

	TheDeleteObjPropertyTime += TimeDiffUs(fc1, fc2);

	}

void DoInsertCol2Prop()

	{

	_LIT(KSql1, "CREATE TABLE IF NOT EXISTS Col2Prop(ObjectDefId INTEGER NOT NULL,PropertyDefId INTEGER NOT NULL,ColumnId INTEGER NOT NULL)");

	TInt KCol2PropCnt = KItemCnt;

	_LIT(KSql2, "INSERT INTO Col2Prop(ObjectDefId,PropertyDefId,ColumnId) Values(?,?,?);");

	TUint32 fc1 = User::FastCounter();