// Copyright (c) 2007-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:

// HEADER FILES

// 

//

/**

 * HEADER FILES

 */

#include <barsc.h>

#include <bautils.h>

#include "msvdbadapter.h"

#include "msventryfreepool.h"

#include "msvsearchsortdbwrapper.h"

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include "msvsearchsortconstants.h"

#endif

#if (defined SYMBIAN_MESSAGESTORE_HEADER_BODY_USING_SQLDB)

	#include "cmessageconvertermanager.h"

#endif

/**

 * CONSTANT DEFINITION

 */

#define SERVER_UID 0x1000484B

#define KMsvNumStdFolder 7

#if (defined SYMBIAN_MSGS_ENHANCED_REMOVABLE_MEDIA_SUPPORT)

	#include "msvindexadapter.h"

	//Main (dummy) DB name.

	#if (defined SYMBIAN_MESSAGESTORE_UNIT_TESTCODE)

		_LIT(KMainDummyDBName, "\\messaging_master.db");

		_LIT(KMessagingDBName, "\\messaging.db");

	#else

		_LIT(KMainDummyDBName, "[1000484B]messaging_master.db");

		_LIT(KMessagingDBName, "[1000484B]messaging.db");

	#endif

	_LIT(KLogicalName, "DB");

	_LIT(KComma, ", ");

	_LIT(KDelimiter, " ;");

#endif		// #if (defined SYMBIAN_MSGS_ENHANCED_REMOVABLE_MEDIA_SUPPORT)

/**

 * LITERAL DEFINITION

 */

//Data definition queries

_LIT8(KEncodingText, "encoding=UTF-8");

_LIT8(KCreateIndexEntryTableQuery,	"CREATE TABLE IF NOT EXISTS IndexEntry ("

								"id INTEGER PRIMARY KEY,"

						  		"parentId INT,"

								"serviceId INT,"

								"mtmId INT,"

								"type INT,"

								"date INT64,"

								"data INT,"

								"size INT,"

								"error INT,"

								"mtmData1 INT,"

								"mtmData2 INT,"

								"mtmData3 INT,"

								"relatedId INT,"

								"bioType INT,"

								"pcSyncCount INT,"

								"reserved INT,"

								"visibleParent INT,"

								"description TEXT,"

						  		"details TEXT" ");"

	  );

_LIT8(KCreateIndexQuery, "CREATE INDEX IF NOT EXISTS INDEX_PARENT ON IndexEntry(parentId);");

_LIT8(KCreateVersionTableQuery, "CREATE TABLE IF NOT EXISTS VersionTable ( "

									"version INTEGER PRIMARY KEY );"

		);

//Common database queries

_LIT8(KGetEntryExistsQuery, "SELECT parentId FROM IndexEntry WHERE id = :id;"); //

_LIT8(KGetVisibleIdQuery, "SELECT data, visibleParent FROM IndexEntry WHERE id = :id;"); //

_LIT8(KGetEntryQuery, "SELECT parentId, serviceId, mtmId, type, date, data, size, error, "

						"mtmData1, mtmData2, mtmData3, relatedId, bioType, pcSyncCount, "

						"reserved, visibleParent, description, details FROM IndexEntry WHERE id = :id;"); //

_LIT8(KGetChildEntriesQuery, "SELECT id, serviceId, mtmId, type, date, data, size, error, "

							"mtmData1, mtmData2, mtmData3, relatedId, bioType, pcSyncCount, "

							"reserved, visibleParent, description, details FROM IndexEntry "

							"WHERE parentId = :parentId order by id ASC;"); //

//Data manipulation queries

_LIT8(KCreateEntryQuery,	 "INSERT INTO IndexEntry VALUES ("

							 ":id, :parentId, :serviceId, :mtmId, :type, :date, :data, :size, :error,"

							 ":mtmData1, :mtmData2, :mtmData3, :relatedId, :bioType, :pcSyncCount,"

							 ":reserved, :visibleParent, :description, :details);"

	 ); //

_LIT8(KUpdateEntryQuery,	"UPDATE IndexEntry SET "

							"parentId = :parentId, serviceId = :serviceId, mtmId = :mtmId, type = :type, date = :date,"

							"data = :data, size = :size, error = :error, mtmData1 = :mtmData1, mtmData2 = :mtmData2,"

							"mtmData3 = :mtmData3, relatedId = :relatedId, bioType = :bioType, pcSyncCount = :pcSyncCount,"

							"reserved = :reserved, visibleParent = :visibleParent, description = :description,"

							"details = :details WHERE id = :id;"

	 ); //

