/*

* 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:  Implementation of applicationmanagement components

 *

*/

#ifndef __SCOMOADAPTERDB_H

#define __SCOMOADAPTERDB_H

// INCLUDE FILES

#include <e32std.h>

#include <e32base.h>

#include <d32dbms.h>

#include <f32file.h>

#include <SyncMLDef.h>

// CONSTANTS

// null final result value

const TInt KAMNullResult = 0;

// Database name & location

const TInt KAMAdapterDbDrive = EDriveC;

const TUid KAMPolicyUID =

    {

    0x20021335

    };

const TInt KAMMaxPkgURLLength( 2048);

const TInt KAMMaxPkgNameLength( 80);

const TInt KAMMaxPkgVersionLength( 80);

_LIT( KDBMSSecureID, "secure[20021335]" );

_LIT( KAMAdapterDbName, "c:TARMAppMgmtAdapterDB.db" );

// Table and column names

_LIT( KTableAMMgmtObject, "AMMgmtObject" );

_LIT( KAMMgmtObjectId, "Id" );

_LIT( KAMMgmtObjectProfileId, "ProfileId" );

_LIT( KAMMgmtObjectServerId, "ServerId" );

_LIT( KAMMgmtObjectRetryCount, "RetryCount");

// SQL statements

_LIT( KCreateAMMgmtObjectTable, "CREATE TABLE AMMgmtObject ( Id \

COUNTER NOT NULL,  ProfileId INTEGER, ServerId CHAR(%d), RetryCount INTEGER" );

_LIT( KGetAMMgmtObject, "SELECT * FROM AMMgmtObject WHERE Id = %d" );

_LIT( KGetUnfinishedAMMgmtObjectByServerId, "SELECT * FROM AMMgmtObject \

WHERE Id = %d AND ServerId = '%S'" );

_LIT( KDeleteAMMgmtObject,"DELETE FROM AMMgmtObject WHERE Id = %d");

// Max. lengths of string fields in AMMgmtObject

const TInt KMaxMgmtUriLength = 60;

const TInt KMaxServerIdLength = 150;

const TInt KMaxCorrelatorLength = 150;

// Estimate of url size used in max row size (OOD checks)

const TInt KPkgURLLengthEstimate = 350;

// space needed for above integers in buffer

const TInt KAMMgmtObjectIntLength = 4;

// space needed for an integer in buffer

const TInt KAMMgmtObjectIntegerLength = 10;

// Size of empty AM database in bytes (+ additional treshold)

const TInt KAMAdapterEmptyDbSize = 350;

// Estimated maximum size of AMMgmtObject table row (+ additional treshold)

const TInt KMaxAMMgmtObjectRowSize = KAMMaxPkgNameLength

        + KAMMaxPkgVersionLength + KPkgURLLengthEstimate + KMaxMgmtUriLength

        + KMaxServerIdLength + KMaxCorrelatorLength + 115;

// TYPEDEFS

typedef TInt TDmAMObjectId;

typedef RArray<TDmAMObjectId> RDmAMObjectArray;

_LIT(NCol1, "Id");

_LIT(NCol2, "LUID");

_LIT(NCol3, "ProfileId");

_LIT(NCol4, "ServerId");

_LIT(NCol5, "Correlator");

_LIT(NCol6, "SourceURI");

_LIT(NCol7, "RetryCount");

class CAMDbItem : public CBase

    {

public:

    static CAMDbItem* NewL();

    ~CAMDbItem();

    TInt id;

    TUint32 iLUID;

    TInt iProfileId;

    HBufC8* iServerID;

    HBufC8* iCorrelator;

    HBufC8* iSourceURI;

    TInt iRetryCount;

    };

// CLASS DECLARATION

/**

 *  CSCOMOAdapterDb provides an interface for accessing AM database.

 *  

 *  @lib SCOMOAdapter.lib

 *  

 */

class CSCOMOAdapterDb : public CBase

    {

public:

    /**

     * Two-phased constructor.

     * @return A pointer to the newly created instance.

     */

    static CSCOMOAdapterDb* NewL();

    /**

     * Two-phased constructor. Pushes the pointer onto the CleanupStack.

     * @return A pointer to the newly created instance.

     */

    static CSCOMOAdapterDb* NewLC();

    /**

     * Destructor.

     */

    virtual ~CSCOMOAdapterDb();

    void CreateTableL(RDbDatabase& aDatabase);

    void CreateandOpenL(TParse& name);

    TBool DeleteFromDatabaseL(TUint32 aLuid);

    void SaveToDatabaseL(TInt& aIndex, TUint32 aLuid, TInt aProfileid,

            TInt aRetryCount, const TDesC8& aSourceURI,

            const TDesC8& aServerid, const TDesC8& aCorrelator);

    void ReadItemsL(RPointerArray<CAMDbItem>& aItemArray, TDesC& aSqlQuery);

    void ReadDbItemsL(RPointerArray<CAMDbItem>& aItemArray);

    void GetEntryForServerIDL(RPointerArray<CAMDbItem>& aItemArray, TDesC8& aValue);

    void UpdateRetryCountForLuidL(TInt aLuid, TInt aRetryCount);

    TInt GetRetryCountForLuidL(TInt aLuid);

    void BeginDatabaseTransaction();

    void CommitDatabaseTransaction();

    void PrepareLuidQuery(TInt aLuid, TDes& aSqlQuery);

private:

    void ConstructL();

    CSCOMOAdapterDb();

private:

    RDbNamedDatabase iDatabase;

    RFs iFsSession;

    RDbs iRdbSession;

    RDbTable iAMObjectTable;

    CDbColSet* iColSet;

    RDbView iView;

    };

#endif // __AMADAPTERDB_H   

// End of File