1.1 --- /dev/null Thu Jan 01 00:00:00 1970 +0000
1.2 +++ b/os/persistentdata/persistentstorage/dbms/ustor/US_STD.H Fri Jun 15 03:10:57 2012 +0200
1.3 @@ -0,0 +1,691 @@
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 "D32REC.H"
1.21 +#include "D32STOR.H"
1.22 +#include <s32buf.h>
1.23 +#include <s32crypt.h>
1.24 +#include <s32btree.h>
1.25 +#include <s32ucmp.h>
1.26 +#include <e32hal.h>
1.27 +#include <e32math.h>
1.28 +
1.29 +// classes defined
1.30 +class TDbStoreIndexStats;
1.31 +class CDbStoreIndexDef;
1.32 +class TRecordSize;
1.33 +class CDbStoreDef;
1.34 +class RClusterMap;
1.35 +class TClusterLinkCache;
1.36 +struct TClusterDes;
1.37 +class CCluster;
1.38 +class CClusterCache;
1.39 +class CDbStoreRecords;
1.40 +class CDbStoreBlobs;
1.41 +class CDbStoreIndex;
1.42 +class CDbStoreTable;
1.43 +class RDbStoreReadStream;
1.44 +class RDbStoreWriteStream;
1.45 +class MDbStreamFilter;
1.46 +class CDbStoreCompression;
1.47 +
1.48 +/**
1.49 +@internalComponent
1.50 +*/
1.51 +enum TStorePanic
1.52 + {
1.53 + EDbUnimplemented,
1.54 + EDbNoStore,
1.55 + EDbCannotSeek,
1.56 + EDbNotFixedFieldType,
1.57 + EDbWrongType
1.58 + };
1.59 +
1.60 +/**
1.61 +@internalComponent
1.62 +*/
1.63 +GLREF_C void Panic(TStorePanic aPanic);
1.64 +
1.65 +/**
1.66 +@internalComponent
1.67 +*/
1.68 +GLREF_D const TDbDriver KBuiltinDriver;
1.69 +
1.70 +/**
1.71 +@internalComponent
1.72 +*/
1.73 +const TUid KDbmsStoreDatabase={268435561};
1.74 +
1.75 +/**
1.76 +@internalComponent
1.77 +*/
1.78 +const TInt KDbStoreMaxRecordLength=0x200A; // v5.10 32 nullable longtext columns
1.79 +const TInt KClusterLimit=0x1000;
1.80 +const TInt KMaxClustering=16;
1.81 +const TInt KBlobRefSize=sizeof(TDbBlobId)+sizeof(TInt32);
1.82 +const TInt KMinInlineLimit=16;
1.83 +const TInt KMaxIndexKeySize=248;
1.84 +
1.85 +/**
1.86 +@internalComponent
1.87 +*/
1.88 +class TDbStoreIndexStats
1.89 + {
1.90 +public:
1.91 + /**
1.92 + @internalComponent
1.93 + */
1.94 + class TBound
1.95 + {
1.96 + public:
1.97 + inline void Set(TReal64 aBound);
1.98 + void Set(const TInt64& aBound);
1.99 + void Set(const TText8* aPtr,TInt aLen,const TTextOps& aConv);
1.100 + void Set(const TText16* aPtr,TInt aLen,const TTextOps& aConv);
1.101 + void Set(const TDbLookupKey::SColumn& aBound,const TTextOps& aConv);
1.102 + public:
1.103 + TReal64 iValue;
1.104 + };
1.105 + enum TType {EContinuous,EDiscrete};
1.106 +public:
1.107 + inline TDbStoreIndexStats();
1.108 +//
1.109 + void InternalizeL(RReadStream& aStream);
1.110 + void ExternalizeL(RWriteStream& aStream) const;
1.111 +//
1.112 + inline void Reset(TInt aCardinality=0);
1.113 + inline void Inc();
1.114 + inline void Dec();
1.115 + inline void Refresh(TType aType);
1.116 +//
1.117 + inline TBool IsValid() const;
1.118 + inline TBool NeedsRefresh() const;
1.119 + inline TInt Cardinality() const;
1.120 + TInt Span(TUint aInclusion,const TDbLookupKey* aLower,const TDbLookupKey* aUpper,const TTextOps& aConv) const;
1.121 +private:
1.122 + inline void Touch();
1.123 + TInt ReverseSpan(TUint aInclusion,const TDbLookupKey* aLower,const TDbLookupKey* aUpper,const TTextOps& aConv) const;
1.124 +private:
1.125 + enum {ERefreshFactor=3};
1.126 + enum {EInvalid=-1,ERefresh=0};
1.127 + enum {ERefreshShift=2+ERefreshFactor,EFlagsMask=(1<<ERefreshShift)-1};
1.128 + enum {EFlgDiscrete=0x1,EFlgClustering=0x2};
1.129 +private:
1.130 + TInt iCardinality;
1.131 + TInt iRefresh;
1.132 + TUint iFlags;
1.133 +public:
1.134 + TBound iLower;
1.135 + TBound iUpper;
1.136 + };
1.137 +
1.138 +/**
1.139 +@internalComponent
1.140 +*/
1.141 +class CDbStoreIndexDef : public CDbTableIndexDef
1.142 + {
1.143 +public:
1.144 + static CDbStoreIndexDef* NewLC(const TDesC& aName,const CDbKey& aKey,const HDbColumnSet& aColumns);
1.145 + static CDbStoreIndexDef* NewL(RReadStream& aStream);
1.146 + void ExternalizeL(RWriteStream& aStream) const;
1.147 + inline void SetTokenId(TStreamId anId);
1.148 + inline TStreamId TokenId() const;
1.149 +//
1.150 + static TInt KeySize(const TDbKeyCol& aKeyCol,const TDbColumnDef& aColumn);
1.151 + static void CheckSizeL(const CDbKey& aKey,const HDbColumnSet& aColSet);
1.152 +private:
1.153 + CDbStoreIndexDef();
1.154 + static CDbStoreIndexDef* NewLC(const TDesC& aName);
1.155 +private:
1.156 + TStreamId iTokenId;
1.157 +public:
1.158 + __MUTABLE TDbStoreIndexStats iStats; // cache the statistics here
1.159 + };
1.160 +
1.161 +/**
1.162 +@internalComponent
1.163 +*/
1.164 +class TRecordSize
1.165 + {
1.166 +public:
1.167 + TBool Set(const HDbColumnSet& aColumns);
1.168 + inline TInt Clustering() const;
1.169 + inline TInt InlineLimit() const;
1.170 +//
1.171 + static void CheckSizeL(const HDbColumnSet& aColumns);
1.172 + static TInt InlineLimit(const HDbColumnSet& aColumns);
1.173 +//
1.174 + static inline TInt FixedFieldSize(TDbColType aType);
1.175 +private:
1.176 + TInt iClustering;
1.177 + TInt iInlineLimit;
1.178 +private:
1.179 + static TUint8 const FieldSizes[];
1.180 + };
1.181 +
1.182 +/**
1.183 +@internalComponent
1.184 +*/
1.185 +NONSHARABLE_CLASS(CDbStoreDef) : public CDbTableDef
1.186 + {
1.187 +public:
1.188 + static CDbStoreDef* NewLC(const TDesC& aName,const CDbColSet& aColSet);
1.189 + static CDbStoreDef* NewL(RReadStream& aStream);
1.190 + void ExternalizeL(RWriteStream& aStream) const;
1.191 + inline void SetTokenId(TStreamId anId);
1.192 + inline TStreamId TokenId() const;
1.193 + inline TInt Clustering() const;
1.194 + inline TInt InlineLimit() const;
1.195 + void Changed();
1.196 +private:
1.197 + void AlteredColumnSetL(HDbColumnSet& aSet,const CDbColSet& aChange,const CDbColSet& aAdd);
1.198 +protected:
1.199 + CDbStoreDef();
1.200 +private:
1.201 + static CDbStoreDef* NewLC(const TDesC& aName,TInt aColumnCount);
1.202 +private:
1.203 + TStreamId iTokenId;
1.204 + TRecordSize iInfo;
1.205 + };
1.206 +
1.207 +/**
1.208 +@internalComponent
1.209 +*/
1.210 +typedef TUint32 TClusterId;
1.211 +
1.212 +/**
1.213 +@internalComponent
1.214 +*/
1.215 +const TClusterId KNullClusterId=0;
1.216 +
1.217 +/**
1.218 +@internalComponent
1.219 +*/
1.220 +inline TClusterId ClusterId(TDbRecordId aRecordId);
1.221 +inline TInt RecordIndex(TDbRecordId aRecordId);
1.222 +inline TDbRecordId RecordId(TClusterId aId,TInt aIndex);
1.223 +inline TClusterId ClusterId(TStreamId aStreamId);
1.224 +
1.225 +/**
1.226 +@internalComponent
1.227 +*/
1.228 +class RClusterMap
1.229 + {
1.230 +private:
1.231 + enum {EGranularity=8};
1.232 + class TIdPair
1.233 + {
1.234 + public:
1.235 + TClusterId iId;
1.236 + TClusterId iPreviousId;
1.237 + };
1.238 +public:
1.239 + enum {ESeparation=16};
1.240 +public:
1.241 + inline RClusterMap();
1.242 + inline void Close();
1.243 +//
1.244 + void ResetL(TClusterId aHeadCluster);
1.245 + inline void BindL(TClusterId aPrevious,TClusterId aCluster);
1.246 + void DropL(TClusterId aCluster,TClusterId aNext);
1.247 + TBool At(TClusterId aCluster,TClusterId& aPrevious);
1.248 + inline TClusterId LastBound() const;
1.249 + inline void Complete(TClusterId aLastCluster);
1.250 + inline TBool IsComplete() const;
1.251 +private:
1.252 + void AddL(TClusterId aCluster);
1.253 + void InsertL(TClusterId aCluster,TClusterId aPrevious);
1.254 + TIdPair* At(TClusterId aCluster);
1.255 +private:
1.256 + TIdPair* iMap;
1.257 + TInt iEntries;
1.258 + TInt iAlloc;
1.259 + TClusterId iLastBound;
1.260 + TClusterId iLastMapped;
1.261 + TInt iSkipped;
1.262 + TBool iComplete;
1.263 + };
1.264 +
1.265 +/**
1.266 +@internalComponent
1.267 +*/
1.268 +class TClusterLinkCache
1.269 + {
1.270 +public:
1.271 + inline void Invalidate();
1.272 + inline void Reset(TClusterId aBaseId);
1.273 + inline void Bind(TClusterId aPrevious,TClusterId aCluster,RClusterMap& aMap);
1.274 + void Add(const TClusterId* aFirst,const TClusterId* aLast);
1.275 + void Drop(TClusterId aCluster,TClusterId aNext);
1.276 + TBool Has(TClusterId aCluster) const;
1.277 + TBool At(TClusterId aCluster,TClusterId& aPrevious) const;
1.278 +private:
1.279 + void Add(TClusterId aCluster,RClusterMap& aMap);
1.280 +private:
1.281 + TClusterId iMap[RClusterMap::ESeparation+1];
1.282 + TClusterId* iEnd;
1.283 + };
1.284 +
1.285 +/**
1.286 +@internalComponent
1.287 +*/
1.288 +struct TClusterDes
1.289 + {
1.290 +public:
1.291 + void InternalizeL(RReadStream& aStream);
1.292 + void ExternalizeL(RWriteStream& aStream) const;
1.293 +public:
1.294 + TClusterId iNext;
1.295 + TUint32 iMembership;
1.296 + };
1.297 +
1.298 +/**
1.299 +@internalComponent
1.300 +*/
1.301 +NONSHARABLE_CLASS(CCluster) : public CBase
1.302 + {
1.303 + friend class CClusterCache;
1.304 +private:
1.305 + enum {EGranularity=0x200};
1.306 + enum {EExpandBuffer=0x40};
1.307 +public:
1.308 + /**
1.309 + @internalComponent
1.310 + */
1.311 + NONSHARABLE_CLASS(MAlter)
1.312 + {
1.313 + public:
1.314 + virtual TInt RecordExpansion(const TUint8* aRec,TInt aLength);
1.315 + virtual TUint8* AlterRecordL(TUint8* aWPtr,const TUint8* aRPtr,TInt aLength) =0;
1.316 + };
1.317 +public:
1.318 + static CCluster* NewL(CDbStoreDatabase& aDatabase);
1.319 + ~CCluster();
1.320 +//
1.321 + void FlushL();
1.322 + void Discard();
1.323 +//
1.324 + void Create(TClusterId aClusterId);
1.325 + void ReadL(TClusterId aCluster);
1.326 + void Relink(TClusterId aNextClusterId);
1.327 + void AlterL(MAlter& anAlterer);
1.328 +//
1.329 + TPtrC8 RecordL(TInt aIndex);
1.330 + TUint8* UpdateL(TInt aIndex,TInt aNewSize);
1.331 + TBool DeleteL(TInt aIndex);
1.332 + inline TBool IsFull() const;
1.333 +//
1.334 + inline TClusterId Id() const;
1.335 + inline const TClusterDes& Des() const;
1.336 +private:
1.337 + CCluster(CDbStoreDatabase& aDatabase);
1.338 +//
1.339 + TInt SetSizeL(TInt aSize);
1.340 + void AdjustMap(TUint8** aMapEntry,TInt aAdjust);
1.341 + void SetRecordL(TInt aIndex,TInt aNewSize);
1.342 + void AdjustL(TUint8** aMapEntry,TInt aAdjust,TUint8* aData);
1.343 +private:
1.344 + TDblQueLink iLink;
1.345 + CDbStoreDatabase& iDatabase;
1.346 + TInt iSize;
1.347 + TClusterId iCluster;
1.348 + TClusterDes iDes;
1.349 + TBool iModified;
1.350 + TUint8* iMap[KMaxClustering+1];
1.351 + };
1.352 +
1.353 +/**
1.354 +@internalComponent
1.355 +*/
1.356 +NONSHARABLE_CLASS(CClusterCache) : public CBase
1.357 + {
1.358 + #ifndef MAX_CLUSTER_CACHE_SIZE
1.359 + #define MAX_CLUSTER_CACHE_SIZE 8
1.360 + #else
1.361 + #if MAX_CLUSTER_CACHE_SIZE < 4
1.362 + #error "MAX_CLUSTER_CACHE_SIZE macro value can't be less than 4"
1.363 + #endif
1.364 + #endif
1.365 + enum {EMaxClusters=MAX_CLUSTER_CACHE_SIZE};
1.366 +public:
1.367 + static CClusterCache* NewL(CDbStoreDatabase& aDatabase);
1.368 + ~CClusterCache();
1.369 +//
1.370 + void FlushL();
1.371 + void Discard();
1.372 +//
1.373 + CCluster* Cluster(TClusterId aCluster);
1.374 + CCluster& ClusterL(TClusterId aCluster);
1.375 + CCluster& ClusterL();
1.376 +//
1.377 + inline CDbStoreDatabase& Database();
1.378 + inline CStreamStore& Store();
1.379 +private:
1.380 + inline CClusterCache(CDbStoreDatabase& aDatabase);
1.381 +//
1.382 + void Apply(void (*aFunc)(CCluster*));
1.383 + CCluster& AddClusterL();
1.384 + CCluster& NewClusterL();
1.385 + CCluster& Touch(CCluster& aCluster);
1.386 +private:
1.387 + CDbStoreDatabase& iDatabase;
1.388 + TClusterId iCachePlus1;
1.389 + TClusterId iCachePlus2;
1.390 + TUint8 iFollowOnHits;
1.391 + TUint8 iClusters;
1.392 + TDblQue<CCluster> iCache;
1.393 + };
1.394 +
1.395 +/**
1.396 +@internalComponent
1.397 +*/
1.398 +NONSHARABLE_CLASS(CDbStoreRecords) : public CDbRecordSpace
1.399 + {
1.400 +public:
1.401 + class TIteratorC;
1.402 + class CIter;
1.403 +public:
1.404 + static TStreamId CreateL(CClusterCache& aCache);
1.405 + static CDbStoreRecords* NewL(CClusterCache& aCache,const CDbStoreDef& aDef);
1.406 +//
1.407 + static TInt CardinalityL(CStreamStore& aStore,const CDbStoreDef& aDef);
1.408 +//
1.409 + TBool GotoL(TDbPosition aPosition,TIteratorC& anIterator);
1.410 + TBool GotoL(TDbRecordId aRecordId,TIteratorC& anIterator);
1.411 + TBool DeletedL(TDbPosition aPosition,TIteratorC& anIterator);
1.412 +//
1.413 + inline TClusterId Head() const;
1.414 + inline TInt Count() const;
1.415 + TInt DiscardL(TClusterId& aCluster);
1.416 + TClusterId AlterL(TClusterId aCluster,CCluster::MAlter& anAlterer);
1.417 + void DestroyL();
1.418 +// providing for CDbRecordSpace
1.419 + TBool ExistsL(TDbRecordId aRecordId);
1.420 + TPtrC8 ReadL(TDbRecordId aRecordId) const;
1.421 + TUint8* DoReplaceL(TDbRecordId aRecordId,TInt aRecordSize);
1.422 + TUint AutoIncrementL();
1.423 + TUint8* DoNewL(TInt aRecordSize);
1.424 + TDbRecordId AppendL();
1.425 + void DoEraseL(TDbRecordId aRecordId);
1.426 + CDbRecordIter* IteratorL();
1.427 + TBool RestoreL();
1.428 + void SynchL();
1.429 +private:
1.430 + CDbStoreRecords(CClusterCache& aCache);
1.431 + ~CDbStoreRecords();
1.432 +//
1.433 + TUint8* UpdateRecordL(TDbRecordId aRecordId,TInt aNewSize);
1.434 + void DesL(TClusterDes& aDes,TClusterId aCluster);
1.435 + void CompleteMapL();
1.436 + TClusterId NextClusterL(TClusterDes& aDes,TClusterId aCluster);
1.437 + TClusterId PreviousClusterL(TClusterDes& aDes,TClusterId aCluster);
1.438 + TBool LocateL(TClusterId aCluster);
1.439 +private:
1.440 + class TToken
1.441 + {
1.442 + public:
1.443 + void InternalizeL(RReadStream& aStream);
1.444 + void ExternalizeL(RWriteStream& aStream) const;
1.445 + public:
1.446 + TClusterId iHead;
1.447 + TDbRecordId iNext;
1.448 + TInt iCount;
1.449 + TUint iAutoIncrement;
1.450 + };
1.451 +private:
1.452 + CClusterCache& iCache;
1.453 + TStreamId iTokenId;
1.454 + TToken iToken;
1.455 + TInt iClustering;
1.456 + TClusterLinkCache iLinks;
1.457 + RClusterMap iMap;
1.458 + };
1.459 +
1.460 +/**
1.461 +@internalComponent
1.462 +*/
1.463 +NONSHARABLE_CLASS(CDbStoreBlobs) : public CDbBlobSpace
1.464 + {
1.465 +public:
1.466 + CDbStoreBlobs(CDbStoreDatabase& aDatabase,TInt aInlineLimit);
1.467 +//
1.468 + MStreamBuf* DoCreateL(TDbBlobId &aBlobId,TDbColType aType);
1.469 + MStreamBuf* ReadL(TDbBlobId aBlobId,TDbColType aType) const;
1.470 + void DoDeleteL(TDbBlobId aBlobId);
1.471 +private:
1.472 + CDbStoreDatabase& iDatabase;
1.473 + };
1.474 +
1.475 +/**
1.476 +@internalComponent
1.477 +*/
1.478 +NONSHARABLE_CLASS(CDbStoreIndex) : public CDbRecordIndex
1.479 + {
1.480 +public:
1.481 + class HKey;
1.482 + class HDupKey;
1.483 + class CIter;
1.484 + class CDiscarder;
1.485 + class CRecover;
1.486 + class CRepair;
1.487 +public:
1.488 + static CDbStoreIndex* NewL(CDbStoreDatabase& aDatabase,const CDbStoreIndexDef& aDef,const CDbTableDef& aTable);
1.489 + ~CDbStoreIndex();
1.490 +//
1.491 + static TStreamId CreateL(CDbStoreDatabase& aDatabase,const CDbStoreIndexDef& aDef);
1.492 + static TBool IsDamagedL(CDbStoreDatabase& aDatabase,const CDbStoreIndexDef& aDef);
1.493 +//
1.494 + inline HKey& Key() const;
1.495 + inline const TBtree& Tree() const;
1.496 + inline TInt Count() const;
1.497 + void RepairL();
1.498 + void DiscardL();
1.499 + void DestroyL();
1.500 +private:
1.501 + CDbStoreIndex(CDbStoreDatabase& aDatabase,const CDbStoreIndexDef& aDef);
1.502 +//
1.503 + void RefreshStatsL();
1.504 +// CDbTableIndex framework
1.505 + TFind FindL(TDbRecordId aRecordId,const RDbTableRow& aRow);
1.506 + TBool DoInsertL(TDbRecordId aRecordId,const RDbTableRow& aRow);
1.507 + void DoDeleteL(TDbRecordId aRecordId,const RDbTableRow& aRow);
1.508 + CDbRecordIter* IteratorL(TUint aInclusion,const TDbLookupKey* aLowerBound,const TDbLookupKey* aUpperBound);
1.509 + TBool RestoreL();
1.510 + void AboutToModifyL();
1.511 + void SynchL();
1.512 +private:
1.513 + CDbStoreDatabase& iDatabase;
1.514 + TStreamId iTokenId;
1.515 + TBtree iTree;
1.516 + HKey* iKey;
1.517 + TBtreeInlineLeafOrg iLeafOrg;
1.518 + TBtreeInlineIndexOrg iIndexOrg;
1.519 + TDbStoreIndexStats& iStats;
1.520 + };
1.521 +
1.522 +/**
1.523 +@internalComponent
1.524 +*/
1.525 +NONSHARABLE_CLASS(CDbStoreIndex::CDiscarder) : public CDbTableDatabase::CStepper
1.526 + {
1.527 +public:
1.528 + CDiscarder();
1.529 + ~CDiscarder();
1.530 + TInt Open(CDbStoreIndex* anIndex);
1.531 +private:
1.532 + TInt StepL(TInt aStep);
1.533 +private:
1.534 + CDbStoreIndex* iIndex;
1.535 + };
1.536 +
1.537 +/**
1.538 +@internalComponent
1.539 +*/
1.540 +NONSHARABLE_CLASS(CDbStoreTable) : public CDbTable
1.541 + {
1.542 +public:
1.543 + class CDiscarder;
1.544 + class CAlter;
1.545 + class CCompressor;
1.546 + friend class CDiscarder;
1.547 + friend class CAlter;
1.548 + friend class CCompressor;
1.549 +public:
1.550 + CDbStoreTable(CDbStoreDatabase& aDatabase,const CDbTableDef& aDef);
1.551 +private:
1.552 + inline const CDbStoreDef& Def() const;
1.553 + inline CDbStoreDatabase& Database();
1.554 + inline CDbStoreRecords& StoreRecordsL();
1.555 +//
1.556 + TInt RowSize(const TUint8* aRec,TInt aLength);
1.557 + const TUint8* CopyToRowL(TDbCell* aCell,TInt aSize,const TUint8* aRec);
1.558 + TUint8* AlterRecordL(TUint8* aWPtr,const TUint8* aRPtr,TInt aLength,TInt aInlineLimit);
1.559 +// providing for CDbTable framework
1.560 + TInt IndexSpanL(const CDbTableIndexDef& aIndex,TUint aInclusion,const TDbLookupKey* aLowerBound,const TDbLookupKey* aUpperBound);
1.561 + CDbRecordSpace* RecordSpaceL();
1.562 + CDbBlobSpace* BlobSpaceL();
1.563 + CDbRecordIndex* RecordIndexL(const CDbTableIndexDef& anIndex);
1.564 + void CopyToRowL(RDbRow& aRow,const TDesC8& aRecord);
1.565 + TInt RecordLength(const RDbRow& aRow);
1.566 + TInt OptimizedRowLength(const RDbRow& aRow);
1.567 + void CopyFromRow(TUint8* aRecord,const RDbRow& aRow);
1.568 + };
1.569 +
1.570 +/**
1.571 +@internalComponent
1.572 +*/
1.573 +NONSHARABLE_CLASS(CDbStoreTable::CDiscarder) : public CDbTableDatabase::CStepper, public CCluster::MAlter
1.574 + {
1.575 +private:
1.576 + enum {EDiscardClusters=32,EBlobDiscardClusters=2};
1.577 +public:
1.578 + CDiscarder();
1.579 + ~CDiscarder();
1.580 + TInt OpenL(CDbStoreTable* aTable);
1.581 +private:
1.582 + TInt StepL(TInt aStep);
1.583 + TUint8* AlterRecordL(TUint8* aWPtr,const TUint8* aRPtr,TInt aLength);
1.584 +private:
1.585 + CDbStoreTable* iTable;
1.586 + CDbStoreRecords* iRecords;
1.587 + TClusterId iCluster;
1.588 + RDbRow iRow;
1.589 + };
1.590 +
1.591 +/**
1.592 +@internalComponent
1.593 +*/
1.594 +NONSHARABLE_CLASS(CDbStoreTable::CAlter) : public CDbTableDatabase::CStepper, public CCluster::MAlter
1.595 + {
1.596 +public:
1.597 + CAlter();
1.598 + ~CAlter();
1.599 + void OpenL(CDbStoreTable* aTable,const HDbColumnSet& aNewSet);
1.600 +private:
1.601 + TUint8* AlterRecordL(TUint8* aWPtr,const TUint8* aRPtr,TInt aLength);
1.602 + TInt RecordExpansion(const TUint8* aRec,TInt aLength);
1.603 + TInt StepL(TInt aStep);
1.604 +private:
1.605 + TInt iExpansion;
1.606 + TInt iInlineLimit;
1.607 + CDbStoreTable* iTable;
1.608 + CDbStoreRecords* iRecords;
1.609 + TClusterId iCluster;
1.610 + TInt iStep;
1.611 + };
1.612 +
1.613 +/**
1.614 +@internalComponent
1.615 +*/
1.616 +class RDbStoreReadStream : public RStoreReadStream
1.617 + {
1.618 +public:
1.619 + enum TType {EMixed,EBinary,EText};
1.620 +public:
1.621 + inline RDbStoreReadStream(CDbStoreDatabase& aDatabase)
1.622 + :iDatabase(aDatabase)
1.623 + {}
1.624 + void FilterL(TType aType,TUint32 aInit);
1.625 +private:
1.626 + CDbStoreDatabase& iDatabase;
1.627 + };
1.628 +
1.629 +/**
1.630 +@internalComponent
1.631 +*/
1.632 +class RDbStoreWriteStream : public RStoreWriteStream
1.633 + {
1.634 +public:
1.635 + enum TType {EMixed,EBinary,EText};
1.636 +public:
1.637 + inline RDbStoreWriteStream(CDbStoreDatabase& aDatabase)
1.638 + :iDatabase(aDatabase)
1.639 + {}
1.640 + void FilterL(TType aType,TUint32 aInit);
1.641 +private:
1.642 + CDbStoreDatabase& iDatabase;
1.643 + };
1.644 +
1.645 +/**
1.646 +@internalComponent
1.647 +*/
1.648 +class MDbStreamFilter
1.649 + {
1.650 +public:
1.651 + virtual MStreamBuf* FilterL(MStreamBuf* aHost,TUint32 aInit,RDbStoreReadStream::TType aType) =0;
1.652 + virtual MStreamBuf* FilterL(MStreamBuf* aHost,TUint32 aInit,RDbStoreWriteStream::TType aType) =0;
1.653 + };
1.654 +
1.655 +
1.656 +/**
1.657 +@internalComponent
1.658 +*/
1.659 +NONSHARABLE_CLASS(CDbStoreCompression) : public CBase, public MDbStreamFilter
1.660 + {
1.661 +public:
1.662 + /**
1.663 + @internalComponent
1.664 + */
1.665 + class TEncoding
1.666 + {
1.667 + public:
1.668 + enum {ELiterals=256,ELengths=28,ESpecials=1,EDistances=44};
1.669 + enum {ELitLens=ELiterals+ELengths+ESpecials};
1.670 + enum {EEos=ELiterals+ELengths};
1.671 + public:
1.672 + TUint32 iLitLen[ELitLens];
1.673 + TUint32 iDistance[EDistances];
1.674 + };
1.675 +public:
1.676 + static CDbStoreCompression* NewL();
1.677 +//
1.678 + void EncodeL();
1.679 + inline void Inflate();
1.680 + void ExternalizeL(RWriteStream& aStream) const;
1.681 + void InternalizeL(RReadStream& aStream);
1.682 +// for MDbStreamFilter
1.683 + MStreamBuf* FilterL(MStreamBuf* aHost,TUint32 aInit,RDbStoreReadStream::TType aType);
1.684 + MStreamBuf* FilterL(MStreamBuf* aHost,TUint32 aInit,RDbStoreWriteStream::TType aType);
1.685 +private:
1.686 + inline CDbStoreCompression();
1.687 +private:
1.688 + enum TState {EAnalysis,EEncoding,EDecoding,EInflating};
1.689 +private:
1.690 + TState iState;
1.691 + TEncoding iEncoding[3];
1.692 + };
1.693 +
1.694 +#include "US_STD.INL"