1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/utable/UT_STD.H Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,843 @@
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 "U32STD.H"
1.20 +#include <d32dbms.h>
1.21 +#include "D32REC.H"
1.22 +#include "D32TABLE.H"
1.23 +#include "D32SQL.H"
1.24 +#include <s32mem.h>
1.25 +
1.26 +/**
1.27 +@internalComponent
1.28 +*/
1.29 +enum TTablePanic
1.30 + {
1.31 + EDbInvalidColumn,
1.32 + EDbWrongType,
1.33 + EDbInUpdate,
1.34 + EDbNotInUpdate,
1.35 + EDbInvalidRow,
1.36 + EDbRowNotRead,
1.37 + EDbReadOnly,
1.38 + EDbTableOpen,
1.39 + EDbNotEvaluated,
1.40 + EDbStreamOpen,
1.41 + EDbRowSetConstraintMismatch,
1.42 + EDbBeginNestedTransaction,
1.43 + EDbUpdatesPendingOnCommit,
1.44 + EDbUpdatesPendingOnRollback,
1.45 + EDbNoCurrentTransaction,
1.46 + EDbStreamsPendingOnCommit,
1.47 + EDbStreamsPendingOnRollback,
1.48 + EDbInvalidBookmark
1.49 + };
1.50 +
1.51 +/**
1.52 +@internalComponent
1.53 +*/
1.54 +GLREF_C void Panic( TTablePanic aPanic );
1.55 +
1.56 +class Validate
1.57 +/**
1.58 +@internalComponent
1.59 +*/
1.60 + {
1.61 +public:
1.62 + static void NameL( const TDesC& aName );
1.63 + static void ColSetL( const CDbColSet& aColSet );
1.64 + static void KeyL( const CDbKey& aKey, const HDbColumnSet& aColumns );
1.65 +private:
1.66 + static void UniqueNameL( TDesC const** aNames, TInt aCount, const TDesC& aName );
1.67 + };
1.68 +
1.69 +class CDbDataSource : public CBase
1.70 +/**
1.71 +@internalComponent
1.72 +*/
1.73 + {
1.74 +public:
1.75 + enum TGoto { ESuccess, ENoRow, EExhausted, ESynchFailure };
1.76 + enum TSynch { ESynch, ENoSynch };
1.77 + enum TDelete { EDeletedAtNext, EDeletedAtEnd, EDeletedInLimbo };
1.78 + enum TWrite { EReplace, EAppend };
1.79 +protected:
1.80 + enum { EWorkToIterate = 1, EWorkToRead = 16 };
1.81 +public:
1.82 + virtual RDbRow* RowBuffer() = 0;
1.83 + virtual TDbColumn Column( TDbColNo aColNo ) = 0;
1.84 + virtual void Reset() = 0;
1.85 + virtual TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow ) = 0;
1.86 + virtual TBool Unevaluated() = 0;
1.87 + virtual TInt CountL() = 0;
1.88 + virtual TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId ) = 0;
1.89 + TGoto GotoL( TDbPosition aPosition, TDbRecordId& aRecordId );
1.90 + virtual TBool GotoL( TDbRecordId aRecordId ) = 0;
1.91 + virtual void ReadRowL( TDbRecordId aRecordId ) = 0;
1.92 + virtual void NewRowL( TDbRecordId aCopyRecord ) = 0;
1.93 + virtual void PrepareToWriteRowL( TWrite aWrite ) = 0;
1.94 + virtual TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch = ESynch ) = 0;
1.95 + virtual TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch = ESynch ) = 0;
1.96 + virtual TInt ColumnCount() const = 0;
1.97 + virtual const TDbColumnDef& ColumnDef( TDbColNo aCol ) const = 0;
1.98 +//
1.99 + virtual void SetIndexL( const TDesC* anIndex ) = 0;
1.100 + virtual TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison, TDbRecordId& aRecordId ) = 0;
1.101 + virtual CSqlSearchCondition* ParseConstraintLC( const TDesC& aCondition ) = 0;
1.102 +protected:
1.103 + CDbDataSource() {};
1.104 + };
1.105 +
1.106 +NONSHARABLE_CLASS(CDbTableSource) : public CDbDataSource
1.107 +/**
1.108 +@internalComponent
1.109 +*/
1.110 + {
1.111 +public:
1.112 + ~CDbTableSource();
1.113 + CDbTableSource();
1.114 + void Construct( CDbTable* aTable );
1.115 + inline void SetIterator( CDbRecordIter* anIter );
1.116 + void ReverseIteratorL();
1.117 + inline const RDbTableRow& Row();
1.118 + inline CDbTable& Table();
1.119 +//
1.120 + RDbRow* RowBuffer();
1.121 + TDbColumn Column( TDbColNo aColNo );
1.122 + void Reset();
1.123 + TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow );
1.124 + TBool Unevaluated();
1.125 + TInt CountL();
1.126 + TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
1.127 + TBool GotoL( TDbRecordId aRecordId );
1.128 + void NewRowL( TDbRecordId aCopyRecord );
1.129 + void PrepareToWriteRowL( TWrite aWrite );
1.130 + TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch );
1.131 + void ReadRowL( TDbRecordId aRecordId );
1.132 + TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
1.133 + TInt ColumnCount() const;
1.134 + const TDbColumnDef& ColumnDef( TDbColNo aCol ) const;
1.135 + void SetIndexL( const TDesC* anIndex );
1.136 + TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison, TDbRecordId& aRecordId );
1.137 + CSqlSearchCondition* ParseConstraintLC( const TDesC& aCondition );
1.138 +private:
1.139 + TBool SynchL( TDbRecordId aRecordId );
1.140 + void OpenIteratorL();
1.141 +private:
1.142 + CDbRecordIter* iIter;
1.143 + TDbGenerationMark iIterMark;
1.144 + RDbTableRow iRow;
1.145 + TBool iReset;
1.146 + };
1.147 +
1.148 +NONSHARABLE_CLASS(CDbDataStage) : public CDbDataSource
1.149 +/**
1.150 +@internalComponent
1.151 +*/
1.152 + {
1.153 +public:
1.154 + ~CDbDataStage();
1.155 + inline void SetSource( CDbDataSource* aSource );
1.156 +protected:
1.157 + CDbDataStage() {};
1.158 + inline CDbDataSource& Source();
1.159 + inline const CDbDataSource& Source() const;
1.160 + RDbRow* RowBuffer();
1.161 + TDbColumn Column( TDbColNo aColNo );
1.162 + void Reset();
1.163 + TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow );
1.164 + TBool Unevaluated();
1.165 + TInt CountL();
1.166 + TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
1.167 + TBool GotoL( TDbRecordId aRecordId );
1.168 + void ReadRowL( TDbRecordId aRecordId );
1.169 + void NewRowL( TDbRecordId aCopyRecord );
1.170 + void PrepareToWriteRowL( TWrite aWrite );
1.171 + TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch );
1.172 + TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
1.173 + TInt ColumnCount() const;
1.174 + const TDbColumnDef& ColumnDef( TDbColNo aCol ) const;
1.175 + void SetIndexL( const TDesC* anIndex );
1.176 + TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison, TDbRecordId& aRecordId );
1.177 + CSqlSearchCondition* ParseConstraintLC( const TDesC& aCondition );
1.178 +private:
1.179 + CDbDataSource* iSource;
1.180 + };
1.181 +
1.182 +NONSHARABLE_CLASS(CDbRestrictStage) : public CDbDataStage
1.183 +/**
1.184 +@internalComponent
1.185 +*/
1.186 + {
1.187 +public:
1.188 + CDbRestrictStage( TDbTextComparison aComparison );
1.189 + ~CDbRestrictStage();
1.190 + inline void SetRestriction( CSqlSearchCondition* aRestriction );
1.191 +private:
1.192 + inline CSqlSearchCondition& Restriction() const;
1.193 + TBool FilterRowL( TDbRecordId aRecordId );
1.194 +//
1.195 + TInt CountL();
1.196 + TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
1.197 + TBool GotoL( TDbRecordId aRecordId );
1.198 + TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
1.199 +private:
1.200 + CSqlSearchCondition* iRestriction;
1.201 + const TTextOps& iTextOp;
1.202 + };
1.203 +
1.204 +class HDbColumnMap;
1.205 +
1.206 +NONSHARABLE_CLASS(CDbProjectStage) : public CDbDataStage
1.207 +/**
1.208 +implement restricted column selection
1.209 +@internalComponent
1.210 +*/
1.211 + {
1.212 +public:
1.213 + CDbProjectStage();
1.214 + ~CDbProjectStage();
1.215 + void ConstructL( const RSqlColumnList& aSelect, const HDbColumnSet& aColumns );
1.216 +private:
1.217 + RDbRow* RowBuffer();
1.218 + TDbColumn Column( TDbColNo aColNo );
1.219 + TInt ColumnCount() const;
1.220 + const TDbColumnDef& ColumnDef( TDbColNo aCol ) const;
1.221 +private:
1.222 + HDbColumnMap* iMap;
1.223 + };
1.224 +
1.225 +NONSHARABLE_CLASS(CDbBasicWindowStage) : public CDbDataStage
1.226 +/**
1.227 +@internalComponent
1.228 +*/
1.229 + {
1.230 +private:
1.231 + enum { EWindowArrayGranularity = 32 }; // 128 byte segments
1.232 +public:
1.233 + CDbBasicWindowStage( const TDbWindow& aWindow );
1.234 +protected:
1.235 +// from CDbDataStage
1.236 + void Reset();
1.237 + TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow );
1.238 + TInt CountL();
1.239 + TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
1.240 + TBool GotoL( TDbRecordId aRecordId );
1.241 + void ReadRowL( TDbRecordId aRecordId );
1.242 + TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch );
1.243 + TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
1.244 +private:
1.245 + TBool GetRecord( TDbRecordId& aRecordId );
1.246 + TInt Find( TDbRecordId aRecordId, TInt& aPos );
1.247 + virtual TBool DoEvaluateL( TInt& aWork ) = 0;
1.248 +protected:
1.249 + TDbWindow iWindow; // the window shape
1.250 + CArrayFixSeg<TDbRecordId> iRecords; // the window itself
1.251 + TInt iPos; // the iterator over the window
1.252 + };
1.253 +
1.254 +NONSHARABLE_CLASS(CDbWindowStage) : public CDbBasicWindowStage
1.255 +/**
1.256 +@internalComponent
1.257 +*/
1.258 + {
1.259 +private:
1.260 + enum TView { EBeginning, EMiddle, EEnd, EAll };
1.261 + enum TIterPos { EAtBeginning, EAtEnd };
1.262 +public:
1.263 + CDbWindowStage( const TDbWindow& aWindow );
1.264 +protected:
1.265 + void Reset();
1.266 + TBool DoEvaluateL( TInt& aWork );
1.267 + TBool Unevaluated();
1.268 +private:
1.269 + TInt WhatToEvaluate();
1.270 + TDbPosition ResetIterToBeginningL();
1.271 + TDbPosition ResetIterToEndL();
1.272 + TDbPosition SetIteratorL( TInt anEval );
1.273 + void ExtendAtBeginningL( TInt aRecords, TDbPosition aFirst, TInt& aWork );
1.274 + void ExtendAtEndL( TInt aRecords, TDbPosition aFirst, TInt& aWork );
1.275 +private:
1.276 + TIterPos iIterPos; // where the underlying iterator is in our window
1.277 + TView iView; // what part of the underlying set we see through the window
1.278 + };
1.279 +
1.280 +NONSHARABLE_CLASS(CDbReorderWindowStage) : public CDbBasicWindowStage
1.281 +/**
1.282 +@internalComponent
1.283 +*/
1.284 + {
1.285 +private:
1.286 + enum TState { EReset, EEvaluate, EComplete, EFailed };
1.287 + enum { EGranularity = 32 };
1.288 +public:
1.289 + CDbReorderWindowStage();
1.290 + ~CDbReorderWindowStage();
1.291 +protected:
1.292 + void Reset();
1.293 + TBool DoEvaluateL( TInt& aWork );
1.294 + TBool Unevaluated();
1.295 +private:
1.296 + TBool ReadL( TInt& aWork, TDbPosition aNext );
1.297 +private:
1.298 + TState iState;
1.299 + RArray<TUint> iRows;
1.300 + };
1.301 +
1.302 +NONSHARABLE_CLASS(CDbOrderByStage) : public CDbBasicWindowStage
1.303 +/**
1.304 +@internalComponent
1.305 +*/
1.306 + {
1.307 +private:
1.308 + class HOrdering;
1.309 + class CKeys;
1.310 + enum TState { EReset, EEvaluate, ESort, EAdd, EComplete, EFailed };
1.311 +public:
1.312 + CDbOrderByStage( const RDbTableRow& aRow );
1.313 + ~CDbOrderByStage();
1.314 + void ConstructL( const CDbKey& aOrderBy );
1.315 +protected:
1.316 + void Reset();
1.317 + TBool DoEvaluateL( TInt& aWork );
1.318 + TBool Unevaluated();
1.319 +private:
1.320 + inline const RDbTableRow& Row();
1.321 + inline CKeys& Keys();
1.322 + inline const HOrdering& Order();
1.323 +//
1.324 + TBool ReadL( TInt& aWork, TDbPosition aNext );
1.325 +private:
1.326 + const RDbTableRow& iRow;
1.327 + TState iState;
1.328 + HOrdering* iOrder;
1.329 + CKeys* iKeys;
1.330 + };
1.331 +
1.332 +class RDbAccessPlan
1.333 +/**
1.334 +@internalComponent
1.335 +*/
1.336 + {
1.337 +public:
1.338 + inline RDbAccessPlan( CSqlQuery* aQuery, TDbTextComparison aComparison );
1.339 + inline RDbAccessPlan();
1.340 + void BuildLC( CDbTableDatabase& aDatabase, RDbRowSet::TAccess aAccess, const TDbWindow& aWindow );
1.341 + void BuildLC( CDbTableDatabase& aDatabase, const TDesC& aTable, RDbRowSet::TAccess aAccess );
1.342 + inline CDbTable& Table();
1.343 + inline CDbDataSource& Source();
1.344 + inline CDbDataSource* Adopt();
1.345 +private:
1.346 + class TPlan
1.347 + {
1.348 + public:
1.349 + enum
1.350 + {
1.351 + EOrder = 0x1, ERestrict = 0x2, EReorder = 0x4,
1.352 + EIndex = 0x8, EBounded = 0x10,
1.353 + EWindow = 0x20, EReverse = 0x40,
1.354 + EMask = 0x1f
1.355 + };
1.356 + enum TType
1.357 + {
1.358 + EPlanA = 0, EPlanB = 0, EPlanC = 0, EPlanD = 0, EPlanEF = 1, EPlanGH = 7, EPlanIJ = 2,
1.359 + EPlanKL = 5, EPlanMN = 4, EPlanOP = 3, EPlanQR = 6, EPlanST = 8
1.360 + };
1.361 + public:
1.362 + inline TPlan();
1.363 + inline TBool operator!=( const TPlan& aPlan ) const;
1.364 + TType Type() const;
1.365 + static TInt OrderByPlan( const TPlan& aLeft, const TPlan& aRight );
1.366 + public:
1.367 + TUint iFlags;
1.368 + const CDbTableIndexDef* iIndex;
1.369 + CSqlCompPredicate* iLower;
1.370 + CSqlCompPredicate* iUpper;
1.371 + };
1.372 +private:
1.373 + CDbTableSource* TableLC( CDbTableDatabase& aDatabase, const TDesC& aTable );
1.374 + void Insert( CDbDataStage* aStage );
1.375 + CDbRecordIter* IteratorL( const TPlan& aPlan );
1.376 + CDbRecordIter* BoundedIteratorL( const TPlan& aPlan );
1.377 + void RestrictionL();
1.378 + void OrderByL( const RDbTableRow& aRowBuf );
1.379 + void ProjectionL();
1.380 + void WindowL( const TPlan& aPlan, const TDbWindow& aWindow );
1.381 + static void Cleanup( TAny* aPtr );
1.382 + TBool IsBoundedIteratorL( TPlan& aPlan, const CDbTableIndexDef* aIndex );
1.383 + TBool IsIndexIteratorL( TPlan& aPlan, const CDbTableIndexDef* aIndex );
1.384 + void EvaluateWindowStage( TPlan& aPlan );
1.385 + void EvaluateReorderStage( TPlan& aPlan, const CDbTableIndexDef* aIndex );
1.386 + void EvaluatePlansL();
1.387 + void ChoosePlanL( TPlan& aPlan );
1.388 + void PrepareQueryL( CDbTableSource* aSource );
1.389 + TInt GetTightestRestrictionL( TPlan& aPlan, TPlan::TType aType );
1.390 + TInt GetSmallestKeySize( TPlan& aPlan, TPlan::TType aType );
1.391 + TInt IndexSpanL( const TPlan& aPlan );
1.392 + void ReducePlans();
1.393 + void CreateTableIteratorPlan( TPlan& aPlan );
1.394 + TUint FindMatchL( const CDbTableIndexDef* aIndex );
1.395 + TBool TextKeyL( const CDbKey& anOrder );
1.396 +private:
1.397 + enum { EGranularity = 4 };
1.398 + enum { EMatch = 0x1, EReverse = 0x2, ETruncated = 0x4 };
1.399 + //
1.400 + class TBounds;
1.401 + class CDbCompPredicateList;
1.402 +private:
1.403 + RArray<TPlan> iPlans;
1.404 + CDbDataSource* iSource;
1.405 + CDbTable* iTable;
1.406 + TDbTextComparison iComparison;
1.407 + CSqlQuery* iQuery;
1.408 + TBool iWindow;
1.409 + RDbRowSet::TAccess iAccess;
1.410 + };
1.411 +
1.412 +class RDbAccessPlan::TBounds
1.413 + {
1.414 +public:
1.415 + TBounds( const TPlan& aPlan );
1.416 +private:
1.417 + void GetLookupKey( const CSqlCompPredicate& aCompPredicate, TDbLookupKey& aLookup );
1.418 + void SetLowerBounds();
1.419 + void SetUpperBounds();
1.420 +public:
1.421 + CSqlCompPredicate* iLowerPred;
1.422 + CSqlCompPredicate* iUpperPred;
1.423 + TDbLookupKey iLowerKey;
1.424 + TDbLookupKey iUpperKey;
1.425 + TDbLookupKey* iLower;
1.426 + TDbLookupKey* iUpper;
1.427 + TUint iInclusion;
1.428 + };
1.429 +
1.430 +class RDbAccessPlan::CDbCompPredicateList : public CArrayFixFlat<CSqlCompPredicate*>
1.431 + {
1.432 +public:
1.433 + enum
1.434 + {
1.435 + EAnd = 0x1,
1.436 + ELess = 0x2,
1.437 + ELessEqual = 0x4,
1.438 + EEqual = 0x8,
1.439 + EGreaterEqual = 0x10,
1.440 + EGreater = 0x20,
1.441 + ECompPred = ELess | ELessEqual | EEqual | EGreaterEqual | EGreater,
1.442 + ENone = 0
1.443 + };
1.444 +public:
1.445 + static CDbCompPredicateList* NewLC( CSqlQuery& aQuery, TDbTextComparison aComparison, const CDbTableDef& aTableDef );
1.446 + CSqlCompPredicate* CompPredicate( TDbColNo aColNo, TUint aType = ECompPred );
1.447 + TUint Type( CSqlSearchCondition::TType aType ) const;
1.448 + inline TBool IsRestriction();
1.449 +private:
1.450 + inline CDbCompPredicateList( const CDbTableDef& aTableDef, TDbTextComparison aComparison );
1.451 + void ConstructL( CSqlSearchCondition& aSeachCondition );
1.452 + TBool IsIndexed( const TDesC& aColumnName );
1.453 +private:
1.454 + enum { EGranularity = 4 };
1.455 +private:
1.456 + const CDbTableDef& iTableDef;
1.457 + TDbTextComparison iComparison;
1.458 + TBool iRestriction;
1.459 + };
1.460 +
1.461 +class CDbTable::TValid
1.462 +/**
1.463 +@internalComponent
1.464 +*/
1.465 + {
1.466 +public:
1.467 + TValid(CDbTable& aTable);
1.468 + TBool Reset();
1.469 +//
1.470 + inline operator TAny*() const;
1.471 + void CheckL() const;
1.472 +//
1.473 + inline RDbTransaction& Transaction() const;
1.474 + inline CDbTable& Table() const;
1.475 +private:
1.476 + CDbTable& iTable;
1.477 + TDbGenerationMark iRollback;
1.478 + };
1.479 +
1.480 +NONSHARABLE_CLASS(CDbTableCursor) : public CDbCursor
1.481 +/**
1.482 +@internalComponent
1.483 +*/
1.484 + {
1.485 +public:
1.486 + static CDbTableCursor* NewL( RDbAccessPlan& aPlan, RDbRowSet::TAccess aAccess );
1.487 +//
1.488 + inline CDbBlobSpace& BlobsL() const;
1.489 + inline void AddSink();
1.490 + inline void ReleaseSink();
1.491 + inline void AddSource();
1.492 + inline void ReleaseSource();
1.493 + void AddBlobSource();
1.494 + void ReleaseBlobSource();
1.495 +private:
1.496 + CDbTableCursor( RDbAccessPlan& aPlan, RDbRowSet::TAccess anAccess );
1.497 + ~CDbTableCursor();
1.498 +//
1.499 + void Reset();
1.500 + TBool EvaluateL();
1.501 + void Evaluate( TRequestStatus& aStatus );
1.502 + TBool Unevaluated();
1.503 +//
1.504 + void SetIndexL( const TDesC* anIndex );
1.505 + TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison );
1.506 + CDbRowConstraint* OpenConstraintL( const TDbQuery& aCriteria );
1.507 + TBool MatchL( CDbRowConstraint& aConstraint );
1.508 +//
1.509 + TInt CountL( RDbRowSet::TAccuracy aAccuracy );
1.510 + TBool AtBeginning();
1.511 + TBool AtEnd();
1.512 + TBool AtRow();
1.513 + TBool GotoL( RDbRowSet::TPosition aPosition );
1.514 + void Bookmark( TDbBookmark::TMark& aMark );
1.515 + void GotoL( const TDbBookmark::TMark& aMark );
1.516 + void GetL();
1.517 + void InsertL( TInsert aClearRow );
1.518 + void UpdateL();
1.519 + void Cancel();
1.520 + void PutL();
1.521 + void DeleteL();
1.522 +//
1.523 + TInt ColumnCount();
1.524 + TDbColType ColumnType( TDbColNo aCol );
1.525 + void ColumnDef( TDbCol& aCol, TDbColNo aColNo );
1.526 +//
1.527 + RDbRow* RowBuffer();
1.528 + TDbColumnC ColumnC( TDbColNo aCol ); // non-writeable row buffer
1.529 + TDbColumn Column( TDbColNo aCol ); // writeable row buffer
1.530 + void SetNullL( TDbColNo aCol );
1.531 + TInt ColumnSize( TDbColNo aCol );
1.532 + MStreamBuf* ColumnSourceL( TDbColNo aCol );
1.533 + MStreamBuf* ColumnSinkL( TDbColNo aCol );
1.534 +//
1.535 + TDbColType Type( TDbColNo aCol ) const;
1.536 + void ReplaceBlobL( TDbColumn& aColumn );
1.537 + inline TBool InUpdate() const;
1.538 + inline RDbTransaction& Transaction();
1.539 + void CheckStateL() const;
1.540 + void CheckReadL() const;
1.541 + void CheckUpdateL() const;
1.542 + void AssertValidRow() const;
1.543 + void AssertNotInUpdate() const;
1.544 + void AssertInUpdate() const;
1.545 + void AssertNoStreams() const;
1.546 +private:
1.547 + enum TState
1.548 + {
1.549 + ERowBeginning,
1.550 + ERowOK,
1.551 + ERowEnd,
1.552 + ERowInvalid,
1.553 + ERowDeletedAtNext,
1.554 + ERowDeletedAtEnd,
1.555 + ERowInLimbo
1.556 + }; // keep these in same order as CDbDataSource::TDelete
1.557 + enum
1.558 + {
1.559 + EUpdatable = 0x01,
1.560 + EReadable = 0x02,
1.561 + ERead = 0x04,
1.562 + EUpdating = 0x08,
1.563 + EInserting = 0x10,
1.564 + EDirty = 0x20,
1.565 + EWriteBuf = 0x40
1.566 + };
1.567 + enum { EMaxReadBuf = 255 };
1.568 + class HColumns;
1.569 + class CConstraint;
1.570 + class HMemBuf;
1.571 + class HWriteBuf;
1.572 + class HReadBuf;
1.573 + class HHeapBuf;
1.574 +private:
1.575 + TUint8 iState;
1.576 + TUint8 iFlags;
1.577 + TUint8 iReadBuf;
1.578 + CDbTable::TValid iValid;
1.579 + CDbDataSource* iDataSource;
1.580 + TDbRecordId iRecord;
1.581 + HColumns* iColumns;
1.582 + };
1.583 +
1.584 +
1.585 +NONSHARABLE_CLASS(CDbTableCursor::HWriteBuf) : public TDesBuf
1.586 + {
1.587 +public:
1.588 + static HWriteBuf* NewL( CDbTableCursor& aCursor, const TDbColumn& aColumn, TDbColType aType );
1.589 +private:
1.590 + inline HWriteBuf( CDbTableCursor& aCursor, const TDbColumn& aColumn, TDbColType aType );
1.591 + virtual inline ~HWriteBuf();
1.592 + void ConstructL();
1.593 +//
1.594 + inline TBool IsBinary() const;
1.595 + void FlipL();
1.596 +// for MStreamBuf
1.597 + void DoRelease();
1.598 + void DoSynchL();
1.599 + TInt DoReadL( TAny* aPtr, TInt aMaxLength );
1.600 + TStreamTransfer DoReadL( MStreamInput& aInput, TStreamTransfer aTransfer );
1.601 + void DoWriteL( const TAny* aPtr, TInt aLength );
1.602 + TStreamTransfer DoWriteL( MStreamOutput& aOutput, TStreamTransfer aTransfer );
1.603 + TStreamPos DoSeekL( TMark aMark, TStreamLocation aLocation, TInt aOffset );
1.604 +private:
1.605 + CDbTableCursor& iCursor;
1.606 + TDbColumn iColumn;
1.607 + TDbColType iType;
1.608 + TDbBlob* iBlob;
1.609 + TPtr8 iInlineBuf;
1.610 + TDbBlobId iBlobId;
1.611 + TInt iSize;
1.612 + MStreamBuf* iOverflowBuf;
1.613 + };
1.614 +
1.615 +NONSHARABLE_CLASS(CDbTableCursor::HMemBuf) : public TMemBuf
1.616 + {
1.617 +public:
1.618 + static HMemBuf* NewL( CDbTableCursor& aCursor, const TDesC8& aDes );
1.619 +protected:
1.620 + HMemBuf( CDbTableCursor& aCursor );
1.621 + virtual inline ~HMemBuf();
1.622 +private:
1.623 + void DoRelease();
1.624 +private:
1.625 + CDbTableCursor& iCursor;
1.626 + };
1.627 +
1.628 +class CDbTableCursor::HHeapBuf : public CDbTableCursor::HMemBuf
1.629 + {
1.630 +public:
1.631 + enum { EMaxBlobBuffer = 0x600 }; // 1.5K to match KDbsStreamBufSize
1.632 +public:
1.633 + static HHeapBuf* NewL( CDbTableCursor& aCursor, const TDbBlob& aBlob, TDbColType aType );
1.634 +private:
1.635 + inline HHeapBuf( CDbTableCursor& aCursor );
1.636 +private:
1.637 + TUint8 iBuf[1];
1.638 + };
1.639 +
1.640 +NONSHARABLE_CLASS(CDbTableCursor::HReadBuf) : public MStreamBuf
1.641 + {
1.642 +public:
1.643 + static HReadBuf* NewLC( CDbTableCursor& aCursor );
1.644 + inline void Set( MStreamBuf* aHost );
1.645 +private:
1.646 + inline HReadBuf( CDbTableCursor& aCursor );
1.647 + virtual inline ~HReadBuf();
1.648 +// from MStreamBuf
1.649 + void DoRelease();
1.650 + TInt DoReadL( TAny* aPtr, TInt aMaxLength );
1.651 + TStreamTransfer DoReadL( MStreamInput& aInput, TStreamTransfer aTransfer );
1.652 + TStreamPos DoSeekL( TMark aMark, TStreamLocation aLocation, TInt aOffset );
1.653 +private:
1.654 + CDbTableCursor& iCursor;
1.655 + MStreamBuf* iHost;
1.656 + };
1.657 +
1.658 +NONSHARABLE_CLASS(CDbTableDatabase::CIncremental) : public CDbSyncIncremental
1.659 +/**
1.660 +@internalComponent
1.661 +*/
1.662 + {
1.663 +protected:
1.664 + enum { ELastStep = 1 };
1.665 + enum TState { ERunning = 0, EFailed, ECommitted };
1.666 +public:
1.667 + inline void Construct( CStepper* aStepper );
1.668 +protected:
1.669 + CIncremental( RDbTransaction& aTransaction );
1.670 + ~CIncremental();
1.671 + inline RDbTransaction& Transaction();
1.672 + inline CDbTableDatabase& Database();
1.673 + inline TBool IsCommitted() const;
1.674 +private:
1.675 + TBool NextL( TInt& aStep );
1.676 + virtual TInt DoNextL( TInt aStep );
1.677 + virtual void DoLastL() =0;
1.678 +private:
1.679 + RDbTransaction& iTransaction;
1.680 + CStepper* iStepper;
1.681 + TState iState;
1.682 + };
1.683 +
1.684 +NONSHARABLE_CLASS(CDbTableDatabase::CIncrementalDDL) : public CDbTableDatabase::CIncremental
1.685 +/**
1.686 +@internalComponent
1.687 +*/
1.688 + {
1.689 +protected:
1.690 + CIncrementalDDL( RDbTransaction& aTransaction );
1.691 + ~CIncrementalDDL();
1.692 +// from CIncremental
1.693 + void DoLastL();
1.694 + };
1.695 +
1.696 +class CDbTableDatabase::CCreateIndex : public CDbTableDatabase::CIncrementalDDL
1.697 +/**
1.698 +@internalComponent
1.699 +*/
1.700 + {
1.701 +public:
1.702 + static CCreateIndex* NewLC( RDbTransaction& aTransaction );
1.703 + TInt ConstructL( const CDbTableDef& aTable, const CDbTableIndexDef& anIndex );
1.704 +private:
1.705 + inline CCreateIndex( RDbTransaction& aTransaction );
1.706 + };
1.707 +
1.708 +NONSHARABLE_CLASS(CDbTableDatabase::CDropIndex) : public CDbTableDatabase::CIncrementalDDL
1.709 +/**
1.710 +@internalComponent
1.711 +*/
1.712 + {
1.713 +public:
1.714 + static CDropIndex* NewL( RDbTransaction& aTransaction, const CDbTableDef& aTable, CDbTableIndexDef* anIndex, TInt& aStep );
1.715 + ~CDropIndex();
1.716 +private:
1.717 + inline CDropIndex( RDbTransaction& aTransaction );
1.718 +private:
1.719 + CDbTableIndexDef* iDef;
1.720 + };
1.721 +
1.722 +NONSHARABLE_CLASS(CDbTableDatabase::CDropTable) : public CDbTableDatabase::CIncrementalDDL
1.723 +/**
1.724 +@internalComponent
1.725 +*/
1.726 + {
1.727 +public:
1.728 + static CDropTable* NewL( RDbTransaction& aTransaction, CDbTableDef* aTable, TInt& aStep );
1.729 + ~CDropTable();
1.730 +private:
1.731 + inline CDropTable( RDbTransaction& aTransaction );
1.732 +private:
1.733 + CDbTableDef* iDef;
1.734 + };
1.735 +
1.736 +NONSHARABLE_CLASS(CDbTableDatabase::CAlterTable) : public CDbTableDatabase::CIncrementalDDL
1.737 +/**
1.738 +@internalComponent
1.739 +*/
1.740 + {
1.741 +public:
1.742 + static CAlterTable* NewL( RDbTransaction& aTransaction, CDbTableDef& aTable, const CDbColSet& aNewDef, TInt& aStep );
1.743 + ~CAlterTable();
1.744 +private:
1.745 + inline CAlterTable( RDbTransaction& aTransaction, CDbTableDef& aDef );
1.746 + void ConstructL( const CDbColSet& aNewDef, TInt& aStep );
1.747 +// from CIncremental
1.748 + void DoLastL();
1.749 +private:
1.750 + CDbTableDef& iDef;
1.751 + HDbColumnSet* iNewSet;
1.752 + };
1.753 +
1.754 +NONSHARABLE_CLASS(CDbTableDatabase::CUtility) : public CDbTableDatabase::CIncremental
1.755 +/**
1.756 +@internalComponent
1.757 +*/
1.758 + {
1.759 +public:
1.760 + static CUtility* NewL( RDbTransaction& aTransaction, CDbDatabase::TUtility aType, TInt& aStep );
1.761 + ~CUtility();
1.762 +private:
1.763 + inline CUtility( RDbTransaction& aTransaction, CDbDatabase::TUtility aType );
1.764 +private:
1.765 + void DoLastL();
1.766 + };
1.767 +
1.768 +NONSHARABLE_CLASS(CDbIncrementalDML) : public CDbSyncIncremental
1.769 +/**
1.770 +@internalComponent
1.771 +*/
1.772 + {
1.773 +public:
1.774 + static CDbIncrementalDML* NewL( CSqlModifyStatement& aStatement, CDbTableDatabase& aDatabase, TDbTextComparison aComparison );
1.775 + ~CDbIncrementalDML();
1.776 +private:
1.777 + enum TState { EInitialising = 0, EEvaluating, EUpdating, EDeleting, ECommitted, EFailed };
1.778 +private:
1.779 + inline CDbIncrementalDML( RDbAccessPlan& aPlan );
1.780 + inline RDbTransaction& Transaction();
1.781 + inline TBool IsUpdate() const;
1.782 + inline void SetState( TState aState );
1.783 +// from CDbSyncIncremental
1.784 + TBool NextL( TInt& aRows );
1.785 +private:
1.786 + TState iState;
1.787 + CDbTable& iTable;
1.788 + CDbDataSource* iSource;
1.789 + TDbRecordId iRecord;
1.790 + CSqlValues* iValues;
1.791 + };
1.792 +
1.793 +NONSHARABLE_CLASS(CDbTableDatabase::CInterface) : public CDbDatabase
1.794 +/**
1.795 +the interface implementation class for the Table database framework
1.796 +@internalComponent
1.797 +*/
1.798 + {
1.799 +public:
1.800 + CInterface(CDbTableDatabase& aDatabase);
1.801 +private:
1.802 + ~CInterface();
1.803 + inline CDbTableDatabase& Database();
1.804 + void PrepareDDLL();
1.805 +// from the interface framework
1.806 + TInt Destroy();
1.807 + TInt Begin();
1.808 + TInt Commit();
1.809 + void Rollback();
1.810 + TInt Property( TProperty aProperty );
1.811 + void CreateTableL( const TDesC& aName, const CDbColSet& aColSet, const CDbKey* aPrimaryKey );
1.812 + void TablesL( CDbTableNames& aNames );
1.813 + void ColumnsL( CDbColSet& aColSet, const TDesC& aName );
1.814 + void IndexesL( CDbIndexNames& aNames, const TDesC& aTable );
1.815 + void KeysL( CDbKey& aKey, const TDesC& aName, const TDesC& aTable );
1.816 + CDbNotifier* OpenNotifierL();
1.817 + CDbCursor* PrepareViewL( const TDbQuery& aQuery, const TDbWindow& aWindow, RDbRowSet::TAccess anAccess );
1.818 + CDbCursor* OpenTableL( const TDesC& aName, RDbRowSet::TAccess anAccess );
1.819 + CDbIncremental* OpenDropTableL( const TDesC& aTable, TInt& aStep );
1.820 + CDbIncremental* OpenAlterTableL( const TDesC& aTable, const CDbColSet& aNewDef, TInt& aStep );
1.821 + CDbIncremental* OpenCreateIndexL( const TDesC& aName, const TDesC& aTable, const CDbKey& aKey, TInt& aStep );
1.822 + CDbIncremental* OpenDropIndexL( const TDesC& aName, const TDesC& aTable, TInt& aStep );
1.823 + CDbIncremental* OpenUtilityL( CDbDatabase::TUtility aType, TInt& aStep );
1.824 + CDbIncremental* OpenExecuteL( const TDesC& aSql, TDbTextComparison aComparison, TInt& aInit );
1.825 +private:
1.826 + CDbTableDatabase& iDatabase;
1.827 + };
1.828 +
1.829 +NONSHARABLE_CLASS(CDbTableDatabase::CSource) : public CDbSource
1.830 +/**
1.831 +@internalComponent
1.832 +*/
1.833 + {
1.834 +public:
1.835 + CSource( CDbTableDatabase& aDatabase );
1.836 +private:
1.837 + ~CSource();
1.838 + inline CDbTableDatabase& Database();
1.839 + // from the framework
1.840 + CDbDatabase* AuthenticateL();
1.841 + CDbNotifier* OpenNotifierL();
1.842 +private:
1.843 + CDbTableDatabase& iDatabase;
1.844 + };
1.845 +
1.846 +#include "UT_STD.INL"