// Copyright (c) 2006-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 "cmtpdpidstore.h"
#include "dbutility.h"


_LIT(KSQLDPIDTableName, "DPIDStore");
_LIT(KSQLInsertDPIDObjectText, "INSERT INTO DPIDStore (DataProviderId, Uid) VALUES (%u, %u)");
_LIT(KSQLCreateDPIDTableText, "CREATE TABLE DPIDStore (DataProviderId UNSIGNED INTEGER, Uid UNSIGNED INTEGER )");
_LIT(KSQLGetDPIDUID, "SELECT * FROM DPIDStore");

/**
Two-phase construction
@param aDatabase	The reference to the database object
@return	pointer to the created suid map instance
*/
CMTPDPIDStore* CMTPDPIDStore::NewL(RDbDatabase& aDatabase)
	{
	CMTPDPIDStore* self = new (ELeave) CMTPDPIDStore(aDatabase);
	CleanupStack::PushL(self);
	self->ConstructL();
	CleanupStack::Pop(self);
	return self;
	}


/**
Standard c++ constructor
*/	
CMTPDPIDStore::CMTPDPIDStore(RDbDatabase& aDatabase)
	:iDatabase(aDatabase)
	{
	}

/**
Second phase constructor.
*/    
void CMTPDPIDStore::ConstructL()
    {    
    CreateDPIDStoteTableL();
    }

/**
Create the table for storing the mapping from object handle to other properties 
(data provider id, storage id, formatcode, etc.)
*/    
void CMTPDPIDStore::CreateDPIDStoteTableL()
	{	
	if (!DBUtility::IsTableExistsL(iDatabase, KSQLDPIDTableName))
		{
		User::LeaveIfError(iDatabase.Execute(KSQLCreateDPIDTableText));			
		}
	iSqlStatement.Format(KSQLGetDPIDUID);    
    RDbView view;
    CleanupClosePushL(view);
    User::LeaveIfError(view.Prepare(iDatabase, TDbQuery(iSqlStatement)));
    User::LeaveIfError(view.Evaluate());
	while (view.NextL())
        {
        view.GetL();
       	iDPIDs.AppendL(view.ColInt64(EDPIDStoreDataProviderId));
		iDPUIDs.AppendL(view.ColInt64(EDPIDStoreUid));
        }
	CleanupStack::PopAndDestroy(&view);	
	}
	
/**
Destructor.
*/    
CMTPDPIDStore::~CMTPDPIDStore()
    {  
	iDPIDs.Close();
	iDPUIDs.Close();
    }


void CMTPDPIDStore::InsertDPIDObjectL(TUint aDPId, TUint aUid)
	{		
	iSqlStatement.Format(KSQLInsertDPIDObjectText, aDPId, aUid);
	TInt err(iDatabase.Execute(iSqlStatement));
	iDatabase.Compact();
	iDPIDs.AppendL(aDPId);
	iDPUIDs.AppendL(aUid);
	}	
  
TUint CMTPDPIDStore::DPIDL(TUint32 aUid, TBool& aFlag) const
    {
	TUint tempDPId = 3;
	aFlag = ETrue;
	TRAPD(err, tempDPId = iDPUIDs.FindL(aUid));
	if(err == KErrNone)
		{
		tempDPId = iDPIDs[tempDPId];
		}
	else
		{
		if(iDPIDs.Count()>0)
			{
			tempDPId = iDPIDs[iDPIDs.Count() - 1];
			tempDPId++;			
			}
		aFlag = EFalse;
		}
	return tempDPId;
    }