/*

* Copyright (c) 2010 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: 

*     Retrieving maptile path from lookup db implementation

*

*/

#include <bautils.h>

#include <maptileservice.h>

#include "maptiledblookuptable.h"

// select all from

_LIT( KSelectAllFrom, "SELECT * FROM " );

// string 'where'

_LIT( KStringWhere, " WHERE " );

// string ' = '

_LIT( KStringEqual, " = " );

// string 'And'

_LIT( KStringAnd, " AND " );

_LIT(KQueryByMaptileState,"SELECT * FROM cntmaptilelookuptable WHERE cntuid = %d AND ( fetchingstatus = %d OR fetchingstatus = %d )");

// -----------------------------------------------------------------------------

// CLookupMapTileDatabase::CLookupMapTileDatabase()

// Default constructor.

// -----------------------------------------------------------------------------

//

CLookupMapTileDatabase::CLookupMapTileDatabase()

{

}

// -----------------------------------------------------------------------------

// CLookupMapTileDatabase::~CLookupMapTileDatabase()

// Destructor.

// -----------------------------------------------------------------------------

//

CLookupMapTileDatabase::~CLookupMapTileDatabase()

{

    // close the database

	iItemsDatabase.Close();

	// close the file session

	iFsSession.Close();

}

// -----------------------------------------------------------------------------

// CLookupMapTileDatabase::~CLookupMapTileDatabase()

// Creates an object of this class and pushes to cleanup stack.

// -----------------------------------------------------------------------------

//

CLookupMapTileDatabase* CLookupMapTileDatabase::NewLC( const TDesC& aLookupTableName )

{

    CLookupMapTileDatabase* self = new (ELeave) CLookupMapTileDatabase;

    CleanupStack::PushL(self);

    self->ConstructL( aLookupTableName );

    return self;

}

// -----------------------------------------------------------------------------

// CLookupMapTileDatabase::NewL()

// Creates an object of this class.

// -----------------------------------------------------------------------------

//

CLookupMapTileDatabase* CLookupMapTileDatabase::NewL( const TDesC& aLookupTableName )

{

    CLookupMapTileDatabase* self = CLookupMapTileDatabase::NewLC( aLookupTableName );

    CleanupStack::Pop( self );

    return self;

}

// -----------------------------------------------------------------------------

// CLookupMapTileDatabase::ConstructL()

// 2nd phase contructor.

// -----------------------------------------------------------------------------

//

void CLookupMapTileDatabase::ConstructL( const TDesC& aLookupTableName )

{

    User::LeaveIfError( iFsSession.Connect() );

    iDbFileName.Copy( KLookupDbPath );

    iDbFileName.Append( aLookupTableName );

    iDatabaseExists = EFalse; 

    if( BaflUtils::FileExists( iFsSession, iDbFileName ) )

    {	

        // database exists 

        iDatabaseExists = ETrue; 

    }

}

// -----------------------------------------------------------------------------

// CLookupMapTileDatabase::FindNumberOfAddressL()

// find the number of address associated with the aId.

// -----------------------------------------------------------------------------

//

int CLookupMapTileDatabase::FindNumberOfAddressL( int& aId )

{

    int count = 0;

    // Create a query to find the item.

    TFileName queryBuffer;

    queryBuffer.Format( KQueryByMaptileState,aId,

             MapTileService::MapTileFetchingInProgress,

             MapTileService::MapTileFetchingNetworkError );

    TInt ret = iItemsDatabase.Open( iFsSession, iDbFileName );

    if( ret != KErrNone )

    {          

        //if already opened , close and open again

        iItemsDatabase.Close();          

        User::LeaveIfError( iItemsDatabase.Open( iFsSession, iDbFileName ) );

    }

    User::LeaveIfError( iItemsDatabase.Begin() );       

    // Create a view of the table with the above query.

    RDbView myView;

    myView.Prepare( iItemsDatabase, TDbQuery( queryBuffer ) );

    CleanupClosePushL( myView );

    myView.EvaluateAll();

    myView.FirstL();

    while (myView.AtRow())

    {

        count++;

        myView.NextL();

    }

    CleanupStack::PopAndDestroy( &myView ); // myView

    //Close the database

    iItemsDatabase.Close();

    return count;

}

// -----------------------------------------------------------------------------

// CLookupMapTileDatabase::FindEntryL()

// Finds an entry in the lookup table.

// -----------------------------------------------------------------------------

//

void CLookupMapTileDatabase::FindEntryL( TLookupItem& aLookupItem )

{ 

    // used to check whether entry available or not

    TBool entryAvailable = EFalse;

    if ( iDatabaseExists )

    {

        // Create a query to find the item.

        TFileName queryBuffer;

        queryBuffer.Copy( KSelectAllFrom );

        queryBuffer.Append( KMapTileLookupTable );

        queryBuffer.Append( KStringWhere );

        queryBuffer.Append( NCntColUid );

        queryBuffer.Append( KStringEqual );

        queryBuffer.AppendNum( aLookupItem.iUid );

        queryBuffer.Append( KStringAnd );

        queryBuffer.Append( NColSource );

        queryBuffer.Append( KStringEqual );

        queryBuffer.AppendNum( aLookupItem.iSource );

        TInt ret = iItemsDatabase.Open( iFsSession, iDbFileName );

        if( ret != KErrNone )

        {          

            //if already opened , close and open again

            iItemsDatabase.Close();          

            User::LeaveIfError( iItemsDatabase.Open( iFsSession, iDbFileName ) );

        }

        User::LeaveIfError( iItemsDatabase.Begin() );       

        // Create a view of the table with the above query.

        RDbView myView;

        myView.Prepare( iItemsDatabase, TDbQuery( queryBuffer ) );

        CleanupClosePushL( myView );

        myView.EvaluateAll();

        myView.FirstL();

        if( myView.AtRow() ) 

        {  

            // Item found. get the details.

            myView.GetL();      

            if( aLookupItem.iUid == myView.ColUint( KColumnUid ) )

            {               

                aLookupItem.iFilePath.Copy( myView.ColDes16( KColumnFilePath ) );

                aLookupItem.iFetchingStatus = myView.ColUint( KColumnMapTileFetchingStatus );

                entryAvailable = ETrue;

            }      

        } 

        CleanupStack::PopAndDestroy( &myView ); // myView

        //Close the database

        iItemsDatabase.Close();

    }

    //No entry found 

    if( !entryAvailable )

    {

        User::Leave( KErrNotFound );

    }

}

// End of file