diff -r 000000000000 -r 7f85d04be362 upnpharvester/common/cmsqlwrapper/src/cmsqlmain.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/upnpharvester/common/cmsqlwrapper/src/cmsqlmain.cpp	Thu Dec 17 08:52:00 2009 +0200
@@ -0,0 +1,325 @@
+/*
+* 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:      Main class in the SQL Wrapper component
+*
+*/
+
+
+
+
+
+
+#include <bautils.h>
+#include "cmsqlconnection.h"
+#include "cmsqldbmaintenance.h"
+#include "cmsqldbclause.h"
+#include "cmsqlmain.h"
+#include "msdebug.h"
+
+// CONSTANTS
+_LIT(KCmSqlDirC, "C:\\System\\Data\\MediaServant\\");
+ 
+// ---------------------------------------------------------------------------
+// CCmSqlMain::NewL
+// ---------------------------------------------------------------------------
+//
+CCmSqlMain* CCmSqlMain::NewL( RFs& aFs )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::NewL"));    
+    CCmSqlMain* self = CCmSqlMain::NewLC( aFs );
+    CleanupStack::Pop( self );
+    return self;
+    }
+ 
+// ---------------------------------------------------------------------------
+// CCmSqlMain::NewLC
+// ---------------------------------------------------------------------------
+//    
+CCmSqlMain* CCmSqlMain::NewLC( RFs& aFs )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::NewLC"));
+    CCmSqlMain* self = new ( ELeave ) CCmSqlMain( aFs );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    return self;  
+    }    
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::~CCmSqlMain
+// ---------------------------------------------------------------------------
+//
+CCmSqlMain::~CCmSqlMain()
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::~CCmSqlMain"));
+    delete iClause;
+    delete iMaintenance;
+    delete iConnection;   
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::CancelAsyncOperation
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::CancelAsyncOperation()
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::CancelAsyncOperation"));
+    
+    iConnection->CancelAsyncOperation();
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::SetMsId
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::SetMsId( TUint aId )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::SetMsId"));
+    
+    iConnection->SetMsId( aId );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::SetQuota
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::SetQuota( TInt64 aQuota )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::SetQuota"));
+    
+    iConnection->SetQuota( aQuota );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::SetDlnaProfileFilters
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::SetDlnaProfileFilters( 
+    const RArray<TInt64>& aProfileIds )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::SetDlnaProfileFilters"));
+    
+    iClause->SetDlnaProfileFilters( aProfileIds );
+    }
+            
+// ---------------------------------------------------------------------------
+// CCmSqlMain::AsyncBatchAdd
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::AsyncBatchAdd( 
+    RPointerArray<CCmSqlGenericItem>& aItems, TRequestStatus& aStatus )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::AsyncBatchAdd"));
+    
+    iConnection->AsyncBatchAdd( aItems, aStatus );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::AsyncBatchAddPropertyItems
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::AsyncBatchAddPropertyItems( 
+    RPointerArray<CCmSqlPropertyItem>& aItems, TCmMetadataField aField,
+    TRequestStatus& aStatus )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::AsyncBatchAddPropertyItems"));
+    
+    iConnection->AsyncBatchAddPropertyItems( aItems, aField, aStatus );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::SyncAddPropertyItemL
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::SyncAddPropertyItemL( 
+    CCmSqlPropertyItem& aItem, TCmMetadataField aField )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::SyncAddPropertyItemL"));
+    
+    iConnection->SyncAddPropertyItemL( aItem, aField );
+    }
+        
+// ---------------------------------------------------------------------------
+// CCmSqlMain::AsyncBatchDelete
+// ---------------------------------------------------------------------------
+//    
+void CCmSqlMain::AsyncBatchDelete( 
+    RPointerArray<CCmSqlBaseItem>& aItems, 
+    TRequestStatus& aStatus )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::AsyncBatchDelete"));
+    
+    iConnection->AsyncBatchDelete( aItems, aStatus );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::AsyncMetadataDelete
+// ---------------------------------------------------------------------------
+//    
+void CCmSqlMain::AsyncMetadataDelete( 
+    RArray<TInt>& aMsIds, TRequestStatus& aStatus )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::AsyncMetadataDelete"));
+    
+    iConnection->AsyncMetadataDelete( aMsIds, aStatus );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::DeleteOldestMediaItemsL
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::DeleteOldestMediaItemsL( TCmMediaType aType, 
+    TInt64 aCount )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::DeleteOldestMediaItemsL"));
+    
+    iConnection->DeleteOldestMediaItemsL( aType, aCount );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::DeleteUnusedPropertys
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::DeleteUnusedPropertys( )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::DeleteUnusedPropertys"));
+    
+    iConnection->DeleteUnusedPropertys( );
+    }
+            
+// ---------------------------------------------------------------------------
+// CCmSqlMain::GetItemsL
+// ---------------------------------------------------------------------------
+//    
+void CCmSqlMain::GetItemsL( RPointerArray<CCmSqlBaseItem>& aItems,
+    TRequestStatus& aStatus )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::GetItemsL"));
+    
+    iConnection->GetItemsL( aItems, aStatus );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::GetFillItemsL
+// ---------------------------------------------------------------------------
+//    
+void CCmSqlMain::GetFillItemsL( 
+    RPointerArray<CCmFillListItem>& aItems, CCmFillRule& aRule, 
+    TRequestStatus& aStatus )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::GetFillItemsL"));
+    
+    iClause->FormatClauseL( aRule );
+    iConnection->GetFillItemsL( aItems, iClause->ClauseL(), aRule, aStatus );
+    }
+    
+// ---------------------------------------------------------------------------
+// CCmSqlMain::GetPropertyValuesL
+// ---------------------------------------------------------------------------
+//    
+void CCmSqlMain::GetPropertyValuesL( 
+    RPointerArray<CCmSqlPropertyItem>& aItems, TRequestStatus& aStatus,
+    TCmMetadataField aField, TCmMediaType aMedia )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::GetPropertyValuesL"));
+    
+    CCmFillRule* rule = NULL;
+    iClause->FormatClauseL( *rule, aField, aMedia );
+    iConnection->GetPropertyValuesL( aItems, iClause->ClauseL(), 
+                                      aStatus );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::GetFilteredPropertyValuesL
+// ---------------------------------------------------------------------------
+//    
+void CCmSqlMain::GetFilteredPropertyValuesL( 
+    CCmSqlPropertyCollector& aPropertys, TRequestStatus& aStatus )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::GetFilteredPropertyValuesL"));
+    
+    iClause->FormatFilteringClauseL( aPropertys );
+    iConnection->GetFilteredPropertyValuesL( aPropertys, iClause->ClauseL(), 
+                                      aStatus );
+    }
+    
+// ---------------------------------------------------------------------------
+// CCmSqlMain::GetMediaCountL
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::GetMediaCountL( TInt64& aCount, 
+    TCmMediaType aType )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::GetMediaCountL"));
+    
+    iConnection->GetMediaCountL( aCount, aType );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::Exists
+// ---------------------------------------------------------------------------
+//   
+TBool CCmSqlMain::ExistsL( const CCmBaseListItem& aItem, 
+    const TInt aDevId )    
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::ExistsL"));
+    
+    return iConnection->ExistsL( aItem, aDevId );
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::Close
+// ---------------------------------------------------------------------------
+//
+void CCmSqlMain::Close()
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::Close"));
+    
+    delete this;
+	}
+    
+// ---------------------------------------------------------------------------
+// CCmSqlMain::CCmSqlMain
+// ---------------------------------------------------------------------------
+//    
+CCmSqlMain::CCmSqlMain( RFs& aFs ): iFs( aFs )
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::CCmSqlMain"));
+    }
+
+// ---------------------------------------------------------------------------
+// CCmSqlMain::ConstructL
+// ---------------------------------------------------------------------------
+//    
+void CCmSqlMain::ConstructL()
+    {
+    LOG(_L("[SQL Wrapper]\t CCmSqlMain::ConstructL"));
+    
+    TRAP_IGNORE( BaflUtils::EnsurePathExistsL( iFs, KCmSqlDirC ) );   
+    iClause = CCmSqlDbClause::NewL();
+    iMaintenance = CCmSqlDbMaintenance::NewL();
+    iConnection = CCmSqlConnection::NewL();
+    
+    if( iMaintenance->InitConnection(*iConnection) )
+        {
+        iMaintenance->CreateDbFile( *iConnection );
+        }
+    if( !iConnection->Validate() )
+        {
+        iMaintenance->CreateDb( *iConnection );
+        iMaintenance->CreateIndexes( *iConnection );        
+        }        
+    }    
+
+// End of file
+