1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/utable/UT_TBSRC.CPP Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,309 @@
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 "UT_STD.H"
1.20 +
1.21 +// Class CDbReverseIterator
1.22 +
1.23 +NONSHARABLE_CLASS(CDbReverseIter) : public CDbRecordIter
1.24 + {
1.25 +public:
1.26 + CDbReverseIter(CDbRecordIter* anIterator);
1.27 + ~CDbReverseIter();
1.28 +private:
1.29 + TInt Count() const;
1.30 + TDbRecordId CurrentL();
1.31 + TBool GotoL(TDbPosition aPosition);
1.32 + TBool GotoL(TDbRecordId aRecordId,RDbTableRow& aBuffer);
1.33 + TBool SeekL(const TDbLookupKey& aKey,RDbTable::TComparison aComparison);
1.34 + TDeleted DoDeletedL(TDbPosition aPosition,TDbRecordId aRecordId,const RDbTableRow* aRow);
1.35 +private:
1.36 + CDbRecordIter* iIter;
1.37 + };
1.38 +
1.39 +CDbReverseIter::CDbReverseIter(CDbRecordIter* aIterator)
1.40 + : CDbRecordIter(aIterator->Host()),iIter(aIterator)
1.41 + {}
1.42 +
1.43 +CDbReverseIter::~CDbReverseIter()
1.44 + {
1.45 + delete iIter;
1.46 + }
1.47 +
1.48 +TInt CDbReverseIter::Count() const
1.49 + {
1.50 + return iIter->Count();
1.51 + }
1.52 +
1.53 +TDbRecordId CDbReverseIter::CurrentL()
1.54 + {
1.55 + return iIter->CurrentL();
1.56 + }
1.57 +
1.58 +TBool CDbReverseIter::GotoL(TDbPosition aPosition)
1.59 + {
1.60 + return iIter->GotoL(TDbPosition(EDbLast-aPosition));
1.61 + }
1.62 +
1.63 +TBool CDbReverseIter::GotoL(TDbRecordId aRecord,RDbTableRow& aRow)
1.64 + {
1.65 + return iIter->GotoL(aRecord,aRow);
1.66 + }
1.67 +
1.68 +TBool CDbReverseIter::SeekL(const TDbLookupKey& aKey,RDbTable::TComparison aComparison)
1.69 +//
1.70 +// Reverse the comparison
1.71 +//
1.72 + {
1.73 + return iIter->SeekL(aKey,RDbTable::TComparison(RDbTable::EGreaterThan-aComparison));
1.74 + }
1.75 +
1.76 +CDbReverseIter::TDeleted CDbReverseIter::DoDeletedL(TDbPosition aPosition,TDbRecordId aRecordId,const RDbTableRow* aRow)
1.77 +//
1.78 +// Need to invert the position.
1.79 +//
1.80 + {
1.81 + return iIter->DoDeletedL(TDbPosition(EDbLast-aPosition),aRecordId,aRow);
1.82 + }
1.83 +
1.84 +// Class CDbTableSource
1.85 +
1.86 +CDbTableSource::CDbTableSource()
1.87 + {}
1.88 +
1.89 +CDbTableSource::~CDbTableSource()
1.90 + {
1.91 + delete iIter;
1.92 + iRow.Close();
1.93 + }
1.94 +
1.95 +void CDbTableSource::Construct(CDbTable* aTable)
1.96 +//
1.97 +// We own the table pass in
1.98 +//
1.99 + {
1.100 + iIterMark.Construct(aTable->Generation());
1.101 + iRow.Open(aTable);
1.102 + }
1.103 +
1.104 +void CDbTableSource::ReverseIteratorL()
1.105 +//
1.106 +// Plug in a reverse iterator adaptor for the iterator
1.107 +//
1.108 + {
1.109 + iIter=new(ELeave) CDbReverseIter(iIter);
1.110 + }
1.111 +
1.112 +TInt CDbTableSource::ColumnCount() const
1.113 + {
1.114 + return iRow.Table().Def().Columns().Count();
1.115 + }
1.116 +
1.117 +const TDbColumnDef& CDbTableSource::ColumnDef(TDbColNo aCol) const
1.118 + {
1.119 + return iRow.Table().Def().Columns()[aCol];
1.120 + }
1.121 +
1.122 +RDbRow* CDbTableSource::RowBuffer()
1.123 + {
1.124 + return &iRow;
1.125 + }
1.126 +
1.127 +TDbColumn CDbTableSource::Column(TDbColNo aColNo)
1.128 + {
1.129 + return TDbColumn(iRow,aColNo);
1.130 + }
1.131 +
1.132 +void CDbTableSource::Reset()
1.133 + {
1.134 + iReset=ETrue;
1.135 + }
1.136 +
1.137 +TBool CDbTableSource::EvaluateL(TInt&,TDbRecordId&,TBool&)
1.138 + {
1.139 + return EFalse;
1.140 + }
1.141 +
1.142 +TBool CDbTableSource::Unevaluated()
1.143 + {
1.144 + return EFalse;
1.145 + }
1.146 +
1.147 +TInt CDbTableSource::CountL()
1.148 +//
1.149 +// Count the records
1.150 +//
1.151 + {
1.152 + if (iReset)
1.153 + OpenIteratorL();
1.154 + return iIter->Count();
1.155 + }
1.156 +
1.157 +void CDbTableSource::OpenIteratorL()
1.158 +//
1.159 +// Re-open the iterator after a reset
1.160 +//
1.161 + {
1.162 + __ASSERT(iIter);
1.163 + if (iIter->Host().OpenL())
1.164 + __LEAVE(KErrCorrupt);
1.165 + iReset=EFalse;
1.166 + }
1.167 +
1.168 +CDbTableSource::TGoto CDbTableSource::GotoL(TInt& aWork,TDbPosition aPosition,TDbRecordId& aRecordId)
1.169 +//
1.170 +// Move to the position specified. If out of synch, try to resynch the iterator
1.171 +// using aRecordId
1.172 +//
1.173 + {
1.174 + __ASSERT(iIter);
1.175 + TInt work=aWork;
1.176 + if (work<0)
1.177 + return EExhausted;
1.178 + aWork=work-EWorkToIterate;
1.179 + CDbRecordIter& iter=*iIter;
1.180 + if (iIterMark.Changed())
1.181 + { // two possible resaons for this
1.182 + if (iReset)
1.183 + OpenIteratorL();
1.184 + if (aPosition==EDbNext || aPosition==EDbPrevious)
1.185 + { // table modified
1.186 + if (aRecordId==KDbNullRecordId)
1.187 + return ESynchFailure;
1.188 + if (!iter.GotoL(aRecordId,iRow))
1.189 + { // record has been deleted
1.190 + switch(iter.DeletedL(aPosition,aRecordId))
1.191 + {
1.192 + case CDbRecordIter::EAtRow: // found it
1.193 + aRecordId=iter.CurrentL();
1.194 + return ESuccess;
1.195 + case CDbRecordIter::ENoRow: // no more rows
1.196 + aRecordId=KDbNullRecordId;
1.197 + return ENoRow;
1.198 + case CDbRecordIter::ENotSupported: // couldn't re-snych
1.199 + return ESynchFailure;
1.200 + }
1.201 + }
1.202 + }
1.203 + iIterMark.Mark();
1.204 + }
1.205 + if (iter.GotoL(aPosition))
1.206 + {
1.207 + aRecordId=iter.CurrentL();
1.208 + return ESuccess;
1.209 + }
1.210 + else
1.211 + {
1.212 + aRecordId=KDbNullRecordId;
1.213 + return ENoRow;
1.214 + }
1.215 + }
1.216 +
1.217 +TBool CDbTableSource::SynchL(TDbRecordId aRecordId)
1.218 + {
1.219 + if (iReset)
1.220 + OpenIteratorL();
1.221 + TBool found=iIter->GotoL(aRecordId,iRow);
1.222 + iIterMark.Mark();
1.223 + return found;
1.224 + }
1.225 +
1.226 +TBool CDbTableSource::GotoL(TDbRecordId aRecordId)
1.227 + {
1.228 + return iRow.Table().ExistsL(aRecordId) ? SynchL(aRecordId) : EFalse;
1.229 + }
1.230 +
1.231 +void CDbTableSource::ReadRowL(TDbRecordId aRecordId)
1.232 + {
1.233 + iRow.ReadL(aRecordId);
1.234 + }
1.235 +
1.236 +void CDbTableSource::NewRowL(TDbRecordId aCopyRecord)
1.237 + {
1.238 + if (iIter!=NULL&&iReset)
1.239 + OpenIteratorL();
1.240 + iRow.NewL(aCopyRecord);
1.241 + }
1.242 +
1.243 +void CDbTableSource::PrepareToWriteRowL(TWrite aWrite)
1.244 + {
1.245 + __ASSERT(aWrite==EReplace||aWrite==EAppend);
1.246 + if (aWrite==EReplace)
1.247 + iRow.PrepareReplaceL();
1.248 + else
1.249 + iRow.PrepareAppendL();
1.250 + }
1.251 +
1.252 +TDbRecordId CDbTableSource::WriteRowL(TWrite aWrite,TSynch aSynch)
1.253 + {
1.254 + __ASSERT(aWrite==EReplace||aWrite==EAppend);
1.255 + TDbRecordId id=aWrite==EReplace ? iRow.ReplaceL() : iRow.AppendL();
1.256 + if (aSynch==ESynch)
1.257 + {
1.258 + __DEBUG(TBool dbgchk=) SynchL(id);
1.259 + __ASSERT(dbgchk);
1.260 + }
1.261 + return id;
1.262 + }
1.263 +
1.264 +CDbTableSource::TDelete CDbTableSource::DeleteRowL(TDbRecordId& aRecordId,TSynch aSynch)
1.265 +//
1.266 +// Remove the row from the table. Synchronise the iterator if required
1.267 +// When not synchronising, the return value is not significant
1.268 +//
1.269 + {
1.270 + // if the table has changed, we may need to re-synch the iterator before deleting
1.271 + // this is important if neighbouring rows have been deleted by another view
1.272 + if (aSynch==ESynch && iIterMark.Changed() && !SynchL(aRecordId))
1.273 + __LEAVE(KErrNotFound); // it has been deleted already!
1.274 + iRow.DeleteL(aRecordId);
1.275 + if (aSynch==ESynch)
1.276 + {
1.277 + CDbRecordIter::TDeleted del=iIter->DeletedL(EDbNext,aRecordId,iRow);
1.278 + __ASSERT(del!=CDbRecordIter::ENotSupported); // must always be able to synch with row data
1.279 + iIterMark.Mark();
1.280 + if (del==CDbRecordIter::EAtRow)
1.281 + { // pass back the next record id
1.282 + aRecordId=iIter->CurrentL();
1.283 + return EDeletedAtNext;
1.284 + }
1.285 + }
1.286 + return EDeletedAtEnd;
1.287 + }
1.288 +
1.289 +void CDbTableSource::SetIndexL(const TDesC* anIndex)
1.290 + {
1.291 + CDbRecordIter* iter=anIndex ? iRow.Table().IteratorL(*anIndex) : iRow.Table().IteratorL();
1.292 + delete iIter;
1.293 + iIter=iter;
1.294 + }
1.295 +
1.296 +TBool CDbTableSource::SeekL(const TDbLookupKey& aKey,RDbTable::TComparison aComparison,TDbRecordId& aRecordId)
1.297 + {
1.298 + if (iReset)
1.299 + OpenIteratorL();
1.300 + CDbRecordIter& iter=*iIter;
1.301 + TBool atrow=iter.SeekL(aKey,aComparison);
1.302 + aRecordId=atrow ? iter.CurrentL() : KDbNullRecordId;
1.303 + iIterMark.Mark();
1.304 + return atrow;
1.305 + }
1.306 +
1.307 +CSqlSearchCondition* CDbTableSource::ParseConstraintLC(const TDesC& aCondition)
1.308 + {
1.309 + CSqlSearchCondition* sc=Sql::ParseSearchConditionLC(aCondition);
1.310 + sc->BindL(iRow);
1.311 + return sc;
1.312 + }