_LIT8(KUpdateEntryNoParentQuery,	"UPDATE IndexEntry SET "

							"serviceId = :serviceId, mtmId = :mtmId, type = :type, date = :date,"

							"data = :data, size = :size, error = :error, mtmData1 = :mtmData1, mtmData2 = :mtmData2,"

							"mtmData3 = :mtmData3, relatedId = :relatedId, bioType = :bioType, pcSyncCount = :pcSyncCount,"

							"reserved = :reserved, visibleParent = :visibleParent, description = :description,"

							"details = :details WHERE id = :id;"

	 ); //

#if (defined SYMBIAN_MESSAGESTORE_HEADER_BODY_USING_SQLDB)

_LIT8(KCreateConversionStatusTableQuery, 	"CREATE TABLE IF NOT EXISTS ConversionStatus ("

								"lastId INT,"

						  		"serviceId INTEGER PRIMARY KEY,"

								"sourceVersion INT,"

								"targetVersion INT,"

								"mtmId INT,"

								"remainingCount INT );"

	 );	

_LIT8(KRemoveConversionStatusTable,  "DROP TABLE IF EXISTS ConversionStatus;");					

#endif

//Literals for parameter indexes

_LIT(KMsgParamId, ":id");

_LIT(KMsgParamParentId, ":parentId");

_LIT(KMsgParamServiceId, ":serviceId");

_LIT(KMsgParamMtmId, ":mtmId");

_LIT(KMsgParamType, ":type");

_LIT(KMsgParamDate, ":date");

_LIT(KMsgParamData, ":data");

_LIT(KMsgParamSize, ":size");

_LIT(KMsgParamError, ":error");

_LIT(KMsgParamMtmData1, ":mtmData1");

_LIT(KMsgParamMtmData2, ":mtmData2");

_LIT(KMsgParamMtmData3, ":mtmData3");

_LIT(KMsgParamRelatedId, ":relatedId");

_LIT(KMsgParamBiotype, ":bioType");

_LIT(KMsgParamPcSyncCount, ":pcSyncCount");

_LIT(KMsgParamReserved, ":reserved");

_LIT(KMsgParamVisibleParent, ":visibleParent");

_LIT(KMsgParamDescriptionTxt, ":description");

_LIT(KMsgParamDetailsTxt, ":details");

//Literals for column indexes

_LIT(KMsgColumnId, "id");

_LIT(KMsgColumnParentId, "parentId");

_LIT(KMsgColumnServiceId, "serviceId");

_LIT(KMsgColumnMtmId, "mtmId");

_LIT(KMsgColumnType, "type");

_LIT(KMsgColumnDate, "date");

_LIT(KMsgColumnData, "data");

_LIT(KMsgColumnSize, "size");

_LIT(KMsgColumnError, "error");

_LIT(KMsgColumnMtmData1, "mtmData1");

_LIT(KMsgColumnMtmData2, "mtmData2");

_LIT(KMsgColumnMtmData3, "mtmData3");

_LIT(KMsgColumnRelatedId, "relatedId");

_LIT(KMsgColumnBiotype, "bioType");

_LIT(KMsgColumnPcSyncCount, "pcSyncCount");

_LIT(KMsgColumnReserved, "reserved");

_LIT(KMsgColumnVisibleParent, "visibleParent");

_LIT(KMsgColumnDescriptionTxt, "description");

_LIT(KMsgColumnDetailsTxt, "details");

#if (defined SYMBIAN_MSGS_ENHANCED_REMOVABLE_MEDIA_SUPPORT)

	_LIT8(KGetChildIdsQuery, "SELECT id, type, data FROM IndexEntry WHERE parentId = :parentId order by id ASC;"); //

	_LIT8(KClearTableContents, "DELETE FROM SearchSortEntry;");

#else

	_LIT8(KDeleteTable,  "DROP TABLE IF EXISTS SearchSortEntry;");

	_LIT8(KGetChildIdsQuery, "SELECT id FROM IndexEntry WHERE parentId = :parentId order by id ASC;"); //

	_LIT8(KGetInPreparationIdQuery, "SELECT id, data FROM IndexEntry;");

#endif

// Changes for PREQ 1667.

//Data definition queries for SearchSort-Table

