FCL/sf/app/musicplayer: comparison mpserviceplugins/mpxsqlitedbhgplugin/src/mpxdbalbum.cpp

equal deleted inserted replaced

-:ecf06a08d4d9
+:3ec52facab4d
 TInt aDriveId,
 TBool& aNewRecord,
 TBool aCaseSensitive)
 {
 MPX_FUNC("CMPXDbAlbum::AddItemL");
 // try to find the item first
 TUint32 rowId(MPXDbCommonUtil::GenerateUniqueIdL(iDbManager.Fs(), iCategory,
 aName, aCaseSensitive));
 aNewRecord = !CategoryItemExistsL(aDriveId, rowId);
 if (aNewRecord)
 {
 // insert new
 HBufC* query = PreProcessStringLC(KQueryAlbumInsert);
 HBufC* name = MPXDbCommonUtil::ProcessSingleQuotesLC(aName);
 		HBufC* art = MPXDbCommonUtil::ProcessSingleQuotesLC(aArt);
 // retrieve the existing record
 HBufC* query = NULL;
 query = PreProcessStringLC(KQueryCategoryItem);
 RSqlStatement recordset(iDbManager.ExecuteSelectQueryL(*query, rowId));
 CleanupStack::PopAndDestroy(query);
 CleanupClosePushL(recordset);
 if (recordset.Next() != KSqlAtRow)
 {
 User::Leave(KErrNotFound);
 	    }
 // Artist
 TUint32 artistId = recordset.ColumnInt64(EAlbumArtist);
 // the current one is Unknown and the new one is Not Unknown.
 if ( IsUnknownArtistL( artistId ) && !IsUnknownArtistL( aArtist ) )
 {
 _LIT( KFormatArtistId, "Artist=%d" );
 HBufC* setStr = HBufC::NewLC(KFormatArtistId().Length() + KMCIntegerLen);
 setStr->Des().Format( KFormatArtistId, aArtist );
 iDbManager.ExecuteQueryL(aDriveId, KQueryAlbumUpdate, setStr, rowId);
 CleanupStack::PopAndDestroy(setStr);
 }
 // Album Art
 TPtrC art(KNullDesC);
 art.Set(MPXDbCommonUtil::GetColumnTextL(recordset, EAlbumArt));
 // the current one is Unknown and the new one is Not Unknown
 if ( art == KNullDesC && aArt != KNullDesC )
 {
 HBufC* artReplaceSingleQuote =
 MPXDbCommonUtil::ProcessSingleQuotesLC( aArt );
 iDbManager.ExecuteQueryL(aDriveId, KQueryAlbumUpdate, setStr, rowId);
 CleanupStack::PopAndDestroy(setStr);
 CleanupStack::PopAndDestroy(artReplaceSingleQuote);
 }
 CleanupStack::PopAndDestroy(&recordset);
 // increment the number of songs for the category
 query = PreProcessStringLC(KQueryCategoryIncrementSongCount);
 iDbManager.ExecuteQueryL(aDriveId, *query, rowId);
 CleanupStack::PopAndDestroy(query);
 }
 }
 }
 else
 {
 aItemExist = ETrue;
 // retrieve the existing record
 HBufC* query = PreProcessStringLC(KQueryCategoryItem);
 RSqlStatement recordset(iDbManager.ExecuteSelectQueryL(*query, aId));
 CleanupStack::PopAndDestroy(query);
 CleanupClosePushL(recordset);
 if (recordset.Next() != KSqlAtRow)
 {
 User::Leave(KErrNotFound);
 }
 TUint32 artistId = recordset.ColumnInt64(EAlbumArtist);
 CleanupStack::PopAndDestroy(&recordset);
 // the current artist is equal to deleted song's artist
 if ( artistId == aArtist )
 {
 TUint32 newArtistId = ArtistForAlbumL(aId);
+if ( artistId != newArtistId )
-_LIT( KFormatArtistId, "Artist=%d" );
-HBufC* setStr = HBufC::NewLC(KFormatArtistId().Length() + KMCIntegerLen);
-setStr->Des().Format(KFormatArtistId, newArtistId);
-iDbManager.ExecuteQueryL(aDriveId, KQueryAlbumUpdate, setStr, aId);
-CleanupStack::PopAndDestroy(setStr);
-if (aItemChangedMessages)
 {
-// add the item changed message
+_LIT( KFormatArtistId, "Artist=%d" );
-MPXDbCommonUtil::AddItemAlbumChangedMessageL(*aItemChangedMessages, aId, EMPXItemModified,
+HBufC* setStr = HBufC::NewLC(KFormatArtistId().Length() + KMCIntegerLen);
-EMPXAlbum, KDBPluginUid, ETrue, 0 );
+setStr->Des().Format(KFormatArtistId, newArtistId);
+iDbManager.ExecuteQueryL(aDriveId, KQueryAlbumUpdate, setStr, aId);
+CleanupStack::PopAndDestroy(setStr);
+if (aItemChangedMessages)
+{
+// add the item changed message
+MPXDbCommonUtil::AddItemAlbumChangedMessageL(*aItemChangedMessages, aId, EMPXItemModified,
+EMPXAlbum, KDBPluginUid, ETrue, 0 );
+}
 }
 }
 // decrement the number of songs for the category
 query = PreProcessStringLC(KQueryCategoryDecrementSongCount);
 iDbManager.ExecuteQueryL(aDriveId, *query, aId);
 CleanupStack::PopAndDestroy(query);
 }
 // ----------------------------------------------------------------------------
 // CMPXDbAlbum::UpdateItemL
 // ----------------------------------------------------------------------------
 //
 void CMPXDbAlbum::UpdateItemL(
 TUint32 aId,
 const CMPXMedia& aMedia,
 TInt aDriveId,
 CMPXMessageArray* aItemChangedMessages)
 	{
 	MPX_FUNC("CMPXDbAlbum::UpdateItemL");
 	CDesCArrayFlat* fields = new (ELeave) CDesCArrayFlat(EAlbumFieldCount);
 RSqlStatement recordset(iDbManager.ExecuteSelectQueryL(KQueryCategorySubcategoryItems, aArtistId));
 TInt prevId(0);
 TInt count(0);
 	TInt err(KErrNone);
 while ((err = recordset.Next()) == KSqlAtRow)
 		{
 		TUint32 rowId(recordset.ColumnInt64(EAlbumUniqueId));
 if (prevId == rowId)
 {
 continue;
 }
 		count++;
 		prevId = rowId;
 		}
 if (err != KSqlAtEnd)
 // ----------------------------------------------------------------------------
 //
 TInt CMPXDbAlbum::GetSongsCountInAlbumMatchingArtistL(TUint32 aArtistId, TUint32 aAlbumId)
 	{
 	MPX_FUNC("CMPXDbAlbum::GetSongsCountInAlbumMatchingArtistL");
 	return ExecuteSumQueryL(KQuerySongsInArtistAlbum, aArtistId, aAlbumId);
 	}
 // ----------------------------------------------------------------------------
 // CMPXDbAlbum::UpdateMediaL
 if (contentId == KMPXMediaIdGeneral)
 {
 if (attributeId & EMPXMediaGeneralId)
 {
 MPX_DEBUG1("    EMPXMediaGeneralId");
 aMedia.SetTObjectValueL<TMPXItemId>(KMPXMediaGeneralId,
 aRecord.ColumnInt64(EAlbumUniqueId));
 }
 if (attributeId & EMPXMediaGeneralTitle)
 {
 MPX_DEBUG1("    EMPXMediaGeneralTitle");
 TPtrC album( MPXDbCommonUtil::GetColumnTextL(aRecord, EAlbumName) );
 aMedia.SetTextValueL(KMPXMediaGeneralTitle,
 MPXDbCommonUtil::GetColumnTextL(aRecord, EAlbumName));
 MPX_DEBUG2("	Album[%S]", &album );
 }
 }
 } // end if contentId == KMPXMediaIdGeneral
 		else if ( contentId == KMPXMediaIdMusic )
 			{
 			if (attributeId & EMPXMediaMusicArtist)
 				{
 				MPX_DEBUG1("	EMPXMediaMusicArtist");
 				TPtrC artistName(KNullDesC);
 				// if album is unknown, ignore arist name
 				if (MPXDbCommonUtil::GetColumnTextL(aRecord, EAlbumName) != KNullDesC)
 					{
 					artistName.Set(MPXDbCommonUtil::GetColumnTextL(aRecord, EAlbumArtistName));
 					}
 				aMedia.SetTextValueL(KMPXMediaMusicArtist, artistName);
 				MPX_DEBUG2("	Artist[%S]", &artistName);
 				}
 			if (attributeId & EMPXMediaMusicAlbum)
 			if (attributeId & EMPXMediaMusicAlbumArtFileName)
 				{
 				MPX_DEBUG1("	EMPXMediaMusicAlbumArtFileName");
 				TPtrC art(KNullDesC);
 				// if album is unknown, ignore album art name
 				if (MPXDbCommonUtil::GetColumnTextL(aRecord, EAlbumName) != KNullDesC)
 					{
 					art.Set(MPXDbCommonUtil::GetColumnTextL(aRecord, EAlbumArt));
 					}
 				aMedia.SetTextValueL(KMPXMediaMusicAlbumArtFileName, art);
 				MPX_DEBUG2("	Art[%S]", &art);
 				}
 			}
 		} // end for
 	if (aMedia.IsSupported(KMPXMediaMusicAlbumArtFileName))
 		{
 		const TDesC& albumArtFilename = aMedia.ValueText(KMPXMediaMusicAlbumArtFileName).Left(KMCMaxTextLen);
 		MPXDbCommonUtil::AppendValueL(aFields, aValues, KMCMusicArt, albumArtFilename);
 		}
 	if (aMedia.IsSupported(KMPXMediaMusicArtist))
 	    {
 	    const TDesC& artistName = aMedia.ValueText(KMPXMediaMusicArtist).Left(KMCMaxTextLen);
 	    TUint32 artistId = MPXDbCommonUtil::GenerateUniqueIdL(iDbManager.Fs(), EMPXArtist,
 	            artistName, ETrue);
 	    MPXDbCommonUtil::AppendValueL(aFields, aValues, KMCMusicArtist, artistId);
 	    }
 	}
 // ----------------------------------------------------------------------------
 // CMPXDbAlbum::IsUnknownArtistL

changeset 25	3ec52facab4d
parent 22	ecf06a08d4d9
child 29	8192e5b5c935