// Copyright (c) 2009 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:
//

/**
 @file
 @internalTechnology
*/

#ifndef CMEDIASYNCDATABASE_H
#define CMEDIASYNCDATABASE_H

#include <d32dbms.h>
#include <comms-infras/commsdebugutility.h>
#include <mdesession.h>
#include <mdccommon.h>
#include <comms-infras/commsdebugutility.h>

class CMediaSyncDataWriter;
class CMdESession;

class CMediaSyncDatabase : public CBase
    {
public:
    static CMediaSyncDatabase* NewL(RFs& aFs);
    ~CMediaSyncDatabase();

    /**        
    * Save MDS notification to database
    *
    * @param aObjectIdArray array of changed object id
    * @param aChangeType type of change related with this changed object
    *
    */
    void SaveNotificationsL(const RArray<TItemId>& aObjectIdArray, TObserverNotificationType aType, CMdESession& aSession); 
    
    /**        
    * Save MDS notification to database
    *
    * @param aObjectIdArray object IDs which are set to present statect
    * @param aPresent state: ETrue - present or  EFales - not present
    *
    */
    void SaveNotificationsL(const RArray<TItemId>& aObjectIdArray, TBool aPresent, CMdESession& aSession);     
    
    /**        
    * Delete all notification record from database
    * 
    */ 
    void RemoveAllNotificationsL();    
    
    /**
     * Delete specific notificaion by object id
     * 
     * @param aObjectId changed object id
     * 
     */
    TBool RemoveNotificationL(TItemId aObjectId, TUint aType);
    
    /**        
    * Get notification record from database
    *
    * @param aResulWriter on return contains serialized results
    * @param aIsFinished flag indicate whether all record has been fetched
    */    
    void FetchNotificationsL(CMediaSyncDataWriter& aResulWriter, TInt aMaxtFetchCount, TBool& aIsFinished);
    
    /**
     * Rollback the current transaction
     */
    void Rollback();
    
    /**
     * Check whether DB file is corrupt
     */
    inline TBool IsMssDbCorrupt() { return iDbCorrupt; }
    
    /**
     * Clear DB corrupt flag
     */    
    inline void ClearMssDbCorrupt() { iDbCorrupt = EFalse; }
    
private:
    CMediaSyncDatabase(RFs& aFs);
    void ConstructL();
    void CreateTableL(const TDesC& aDbFile);
    void CreateTabIndexL();
    
    void SaveAddNotificationsL(const RArray<TItemId>& aObjectIdArray, CMdESession& aSession);        
    void SaveAndCheckWithUriL(const RArray<TItemId>& aObjectIdArray, TUint aType, CMdESession& aSession);
    void SaveWithoutUriL(const RArray<TItemId>& aObjectIdArray, TUint aType);         
    void CompactDatabase();
    
    TBool UpdateUriColumnL(TItemId aObjectId, TUint aType, const TDesC& aUri);     
    TBool OptimizeL(TItemId aObjectId, TUint aType, const TDesC& aUri);
    inline TBool OptimizeL(TItemId aObjectId, TUint aType);
    
    static void RollbackTable(TAny* aTable);
    
private:
    /**
    FLOGGER debug trace member variable.
    */
    __FLOG_DECLARATION_MEMBER_MUTABLE;
    
    RFs&             iFs;
    RDbNamedDatabase iDatabase;
    RDbTable         iBatched;    
    TBool            iDbCorrupt;// flag that indicate whether database is corrupt
    TBool            iSavePosition;
    TDbBookmark      iBookmark;   
    TInt             iCompactCounter;
    };

#endif /*CMEDIASYNCDATABASE_H*/