_LIT8(KCreateSearchSortEntryTableQuery,	"CREATE TABLE IF NOT EXISTS SearchSortEntry ("

						"Qid INT,"

				  		"id INT,"

						"sortfield TEXT" ");"

);

_LIT8(KCreateSearchSortQuery, "CREATE UNIQUE INDEX IF NOT EXISTS SearchSortEntry_UNIQUE ON SearchSortEntry (Qid, id,sortfield);");

//Common database queries

_LIT8(KGetEntryAsc, "SELECT DISTINCT id FROM SearchSortEntry WHERE Qid = :Qid ORDER by sortfield ASC;");

_LIT8(KGetEntryDesc, "SELECT DISTINCT id FROM SearchSortEntry WHERE Qid = :Qid ORDER by sortfield DESC;");

_LIT8(KGetEntryNumAsc, "SELECT DISTINCT id FROM SearchSortEntry WHERE Qid = :Qid ORDER by CAST(sortfield AS INT) ASC;");

_LIT8(KGetEntryNumDesc, "SELECT DISTINCT id FROM SearchSortEntry WHERE Qid = :Qid ORDER by CAST(sortfield AS INT) DESC;");

_LIT8(KGetLastNIdsAsc, "SELECT DISTINCT id FROM SearchSortEntry WHERE ROWID > (LAST_INSERT_ROWID() - :RowId) AND Qid = :Qid ORDER by sortfield ASC;");

_LIT8(KGetLastNIdsDesc, "SELECT DISTINCT id FROM SearchSortEntry WHERE ROWID > (LAST_INSERT_ROWID() - :RowId) AND Qid = :Qid ORDER by sortfield DESC;");

_LIT8(KGetLastNIdsNumAsc, "SELECT DISTINCT id FROM SearchSortEntry WHERE ROWID > (LAST_INSERT_ROWID() - :RowId) AND Qid = :Qid ORDER by CAST(sortfield AS INT) ASC;");

_LIT8(KGetLastNIdsNumDesc, "SELECT DISTINCT id FROM SearchSortEntry WHERE ROWID > (LAST_INSERT_ROWID() - :RowId) AND Qid = :Qid ORDER by CAST(sortfield AS INT) DESC;");

_LIT8(KGetQueryCount, "SELECT COUNT(DISTINCT id) FROM SearchSortEntry WHERE Qid = :Qid");

_LIT8(KGetFolderIds, "SELECT id FROM IndexEntry WHERE parentId = :parentId AND type LIKE :type");

_LIT8(KGetIterResultCastAsc, "SELECT id FROM SearchSortEntry WHERE Qid = :qid ORDER by CAST(sortfield AS INT) ASC LIMIT :lim OFFSET :off ");

_LIT8(KGetIterResultCastDesc, "SELECT id FROM SearchSortEntry WHERE Qid = :qid ORDER by CAST(sortfield AS INT) DESC LIMIT :lim OFFSET :off ");

_LIT8(KGetIterResultAsc, "SELECT id FROM SearchSortEntry WHERE Qid = :qid ORDER by sortfield ASC LIMIT :lim OFFSET :off ");

_LIT8(KGetIterResultDesc, "SELECT id FROM SearchSortEntry WHERE Qid = :qid ORDER by sortfield ASC LIMIT :lim OFFSET :off ");

//Data manipulation queries

_LIT8(KDeleteId, 	 "DELETE FROM SearchSortEntry WHERE id = ");

_LIT8(KCreateQueryEntry,	 "INSERT OR IGNORE INTO SearchSortEntry VALUES ("

							 ":Qid, :id, :sortfield);");

_LIT8(KDeleteQueryId, 	 "DELETE FROM SearchSortEntry WHERE Qid = ");

_LIT8(KAndId, " AND id = ");

_LIT8(KSemiColon, ";");

//Literals for parameter indexes

_LIT(KQueryQId, ":Qid");

_LIT(KQueryTMsvId, ":id");

_LIT(KQuerySortfield, ":sortfield");

_LIT(KQueryRowId, ":RowId");

_LIT(KOffset, ":off");

_LIT(KLimit, ":lim");

//Literals for column indexes

_LIT(KQueryColumnTMsvId, "id");

/**

 * MEMBER FUNCTIONS OF CMsvDBAdapter

 */

/**

 * CMsvDBAdapter()

 * The default Constructor. 

 */

CMsvDBAdapter::CMsvDBAdapter():isTransactionOpen(EFalse)

