/*

 * 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: CCASqlQuery implementation

 *

 */

#include <sqldb.h>

#include "casqlquery.h"

#include "casqlcommands.h"

#include "cainnerquery.h"

#include "caentryattribute.h"

#include "casqlquerycreator.h"

#include "caoperationparams.h"

#include "cadef.h"

#include "calocalizationentry.h"

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

//

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

//

CCaSqlQuery::CCaSqlQuery( RSqlDatabase& aSql ) :

    iSqlDb( aSql )

    {

    }

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

//

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

//

CCaSqlQuery::~CCaSqlQuery()

    {

    iStatement.Close();

    iQuery.Close();

    }

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

//

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

//

CCaSqlQuery* CCaSqlQuery::NewLC( RSqlDatabase& aSql )

    {

    CCaSqlQuery* self = new ( ELeave ) CCaSqlQuery( aSql );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

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

//

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

//

CCaSqlQuery* CCaSqlQuery::NewL( RSqlDatabase& aSql )

    {

    CCaSqlQuery* self = CCaSqlQuery::NewLC( aSql );

    CleanupStack::Pop( self );

    return self;

    }

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

//

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

//

void CCaSqlQuery::ConstructL()

    {

    }

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

//

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

//

void CCaSqlQuery::PrepareL()

    {

    User::LeaveIfError( iStatement.Prepare( iSqlDb, iQuery ) );

    }

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

//

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

//

void CCaSqlQuery::CloseStatement()

    {

    iStatement.Close();

    }

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

//

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

//

void CCaSqlQuery::ResetStatement()

    {

    iStatement.Reset();

    }

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

//

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

//

void CCaSqlQuery::BindValuesForAddL( const CCaInnerEntry* aEntry )

    {

    switch ( Type() )

        {

        case EEntryTable: // = 1

            {

            BindValuesForAddEntryL( aEntry );

            break;

            }

        case EIconTable:

            {

            BindValuesForAddIconL( aEntry );

            break;

            }

        case EAttributeTable:

            {

            break;

            }

        default:

            User::Leave( KErrNotSupported );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForAddEntryL( const CCaInnerEntry* aEntry )

    {

    if( iQuery.Find( KSQLEnText ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( KSQLEnText ),

                aEntry->GetText() );

        }

    if( iQuery.Find( KSQLEnDescription )!= KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( KSQLEnDescription ),

                aEntry->GetDescription() );

        }    

    if( iQuery.Find( KSQLEnRole ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnRole ),

                aEntry->GetRole() );

        }

    if( iQuery.Find( KSQLEnTypeName ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( KSQLEnTypeName ),

                aEntry->GetEntryTypeName() );

        }

    if( iQuery.Find( KSQLEnIdIcon ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnIdIcon ),

                aEntry->GetIconId() );

        }

    if( iQuery.Find( KSQLEnCreationTime ) != KErrNotFound )

        {

        TTime currentTime( 0 );

        currentTime.UniversalTime();

        BindInt64L( iStatement.ParameterIndex( KSQLEnCreationTime ),

                currentTime.Int64() );

        }

    if( iQuery.Find( KSQLEnUid ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnUid ),

                aEntry->GetUid() );

        }

    if( iQuery.Find( KSQLEnFlags )!= KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnFlags ),

                aEntry->GetFlags() );

        }

    if( iQuery.Find( KSQLEntryId ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEntryId ),

                aEntry->GetId() );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForAddIconL( const CCaInnerEntry* aEntry )

    {

    BindValuesForGetIconL( aEntry );

    }

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

//

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

//

