diff -r 000000000000 -r 95b198f216e5 wmdrm/wmdrmengine/wmdrmserver/server/inc/wmdrmdb.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/wmdrm/wmdrmengine/wmdrmserver/server/inc/wmdrmdb.h	Thu Dec 17 08:52:27 2009 +0200
@@ -0,0 +1,180 @@
+/*
+* Copyright (c) 2008 Nokia Corporation and/or its subsidiary(-ies).
+* All rights reserved.
+* This component and the accompanying materials are made available
+* under the terms of "Eclipse Public License v1.0"
+* which accompanies this distribution, and is available
+* at the URL "http://www.eclipse.org/legal/epl-v10.html".
+*
+* Initial Contributors:
+* Nokia Corporation - initial contribution.
+*
+* Contributors:
+*
+* Description:  WMDRM database access interface
+*
+*/
+
+
+#ifndef C_WMDRMDB_H
+#define C_WMDRMDB_H
+
+#include <sqldb.h>
+#include "wmdrmserver.h"
+/**
+ *  Interface class to wmdrm database
+ *
+ *  @since S60 v3.2
+ */
+class CWmDrmDb : public CTimer
+    {
+public:
+
+    /** table type */
+    enum TWmDrmTableType
+        {
+        EWmDrmLicenseTable,
+        EWmDrmSecureTable,
+        EWmDrmSyncTable,
+        EWmDrmMeteringTable
+        };
+        
+    static CWmDrmDb* NewL( CWmDrmServer* aServer );
+    static CWmDrmDb* NewLC( CWmDrmServer* aServer );
+
+    virtual ~CWmDrmDb();
+
+    void InitStoreL( 
+        const TDesC8& aStore,
+        TBool aCreateIfMissing );
+    
+    void InitNameSpaceL( 
+        const TDesC8& aStore,
+        const TDesC8& aNamespace,
+        TBool aCreateIfMissing );
+
+    void RemoveStoreL( const TDesC8& aStore );
+
+    void RemoveNameSpaceL( 
+        const TDesC8& aStore,
+        const TDesC8& aNamespace );
+    
+    void DeleteLicenseStoreL();
+
+    void CreateRecordL(  
+        const TDesC8& aStore,
+        const TDesC8& aNamespace,
+        const TDesC8& aHashKey,
+        const TDesC8& aUniqueKey,
+        const TInt&   aSize );
+
+    void ReadRecordL( 
+        const TDesC8& aStore,
+        const TDesC8& aNamespace,
+        const TDesC8& aHashKey,
+        const TDesC8& aUniqueKey );
+
+    void GetDataSizeL( TInt& aDataSize );
+
+    void DeleteData();
+
+    void DeleteRecordL(  
+        const TDesC8& aStore,
+        const TDesC8& aNamespace,
+        const TDesC8& aHashKey,
+        const TDesC8& aUniqueKey );
+
+    void ReadDataL( TDes8& aData );
+
+    void WriteDataL(  
+        const TDesC8& aStore,
+        const TDesC8& aNamespace,
+        const TDesC8& aHashKey,
+        const TDesC8& aUniqueKey, 
+        TDesC8& aData );
+    
+    void EnumerateDataL(  
+        const TDesC8& aStore,
+        const TDesC8& aNamespace,
+        const TDesC8& aHashKey,
+        RPointerArray<HBufC8>& aUniqueKeyEntries );
+    
+    void EnumerateNameSpaceStartL(  
+        const TDesC8& aStore,
+        const TDesC8& aNamespace );
+    
+    void EnumerateNameSpaceNextL(  
+        TBuf8<KWmDrmIdSize>& aHashKey,
+        TBuf8<KWmDrmIdSize>& aUniqueKey );
+
+    TInt DataBaseSize( TBool aConfiguredDrive );
+
+
+protected: // from base class CActive
+    void RunL();
+    TInt RunError( TInt aError );
+
+private: // from base class CActive
+
+private:
+    CWmDrmDb( CWmDrmServer* aServer );
+    void ConstructL();
+    
+    void CreateDatabaseL( TFileName& aFileNamePath, RSqlDatabase& aDatabase, TBool aConfiguredDrive );
+    void CreateTableL( TWmDrmTableType aTableType, RSqlDatabase& aDatabase );
+    void DeleteTableL( TWmDrmTableType aTableType );
+    void SelectNRecordsWithRowIdL( TWmDrmTableType aTableType, TInt aNumber, RArray<TInt64>& aArray );
+    void DeleteRecordsWithRowIdsL( TWmDrmTableType aTableType, RArray<TInt64>& aArray );
+    void DropTableL( TWmDrmTableType aTableType );
+    TWmDrmTableType TableTypeL( const TDesC8& aNamespace );
+    void OpenDatabaseL( TFileName& aFileNamePath, RSqlDatabase& aDatabase, TBool aConfiguredDrive );
+    
+    void ConvertOldLicenseStoreL();
+    
+    // Checks how many SQL statements are prepared (buffered) currently and if either the maximum 
+    // amount of buffered statements is exceeded or an enforced commit is needed, COMMITs the 
+    // statements. The method also starts a new BEGIN statement after the commit operation to 
+    // start a new buffering round of SQL statements. This method also controls a timer for 
+    // triggering enforced commit after a predefined idle period without any prepared SQL statements. 
+    void CheckDatabaseCommitL( TBool aEnforcedCommit );
+    void Activate();
+
+private: // data
+
+    // Not owned
+    CWmDrmServer* iServer;
+    
+    // Located in the system drive
+    RSqlDatabase    iDatabase;
+    // Located in the configured drive (internal mass drive)
+    RSqlDatabase    iDatabase2;
+
+    HBufC8* iData;
+    
+    RSqlStatement iEnumerateNamespaceStmt;
+    TInt iEnumerateNamespaceHashKeyColumnIndex;
+    TInt iEnumerateNamespaceUniqueKeyColumnIndex;
+    TBool iEnumerateNamespaceStarted;
+    
+    // Path in the system drive for the data base
+    TFileName iDatabasePath;
+    // Path in the internal mass drive (configured drive)
+    TFileName iDatabasePath2;
+    
+    // Whether WM DRM rights storing location is found to be
+    // configured to the internal mass drive or not
+    TBool iWmDrmRightsConfigFound;
+    
+    // Amount of cached database import, update or delete operations that will be committed
+    // to the database when certain conditions are met.
+    TInt iAmountOperationsWithoutCommit;
+    
+    // When the flag is on, an SQL BEGIN statement has been issued, but not committed 
+    // with COMMIT statement. The first one is for the database on the system drive and the 
+    // second one is for the database on the configured drive. 
+    TBool iSqlTransactionOngoing;
+    TBool iSqlTransactionOngoing2;
+    
+    };
+
+#endif // ? C_CLASSNAME_H