sl@0: // Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #include "UD_STD.H"
sl@0: 
sl@0: #define UNUSED_VAR(a) a = a
sl@0: 
sl@0: // Class TDbColumn
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetL(const TAny* aPtr,TInt aSize)
sl@0: 	{
sl@0: 	Mem::Copy(Row().SetColumnWidthL(iColumn,aSize),aPtr,aSize);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetL(TUint32 aValue)
sl@0: 	{
sl@0: 	*(TUint32*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetL(TInt64 aValue)
sl@0: 	{
sl@0: 	*(TInt64*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetL(TReal32 aValue) __SOFTFP
sl@0: 	{
sl@0: 	*(TReal32*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetL(TReal64 aValue) __SOFTFP
sl@0: 	{
sl@0: 	*(TReal64*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetL(const TDesC8& aValue)
sl@0: 	{
sl@0: 	SetL(aValue.Ptr(),aValue.Length());
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetL(const TDesC16& aValue)
sl@0: 	{
sl@0: 	SetL(aValue.Ptr(),aValue.Length()<<1);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetBlobL(TDbBlobId aBlobId,TInt aSize)
sl@0: 	{
sl@0: 	new(Row().SetColumnWidthL(iColumn,TDbBlob::RefSize())) TDbBlob(aBlobId,aSize);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::SetBlobL(const TUint8* aData,TInt aSize)
sl@0: 	{
sl@0: 	new(Row().SetColumnWidthL(iColumn,TDbBlob::InlineSize(aSize))) TDbBlob(aData,aSize);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TDbBlob& TDbColumn::InitBlobL()
sl@0: 	{
sl@0: 	return *new(Row().SetColumnWidthL(iColumn,sizeof(TDbBlob))) TDbBlob;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void TDbColumn::CommitBlob(const TDbBlob& aBlob)
sl@0: 	{
sl@0: #if defined(_DEBUG)
sl@0: 	TDbColumnC colC(*this);
sl@0: 	__ASSERT(&colC.Blob()==&aBlob);
sl@0: 	__ASSERT(colC.Size()>=aBlob.CellSize());
sl@0: #endif
sl@0: 	TRAPD(errCode, Row().SetColumnWidthL(iColumn,aBlob.Size() ? aBlob.CellSize() : 0));
sl@0:     UNUSED_VAR(errCode);
sl@0: 	}
sl@0: 
sl@0: // The row buffer
sl@0: // Minimum data width is 4 bytes for strict alignment
sl@0: // No integral set members for small integers and extractors do the cast down from 4-byte integers
sl@0: 
sl@0: EXPORT_C RDbRow::RDbRow()
sl@0: //
sl@0: // default to dynamic-owned empty row buffer
sl@0: //
sl@0: 	:iFirst(0),iLast(0),iEnd(0),iCell(0),iColumn(TUint(EOwned))
sl@0: 	{}
sl@0: 
sl@0: EXPORT_C void RDbRow::Open(TAny* aBuf,TInt aSize,TInt aMaxSize)
sl@0: //
sl@0: // Use the provided row buffer
sl@0: //
sl@0: 	{
sl@0: 	iFirst=(TDbCell*)aBuf;
sl@0: 	iEnd=PtrAdd(iFirst,aMaxSize);
sl@0: 	iColumn=0;			// non-owned buffer
sl@0: 	SetSize(aSize);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RDbRow::CreateL(TInt aMaxSize)
sl@0: 	{
sl@0: 	__ASSERT(!iFirst && Owned());
sl@0: 	GrowL(aMaxSize);
sl@0: 	}
sl@0: 
sl@0: void RDbRow::PushL()
sl@0: //
sl@0: // Dynamic reallocation requires that the buffer is pushed
sl@0: //
sl@0: 	{
sl@0: 	CleanupClosePushL(*this);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RDbRow::Close()
sl@0: //
sl@0: // release the buffer if owned, and return to default constructed state
sl@0: //
sl@0: 	{
sl@0: 	if (Owned())
sl@0: 		User::Free(iFirst);
sl@0: 	iFirst=iLast=iEnd=iCell=0;
sl@0: 	iColumn=TUint(EOwned);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RDbRow::SetSize(TInt aSize)
sl@0: //
sl@0: // Set the current buffer size: assert that it is valid
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(PtrAdd(iFirst,aSize)<=iEnd);
sl@0: 	iLast=PtrAdd(iFirst,aSize);
sl@0: 	SetCache(iFirst,0);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void RDbRow::GrowL(TInt aMaxSize)
sl@0: //
sl@0: // Grow the buffer to at least aMaxSize, the buffer empty on return
sl@0: //
sl@0: 	{
sl@0: 	if (aMaxSize>MaxSize())
sl@0: 		{
sl@0: 		ReallocL(aMaxSize);
sl@0: 		Reset();
sl@0: 	//
sl@0: 		__ASSERT(iFirst<=iEnd);
sl@0: 		__ASSERT(iFirst<=iLast && iLast<=iEnd);
sl@0: 		__ASSERT(iFirst<=iCell && iCell<=iLast);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void RDbRow::ExtendL(TInt aAdjust)
sl@0: //
sl@0: // Adjust the buffer length by aAdjust, leave if no room, preserve contents and cache
sl@0: //
sl@0: 	{
sl@0: 	TDbCell* newLast=PtrAdd(iLast,aAdjust);
sl@0: 	if (newLast>iEnd)
sl@0: 		{
sl@0: 		TInt move=ReallocL(Diff(iFirst,newLast));
sl@0: 		iCell=PtrAdd(iCell,move);
sl@0: 		newLast=PtrAdd(newLast,move);
sl@0: 		}
sl@0: 	iLast=newLast;
sl@0: // check invariant
sl@0: 	__ASSERT(iFirst<=iEnd);
sl@0: 	__ASSERT(iFirst<=iLast && iLast<=iEnd);
sl@0: 	__ASSERT(iFirst<=iCell && iCell<=iLast);
sl@0: 	}
sl@0: 
sl@0: TInt RDbRow::ReallocL(TInt aMaxSize)
sl@0: //
sl@0: // Grow the buffer to aMaxSize, return the offset of buffer movement
sl@0: // leave iLast and cache untouched
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(aMaxSize>MaxSize());
sl@0: 	if (!Owned())
sl@0: 		__LEAVE(KErrTooBig);	// cannot reallocate if not owned
sl@0: //
sl@0: 	aMaxSize+=EGranularity-1;
sl@0: 	aMaxSize&=~(EGranularity-1);
sl@0: 	TDbCell* buf=(TDbCell*)User::ReAllocL(iFirst,aMaxSize);
sl@0: 	TInt move=Diff(iFirst,buf);
sl@0: 	iFirst=buf;
sl@0: 	iEnd=PtrAdd(buf,aMaxSize);
sl@0: 	return move;
sl@0: 	}
sl@0: 
sl@0: TDbCell* RDbRow::Column(TInt aColIx) const
sl@0: //
sl@0: // aCol is now zero-based
sl@0: // Return a pointer to column aCol in the buffer
sl@0: // Return 0 if the column is past the end
sl@0: //
sl@0: 	{
sl@0: 	TInt ix=Column();
sl@0: 	TDbCell* pC;
sl@0: 	if (aColIx<ix)
sl@0: 		{
sl@0: 		ix=0;
sl@0: 		pC=iFirst;
sl@0: 		}
sl@0: 	else
sl@0: 		pC=iCell;
sl@0: 	TDbCell* last=iLast;
sl@0: 	for (;;)
sl@0: 		{
sl@0: 		if (pC>=last)
sl@0: 			break;
sl@0: 		if (ix>=aColIx)
sl@0: 			break;
sl@0: 		pC=pC->Next();
sl@0: 		++ix;
sl@0: 		}
sl@0: 	CONST_CAST(RDbRow*,this)->SetCache(pC,ix);
sl@0: 	return pC<last?pC:0;
sl@0: 	}
sl@0: 
sl@0: LOCAL_C const TDbCell* NullCell()
sl@0: 	{
sl@0: 	static TUint32 const NullCell[3]={0,0,0};	// 3 zero words represent any "Null" value
sl@0: //
sl@0: 	return REINTERPRET_CAST(const TDbCell*,&NullCell[0]);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C const TDbCell* RDbRow::ColCell(TDbColNo aColNo) const
sl@0: 	{
sl@0: 	__ASSERT(aColNo>0);
sl@0: 	const TDbCell* cell=Column(aColNo-1);
sl@0: 	return cell && cell->Length() ? cell : NullCell();
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TAny* RDbRow::SetColumnWidthL(TDbColNo aColNo,TInt aWidth)
sl@0: // set the width for column aCol to Width
sl@0: // add extra NULL columns to buffer as required
sl@0: // return pointer to data for that column
sl@0: 	{
sl@0: 	__ASSERT(aColNo>0);
sl@0: 	TDbCell* pC=Column(--aColNo);
sl@0: 	if (pC==0)
sl@0: 		{		// add extra NULL columns to buffer
sl@0: 		if (aWidth==0)
sl@0: 			return 0;	// setting to NULL, don't bother padding
sl@0: 		TInt cFill=(aColNo-iColumn)*sizeof(TInt);
sl@0: 		ExtendL(cFill+TDbCell::Size(aWidth));
sl@0: 		pC=iCell;
sl@0: 		Mem::FillZ(pC,cFill);
sl@0: 		pC=PtrAdd(pC,cFill);		// set cache
sl@0: 		SetCache(pC,aColNo);
sl@0: 		}
sl@0: 	else
sl@0: 		{
sl@0: 		TInt adjust=TDbCell::Size(aWidth)-pC->Size();	// how much to add
sl@0: 		if (adjust!=0)
sl@0: 			{
sl@0: 			ExtendL(adjust);
sl@0: 			pC=iCell;		// may have moved in extension
sl@0: 			TDbCell* pNext=pC->Next();
sl@0: 			TDbCell* pAdjust=PtrAdd(pNext,adjust);
sl@0: 			Mem::Move(pAdjust,pNext,Diff(pAdjust,iLast));
sl@0: 			}
sl@0: 		}
sl@0: 	pC->SetLength(aWidth);
sl@0: 	return pC->Data();
sl@0: 	}