1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/udbms/UD_ROW.CPP Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,270 @@
1.4 +// Copyright (c) 1998-2009 Nokia Corporation and/or its subsidiary(-ies).
1.5 +// All rights reserved.
1.6 +// This component and the accompanying materials are made available
1.7 +// under the terms of "Eclipse Public License v1.0"
1.8 +// which accompanies this distribution, and is available
1.9 +// at the URL "http://www.eclipse.org/legal/epl-v10.html".
1.10 +//
1.11 +// Initial Contributors:
1.12 +// Nokia Corporation - initial contribution.
1.13 +//
1.14 +// Contributors:
1.15 +//
1.16 +// Description:
1.17 +//
1.18 +
1.19 +#include "UD_STD.H"
1.20 +
1.21 +#define UNUSED_VAR(a) a = a
1.22 +
1.23 +// Class TDbColumn
1.24 +
1.25 +EXPORT_C void TDbColumn::SetL(const TAny* aPtr,TInt aSize)
1.26 + {
1.27 + Mem::Copy(Row().SetColumnWidthL(iColumn,aSize),aPtr,aSize);
1.28 + }
1.29 +
1.30 +EXPORT_C void TDbColumn::SetL(TUint32 aValue)
1.31 + {
1.32 + *(TUint32*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
1.33 + }
1.34 +
1.35 +EXPORT_C void TDbColumn::SetL(TInt64 aValue)
1.36 + {
1.37 + *(TInt64*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
1.38 + }
1.39 +
1.40 +EXPORT_C void TDbColumn::SetL(TReal32 aValue) __SOFTFP
1.41 + {
1.42 + *(TReal32*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
1.43 + }
1.44 +
1.45 +EXPORT_C void TDbColumn::SetL(TReal64 aValue) __SOFTFP
1.46 + {
1.47 + *(TReal64*)Row().SetColumnWidthL(iColumn,sizeof(aValue))=aValue;
1.48 + }
1.49 +
1.50 +EXPORT_C void TDbColumn::SetL(const TDesC8& aValue)
1.51 + {
1.52 + SetL(aValue.Ptr(),aValue.Length());
1.53 + }
1.54 +
1.55 +EXPORT_C void TDbColumn::SetL(const TDesC16& aValue)
1.56 + {
1.57 + SetL(aValue.Ptr(),aValue.Length()<<1);
1.58 + }
1.59 +
1.60 +EXPORT_C void TDbColumn::SetBlobL(TDbBlobId aBlobId,TInt aSize)
1.61 + {
1.62 + new(Row().SetColumnWidthL(iColumn,TDbBlob::RefSize())) TDbBlob(aBlobId,aSize);
1.63 + }
1.64 +
1.65 +EXPORT_C void TDbColumn::SetBlobL(const TUint8* aData,TInt aSize)
1.66 + {
1.67 + new(Row().SetColumnWidthL(iColumn,TDbBlob::InlineSize(aSize))) TDbBlob(aData,aSize);
1.68 + }
1.69 +
1.70 +EXPORT_C TDbBlob& TDbColumn::InitBlobL()
1.71 + {
1.72 + return *new(Row().SetColumnWidthL(iColumn,sizeof(TDbBlob))) TDbBlob;
1.73 + }
1.74 +
1.75 +EXPORT_C void TDbColumn::CommitBlob(const TDbBlob& aBlob)
1.76 + {
1.77 +#if defined(_DEBUG)
1.78 + TDbColumnC colC(*this);
1.79 + __ASSERT(&colC.Blob()==&aBlob);
1.80 + __ASSERT(colC.Size()>=aBlob.CellSize());
1.81 +#endif
1.82 + TRAPD(errCode, Row().SetColumnWidthL(iColumn,aBlob.Size() ? aBlob.CellSize() : 0));
1.83 + UNUSED_VAR(errCode);
1.84 + }
1.85 +
1.86 +// The row buffer
1.87 +// Minimum data width is 4 bytes for strict alignment
1.88 +// No integral set members for small integers and extractors do the cast down from 4-byte integers
1.89 +
1.90 +EXPORT_C RDbRow::RDbRow()
1.91 +//
1.92 +// default to dynamic-owned empty row buffer
1.93 +//
1.94 + :iFirst(0),iLast(0),iEnd(0),iCell(0),iColumn(TUint(EOwned))
1.95 + {}
1.96 +
1.97 +EXPORT_C void RDbRow::Open(TAny* aBuf,TInt aSize,TInt aMaxSize)
1.98 +//
1.99 +// Use the provided row buffer
1.100 +//
1.101 + {
1.102 + iFirst=(TDbCell*)aBuf;
1.103 + iEnd=PtrAdd(iFirst,aMaxSize);
1.104 + iColumn=0; // non-owned buffer
1.105 + SetSize(aSize);
1.106 + }
1.107 +
1.108 +EXPORT_C void RDbRow::CreateL(TInt aMaxSize)
1.109 + {
1.110 + __ASSERT(!iFirst && Owned());
1.111 + GrowL(aMaxSize);
1.112 + }
1.113 +
1.114 +void RDbRow::PushL()
1.115 +//
1.116 +// Dynamic reallocation requires that the buffer is pushed
1.117 +//
1.118 + {
1.119 + CleanupClosePushL(*this);
1.120 + }
1.121 +
1.122 +EXPORT_C void RDbRow::Close()
1.123 +//
1.124 +// release the buffer if owned, and return to default constructed state
1.125 +//
1.126 + {
1.127 + if (Owned())
1.128 + User::Free(iFirst);
1.129 + iFirst=iLast=iEnd=iCell=0;
1.130 + iColumn=TUint(EOwned);
1.131 + }
1.132 +
1.133 +EXPORT_C void RDbRow::SetSize(TInt aSize)
1.134 +//
1.135 +// Set the current buffer size: assert that it is valid
1.136 +//
1.137 + {
1.138 + __ASSERT(PtrAdd(iFirst,aSize)<=iEnd);
1.139 + iLast=PtrAdd(iFirst,aSize);
1.140 + SetCache(iFirst,0);
1.141 + }
1.142 +
1.143 +EXPORT_C void RDbRow::GrowL(TInt aMaxSize)
1.144 +//
1.145 +// Grow the buffer to at least aMaxSize, the buffer empty on return
1.146 +//
1.147 + {
1.148 + if (aMaxSize>MaxSize())
1.149 + {
1.150 + ReallocL(aMaxSize);
1.151 + Reset();
1.152 + //
1.153 + __ASSERT(iFirst<=iEnd);
1.154 + __ASSERT(iFirst<=iLast && iLast<=iEnd);
1.155 + __ASSERT(iFirst<=iCell && iCell<=iLast);
1.156 + }
1.157 + }
1.158 +
1.159 +void RDbRow::ExtendL(TInt aAdjust)
1.160 +//
1.161 +// Adjust the buffer length by aAdjust, leave if no room, preserve contents and cache
1.162 +//
1.163 + {
1.164 + TDbCell* newLast=PtrAdd(iLast,aAdjust);
1.165 + if (newLast>iEnd)
1.166 + {
1.167 + TInt move=ReallocL(Diff(iFirst,newLast));
1.168 + iCell=PtrAdd(iCell,move);
1.169 + newLast=PtrAdd(newLast,move);
1.170 + }
1.171 + iLast=newLast;
1.172 +// check invariant
1.173 + __ASSERT(iFirst<=iEnd);
1.174 + __ASSERT(iFirst<=iLast && iLast<=iEnd);
1.175 + __ASSERT(iFirst<=iCell && iCell<=iLast);
1.176 + }
1.177 +
1.178 +TInt RDbRow::ReallocL(TInt aMaxSize)
1.179 +//
1.180 +// Grow the buffer to aMaxSize, return the offset of buffer movement
1.181 +// leave iLast and cache untouched
1.182 +//
1.183 + {
1.184 + __ASSERT(aMaxSize>MaxSize());
1.185 + if (!Owned())
1.186 + __LEAVE(KErrTooBig); // cannot reallocate if not owned
1.187 +//
1.188 + aMaxSize+=EGranularity-1;
1.189 + aMaxSize&=~(EGranularity-1);
1.190 + TDbCell* buf=(TDbCell*)User::ReAllocL(iFirst,aMaxSize);
1.191 + TInt move=Diff(iFirst,buf);
1.192 + iFirst=buf;
1.193 + iEnd=PtrAdd(buf,aMaxSize);
1.194 + return move;
1.195 + }
1.196 +
1.197 +TDbCell* RDbRow::Column(TInt aColIx) const
1.198 +//
1.199 +// aCol is now zero-based
1.200 +// Return a pointer to column aCol in the buffer
1.201 +// Return 0 if the column is past the end
1.202 +//
1.203 + {
1.204 + TInt ix=Column();
1.205 + TDbCell* pC;
1.206 + if (aColIx<ix)
1.207 + {
1.208 + ix=0;
1.209 + pC=iFirst;
1.210 + }
1.211 + else
1.212 + pC=iCell;
1.213 + TDbCell* last=iLast;
1.214 + for (;;)
1.215 + {
1.216 + if (pC>=last)
1.217 + break;
1.218 + if (ix>=aColIx)
1.219 + break;
1.220 + pC=pC->Next();
1.221 + ++ix;
1.222 + }
1.223 + CONST_CAST(RDbRow*,this)->SetCache(pC,ix);
1.224 + return pC<last?pC:0;
1.225 + }
1.226 +
1.227 +LOCAL_C const TDbCell* NullCell()
1.228 + {
1.229 + static TUint32 const NullCell[3]={0,0,0}; // 3 zero words represent any "Null" value
1.230 +//
1.231 + return REINTERPRET_CAST(const TDbCell*,&NullCell[0]);
1.232 + }
1.233 +
1.234 +EXPORT_C const TDbCell* RDbRow::ColCell(TDbColNo aColNo) const
1.235 + {
1.236 + __ASSERT(aColNo>0);
1.237 + const TDbCell* cell=Column(aColNo-1);
1.238 + return cell && cell->Length() ? cell : NullCell();
1.239 + }
1.240 +
1.241 +EXPORT_C TAny* RDbRow::SetColumnWidthL(TDbColNo aColNo,TInt aWidth)
1.242 +// set the width for column aCol to Width
1.243 +// add extra NULL columns to buffer as required
1.244 +// return pointer to data for that column
1.245 + {
1.246 + __ASSERT(aColNo>0);
1.247 + TDbCell* pC=Column(--aColNo);
1.248 + if (pC==0)
1.249 + { // add extra NULL columns to buffer
1.250 + if (aWidth==0)
1.251 + return 0; // setting to NULL, don't bother padding
1.252 + TInt cFill=(aColNo-iColumn)*sizeof(TInt);
1.253 + ExtendL(cFill+TDbCell::Size(aWidth));
1.254 + pC=iCell;
1.255 + Mem::FillZ(pC,cFill);
1.256 + pC=PtrAdd(pC,cFill); // set cache
1.257 + SetCache(pC,aColNo);
1.258 + }
1.259 + else
1.260 + {
1.261 + TInt adjust=TDbCell::Size(aWidth)-pC->Size(); // how much to add
1.262 + if (adjust!=0)
1.263 + {
1.264 + ExtendL(adjust);
1.265 + pC=iCell; // may have moved in extension
1.266 + TDbCell* pNext=pC->Next();
1.267 + TDbCell* pAdjust=PtrAdd(pNext,adjust);
1.268 + Mem::Move(pAdjust,pNext,Diff(pAdjust,iLast));
1.269 + }
1.270 + }
1.271 + pC->SetLength(aWidth);
1.272 + return pC->Data();
1.273 + }