void CCaSqlQuery::BindValuesForAddAttributeL( const CCaInnerEntry* aEntry,

        const CCaEntryAttribute* aAttr )

    {

    if( iQuery.Find( KSQLAttrEntryID ) != KErrNotFound )

        {

        BindIntL(iStatement.ParameterIndex( KSQLAttrEntryID ),

                aEntry->GetId() );

        }

    if( iQuery.Find( KSQLAttrName ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( KSQLAttrName ),

                aAttr->Name() );

        }

    if( iQuery.Find( KSQLAttrValue ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( KSQLAttrValue ),

                aAttr->Value() );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForOrganizeL( const RArray<TInt>& aEntryIds,

        TCaOperationParams& aParams, const TInt aEntryId )

    {

    if( aEntryIds.Count() > 0 )

        {

        BindIdsL( aEntryIds, KSQLEntryId );

        }

    if( iQuery.Find( KSQLGEIdGroup ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLGEIdGroup ),

                aParams.iGroupId );

        }

    if( iQuery.Find( KSQLEntryIdBefore ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEntryIdBefore ),

                aParams.iBeforeEntryId );

        }

    if( iQuery.Find( KSQLGEEntryId ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLGEEntryId ), aEntryId );

        }

    if( iQuery.Find( KSQLShiftThreshold ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLShiftThreshold ),

                aEntryIds.Count() );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForLaunchL( const TInt aEntryId,

        const TInt64 aLaunchTime )

    {

    if( iQuery.Find( KSQLLaLaunchEntryId ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( 

                KSQLLaLaunchEntryId ), aEntryId );

        }

    if( iQuery.Find( KSQLLaLaunchTime ) != KErrNotFound )

        {

        BindInt64L( iStatement.ParameterIndex( 

                KSQLLaLaunchTime ), aLaunchTime );

        }

    if( iQuery.Find( KSQLEnFlags ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnFlags ), EUsed );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForRemoveL( const TInt aEntryId,

        const TInt aIconId )

    {

    if( iQuery.Find( KSQLEntryId )!= KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEntryId ), aEntryId );

        }

    if( iQuery.Find( KSQLIconId )!= KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLIconId ), aIconId );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForCustomSortL( const TInt aGroupId, const TInt aEntryId,

        const TInt aNewPostion )

    {

    if( iQuery.Find( KSQLGEIdGroup )!= KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLGEIdGroup ), aGroupId );

        }

    if( iQuery.Find( KSQLGEEntryId )!= KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLGEEntryId ), aEntryId );

        }

    if( iQuery.Find( KSQLGEPosition )!= KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLGEPosition ), aNewPostion );

        }

    }

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

//

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

//

void CCaSqlQuery::BindTextL( TInt aParameterIndex,

        const TDesC& aParameterValue )

    {

    User::LeaveIfError( iStatement.BindText( aParameterIndex,

            aParameterValue ) );

    }

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

//

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

//

void CCaSqlQuery::BindIntL( TInt aParameterIndex,

        TInt aParameterValue )

    {

    User::LeaveIfError( aParameterIndex );

    User::LeaveIfError( iStatement.BindInt( aParameterIndex,

            aParameterValue ) );

    }

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

//

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

//

void CCaSqlQuery::BindInt64L( TInt aParameterIndex,

        TInt64 aParameterValue )

    {

    User::LeaveIfError( aParameterIndex );

    User::LeaveIfError( iStatement.BindInt64( aParameterIndex,

            aParameterValue ) );

    }

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

//

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

//

void CCaSqlQuery::SetQueryL( const TDesC& aQuery )

    {

    iQuery.Close();

    iQuery.CreateL( aQuery );

    }

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

//

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

//

