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 <u32std.h>
sl@0: #include <d32dbms.h>
sl@0: #include "D32REC.H"
sl@0: #include "D32TABLE.H"
sl@0: #include "D32SQL.H"
sl@0: #include <s32mem.h>
sl@0: 
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: enum TTablePanic
sl@0: 	{
sl@0: 	EDbInvalidColumn,
sl@0: 	EDbWrongType,
sl@0: 	EDbInUpdate,
sl@0: 	EDbNotInUpdate,
sl@0: 	EDbInvalidRow,
sl@0: 	EDbRowNotRead,
sl@0: 	EDbReadOnly,
sl@0: 	EDbTableOpen,
sl@0: 	EDbNotEvaluated,
sl@0: 	EDbStreamOpen,
sl@0: 	EDbRowSetConstraintMismatch,
sl@0: 	EDbBeginNestedTransaction,
sl@0: 	EDbUpdatesPendingOnCommit,
sl@0: 	EDbUpdatesPendingOnRollback,
sl@0: 	EDbNoCurrentTransaction,
sl@0: 	EDbStreamsPendingOnCommit,
sl@0: 	EDbStreamsPendingOnRollback,
sl@0: 	EDbInvalidBookmark
sl@0: 	};
sl@0: 
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: GLREF_C void Panic( TTablePanic aPanic );
sl@0: 
sl@0: class Validate
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static void NameL( const TDesC& aName );
sl@0: 	static void ColSetL( const CDbColSet& aColSet );
sl@0: 	static void KeyL( const CDbKey& aKey, const HDbColumnSet& aColumns );
sl@0: private:
sl@0: 	static void UniqueNameL( TDesC const** aNames, TInt aCount, const TDesC& aName );
sl@0: 	};
sl@0: 
sl@0: class CDbDataSource : public CBase
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	enum TGoto { ESuccess, ENoRow, EExhausted, ESynchFailure };
sl@0: 	enum TSynch { ESynch, ENoSynch };
sl@0: 	enum TDelete { EDeletedAtNext, EDeletedAtEnd, EDeletedInLimbo };
sl@0: 	enum TWrite { EReplace, EAppend };
sl@0: protected:
sl@0: 	enum { EWorkToIterate = 1, EWorkToRead = 16 };
sl@0: public:
sl@0: 	virtual RDbRow* RowBuffer() = 0;
sl@0: 	virtual TDbColumn Column( TDbColNo aColNo ) = 0;
sl@0: 	virtual void Reset() = 0;
sl@0: 	virtual TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow ) = 0;
sl@0: 	virtual TBool Unevaluated() = 0;
sl@0: 	virtual TInt CountL() = 0;
sl@0: 	virtual TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId ) = 0;
sl@0: 	TGoto GotoL( TDbPosition aPosition, TDbRecordId& aRecordId );
sl@0: 	virtual TBool GotoL( TDbRecordId aRecordId ) = 0;
sl@0: 	virtual void ReadRowL( TDbRecordId aRecordId ) = 0;
sl@0: 	virtual void NewRowL( TDbRecordId aCopyRecord ) = 0;
sl@0: 	virtual void PrepareToWriteRowL( TWrite aWrite ) = 0;
sl@0: 	virtual TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch = ESynch ) = 0;
sl@0: 	virtual TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch = ESynch ) = 0;
sl@0: 	virtual TInt ColumnCount() const = 0;
sl@0: 	virtual const TDbColumnDef& ColumnDef( TDbColNo aCol ) const = 0;
sl@0: //
sl@0: 	virtual void SetIndexL( const TDesC* anIndex ) = 0;
sl@0: 	virtual TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison, TDbRecordId& aRecordId ) = 0;
sl@0: 	virtual CSqlSearchCondition* ParseConstraintLC( const TDesC& aCondition ) = 0;
sl@0: protected:
sl@0: 	CDbDataSource() {};
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableSource) : public CDbDataSource
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	~CDbTableSource();
sl@0: 	CDbTableSource();
sl@0: 	void Construct( CDbTable* aTable );
sl@0: 	inline void SetIterator( CDbRecordIter* anIter );
sl@0: 	void ReverseIteratorL();
sl@0: 	inline const RDbTableRow& Row();
sl@0: 	inline CDbTable& Table();
sl@0: //
sl@0: 	RDbRow* RowBuffer();
sl@0: 	TDbColumn Column( TDbColNo aColNo );
sl@0: 	void Reset();
sl@0: 	TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow );
sl@0: 	TBool Unevaluated();
sl@0: 	TInt CountL();
sl@0: 	TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
sl@0: 	TBool GotoL( TDbRecordId aRecordId );
sl@0: 	void NewRowL( TDbRecordId aCopyRecord );
sl@0: 	void PrepareToWriteRowL( TWrite aWrite );
sl@0: 	TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch );
sl@0: 	void ReadRowL( TDbRecordId aRecordId );
sl@0: 	TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
sl@0: 	TInt ColumnCount() const;
sl@0: 	const TDbColumnDef& ColumnDef( TDbColNo aCol ) const;
sl@0: 	void SetIndexL( const TDesC* anIndex );
sl@0: 	TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison, TDbRecordId& aRecordId );
sl@0: 	CSqlSearchCondition* ParseConstraintLC( const TDesC& aCondition );
sl@0: private:
sl@0: 	TBool SynchL( TDbRecordId aRecordId );
sl@0: 	void OpenIteratorL();
sl@0: private:
sl@0: 	CDbRecordIter* iIter;
sl@0: 	TDbGenerationMark iIterMark;
sl@0: 	RDbTableRow iRow;
sl@0: 	TBool iReset;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbDataStage) : public CDbDataSource
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	~CDbDataStage();
sl@0: 	inline void SetSource( CDbDataSource* aSource );
sl@0: protected:
sl@0: 	CDbDataStage() {};
sl@0: 	inline CDbDataSource& Source();
sl@0: 	inline const CDbDataSource& Source() const;
sl@0: 	RDbRow* RowBuffer();
sl@0: 	TDbColumn Column( TDbColNo aColNo );
sl@0: 	void Reset();
sl@0: 	TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow );
sl@0: 	TBool Unevaluated();
sl@0: 	TInt CountL();
sl@0: 	TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
sl@0: 	TBool GotoL( TDbRecordId aRecordId );
sl@0: 	void ReadRowL( TDbRecordId aRecordId );
sl@0: 	void NewRowL( TDbRecordId aCopyRecord );
sl@0: 	void PrepareToWriteRowL( TWrite aWrite );
sl@0: 	TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch );
sl@0: 	TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
sl@0: 	TInt ColumnCount() const;
sl@0: 	const TDbColumnDef& ColumnDef( TDbColNo aCol ) const;
sl@0: 	void SetIndexL( const TDesC* anIndex );
sl@0: 	TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison, TDbRecordId& aRecordId );
sl@0: 	CSqlSearchCondition* ParseConstraintLC( const TDesC& aCondition );
sl@0: private:
sl@0: 	CDbDataSource* iSource;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbRestrictStage) : public CDbDataStage
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	CDbRestrictStage( TDbTextComparison aComparison );
sl@0: 	~CDbRestrictStage();
sl@0: 	inline void SetRestriction( CSqlSearchCondition* aRestriction );
sl@0: private:
sl@0: 	inline CSqlSearchCondition& Restriction() const;
sl@0: 	TBool FilterRowL( TDbRecordId aRecordId );
sl@0: //
sl@0: 	TInt CountL();
sl@0: 	TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
sl@0: 	TBool GotoL( TDbRecordId aRecordId );
sl@0: 	TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
sl@0: private:
sl@0: 	CSqlSearchCondition* iRestriction;
sl@0: 	const TTextOps& iTextOp;
sl@0: 	};
sl@0: 
sl@0: class HDbColumnMap;
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbProjectStage) : public CDbDataStage
sl@0: /**
sl@0: implement restricted column selection
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	CDbProjectStage();
sl@0: 	~CDbProjectStage();
sl@0: 	void ConstructL( const RSqlColumnList& aSelect, const HDbColumnSet& aColumns );
sl@0: private:
sl@0: 	RDbRow* RowBuffer();
sl@0: 	TDbColumn Column( TDbColNo aColNo );
sl@0: 	TInt ColumnCount() const;
sl@0: 	const TDbColumnDef& ColumnDef( TDbColNo aCol ) const;
sl@0: private:
sl@0: 	HDbColumnMap* iMap;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbBasicWindowStage) : public CDbDataStage
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: private:
sl@0: 	enum { EWindowArrayGranularity = 32 };	// 128 byte segments
sl@0: public:
sl@0: 	CDbBasicWindowStage( const TDbWindow& aWindow );
sl@0: protected:
sl@0: // from CDbDataStage
sl@0: 	void Reset();
sl@0: 	TBool EvaluateL( TInt& aWork, TDbRecordId& aRecordId, TBool& aAtRow );
sl@0: 	TInt CountL();
sl@0: 	TGoto GotoL( TInt& aWork, TDbPosition aPosition, TDbRecordId& aRecordId );
sl@0: 	TBool GotoL( TDbRecordId aRecordId );
sl@0: 	void ReadRowL( TDbRecordId aRecordId );
sl@0: 	TDbRecordId WriteRowL( TWrite aWrite, TSynch aSynch );
sl@0: 	TDelete DeleteRowL( TDbRecordId& aRecordId, TSynch aSynch );
sl@0: private:
sl@0: 	TBool GetRecord( TDbRecordId& aRecordId );
sl@0: 	TInt Find( TDbRecordId aRecordId, TInt& aPos );
sl@0: 	virtual TBool DoEvaluateL( TInt& aWork ) = 0;
sl@0: protected:
sl@0: 	TDbWindow iWindow;		// the window shape
sl@0: 	CArrayFixSeg<TDbRecordId> iRecords;	// the window itself
sl@0: 	TInt iPos;				// the iterator over the window
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbWindowStage) : public CDbBasicWindowStage
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: private:
sl@0: 	enum TView { EBeginning, EMiddle, EEnd, EAll };
sl@0: 	enum TIterPos { EAtBeginning, EAtEnd };
sl@0: public:
sl@0: 	CDbWindowStage( const TDbWindow& aWindow );
sl@0: protected:
sl@0: 	void Reset();
sl@0: 	TBool DoEvaluateL( TInt& aWork );
sl@0: 	TBool Unevaluated();
sl@0: private:
sl@0: 	TInt WhatToEvaluate();
sl@0: 	TDbPosition ResetIterToBeginningL();
sl@0: 	TDbPosition ResetIterToEndL();
sl@0: 	TDbPosition SetIteratorL( TInt anEval );
sl@0: 	void ExtendAtBeginningL( TInt aRecords, TDbPosition aFirst, TInt& aWork );
sl@0: 	void ExtendAtEndL( TInt aRecords, TDbPosition aFirst, TInt& aWork );
sl@0: private:
sl@0: 	TIterPos iIterPos;		// where the underlying iterator is in our window
sl@0: 	TView iView;			// what part of the underlying set we see through the window
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbReorderWindowStage) : public CDbBasicWindowStage
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: private:
sl@0: 	enum TState { EReset, EEvaluate, EComplete, EFailed };
sl@0: 	enum { EGranularity = 32 };
sl@0: public:
sl@0: 	CDbReorderWindowStage();
sl@0: 	~CDbReorderWindowStage();
sl@0: protected:
sl@0: 	void Reset();
sl@0: 	TBool DoEvaluateL( TInt& aWork );
sl@0: 	TBool Unevaluated();
sl@0: private:
sl@0: 	TBool ReadL( TInt& aWork, TDbPosition aNext );
sl@0: private:
sl@0: 	TState iState;
sl@0: 	RArray<TUint> iRows;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbOrderByStage) : public CDbBasicWindowStage
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: private:
sl@0: 	class HOrdering;
sl@0: 	class CKeys;
sl@0: 	enum TState { EReset, EEvaluate, ESort, EAdd, EComplete, EFailed };
sl@0: public:
sl@0: 	CDbOrderByStage( const RDbTableRow& aRow );
sl@0: 	~CDbOrderByStage();
sl@0: 	void ConstructL( const CDbKey& aOrderBy );
sl@0: protected:
sl@0: 	void Reset();
sl@0: 	TBool DoEvaluateL( TInt& aWork );
sl@0: 	TBool Unevaluated();
sl@0: private:
sl@0: 	inline const RDbTableRow& Row();
sl@0: 	inline CKeys& Keys();
sl@0: 	inline const HOrdering& Order();
sl@0: //
sl@0: 	TBool ReadL( TInt& aWork, TDbPosition aNext );
sl@0: private:
sl@0: 	const RDbTableRow& iRow;
sl@0: 	TState iState;
sl@0: 	HOrdering* iOrder;
sl@0: 	CKeys* iKeys;
sl@0: 	};
sl@0: 
sl@0: class RDbAccessPlan
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	inline RDbAccessPlan( CSqlQuery* aQuery, TDbTextComparison aComparison );
sl@0: 	inline RDbAccessPlan();
sl@0: 	void BuildLC( CDbTableDatabase& aDatabase, RDbRowSet::TAccess aAccess, const TDbWindow& aWindow );
sl@0: 	void BuildLC( CDbTableDatabase& aDatabase, const TDesC& aTable, RDbRowSet::TAccess aAccess );
sl@0: 	inline CDbTable& Table();
sl@0: 	inline CDbDataSource& Source();
sl@0: 	inline CDbDataSource* Adopt();
sl@0: private:
sl@0: 	class TPlan
sl@0: 		{
sl@0: 	public:
sl@0: 		enum 
sl@0: 			{
sl@0: 			EOrder = 0x1, ERestrict = 0x2, EReorder = 0x4,
sl@0: 			EIndex = 0x8, EBounded = 0x10,
sl@0: 			EWindow = 0x20, EReverse = 0x40,
sl@0: 			EMask = 0x1f
sl@0: 			};
sl@0: 		enum TType 
sl@0: 			{
sl@0: 			EPlanA = 0, EPlanB = 0, EPlanC = 0, EPlanD = 0, EPlanEF = 1, EPlanGH = 7, EPlanIJ = 2,
sl@0: 			EPlanKL = 5, EPlanMN = 4, EPlanOP = 3, EPlanQR = 6, EPlanST = 8
sl@0: 			};
sl@0: 	public:
sl@0: 		inline TPlan();
sl@0: 		inline TBool operator!=( const TPlan& aPlan ) const;
sl@0: 		TType Type() const;
sl@0: 		static TInt OrderByPlan( const TPlan& aLeft, const TPlan& aRight );
sl@0: 	public:
sl@0: 		TUint iFlags;
sl@0: 		const CDbTableIndexDef* iIndex;
sl@0: 		CSqlCompPredicate* iLower;
sl@0: 		CSqlCompPredicate* iUpper;		
sl@0: 		};	
sl@0: private:
sl@0: 	CDbTableSource* TableLC( CDbTableDatabase& aDatabase, const TDesC& aTable );
sl@0: 	void Insert( CDbDataStage* aStage );
sl@0: 	CDbRecordIter* IteratorL( const TPlan& aPlan );
sl@0: 	CDbRecordIter* BoundedIteratorL( const TPlan& aPlan );
sl@0: 	void RestrictionL();
sl@0: 	void OrderByL( const RDbTableRow& aRowBuf );
sl@0: 	void ProjectionL();
sl@0: 	void WindowL( const TPlan& aPlan, const TDbWindow& aWindow );
sl@0: 	static void Cleanup( TAny* aPtr );
sl@0: 	TBool IsBoundedIteratorL( TPlan& aPlan, const CDbTableIndexDef* aIndex );
sl@0: 	TBool IsIndexIteratorL( TPlan& aPlan, const CDbTableIndexDef* aIndex );
sl@0: 	void EvaluateWindowStage( TPlan& aPlan );
sl@0: 	void EvaluateReorderStage( TPlan& aPlan, const CDbTableIndexDef* aIndex );
sl@0: 	void EvaluatePlansL();
sl@0: 	void ChoosePlanL( TPlan& aPlan );
sl@0: 	void PrepareQueryL( CDbTableSource* aSource );
sl@0: 	TInt GetTightestRestrictionL( TPlan& aPlan, TPlan::TType aType );
sl@0: 	TInt GetSmallestKeySize( TPlan& aPlan, TPlan::TType aType );
sl@0: 	TInt IndexSpanL( const TPlan& aPlan );
sl@0: 	void ReducePlans();
sl@0: 	void CreateTableIteratorPlan( TPlan& aPlan );
sl@0: 	TUint FindMatchL( const CDbTableIndexDef* aIndex );
sl@0: 	TBool TextKeyL( const CDbKey& anOrder );
sl@0: private:
sl@0: 	enum { EGranularity = 4 };
sl@0: 	enum { EMatch = 0x1, EReverse = 0x2, ETruncated = 0x4 };
sl@0: 	//
sl@0: 	class TBounds;
sl@0: 	class CDbCompPredicateList;
sl@0: private:
sl@0: 	RArray<TPlan> iPlans;
sl@0: 	CDbDataSource* iSource;
sl@0: 	CDbTable* iTable;
sl@0: 	TDbTextComparison iComparison;
sl@0: 	CSqlQuery* iQuery;
sl@0: 	TBool iWindow;
sl@0: 	RDbRowSet::TAccess iAccess;
sl@0: 	};
sl@0: 
sl@0: class RDbAccessPlan::TBounds
sl@0: 	{
sl@0: public:
sl@0: 	TBounds( const TPlan& aPlan );
sl@0: private:
sl@0: 	void GetLookupKey( const CSqlCompPredicate& aCompPredicate, TDbLookupKey& aLookup );
sl@0: 	void SetLowerBounds();
sl@0: 	void SetUpperBounds();
sl@0: public:
sl@0: 	CSqlCompPredicate* iLowerPred;
sl@0: 	CSqlCompPredicate* iUpperPred;		
sl@0: 	TDbLookupKey iLowerKey;
sl@0: 	TDbLookupKey iUpperKey;
sl@0: 	TDbLookupKey* iLower;
sl@0: 	TDbLookupKey* iUpper;
sl@0: 	TUint iInclusion;
sl@0: 	};
sl@0: 
sl@0: class RDbAccessPlan::CDbCompPredicateList : public CArrayFixFlat<CSqlCompPredicate*>
sl@0: 	{
sl@0: public:
sl@0: 	enum
sl@0: 		{
sl@0: 		EAnd = 0x1,
sl@0: 		ELess = 0x2,
sl@0: 		ELessEqual = 0x4,
sl@0: 		EEqual = 0x8,
sl@0: 		EGreaterEqual = 0x10,
sl@0: 		EGreater = 0x20,
sl@0: 		ECompPred = ELess | ELessEqual | EEqual | EGreaterEqual | EGreater,
sl@0: 		ENone = 0
sl@0: 		};
sl@0: public:
sl@0: 	static CDbCompPredicateList* NewLC( CSqlQuery& aQuery, TDbTextComparison aComparison, const CDbTableDef& aTableDef );
sl@0: 	CSqlCompPredicate* CompPredicate( TDbColNo aColNo, TUint aType = ECompPred );
sl@0: 	TUint Type( CSqlSearchCondition::TType aType ) const;
sl@0: 	inline TBool IsRestriction();
sl@0: private:
sl@0: 	inline CDbCompPredicateList( const CDbTableDef& aTableDef, TDbTextComparison aComparison );
sl@0: 	void ConstructL( CSqlSearchCondition& aSeachCondition );
sl@0: 	TBool IsIndexed( const TDesC& aColumnName );
sl@0: private:
sl@0: 	enum { EGranularity = 4 };
sl@0: private:
sl@0: 	const CDbTableDef& iTableDef;
sl@0: 	TDbTextComparison iComparison;
sl@0: 	TBool iRestriction;
sl@0: 	};
sl@0: 
sl@0: class CDbTable::TValid
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	TValid(CDbTable& aTable);
sl@0: 	TBool Reset();
sl@0: //
sl@0: 	inline operator TAny*() const;
sl@0: 	void CheckL() const;
sl@0: //
sl@0: 	inline RDbTransaction& Transaction() const;
sl@0: 	inline CDbTable& Table() const;
sl@0: private:
sl@0: 	CDbTable& iTable;
sl@0: 	TDbGenerationMark iRollback;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableCursor) : public CDbCursor
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static CDbTableCursor* NewL( RDbAccessPlan& aPlan, RDbRowSet::TAccess aAccess );
sl@0: //
sl@0: 	inline CDbBlobSpace& BlobsL() const;
sl@0: 	inline void AddSink();
sl@0: 	inline void ReleaseSink();
sl@0: 	inline void AddSource();
sl@0: 	inline void ReleaseSource();
sl@0: 	void AddBlobSource();
sl@0: 	void ReleaseBlobSource();
sl@0: private:
sl@0: 	CDbTableCursor( RDbAccessPlan& aPlan, RDbRowSet::TAccess anAccess );
sl@0: 	~CDbTableCursor();
sl@0: //
sl@0: 	void Reset();
sl@0: 	TBool EvaluateL();
sl@0: //	void Evaluate( TRequestStatus& aStatus );
sl@0: 	TBool Unevaluated();
sl@0: //
sl@0: 	void SetIndexL( const TDesC* anIndex );
sl@0: 	TBool SeekL( const TDbLookupKey& aKey, RDbTable::TComparison aComparison );
sl@0: 	CDbRowConstraint* OpenConstraintL( const TDbQuery& aCriteria );
sl@0: 	TBool MatchL( CDbRowConstraint& aConstraint );
sl@0: //
sl@0: 	TInt CountL( RDbRowSet::TAccuracy aAccuracy );
sl@0: 	TBool AtBeginning();
sl@0: 	TBool AtEnd();
sl@0: 	TBool AtRow();
sl@0: 	TBool GotoL( RDbRowSet::TPosition aPosition );
sl@0: 	void Bookmark( TDbBookmark::TMark& aMark );
sl@0: 	void GotoL( const TDbBookmark::TMark& aMark );
sl@0: 	void GetL();
sl@0: 	void InsertL( TInsert aClearRow );
sl@0: 	void UpdateL();
sl@0: 	void Cancel();
sl@0: 	void PutL();
sl@0: 	void DeleteL();
sl@0: //
sl@0: 	TInt ColumnCount();
sl@0: 	TDbColType ColumnType( TDbColNo aCol );
sl@0: 	void ColumnDef( TDbCol& aCol, TDbColNo aColNo );
sl@0: //
sl@0: 	RDbRow* RowBuffer();
sl@0: 	TDbColumnC ColumnC( TDbColNo aCol );	// non-writeable row buffer
sl@0: 	TDbColumn Column( TDbColNo aCol );		// writeable row buffer
sl@0: 	void SetNullL( TDbColNo aCol );
sl@0: 	TInt ColumnSize( TDbColNo aCol );
sl@0: 	MStreamBuf* ColumnSourceL( TDbColNo aCol );
sl@0: 	MStreamBuf* ColumnSinkL( TDbColNo aCol );
sl@0: //
sl@0: 	TDbColType Type( TDbColNo aCol ) const;
sl@0: 	void ReplaceBlobL( TDbColumn& aColumn );
sl@0: 	inline TBool InUpdate() const;
sl@0: 	inline RDbTransaction& Transaction();
sl@0: 	void CheckStateL() const;
sl@0: 	void CheckReadL() const;
sl@0: 	void CheckUpdateL() const;
sl@0: 	void AssertValidRow() const;
sl@0: 	void AssertNotInUpdate() const;
sl@0: 	void AssertInUpdate() const;
sl@0: 	void AssertNoStreams() const;
sl@0: private:
sl@0: 	enum TState
sl@0: 		{
sl@0: 		ERowBeginning,
sl@0: 		ERowOK,
sl@0: 		ERowEnd,
sl@0: 		ERowInvalid,
sl@0: 		ERowDeletedAtNext,
sl@0: 		ERowDeletedAtEnd,
sl@0: 		ERowInLimbo
sl@0: 		};	// keep these in same order as CDbDataSource::TDelete
sl@0: 	enum
sl@0: 		{
sl@0: 		EUpdatable = 0x01,
sl@0: 		EReadable = 0x02,
sl@0: 		ERead = 0x04,
sl@0: 		EUpdating = 0x08,
sl@0: 		EInserting = 0x10,
sl@0: 		EDirty = 0x20,
sl@0: 		EWriteBuf = 0x40
sl@0: 		};
sl@0: 	enum { EMaxReadBuf = 255 };
sl@0: 	class HColumns;
sl@0: 	class CConstraint;
sl@0: 	class HMemBuf;
sl@0: 	class HWriteBuf;
sl@0: 	class HReadBuf;
sl@0: 	class HHeapBuf;
sl@0: private:
sl@0: 	TUint8 iState;
sl@0: 	TUint8 iFlags;
sl@0: 	TUint8 iReadBuf;
sl@0: 	CDbTable::TValid iValid;
sl@0: 	CDbDataSource* iDataSource;
sl@0: 	TDbRecordId iRecord;
sl@0: 	HColumns* iColumns;
sl@0: 	};
sl@0: 
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableCursor::HWriteBuf) : public TDesBuf
sl@0: 	{
sl@0: public:
sl@0: 	static HWriteBuf* NewL( CDbTableCursor& aCursor, const TDbColumn& aColumn, TDbColType aType );
sl@0: private:
sl@0: 	inline HWriteBuf( CDbTableCursor& aCursor, const TDbColumn& aColumn, TDbColType aType );
sl@0: 	virtual inline ~HWriteBuf();
sl@0: 	void ConstructL();
sl@0: //
sl@0: 	inline TBool IsBinary() const;
sl@0: 	void FlipL();
sl@0: // for MStreamBuf
sl@0: 	void DoRelease();
sl@0: 	void DoSynchL();
sl@0: 	TInt DoReadL( TAny* aPtr, TInt aMaxLength );
sl@0: 	TStreamTransfer DoReadL( MStreamInput& aInput, TStreamTransfer aTransfer );
sl@0: 	void DoWriteL( const TAny* aPtr, TInt aLength );
sl@0: 	TStreamTransfer DoWriteL( MStreamOutput& aOutput, TStreamTransfer aTransfer );
sl@0: 	TStreamPos DoSeekL( TMark aMark, TStreamLocation aLocation, TInt aOffset );
sl@0: private:
sl@0: 	CDbTableCursor& iCursor;
sl@0: 	TDbColumn iColumn;
sl@0: 	TDbColType iType;
sl@0: 	TDbBlob* iBlob;
sl@0: 	TPtr8 iInlineBuf;
sl@0: 	TDbBlobId iBlobId;
sl@0: 	TInt iSize;
sl@0: 	MStreamBuf* iOverflowBuf;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableCursor::HMemBuf) : public TMemBuf
sl@0: 	{
sl@0: public:
sl@0: 	static HMemBuf* NewL( CDbTableCursor& aCursor, const TDesC8& aDes );
sl@0: protected:
sl@0: 	HMemBuf( CDbTableCursor& aCursor );
sl@0: 	virtual inline ~HMemBuf();
sl@0: private:
sl@0: 	void DoRelease();
sl@0: private:
sl@0: 	CDbTableCursor& iCursor;
sl@0: 	};
sl@0: 
sl@0: class CDbTableCursor::HHeapBuf : public CDbTableCursor::HMemBuf
sl@0: 	{
sl@0: public:
sl@0: 	enum { EMaxBlobBuffer = 0x600 };	// 1.5K to match KDbsStreamBufSize
sl@0: public:
sl@0: 	static HHeapBuf* NewL( CDbTableCursor& aCursor, const TDbBlob& aBlob, TDbColType aType );
sl@0: private:
sl@0: 	inline HHeapBuf( CDbTableCursor& aCursor );
sl@0: private:
sl@0: 	TUint8 iBuf[1];
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableCursor::HReadBuf) : public MStreamBuf
sl@0: 	{
sl@0: public:
sl@0: 	static HReadBuf* NewLC( CDbTableCursor& aCursor );
sl@0: 	inline void Set( MStreamBuf* aHost );
sl@0: private:
sl@0: 	inline HReadBuf( CDbTableCursor& aCursor );
sl@0: 	virtual inline ~HReadBuf();
sl@0: // from MStreamBuf
sl@0: 	void DoRelease();
sl@0: 	TInt DoReadL( TAny* aPtr, TInt aMaxLength );
sl@0: 	TStreamTransfer DoReadL( MStreamInput& aInput, TStreamTransfer aTransfer );
sl@0: 	TStreamPos DoSeekL( TMark aMark, TStreamLocation aLocation, TInt aOffset );
sl@0: private:
sl@0: 	CDbTableCursor& iCursor;
sl@0: 	MStreamBuf* iHost;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CIncremental) : public CDbSyncIncremental
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: protected:
sl@0: 	enum { ELastStep = 1 };
sl@0: 	enum TState { ERunning = 0, EFailed, ECommitted };
sl@0: public:
sl@0: 	inline void Construct( CStepper* aStepper );
sl@0: protected:
sl@0: 	CIncremental( RDbTransaction& aTransaction );
sl@0: 	~CIncremental();
sl@0: 	inline RDbTransaction& Transaction();
sl@0: 	inline CDbTableDatabase& Database();
sl@0: 	inline TBool IsCommitted() const;
sl@0: private:
sl@0: 	TBool NextL( TInt& aStep );
sl@0: 	virtual TInt DoNextL( TInt aStep );
sl@0: 	virtual void DoLastL() =0;
sl@0: private:
sl@0: 	RDbTransaction& iTransaction;
sl@0: 	CStepper* iStepper;
sl@0: 	TState iState;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CIncrementalDDL) : public CDbTableDatabase::CIncremental
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: protected:
sl@0: 	CIncrementalDDL( RDbTransaction& aTransaction );
sl@0: 	~CIncrementalDDL();
sl@0: // from CIncremental
sl@0: 	void DoLastL();
sl@0: 	};
sl@0: 
sl@0: class CDbTableDatabase::CCreateIndex : public CDbTableDatabase::CIncrementalDDL
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static CCreateIndex* NewLC( RDbTransaction& aTransaction );
sl@0: 	TInt ConstructL( const CDbTableDef& aTable, const CDbTableIndexDef& anIndex );
sl@0: private:
sl@0: 	inline CCreateIndex( RDbTransaction& aTransaction );
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CDropIndex) : public CDbTableDatabase::CIncrementalDDL
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static CDropIndex* NewL( RDbTransaction& aTransaction, const CDbTableDef& aTable, CDbTableIndexDef* anIndex, TInt& aStep );
sl@0: 	~CDropIndex();
sl@0: private:
sl@0: 	inline CDropIndex( RDbTransaction& aTransaction );
sl@0: private:
sl@0: 	CDbTableIndexDef* iDef;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CDropTable) : public CDbTableDatabase::CIncrementalDDL
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static CDropTable* NewL( RDbTransaction& aTransaction, CDbTableDef* aTable, TInt& aStep );
sl@0: 	~CDropTable();
sl@0: private:
sl@0: 	inline CDropTable( RDbTransaction& aTransaction );
sl@0: private:
sl@0: 	CDbTableDef* iDef;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CAlterTable) : public CDbTableDatabase::CIncrementalDDL
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static CAlterTable* NewL( RDbTransaction& aTransaction, CDbTableDef& aTable, const CDbColSet& aNewDef, TInt& aStep );
sl@0: 	~CAlterTable();
sl@0: private:
sl@0: 	inline CAlterTable( RDbTransaction& aTransaction, CDbTableDef& aDef );
sl@0: 	void ConstructL( const CDbColSet& aNewDef, TInt& aStep );
sl@0: // from CIncremental
sl@0: 	void DoLastL();
sl@0: private:
sl@0: 	CDbTableDef& iDef;
sl@0: 	HDbColumnSet* iNewSet;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CUtility) : public CDbTableDatabase::CIncremental
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static CUtility* NewL( RDbTransaction& aTransaction, CDbDatabase::TUtility aType, TInt& aStep );
sl@0: 	~CUtility();
sl@0: private:
sl@0: 	inline CUtility( RDbTransaction& aTransaction, CDbDatabase::TUtility aType );
sl@0: private:
sl@0: 	void DoLastL();
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbIncrementalDML) : public CDbSyncIncremental
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	static CDbIncrementalDML* NewL( CSqlModifyStatement& aStatement, CDbTableDatabase& aDatabase, TDbTextComparison aComparison );
sl@0: 	~CDbIncrementalDML();
sl@0: private:
sl@0: 	enum TState { EInitialising = 0, EEvaluating, EUpdating, EDeleting, ECommitted, EFailed };
sl@0: private:
sl@0: 	inline CDbIncrementalDML( RDbAccessPlan& aPlan );
sl@0: 	inline RDbTransaction& Transaction();
sl@0: 	inline TBool IsUpdate() const;
sl@0: 	inline void	SetState( TState aState );
sl@0: // from CDbSyncIncremental
sl@0: 	TBool NextL( TInt& aRows );
sl@0: private:
sl@0: 	TState iState;
sl@0: 	CDbTable& iTable;
sl@0: 	CDbDataSource* iSource;
sl@0: 	TDbRecordId iRecord;
sl@0: 	CSqlValues* iValues;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CInterface) : public CDbDatabase
sl@0: /**
sl@0: the interface implementation class for the Table database framework
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	CInterface(CDbTableDatabase& aDatabase);
sl@0: private:
sl@0: 	~CInterface();
sl@0: 	inline CDbTableDatabase& Database();
sl@0: 	void PrepareDDLL();
sl@0: //	from the interface framework
sl@0: 	TInt Destroy();
sl@0: 	TInt Begin();
sl@0: 	TInt Commit();
sl@0: 	void Rollback();
sl@0: 	TInt Property( TProperty aProperty );
sl@0: 	void CreateTableL( const TDesC& aName, const CDbColSet& aColSet, const CDbKey* aPrimaryKey );
sl@0: 	void TablesL( CDbTableNames& aNames );
sl@0: 	void ColumnsL( CDbColSet& aColSet, const TDesC& aName );
sl@0: 	void IndexesL( CDbIndexNames& aNames, const TDesC& aTable );
sl@0: 	void KeysL( CDbKey& aKey, const TDesC& aName, const TDesC& aTable );
sl@0: 	CDbNotifier* OpenNotifierL();
sl@0: 	CDbCursor* PrepareViewL( const TDbQuery& aQuery, const TDbWindow& aWindow, RDbRowSet::TAccess anAccess );
sl@0: 	CDbCursor* OpenTableL( const TDesC& aName, RDbRowSet::TAccess anAccess );
sl@0: 	CDbIncremental* OpenDropTableL( const TDesC& aTable, TInt& aStep );
sl@0: 	CDbIncremental* OpenAlterTableL( const TDesC& aTable, const CDbColSet& aNewDef, TInt& aStep );
sl@0: 	CDbIncremental* OpenCreateIndexL( const TDesC& aName, const TDesC& aTable, const CDbKey& aKey, TInt& aStep );
sl@0: 	CDbIncremental* OpenDropIndexL( const TDesC& aName, const TDesC& aTable, TInt& aStep );
sl@0: 	CDbIncremental* OpenUtilityL( CDbDatabase::TUtility aType, TInt& aStep );
sl@0: 	CDbIncremental* OpenExecuteL( const TDesC& aSql, TDbTextComparison aComparison, TInt& aInit );
sl@0: private:
sl@0: 	CDbTableDatabase& iDatabase;
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbTableDatabase::CSource) : public CDbSource
sl@0: /**
sl@0: @internalComponent
sl@0: */
sl@0: 	{
sl@0: public:
sl@0: 	CSource( CDbTableDatabase& aDatabase );
sl@0: private:
sl@0: 	~CSource();
sl@0: 	inline CDbTableDatabase& Database();
sl@0: 	// from the framework
sl@0: 	CDbDatabase* AuthenticateL();
sl@0: 	CDbNotifier* OpenNotifierL();
sl@0: private:
sl@0: 	CDbTableDatabase& iDatabase;
sl@0: 	};
sl@0: 
sl@0: #include "UT_STD.INL"