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 "UT_STD.H"
sl@0: #include "U32STD_DBMS.H"
sl@0: 
sl@0: #define UNUSED_VAR(a) a = a
sl@0: 
sl@0: const TUint KTableExpiry=0x100000;	// ~1.0s
sl@0: 
sl@0: // Class Blob cleanup
sl@0: 
sl@0: NONSHARABLE_CLASS(CDbBlobCleanup) : public CArrayFixFlat<TDbBlobId>
sl@0: 	{
sl@0: public:
sl@0: 	static CDbBlobCleanup* NewLC(CDbBlobSpace& aBlobSpace);
sl@0: 	~CDbBlobCleanup();
sl@0: private:
sl@0: 	inline CDbBlobCleanup(CDbBlobSpace& aBlobSpace);
sl@0: private:
sl@0: 	CDbBlobSpace& iBlobSpace;
sl@0: 	};
sl@0: 
sl@0: inline CDbBlobCleanup::CDbBlobCleanup(CDbBlobSpace& aBlobSpace)
sl@0: 	: CArrayFixFlat<TDbBlobId>(8),iBlobSpace(aBlobSpace)
sl@0: 	{}
sl@0: 
sl@0: CDbBlobCleanup* CDbBlobCleanup::NewLC(CDbBlobSpace& aBlobSpace)
sl@0: 	{
sl@0: 	CDbBlobCleanup* self=new(ELeave) CDbBlobCleanup(aBlobSpace);
sl@0: 	CleanupStack::PushL(self);
sl@0: 	return self;
sl@0: 	}
sl@0: 
sl@0: CDbBlobCleanup::~CDbBlobCleanup()
sl@0: 	{
sl@0: 	TInt count=Count();
sl@0: 	if (count)
sl@0: 		{
sl@0: 		const TDbBlobId* blob=&(*this)[0];
sl@0: 		const TDbBlobId* const end=blob+count;
sl@0: 		for (;blob<end;++blob)
sl@0: 			iBlobSpace.Delete(*blob);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: // Class CDbTable
sl@0: 
sl@0: 
sl@0: EXPORT_C CDbTable::CDbTable(CDbTableDatabase& aDatabase,const CDbTableDef& aDef)
sl@0: 	: iDatabase(&aDatabase),iDef(&aDef)
sl@0: 	{
sl@0: 	aDatabase.Open();
sl@0: 	aDatabase.AddTable(*this);		// we reference database
sl@0: 	}
sl@0: 
sl@0: EXPORT_C CDbTable::~CDbTable()
sl@0: //
sl@0: // Destroy components
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(!InUse());		// cannot be directly deleted
sl@0: 	if (IsActive())
sl@0: 		Disconnect();
sl@0: 	}
sl@0: 
sl@0: void CDbTable::Disconnect()
sl@0: //
sl@0: // Disconnect the table from the database collection.
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsActive());
sl@0: 	Database().RemoveTable(*this);
sl@0: 	TRAPD(errCode, ApplyToComponentsL(CDbRecordBase::DoDelete));
sl@0:     UNUSED_VAR(errCode);
sl@0: 	}
sl@0: 
sl@0: void CDbTable::Open()
sl@0: 	{
sl@0: 	__ASSERT(IsActive());
sl@0: 	TInt r=++iRef;
sl@0: 	if (r<=0)
sl@0: 		{	// were idle or cached
sl@0: 		if (r<0)
sl@0: 			{
sl@0: 			Cache().Release(*this);	// was cached
sl@0: 			iRef=0;
sl@0: 			}
sl@0: 		Database().Open();
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CDbTable::Close()
sl@0: //
sl@0: // We may destroy this object when the last reference goes away
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(InUse());
sl@0: 	if (--iRef<0)
sl@0: 		{
sl@0: 		if (!IsActive())
sl@0: 			delete this;		// disconnected table
sl@0: 		else
sl@0: 			{
sl@0: 			CDbTableDatabase& db=Database();
sl@0: 			if (!db.Transaction().IsLocked())
sl@0: 				Idle();			// no transaction, idle now
sl@0: 			db.Close();			// this must be done last to avoid early self destruction
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CDbTable::Idle()
sl@0: //
sl@0: // Called when idle, change to cached state
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsIdle());
sl@0: 	__ASSERT(IsActive());
sl@0: //
sl@0: 	iRef=ECached;
sl@0: 	Cache().Hold(this,KTableExpiry);	// may delete this
sl@0: 	}
sl@0: 
sl@0: void CDbTable::FlushL()
sl@0: //
sl@0: // Ensure all records objects are flushed
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsActive());
sl@0: 	if (iRef!=ECached)
sl@0: 		ApplyToComponentsL(CDbRecordBase::DoFlushL);
sl@0: 	}
sl@0: 
sl@0: void CDbTable::Abandon()
sl@0: //
sl@0: // Discard all components
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsActive());
sl@0: 	TRAPD(errCode, ApplyToComponentsL(CDbRecordBase::DoAbandon));
sl@0:     UNUSED_VAR(errCode);
sl@0: 	iIndexesEnd=NULL;	// flags indexes as abandoned
sl@0: 	++iGeneration;
sl@0: 	}
sl@0: 
sl@0: void CDbTable::Release()
sl@0: //
sl@0: // Release the table and all its cursors as DDL is about to begin
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsActive());
sl@0: 	switch (iRef)
sl@0: 		{
sl@0: 	case ECached:
sl@0: 		Cache().Release(*this);
sl@0: 		// fall throught to Idle
sl@0: 	case EIdle:
sl@0: 		delete this;
sl@0: 		break;
sl@0: 	default:
sl@0: 		__ASSERT(InUse());
sl@0: 		Database().Close();
sl@0: 		Disconnect();
sl@0: 		iDatabase=0;		// this marks us as released
sl@0: 		iDef=0;
sl@0: 		break;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CDbTable::ApplyToBlobsL(RDbRow& aRow,TBlobFuncL aFuncL,CDbBlobCleanup* aCleanup)
sl@0: 	{
sl@0: 	__ASSERT(Def().Columns().HasLongColumns());
sl@0: 	CDbBlobSpace* blobs=BlobsL();
sl@0: 	__ASSERT(blobs);
sl@0: 	TDbColNo col=1;
sl@0: 	HDbColumnSet::TIteratorC iter=Def().Columns().Begin();
sl@0: 	const HDbColumnSet::TIteratorC end=Def().Columns().End();
sl@0: 	do
sl@0: 		{
sl@0: 		if (!TDbCol::IsLong(iter->Type()))
sl@0: 			continue;
sl@0: 		const TDbColumnC column(aRow,col);
sl@0: 		if (column.IsNull())
sl@0: 			continue;
sl@0: 		aFuncL(*blobs,CONST_CAST(TDbBlob&,column.Blob()),iter->Type(),aCleanup);
sl@0: 		} while (++col,++iter<end);
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void DuplicateBlobL(CDbBlobSpace& aBlobStore,TDbBlob& aBlob,TDbColType aType,CDbBlobCleanup* aCleanup)
sl@0: 	{
sl@0: 	__ASSERT(aCleanup);
sl@0: 	if (aBlob.IsInline())
sl@0: 		return;
sl@0: // need to duplicate blob
sl@0: 	RReadStream old(aBlobStore.ReadLC(aBlob.Id(),aType));
sl@0: 	TDbBlobId& newId=aCleanup->ExtendL();
sl@0: 	newId=KDbNullBlobId;
sl@0: 	RWriteStream dup(aBlobStore.CreateL(newId,aType));
sl@0: 	dup.PushL();
sl@0: 	dup.WriteL(old,aBlob.Size());
sl@0: 	dup.CommitL();
sl@0: 	CleanupStack::PopAndDestroy(2);		// old and dup streams
sl@0: 	aBlob.SetId(newId);		// row is writable
sl@0: 	}
sl@0: 
sl@0: void CDbTable::DuplicateBlobsL(RDbRow& aRow)
sl@0: //
sl@0: // duplicate any blobs
sl@0: //
sl@0: 	{
sl@0: 	if (!Def().Columns().HasLongColumns())
sl@0: 		return;
sl@0: 
sl@0: 	CDbBlobCleanup* cleaner=CDbBlobCleanup::NewLC(*BlobsL());
sl@0: 	ApplyToBlobsL(aRow,DuplicateBlobL,cleaner);
sl@0: 	cleaner->Reset();
sl@0: 	CleanupStack::PopAndDestroy();
sl@0: 	}
sl@0: 
sl@0: TBool CDbTable::ExistsL(TDbRecordId aRecordId)
sl@0: //
sl@0: // Check that aRecordId is good for this table
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsActive() && InUse());
sl@0: 	return RecordsL().ExistsL(aRecordId);
sl@0: 	}
sl@0: 
sl@0: void CDbTable::NewRowL(RDbRow& aRow)
sl@0: //
sl@0: // Initialise any auto-increment columns in the row
sl@0: //
sl@0: 	{
sl@0: 	const HDbColumnSet& columns=Def().Columns();
sl@0: 	if (!columns.HasAutoIncrement())
sl@0: 		return;
sl@0: 
sl@0: 	TUint value=RecordsL().AutoIncrementL();
sl@0: 	TDbColNo col=1;
sl@0: 	HDbColumnSet::TIteratorC iter=columns.Begin();
sl@0: 	const HDbColumnSet::TIteratorC end=columns.End();
sl@0: 	do
sl@0: 		{
sl@0: 		if (iter->iAttributes&TDbCol::EAutoIncrement)
sl@0: 			{
sl@0: 			// auto-increment only for integral types <=32 bits wide
sl@0: 			__ASSERT(iter->iType<=EDbColUint32);
sl@0: 			TDbColumn column(aRow,col);
sl@0: 			column.SetL(TUint32(value));
sl@0: 			}
sl@0: 		} while (++col,++iter<end);
sl@0: 	}
sl@0: 
sl@0: void CDbTable::ValidateL(const RDbRow& aRow)
sl@0: //
sl@0: // Ensure that the column data conforms to type size/flags etc
sl@0: //
sl@0: 	{
sl@0: 	HDbColumnSet::TIteratorC iter=Def().Columns().Begin();
sl@0: 	const HDbColumnSet::TIteratorC end=Def().Columns().End();
sl@0: 	const TDbCell* const last=aRow.Last();
sl@0: 	for (const TDbCell* column=aRow.First();column<last;++iter,column=column->Next())
sl@0: 		{
sl@0: 		TInt size=column->Length();
sl@0: 		if (size==0)
sl@0: 			{	// check for Null
sl@0: 			if (iter->iAttributes&TDbCol::ENotNull)
sl@0: 				{
sl@0: 				__LEAVE(KErrNotFound);
sl@0: 				return;
sl@0: 				}
sl@0: 			continue;
sl@0: 			}
sl@0: 		const TUint32* data=(const TUint32*)column->Data();
sl@0: 		switch (iter->iType)
sl@0: 			{
sl@0: 		case EDbColBit:
sl@0: 			if (*data>1)
sl@0: 				__LEAVE(KErrOverflow);
sl@0: 			break;
sl@0: 		case EDbColInt8:
sl@0: 			{
sl@0: 			TInt val=*data;
sl@0: 			if (TInt8(val)!=val)
sl@0: 				__LEAVE(KErrOverflow);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EDbColInt16:
sl@0: 			{
sl@0: 			TInt val=*data;
sl@0: 			if (TInt16(val)!=val)
sl@0: 				__LEAVE(KErrOverflow);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EDbColUint8:
sl@0: 			{
sl@0: 			TUint val=*data;
sl@0: 			if (TUint8(val)!=val)
sl@0: 				__LEAVE(KErrOverflow);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EDbColUint16:
sl@0: 			{
sl@0: 			TUint val=*data;
sl@0: 			if (TUint16(val)!=val)
sl@0: 				__LEAVE(KErrOverflow);
sl@0: 			}
sl@0: 			break;
sl@0: 		case EDbColText16:
sl@0: 			size>>=1;
sl@0: 		case EDbColBinary:
sl@0: 		case EDbColText8:
sl@0: 			if (iter->iMaxLength==KDbUndefinedLength)
sl@0: 				break;
sl@0: 			if (size>iter->iMaxLength)
sl@0: 				__LEAVE(KErrOverflow);
sl@0: 			break;
sl@0: 		case EDbColLongBinary:
sl@0: 		case EDbColLongText8:
sl@0: 		case EDbColLongText16:
sl@0: 			if (iter->iMaxLength==KDbUndefinedLength)
sl@0: 				break;
sl@0: 			size=((TDbBlob*)data)->Size();
sl@0: 			if (size==KDbUndefinedLength)
sl@0: 				break;
sl@0: 			if (iter->iType==EDbColText16)
sl@0: 				size>>=1;
sl@0: 			if (size>iter->iMaxLength)
sl@0: 				__LEAVE(KErrOverflow);
sl@0: 			break;
sl@0: 		default:
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 	for (;iter<end;++iter)
sl@0: 		{	// check for Null
sl@0: 		if (iter->iAttributes&TDbCol::ENotNull)
sl@0: 			{
sl@0: 			__LEAVE(KErrNotFound);
sl@0: 			return;
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CDbTable::ReadRowL(RDbRow& aRow,TDbRecordId aRecordId)
sl@0: //
sl@0: // Read a record from the table
sl@0: //
sl@0: 	{
sl@0: 	CopyToRowL(aRow,RecordsL().ReadL(aRecordId));
sl@0: 	}
sl@0: 
sl@0: void CDbTable::PrepareAppendL(const RDbTableRow& aRow)
sl@0: //
sl@0: // Validate a new record for appending
sl@0: //
sl@0: 	{
sl@0: 	EnsureIndexesL();
sl@0: 	ValidateL(aRow);
sl@0: 	CDbRecordIndex** end=iIndexesEnd;
sl@0: 	for (CDbRecordIndex** pix=iIndexes;pix<end;++pix)
sl@0: 		{
sl@0: 		CDbRecordIndex& ix=**pix;
sl@0: 		if (ix.IsBroken())
sl@0: 			continue;
sl@0: 		if (ix.FindL(KDbNullRecordId,aRow)==CDbRecordIndex::EKeyMatch)
sl@0: 			__LEAVE(KErrAlreadyExists);	// duplicate found
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: TDbRecordId CDbTable::AppendRowL(const RDbTableRow& aRow)
sl@0: //
sl@0: // Validate and add a new record to the table and any open indexes
sl@0: //
sl@0: 	{
sl@0: 	CDbRecordSpace& records=RecordsL();
sl@0: 	CopyFromRow(records.NewL(RecordLength(aRow)),aRow);
sl@0: 	TDbRecordId id=records.AppendL();
sl@0: 	CDbRecordIndex** end=iIndexesEnd;
sl@0: 	for (CDbRecordIndex** pix=iIndexes;pix<end;++pix)
sl@0: 		{
sl@0: 		CDbRecordIndex& ix=**pix;
sl@0: 		if (ix.IsBroken())
sl@0: 			continue;
sl@0: 		__DEBUG(TInt dbgchk=) ix.InsertL(id,aRow);
sl@0: 		__ASSERT(dbgchk);
sl@0: 		}
sl@0: 	++iGeneration;
sl@0: 	return id;
sl@0: 	}
sl@0: 
sl@0: void CDbTable::PrepareReplaceL(const RDbTableRow& aRow,TDbRecordId aRecordId)
sl@0: //
sl@0: // Validate a record for replacement
sl@0: //
sl@0: 	{
sl@0: 	EnsureIndexesL();
sl@0: 	ValidateL(aRow);
sl@0: 	TUint32 update=0;
sl@0: 	CDbRecordIndex** end=iIndexes;
sl@0: 	for (CDbRecordIndex** pix=iIndexesEnd;--pix>=end;)
sl@0: 		{
sl@0: 		update<<=1;
sl@0: 		CDbRecordIndex& ix=**pix;
sl@0: 		if (ix.IsBroken())
sl@0: 			continue;
sl@0: 		switch (ix.FindL(aRecordId,aRow))
sl@0: 			{
sl@0: 		case CDbRecordIndex::ENoMatch:		// key has changed in index
sl@0: 			update|=1;
sl@0: 			break;
sl@0: 		case CDbRecordIndex::EKeyMatch:	// duplicate found
sl@0: 			__LEAVE(KErrAlreadyExists);
sl@0: 		case CDbRecordIndex::EEntryMatch:	// no change in index
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 	iUpdateMap=update;
sl@0: 	}
sl@0: 
sl@0: void CDbTable::DoReplaceRowL(const RDbRow& aRow,TDbRecordId aRecordId)
sl@0: 	{
sl@0: 	CopyFromRow(RecordsL().ReplaceL(aRecordId,RecordLength(aRow)),aRow);
sl@0: 	++iGeneration;
sl@0: 	}
sl@0: 
sl@0: void CDbTable::ReplaceRowL(RDbTableRow& aRow,TDbRecordId aRecordId)
sl@0: //
sl@0: // Replace a record in the table
sl@0: //
sl@0: 	{
sl@0: 	if (Def().Columns().HasLongColumns())
sl@0: 		CheckInliningL(aRow);
sl@0: 	TUint32 update=iUpdateMap;
sl@0: 	if (update==0)
sl@0: 		{
sl@0: 		DoReplaceRowL(aRow,aRecordId);
sl@0: 		return;
sl@0: 		}
sl@0: 	RDbTableRow oldRow;		// temporary row buffer for old row values
sl@0: 	oldRow.Open(this);
sl@0: 	oldRow.PushL();			// cleanup buffer if there is trouble
sl@0: 	ReadRowL(oldRow,aRecordId);
sl@0: 	DoReplaceRowL(aRow,aRecordId);
sl@0: 	for (CDbRecordIndex** pix=iIndexes;update;++pix,update>>=1)
sl@0: 		{
sl@0: 		if (update&1)
sl@0: 			{
sl@0: 			CDbRecordIndex& index=**pix;
sl@0: 			index.DeleteL(aRecordId,oldRow);
sl@0: 			__DEBUG(TInt dbgchk=) index.InsertL(aRecordId,aRow);
sl@0: 			__ASSERT(dbgchk);
sl@0: 			}
sl@0: 		}
sl@0: 	CleanupStack::PopAndDestroy();	// temp row buffer
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void CheckInlineL(CDbBlobSpace& aBlobStore,TDbBlob& aBlob,TDbColType aType,CDbBlobCleanup*)
sl@0: 	{
sl@0: 	if (!aBlob.IsInline())
sl@0: 		return;
sl@0: 	if (aBlob.Size()>aBlobStore.InlineLimit())
sl@0: 		aBlob.SetId(aBlobStore.CreateL(aType,aBlob.Data(),aBlob.Size()));
sl@0: 	}
sl@0: 
sl@0: void CDbTable::CheckInliningL(RDbRow& aRow)
sl@0: //
sl@0: // Ensure that all Blobs are within the current inline limit
sl@0: //
sl@0: 	{
sl@0: 	ApplyToBlobsL(aRow,CheckInlineL);
sl@0: 	}
sl@0: 
sl@0: LOCAL_C void DiscardBlobL(CDbBlobSpace& aBlobStore,TDbBlob& aBlob,TDbColType,CDbBlobCleanup*)
sl@0: 	{
sl@0: 	if (!aBlob.IsInline())
sl@0: 		aBlobStore.DeleteL(aBlob.Id());
sl@0: 	}
sl@0: 
sl@0: EXPORT_C void CDbTable::DiscardBlobsL(RDbRow& aRow)
sl@0: //
sl@0: // Default implemtation xlates the record and then walks the row buffer
sl@0: //
sl@0: 	{
sl@0: 	ApplyToBlobsL(aRow,DiscardBlobL);
sl@0: 	}
sl@0: 
sl@0: void CDbTable::DeleteRowL(RDbTableRow& aRow,TDbRecordId aRecordId)
sl@0: //
sl@0: // Delete the record from the file and unlock it.
sl@0: //
sl@0: 	{
sl@0: 	EnsureIndexesL();
sl@0: 
sl@0: 	if (Def().Columns().HasLongColumns())
sl@0: 		{
sl@0: 		// Read data from the stream but do not delete the stream yet.
sl@0: 		aRow.ReadL(aRecordId);
sl@0: 		}
sl@0: 
sl@0: 	CDbRecordIndex** end=iIndexes;
sl@0: 	CDbRecordIndex** pix=iIndexesEnd;
sl@0: 	if (pix!=end)
sl@0: 		aRow.ReadL(aRecordId);
sl@0: 	RecordsL().EraseL(aRecordId);
sl@0: 	while (--pix>=end)
sl@0: 		{
sl@0: 		CDbRecordIndex& ix=**pix;
sl@0: 		if (!ix.IsBroken())
sl@0: 			ix.DeleteL(aRecordId,aRow);
sl@0: 		}
sl@0: 
sl@0: 	if (Def().Columns().HasLongColumns())
sl@0: 		{
sl@0: 		// Now delete the stream.
sl@0: 		DiscardBlobsL(aRow);
sl@0: 		}
sl@0: 
sl@0: 	++iGeneration;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C CDbRecordSpace& CDbTable::RecordsL()
sl@0: 	{
sl@0: 	__ASSERT(IsActive() && InUse());
sl@0: 	CDbRecordSpace* rec=iRecords;
sl@0: 	if (rec==NULL)
sl@0: 		iRecords=rec=RecordSpaceL();
sl@0: 	if (rec->OpenL())
sl@0: 		__LEAVE(KErrCorrupt);
sl@0: 	return *rec;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C CDbBlobSpace* CDbTable::BlobsL()
sl@0: 	{
sl@0: 	__ASSERT(IsActive() && InUse());
sl@0: 	CDbBlobSpace* blob=iBlobs;
sl@0: 	if (blob==NULL)
sl@0: 		iBlobs=blob=BlobSpaceL();
sl@0: 	if (blob->OpenL())
sl@0: 		__LEAVE(KErrCorrupt);
sl@0: 	return blob;
sl@0: 	}
sl@0: 
sl@0: EXPORT_C CDbRecordIndex& CDbTable::IndexL(const CDbTableIndexDef& aIndex)
sl@0: //
sl@0: // Load the index associated with the index definition and ensure it is operational
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsActive() && InUse());
sl@0: 	// find the matching slot in the indexes array
sl@0: 	CDbRecordIndex** slot=&iIndexes[0];
sl@0: 	for (TSglQueIterC<CDbTableIndexDef> iter(Def().Indexes().AsQue());iter++!=&aIndex;)
sl@0: 		++slot;
sl@0: 	__ASSERT(iIndexesEnd==NULL||(slot>=iIndexes&&slot<iIndexesEnd));
sl@0: 	// load (if required) and open the index
sl@0: 	CDbRecordIndex* index=*slot;
sl@0: 	if (index==0)
sl@0: 		*slot=index=RecordIndexL(aIndex);
sl@0: 	if (index->OpenL())
sl@0: 		__LEAVE(KErrCorrupt);
sl@0: 	return *index;
sl@0: 	}
sl@0: 
sl@0: void CDbTable::EnsureIndexesL()
sl@0: //
sl@0: // Ensure that all indexes are open
sl@0: //
sl@0: 	{
sl@0: 	__ASSERT(IsActive() && InUse());
sl@0: 	if (iIndexesEnd==NULL)
sl@0: 		{
sl@0: 		CDbRecordIndex** pp=iIndexes;
sl@0: 		TSglQueIterC<CDbTableIndexDef> iter(Def().Indexes().AsQue());
sl@0: 		for (const CDbTableIndexDef* xDef;(xDef=iter++)!=NULL;++pp)
sl@0: 			{
sl@0: 			CDbRecordIndex* ix=*pp;
sl@0: 			if (ix==NULL)
sl@0: 				*pp=ix=RecordIndexL(*xDef);
sl@0: 			ix->OpenL();	// ignore broken-ness
sl@0: 			}
sl@0: 		iIndexesEnd=pp;
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: CDbRecordIter* CDbTable::IteratorL()
sl@0: 	{
sl@0: 	return RecordsL().IteratorL();
sl@0: 	}
sl@0: 
sl@0: CDbRecordIter* CDbTable::IteratorL(const CDbTableIndexDef& aIndex,TUint aInclusion,const TDbLookupKey* aLowerBound,const TDbLookupKey* aUpperBound)
sl@0: //
sl@0: // create an interator for the index parameter
sl@0: //
sl@0: 	{
sl@0: 	return IndexL(aIndex).IteratorL(aInclusion,aLowerBound,aUpperBound);
sl@0: 	}
sl@0: 
sl@0: EXPORT_C TInt CDbTable::IndexSpanL(const CDbTableIndexDef&,TUint,const TDbLookupKey*,const TDbLookupKey*)
sl@0: //
sl@0: // Default implementation: no statistics are available
sl@0: //
sl@0: 	{
sl@0: 	return EUnavailableSpan;
sl@0: 	}
sl@0: 
sl@0: CDbRecordIter* CDbTable::IteratorL(const TDesC& aIndex)
sl@0: //
sl@0: // create an interator for the index named
sl@0: //
sl@0: 	{
sl@0: 	return IteratorL(Def().Indexes().FindL(aIndex));
sl@0: 	}
sl@0: 
sl@0: void CDbTable::ApplyToComponentsL(void (*anOperationL)(CDbRecordBase*))
sl@0: //
sl@0: // Invoke anOperation on all components of the table
sl@0: //
sl@0: 	{
sl@0: 	if (iRecords)
sl@0: 		anOperationL(iRecords);
sl@0: 	if (iBlobs)
sl@0: 		anOperationL(iBlobs);
sl@0: 	CDbRecordIndex** const ixs=iIndexes;
sl@0: 	CDbRecordIndex** pix=iIndexesEnd;
sl@0: 	if (pix==NULL)
sl@0: 		pix=&iIndexes[KDbTableMaxIndexes];
sl@0: 	while (--pix>=ixs)
sl@0: 		if (*pix)
sl@0: 			anOperationL(*pix);
sl@0: 	}
sl@0: 
sl@0: // Class CDbtable::TValid
sl@0: 
sl@0: // this class is used by the cursor to check that it is still operational
sl@0: 
sl@0: CDbTable::TValid::TValid(CDbTable& aTable)
sl@0: 	:iTable(aTable)
sl@0: 	{
sl@0: 	__ASSERT(aTable.IsActive());
sl@0: 	iRollback.Construct(aTable.Database().Transaction().RollbackGeneration());
sl@0: 	}
sl@0: 
sl@0: TBool CDbTable::TValid::Reset()
sl@0: 	{
sl@0: 	TBool b=Table().IsActive();
sl@0: 	if (b)
sl@0: 		iRollback.Mark();
sl@0: 	return b;
sl@0: 	}
sl@0: 
sl@0: void CDbTable::TValid::CheckL() const
sl@0: 	{
sl@0: 	CDbTableDatabase* d=Table().iDatabase;
sl@0: 	if (!d)
sl@0: 		__LEAVE(KErrDisconnected);
sl@0: 	else
sl@0: 		d->Transaction().ReadyL();
sl@0: 	if (iRollback.Changed())
sl@0: 		__LEAVE(KErrNotReady);
sl@0: 	}