#if (defined SYMBIAN_MSGS_ENHANCED_REMOVABLE_MEDIA_SUPPORT)

		,iDbPtrInitialized(EFalse)

#endif

	{

	}

/**

 * ~CMsvDBAdapter()

 * The default Destructor. 

 */

CMsvDBAdapter::~CMsvDBAdapter()

	{

	//Close all RSqlStatement object.

	for(TInt index = ECreateEntry; index < EIndexSentinel; index++)

		{

		iStatement[index].Close();

		}

	for(TInt index = EQueryCreateEntry; index < EQuerySentinel; index++)

		{

		iQueryStatement[index].Close();

		}

	iDatabase.Close();

#if (defined SYMBIAN_MSGS_ENHANCED_REMOVABLE_MEDIA_SUPPORT)

	if(iDatabasePresent)

		{

		iDatabasePresent->Close();

		delete iDatabasePresent;

		}

#endif

	}

// Code added in PREQ 557.

#if (defined SYMBIAN_MSGS_ENHANCED_REMOVABLE_MEDIA_SUPPORT)

/**

 * NewL()

 * @param None.

 * @return None.

 * 

 * Allocates and constructs a new DBAdapter object, calls ConstructL 

 * to create the dummy database and returns a handle to the DBAdapter.

 */

CMsvDBAdapter* CMsvDBAdapter::NewL()

	{

	//Create the DBAdapter object.

	CMsvDBAdapter* self = new(ELeave) CMsvDBAdapter();

	CleanupStack::PushL(self);

	// Create the database.

	self->ConstructL();

	CleanupStack::Pop(self);

	return self;

	}

/**

 * ConstructL()

 * @param None.

 * @return None.

 * 

 * Checks if there is the main (dummy) DB in the system drive

 * and creates one if it is not present. Other databases will

 * be attached to this DB which will not get deleted during

 * the operation of the message server.

 */

void CMsvDBAdapter::ConstructL()

	{

	//Get the system drive.

	TInt systemDrive = (TInt)RFs::GetSystemDrive();

	RBuf dbFile;

	CleanupClosePushL(dbFile);

	dbFile.CreateL(50);	

	dbFile.Append(TDriveUnit(systemDrive).Name());

	dbFile.Append(KMainDummyDBName);

	//Check if the main DB exists. If not, then create it.

	// > KErrNotFound, KErrPathNotFound - DB doesn't exist.

	// > KErrNone, KErrInUse - DB exists.

	TRAPD(err, iDatabase.OpenL(dbFile));

	if(KErrNone != err)

		{

		// Leave in unfavorable condition.

		if(KErrNoMemory == err ||

		   KErrNotReady == err ||

		   KErrInUse    == err

		  )

			{

			User::Leave(err);

			}

		HBufC8* heapBuf = KEncodingText().AllocLC();

		if(KSqlErrCorrupt == err || KSqlErrNotDb == err)

			{

			RSqlDatabase::Delete(dbFile);

			}

		//Create the dummy DB.		

#if (defined SYMBIAN_MESSAGESTORE_UNIT_TESTCODE)

		// Create the non-secure database.

		User::LeaveIfError(iDatabase.Create(dbFile, heapBuf));

#else

		// Using SID based security policy.

		TSecureId sid(SERVER_UID);

		const TSecurityPolicy KDefaultPolicy(sid);

		//Create security policy

		RSqlSecurityPolicy securityPolicy;

		CleanupClosePushL(securityPolicy);	

		User::LeaveIfError(securityPolicy.Create(KDefaultPolicy));

		User::LeaveIfError(iDatabase.Create(dbFile, securityPolicy, heapBuf));

		CleanupStack::PopAndDestroy(); //securityPolicy

#endif		// #if (defined SYMBIAN_MESSAGESTORE_UNIT_TESTCODE)

		CleanupStack::PopAndDestroy(); //heapBuf

		}

	CleanupStack::PopAndDestroy(); //dbFile

	//Construct the data structure to store maximum TMsvIds in

	//a given driveId.

	iDatabasePresent = new(ELeave)RArray<TBool>(KMaxNumberOfDrives);

	//Initialisation.

	for(TInt index = 0; index < KMaxNumberOfDrives; ++index)

		{

		iDatabasePresent->Append(EFalse);

		}

	}