void CCaSqlQuery::BindValuesForLocalizeL( CCaLocalizationEntry& aLocalization )

    {

    if( iQuery.Find( KSQLLocRowId ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( 

        		KSQLLocRowId ), aLocalization.GetRowId() );

        }

    if( iQuery.Find( KSQLLocTable ) != KErrNotFound )

        {

        BindTextL(iStatement.ParameterIndex( KSQLLocTable ),

                aLocalization.GetTableName() );

        }

    if( iQuery.Find( KSQLLocAttribute ) != KErrNotFound )

        {

        BindTextL(iStatement.ParameterIndex( KSQLLocAttribute ),

                aLocalization.GetAttributeName() );

        }

    if( iQuery.Find( KSQLLocString ) != KErrNotFound )

        {

        BindTextL(iStatement.ParameterIndex( KSQLLocString ),

                aLocalization.GetLocalizedString() );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForPropertyL( const TDesC& aProperty )

    {

    if( iQuery.Find( KSQLDbProperty ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( 

                KSQLDbProperty ), aProperty );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForPropertyUpdateL( const TDesC& aProperty, const TDesC& aPropertyValue )

    {

    BindValuesForPropertyL( aProperty );

    if( iQuery.Find( KSQLDbValue ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( 

                KSQLDbValue ), aPropertyValue );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForGetEntriesL( const CCaInnerQuery* aQuery )

    {

    if( aQuery->GetIds().Count() > 0 )

        {

        BindIdsL( aQuery->GetIds(), KSQLEntryId );

        }

    else

        {

        if( aQuery->GetFlagsOn() != 0 && iQuery.Find( KSQLFlagsOn )

                != KErrNotFound )

            {

            BindIntL( iStatement.ParameterIndex( KSQLFlagsOn ),

                    aQuery->GetFlagsOn() );

            }

        if( aQuery->GetFlagsOff() != 0 && iQuery.Find( KSQLFlagsOff )

                != KErrNotFound )

            {

            BindIntL( iStatement.ParameterIndex( KSQLFlagsOff ),

                    aQuery->GetFlagsOff() );

            }

        if( aQuery->GetRole() != -1 && iQuery.Find( KSQLEnRole )

                != KErrNotFound )

            {

            BindIntL( iStatement.ParameterIndex( KSQLEnRole ),

                    aQuery->GetRole() );

            }

        if( aQuery->GetParentId() != -1 && iQuery.Find( KSQLGEIdGroup )

                != KErrNotFound )

            {

            BindIntL( iStatement.ParameterIndex( KSQLGEIdGroup ),

                    aQuery->GetParentId() );

            }

        if( aQuery->GetUid() != 0 && iQuery.Find( KSQLEnUid )

                != KErrNotFound )

            {

            BindIntL( iStatement.ParameterIndex( KSQLEnUid ),

                    aQuery->GetUid() );

            }

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForGetEntriesL( const CCaInnerEntry* aEntry )

    {

    if( iQuery.Find( KSQLEntryId ) != KErrNotFound )

        {

        BindIntL(iStatement.ParameterIndex( KSQLEntryId ), 

                aEntry->GetId() );

        }

    if( iQuery.Find( KSQLEnText) != KErrNotFound )

        {

        BindTextL(iStatement.ParameterIndex( KSQLEnText ), 

                aEntry->GetText() );

        }

    if( iQuery.Find( KSQLEnDescription ) != KErrNotFound )

        {

        BindTextL(iStatement.ParameterIndex( KSQLEnDescription ),

                aEntry->GetDescription() );

        }    

    if( iQuery.Find( KSQLEnRole ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnRole ), 

                aEntry->GetRole() );

        }

    if( iQuery.Find( KSQLEnTypeName ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( KSQLEnTypeName ),

                aEntry->GetEntryTypeName() );

        }

    if( iQuery.Find( KSQLEnIdIcon ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnIdIcon ),

                aEntry->GetIconId() );

        }

    if( iQuery.Find( KSQLEnUid ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex(KSQLEnUid), aEntry->GetUid() );

        }

    if( iQuery.Find( KSQLEnFlags ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLEnFlags ),

                aEntry->GetFlags() );

        }

    }

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

//

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

//

void CCaSqlQuery::BindValuesForGetIconL( const CCaInnerEntry* aEntry )

    {

    if( iQuery.Find( KSQLIconId ) != KErrNotFound )

        {

        BindIntL(iStatement.ParameterIndex( KSQLIconId ),

                aEntry->GetIcon().iId );

        }

    if( iQuery.Find( KSQLIcFileName ) != KErrNotFound )

        {

        BindTextL( iStatement.ParameterIndex( KSQLIcFileName ),

                aEntry->GetIcon().iFileName );

        }

    if( iQuery.Find( KSQLIcBitmapId ) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLIcBitmapId ),

                aEntry->GetIcon().iBitmapId );

        }

    if( iQuery.Find(KSQLIcMaskId) != KErrNotFound )

        {

        BindIntL( iStatement.ParameterIndex( KSQLIcMaskId ),

                aEntry->GetIcon().iMaskId );

        }