/*

* Copyright (c) 2005-2009 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:  SQL database startup routines*

*/

// INCLUDE FILES

#include "mdssqldbmaintenance.h"

#include "mdccommon.h"

#include "mdspreferences.h"

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

CMdSSqlDbMaintenance* CMdSSqlDbMaintenance::NewL()

    {

    CMdSSqlDbMaintenance* self = CMdSSqlDbMaintenance::NewLC();

    CleanupStack::Pop( self );

    return self;

    }

CMdSSqlDbMaintenance* CMdSSqlDbMaintenance::NewLC()

    {

    CMdSSqlDbMaintenance* self = new ( ELeave ) CMdSSqlDbMaintenance();

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

void CMdSSqlDbMaintenance::ConstructL( )

    {

    }

CMdSSqlDbMaintenance::CMdSSqlDbMaintenance()

    {

    }

CMdSSqlDbMaintenance::~CMdSSqlDbMaintenance()

    {

    }

TBool CMdSSqlDbMaintenance::ValidateL(  )

    {

    //validate content of critical tables

    _LIT( KValidateTableExistence, "SELECT COUNT(*) FROM MdE_Preferences;" );

    _LIT( KValidateObjectDef, "SELECT COUNT(*) FROM ObjectDef;" );

    _LIT( KValidatePropertyDef, "SELECT COUNT(*) FROM PropertyDef;" );

    _LIT( KValidateRelationDef, "SELECT COUNT(*) FROM RelationDef;" );

    _LIT( KValidateCol2Prop, "SELECT COUNT(*) FROM Col2Prop;" );

    TInt test(KErrNone);

    TUint32 count(0);

    RRowData emptyRowData;

    CleanupClosePushL( emptyRowData );

    RMdsStatement validationQuery;

    CleanupClosePushL( validationQuery );

    CMdSSqLiteConnection& connection = MMdSDbConnectionPool::GetDefaultDBL();

	TRAP( test, connection.ExecuteQueryL( KValidateTableExistence, validationQuery, emptyRowData ) );

	if(test == KErrNone)

        {

        emptyRowData.AppendL( TColumn( count ) );

        TRAP( test, connection.NextRowL(validationQuery, emptyRowData));

        if(test == KErrNone)

            {

            emptyRowData.Column(0).Get( count );

            if(count <= 0)

                {

                test = KErrCorrupt;

                }

            }

        }

	CleanupStack::PopAndDestroy( &validationQuery );

	emptyRowData.Reset();

	RMdsStatement objectDefQuery;

	CleanupClosePushL( objectDefQuery );

	if( test == KErrNone )

        {

        TRAP( test, connection.ExecuteQueryL( KValidateObjectDef, objectDefQuery, emptyRowData ) );

        if(test == KErrNone)

            {

            emptyRowData.AppendL( TColumn( count ) );

            TRAP( test, connection.NextRowL(objectDefQuery, emptyRowData));

            if(test == KErrNone)

                {

                emptyRowData.Column(0).Get( count );

                if(count <= 0)

                    {

                    test = KErrCorrupt;

                    }

                }

            }

        }

	CleanupStack::PopAndDestroy( &objectDefQuery );

	emptyRowData.Reset();

	RMdsStatement propertyDefQuery;

	CleanupClosePushL( propertyDefQuery );

	if( test == KErrNone )

	    {

        TRAP( test, connection.ExecuteQueryL( KValidatePropertyDef, propertyDefQuery, emptyRowData ) );

        if(test == KErrNone)

            {

            emptyRowData.AppendL( TColumn( count ) );

            TRAP( test, connection.NextRowL(propertyDefQuery, emptyRowData));

            if(test == KErrNone)

                {

                emptyRowData.Column(0).Get( count );

                if(count <= 0)

                    {

                    test = KErrCorrupt;

                    }

                }

            }

	    }

	CleanupStack::PopAndDestroy( &propertyDefQuery );

	emptyRowData.Reset();

    RMdsStatement relationDefQuery;

    CleanupClosePushL( relationDefQuery );

	if( test == KErrNone )

	    {

	    TRAP( test, connection.ExecuteQueryL( KValidateRelationDef, relationDefQuery, emptyRowData ) );

	    if(test == KErrNone)

	        {

            emptyRowData.AppendL( TColumn( count ) );

            TRAP( test, connection.NextRowL(relationDefQuery, emptyRowData));

            if(test == KErrNone)

                {

                emptyRowData.Column(0).Get( count );

                if(count <= 0)

                    {

                    test = KErrCorrupt;

                    }

                }

            }

	    }

	CleanupStack::PopAndDestroy( &relationDefQuery );

	emptyRowData.Reset();

    RMdsStatement col2propQuery;

    CleanupClosePushL( col2propQuery );

    if( test == KErrNone )

        {

        TRAP( test, connection.ExecuteQueryL( KValidateCol2Prop, col2propQuery, emptyRowData ) );

        if(test == KErrNone)

            {

            emptyRowData.AppendL( TColumn( count ) );

            TRAP( test, connection.NextRowL(col2propQuery, emptyRowData));

            if(test == KErrNone)

                {

                emptyRowData.Column(0).Get( count );

                if(count <= 0)

                    {

                    test = KErrCorrupt;

                    }

                }

            }

          }

    CleanupStack::PopAndDestroy( &col2propQuery );

    CleanupStack::PopAndDestroy( &emptyRowData );

    if(test == KErrCorrupt )

        {

        User::Leave( test );

        }

    return ( test == KErrNone );

    }

void CMdSSqlDbMaintenance::CreateDatabaseL()

    {

    _LIT( KCreateTblMdE_Preferences, // Table for metadata engine use

    	"CREATE TABLE MdE_Preferences(Key TEXT,Value NONE,ExtraValue LARGEINT,UNIQUE(Key,Value));");

    _LIT( KCreateTblMdS_Medias, // Table for metadata engine use

		"CREATE TABLE MdS_Medias(MediaId INTEGER PRIMARY KEY,Drive INTEGER,PresentState INTEGER,Time LARGEINT);");

    RRowData emptyRowData;

    CleanupClosePushL( emptyRowData );

    // Create ontology tables

    CMdSSqLiteConnection& connection = MMdSDbConnectionPool::GetDefaultDBL();

    connection.ExecuteL( KCreateTblMdE_Preferences, emptyRowData );

    connection.ExecuteL( KCreateTblMdS_Medias, emptyRowData );

    TInt majorVersion = KMdSServMajorVersionNumber;

	TInt64 minorVersion = KMdSServMinorVersionNumber;

    MMdsPreferences::InsertL( KMdsDBVersionName, MMdsPreferences::EPreferenceBothSet,

    						  majorVersion, minorVersion );

	CleanupStack::PopAndDestroy( &emptyRowData );

    }