/**

 * AttachDBL()

 * @param TDriveUnit The drive information of the drive to be checked.

 * @param TUint The driveId of the drive (0-7).

 * @param TMsvId& An output parameter that gives the maximum TMsvId of an 

 *				  entry in the messaging database of that drive.

 * 

 * Attaches a database on the specified drive to the main (dummy) 

 * database on the system drive so that appropriate queries 

 * access entries in that database too. The function calls MaxTMsvIdL()

 * to query the particular database to get the maximum TMsvId of an entry 

 * stored in it. This TMsvId is maintained in a data structure which has 

 * the driveId as the index.

 *

 * The database is detached by using its logical name which can

 * be obtained from the driveId.

 * (E.g.: logical name of a database on driveId 3 is 'DB3'. A query on the

 * IndexEntry in this database should address the table as DB3.IndexEntry.)

 */

#if (defined SYMBIAN_MESSAGESTORE_HEADER_BODY_USING_SQLDB)	

void CMsvDBAdapter::AttachDBL(TDriveUnit aDriveUnit, TUint aDriveId, TMsvId& aMaxId, CMsvMessageDBAdapter* iMessageDBAdapter/*default= NULL*/)

#else

void CMsvDBAdapter::AttachDBL(TDriveUnit aDriveUnit, TUint aDriveId, TMsvId& aMaxId)

#endif

	{

	//Construct the logical name of the database to be attached from 

	//the driveId.

	RBuf logicalName;

	CleanupClosePushL(logicalName);

	logicalName.CreateL(5);	

	logicalName.Append(KLogicalName);

	logicalName.AppendNum(aDriveId);

	//Construct the DB filename appending messaging DB name to the drive name.

	RBuf dbFile;

	CleanupClosePushL(dbFile);

	dbFile.CreateL(50);	

	dbFile.Append(aDriveUnit.Name());

	dbFile.Append(KMessagingDBName);

	//Attach the database to the connection.

	User::LeaveIfError(iDatabase.Attach(dbFile, logicalName));

	//Find the parameter and column indexes just once.

	if((KErrNotFound == iDatabasePresent->Find(ETrue)) && (!iDbPtrInitialized))

		{

		InitializeL();

		iDbPtrInitialized = ETrue;

		}

	//Find the maximum TMsvId in the database and store it.

	aMaxId = MaxTMsvIdL(aDriveId);

	(*iDatabasePresent)[aDriveId] = ETrue;

#if (defined SYMBIAN_MESSAGESTORE_HEADER_BODY_USING_SQLDB)

	if(iMessageDBAdapter)

		{

		iMessageDBAdapter->UpdateMetadataStructureL(aDriveId);		

		}	

#endif

	CleanupStack::PopAndDestroy(2); //logicalName, dbFile	

	}

/**

 * DetachDBL()

 * @param TUint The driveId (0-7) of the drive from which the database

 * 				is to be detached.

 * @return None.

 *

 * Detaches a database on the drive specified by the driveId from

 * the main database connection. This is done when:

 * a. The disk is removed from the drive.

 * b. The drive is removed from the preferred drive list.

 *

 * The database is detached by using its logical name which can

 * be obtained from the driveId.

 * (E.g.: logical name of a database on driveId 3 is 'DB3'.)

 */

void CMsvDBAdapter::DetachDBL(TUint aDriveId)

	{

	//Construct the logical name.

	RBuf logicalName;

	CleanupClosePushL(logicalName);

	logicalName.CreateL(5);	

	logicalName.Append(KLogicalName);

	logicalName.AppendNum(aDriveId);

	User::LeaveIfError(iDatabase.Detach(logicalName));

	CleanupStack::PopAndDestroy(); //logicalName

	(*iDatabasePresent)[aDriveId] = EFalse;

	}

/**

 * CreateDBL()

 * @param TDriveNumber The drive number of the drive on which a 

 *						a new messaging database is to be created.

 * @return None.

 *

 * Creates the messaging database on the drive specified by the TDriveNumber

 * using a temporary local database connection.

 * Also creates the IndexEntry table and an index on the parentId field in it,

 * and then the Root entry in the database.

 * Also creates a version table, which is a database with just one column

 * and row which stores the current database version for message store

 * versioning.

 */

#if (defined SYMBIAN_MESSAGESTORE_UNIT_TESTCODE)

void CMsvDBAdapter::CreateDBL(TDriveNumber aDriveNumber, TBool aCreateVersionTable /*Default=ETrue*/, TBool aInvalid /*Default=EFalse*/)

#else

void CMsvDBAdapter::CreateDBL(TDriveNumber aDriveNumber)

#endif

	{