/*

* Copyright (c) 2007 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:  Responsible for interation with the Artist table

*

*

*/

// INCLUDE FILES

#include <sqldb.h>

#include <mpxlog.h>

#include "mpxdbcommonutil.h"

#include "mpxdbcommondef.h"

#include "mpxmediamusicdefs.h"

#include "mpxdbmanager.h"

#include "mpxcollectiondbdef.h"

#include "mpxdbpluginqueries.h"

#include "mpxdbutil.h"

#include "mpxdbartist.h"

// CONSTANTS

// ============================ MEMBER FUNCTIONS ==============================

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

// Two-phased constructor.

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

//

CMPXDbArtist* CMPXDbArtist::NewL(

    CMPXDbManager& aDbManager,

    {

    MPX_FUNC("CMPXDbArtist::NewL");

    CleanupStack::Pop(self);

    return self;

    }

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

// Two-phased constructor.

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

//

CMPXDbArtist* CMPXDbArtist::NewLC(

    CMPXDbManager& aDbManager,

    {

    MPX_FUNC("CMPXDbArtist::NewLC");

    CleanupStack::PushL(self);

    self->ConstructL();

    return self;

    }

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

// Destructor

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

//

CMPXDbArtist::~CMPXDbArtist()

    {

    MPX_FUNC("CMPXDbArtist::~CMPXDbArtist");

    }

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

// Constructor

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

//

CMPXDbArtist::CMPXDbArtist(

    CMPXDbManager& aDbManager,

    {

    MPX_FUNC("CMPXDbArtist::CMPXDbArtist");

    }

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

// Second phase constructor.

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

//

void CMPXDbArtist::ConstructL()

    {

    MPX_FUNC("CMPXDbArtist::ConstructL");

    BaseConstructL();

    }

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

// CMPXDbArtist::AddItemL

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

//

TUint32 CMPXDbArtist::AddItemL(

    TInt aDriveId,

    TBool& aNewRecord,

    TBool aCaseSensitive)

    {

    MPX_FUNC("CMPXDbArtist::AddItemL");

    // try to find the item first

    TUint32 rowId(MPXDbCommonUtil::GenerateUniqueIdL(iDbManager.Fs(), iCategory,

        {

        // insert new

        CleanupStack::PopAndDestroy(art);

        CleanupStack::PopAndDestroy(name);

        }

        {

        TPtrC art(KNullDesC);

        art.Set(MPXDbCommonUtil::GetColumnTextL(recordset, EArtistArt));

        // the current one is Unknown and the new one is Not Unknown

            {

            HBufC* artReplaceSingleQuote = 

            _LIT( KFormatArt, "Art=\'%S\'" );

            setStr->Des().Format( KFormatArt, artReplaceSingleQuote );

            iDbManager.ExecuteQueryL(aDriveId, KQueryArtistUpdate, setStr, rowId);

            CleanupStack::PopAndDestroy(setStr);

            CleanupStack::PopAndDestroy(artReplaceSingleQuote);

            }

        // increment the number of songs for the category

        query = PreProcessStringLC(KQueryCategoryIncrementSongCount);

        iDbManager.ExecuteQueryL(aDriveId, *query, rowId);

        CleanupStack::PopAndDestroy(query);

        }

    return rowId;

    }

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

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

//

    {

    }

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

// CMPXDbArtist::UpdateMediaL

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

//

void CMPXDbArtist::UpdateMediaL(

    RSqlStatement& aRecord,

    const TArray<TMPXAttribute>& aAttrs,

    CMPXMedia& aMedia)

    {

    MPX_FUNC("CMPXDbArtist::UpdateMediaL");

    TInt count(aAttrs.Count());

    for (TInt i = 0; i < count; ++i)

        {

        TInt contentId(aAttrs[i].ContentId());

        TUint attributeId(aAttrs[i].AttributeId());

        if (contentId == KMPXMediaIdGeneral)

            {

            if (attributeId & EMPXMediaGeneralId)

                {

                MPX_DEBUG1("	EMPXMediaGeneralId");

                aMedia.SetTObjectValueL<TMPXItemId>(KMPXMediaGeneralId,

                    aRecord.ColumnInt64(EArtistUniqueId));

				MPX_DEBUG2("	Id[%d]", aRecord.ColumnInt64(EArtistUniqueId));

                }

            if (attributeId & EMPXMediaGeneralTitle)

                {

                MPX_DEBUG1("	EMPXMediaGeneralTitle");

                TPtrC artist( MPXDbCommonUtil::GetColumnTextL(aRecord, EArtistName) );

                aMedia.SetTextValueL(KMPXMediaGeneralTitle,

                    MPXDbCommonUtil::GetColumnTextL(aRecord, EArtistName));

				MPX_DEBUG2("	Artist[%S]", &artist);

                }

            if (attributeId & EMPXMediaGeneralCount)

                {

                // get songs count from all drives

                TInt songCount = GetSongsCountL( KDbManagerAllDrives,

                                    aRecord.ColumnInt64( EArtistUniqueId ) );

				aMedia.SetTObjectValueL<TInt>(KMPXMediaGeneralCount, songCount); // mod by anjokela

                MPX_DEBUG1("	EMPXMediaGeneralCount");

				MPX_DEBUG2("	SongCount[%d]", songCount);

                }

            } // end if contentId == KMPXMediaIdGeneral

        else if ( contentId == KMPXMediaIdMusic )

            {

            if (attributeId & EMPXMediaMusicAlbumArtFileName)

                {

                MPX_DEBUG1("    EMPXMediaMusicAlbumArtFileName");

                TPtrC art(KNullDesC);

                art.Set(MPXDbCommonUtil::GetColumnTextL(aRecord, EArtistArt));

                aMedia.SetTextValueL(KMPXMediaMusicAlbumArtFileName, art);

                MPX_DEBUG2("    Art[%S]", &art);

                }

            }

		} // end for

    aMedia.SetTObjectValueL<TMPXGeneralType>(KMPXMediaGeneralType, EMPXItem);

    aMedia.SetTObjectValueL<TMPXGeneralCategory>(KMPXMediaGeneralCategory, iCategory);

    }

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

// CMPXDbArtist::GenerateArtistFieldsValuesL

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

//

void CMPXDbArtist::GenerateArtistFieldsValuesL(const CMPXMedia& aMedia, CDesCArray& aFields, CDesCArray& aValues)

    {

    if (aMedia.IsSupported(KMPXMediaMusicAlbumArtFileName))

        {

        const TDesC& albumArtFilename = aMedia.ValueText(KMPXMediaMusicAlbumArtFileName).Left(KMCMaxTextLen);

        MPXDbCommonUtil::AppendValueL(aFields, aValues, KMCMusicArt, albumArtFilename);

        }

    }

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

// CMPXDbArtist::GetAllCategoryItemsL

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

//

void CMPXDbArtist::GetAllCategoryItemsL(

    const TArray<TMPXAttribute>& aAttrs,

    CMPXMediaArray& aMediaArray)

    {

    MPX_FUNC("CMPXDbArtist::GetAllCategoryItemsL");

    CleanupClosePushL(recordset);

    ProcessRecordsetL(aAttrs, recordset, aMediaArray);

    CleanupStack::PopAndDestroy(&recordset);

    }

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

// CMPXDbArtist::UpdateItemL

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

//

void CMPXDbArtist::UpdateItemL(

    TUint32 aId,

    const CMPXMedia& aMedia,

    TInt aDriveId,

    CMPXMessageArray* aItemChangedMessages)

    {

    MPX_FUNC("CMPXDbAlbum::UpdateItemL");

    CDesCArrayFlat* fields = new (ELeave) CDesCArrayFlat(EArtistFieldCount);

    CleanupStack::PushL(fields);

    CDesCArrayFlat* values = new (ELeave) CDesCArrayFlat(EArtistFieldCount);

    CleanupStack::PushL(values);

    // process the media parameter and construct the fields and values array

    GenerateArtistFieldsValuesL(aMedia, *fields, *values);

    // construct the SET string

    HBufC* setStr = MPXDbCommonUtil::StringFromArraysLC(*fields, *values, KMCEqualSign, KMCCommaSign);

    if (setStr->Length())

        {

        // execute the query

        iDbManager.ExecuteQueryL(aDriveId, KQueryArtistUpdate, setStr, aId);

        MPXDbCommonUtil::AddItemAlbumChangedMessageL(*aItemChangedMessages, aId, EMPXItemModified,

        		EMPXArtist, KDBPluginUid, ETrue, 0 );          

        }

    CleanupStack::PopAndDestroy(setStr);

    CleanupStack::PopAndDestroy(values);

    CleanupStack::PopAndDestroy(fields);

    }

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

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

//

void CMPXDbArtist::CreateTableL(

    RSqlDatabase& aDatabase,

    TBool /* aCorruptTable */)

    {