// 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:
// DBMS server and support classes
// 
//

#include "SD_STD.H"

// Class RDbsObject
void RDbsObject::OpenL(const RDbsObject& aDbs,TDbsFunction aFunction,const TIpcArgs* aArgs)
	{
	__ASSERT(!iHandle);
	iHandle=aDbs.SendReceiveL(TDbsFunction(aFunction|KDbsObjectReturn),aArgs);
	RDbs::operator=(STATIC_CAST(const RDbs&,aDbs));
	}

void RDbsObject::Close()
	{
	if (iHandle)
		{
		SendReceive(EDbsClose);
		iHandle=0;
		SetHandle(KNullHandle);		// set session handle
		}
	}

TInt RDbsObject::SendReceive(TDbsFunction aFunction,const TIpcArgs* aArgs) const
	{
	__ASSERT(iHandle);
	if(aArgs)
		return RDbs::SendReceive(DbsMessage(aFunction,iHandle),*aArgs);
	else
		return RDbs::SendReceive(DbsMessage(aFunction,iHandle),TIpcArgs());
	}

TInt RDbsObject::SendReceive(TDbsFunction aFunction) const
	{
	return SendReceive(aFunction,0);
	}

TInt RDbsObject::SendReceiveL(TDbsFunction aFunction,const TIpcArgs* aArgs) const
	{
	return __LEAVE_IF_ERROR(SendReceive(aFunction,aArgs));
	}

TInt RDbsObject::SendReceiveL(TDbsFunction aFunction) const
	{
	return SendReceiveL(aFunction,0);
	}

void RDbsObject::SendReceive(TDbsFunction aFunction,const TIpcArgs* aArgs,TRequestStatus& aStatus) const
	{
	__ASSERT(iHandle);
	if(aArgs)
		RDbs::SendReceive(DbsMessage(aFunction,iHandle),*aArgs,aStatus);
	else
		RDbs::SendReceive(DbsMessage(aFunction,iHandle),TIpcArgs(),aStatus);
	}

// Class TDbsParam

const TInt KBufGranularity=0x200;

TPtrC8 TDbsParam::PrepareLC(const CDbColSet& aColSet)
	{
	CBufFlat* buf=CBufFlat::NewL(KBufGranularity);
	CleanupStack::PushL(buf);
	RBufWriteStream strm(*buf);
	strm<<aColSet;
	return buf->Ptr(0);
	}

TPtrC8 TDbsParam::PrepareLC(const CDbKey& aKey)
	{
	CBufFlat* buf=CBufFlat::NewL(KBufGranularity);
	CleanupStack::PushL(buf);
	RBufWriteStream strm(*buf);
	strm<<aKey;
	return buf->Ptr(0);
	}

TPtrC8 TDbsParam::PrepareLC(const TDbLookupKey& aKey)
	{
	TInt tsize=0;
	const TDbLookupKey::SColumn* iter=aKey.First();
	const TDbLookupKey::SColumn* end=iter+aKey.Count();
	do
		{
		switch (iter->iType)
			{
		default:
			break;
		case EDbColText8:
			tsize+=iter->iDes8.iLength;
			break;
		case EDbColText16:
			tsize+=iter->iDes16.iLength<<1;
			break;
			};
		} while (++iter<end);
	//
	TInt size=(TUint8*)end-(TUint8*)&aKey;
	TDbLookupKey* key=(TDbLookupKey*)User::AllocLC(size+tsize);
	TUint8* text=Mem::Copy(key,&aKey,size);
	if (tsize)
		{
		TDbLookupKey::SColumn* iter=CONST_CAST(TDbLookupKey::SColumn*,key->First());
		TDbLookupKey::SColumn* end=(TDbLookupKey::SColumn*)text;
		do
			{
			switch (iter->iType)
				{
			default:
				break;
			case EDbColText8:
				{
				const TUint8* p=iter->iDes8.iPtr;
				iter->iDes8.iPtr=REINTERPRET_CAST(const TUint8*,(text-(TUint8*)key));
				text=Mem::Copy(text,p,iter->iDes8.iLength);
				}
				break;
			case EDbColText16:
				{
				const TUint16* p=iter->iDes16.iPtr;
				iter->iDes16.iPtr=REINTERPRET_CAST(const TUint16*,(text-(TUint8*)key));
				text=Mem::Copy(text,p,iter->iDes16.iLength<<1);
				}
				break;
				};
			} while (++iter<end);
		}
	return TPtrC8((TUint8*)key,size+tsize);
	}