/*

* 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:  This is Metadata engine server file*

*/

// INCLUDE FILES

#include <e32std.h>

#include "mdsindexer.h"  

#include "mdsdbconnectionpool.h"

#include "mdssqliteconnection.h"

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

TItemId MMdSIndexer::StartIndexL()

	{

	GetLastItemIdL();

	return iId;

	}

TItemId MMdSIndexer::GetIndex( )

	{

	return ++iId;

	}

void MMdSIndexer::RevertIndex( )

	{

	--iId;

	}

void MMdSIndexer::GetLastItemIdL()

	{

	_LIT( KGetLastMaxId, "SELECT max(seq) FROM SQLITE_SEQUENCE WHERE name!='symbian_security';" );

	CMdSSqLiteConnection& connection = MMdSDbConnectionPool::GetDefaultDBL();

	RRowData getData;

	CleanupClosePushL(getData);

	RMdsStatement selectObject;

	CleanupClosePushL(selectObject);

	//Get one row and set first column to id

	connection.ExecuteQueryL( KGetLastMaxId, selectObject, getData );

	getData.AppendL( TColumn( iId ) );

	if (connection.NextRowL(selectObject, getData))

		{

		getData.Column(0).Get( iId );

		}

	CleanupStack::PopAndDestroy(2, &getData);

	}

TItemId MMdSIndexer::GetIndexL()

	{

	_LIT( KIndexerQuery, "SELECT last_insert_rowid();" );

	CMdSSqLiteConnection& connection = MMdSDbConnectionPool::GetDefaultDBL();

	RRowData getData;

	CleanupClosePushL(getData);

	RMdsStatement selectObject;

	CleanupClosePushL(selectObject);

	TItemId id = KNoId;

	//Get one row and set first column to id

	connection.ExecuteQueryL(KIndexerQuery,selectObject,getData);

	getData.AppendL(TColumn(id));

	if (connection.NextRowL(selectObject, getData))

		{

		getData.Column(0).Get(id);

		}

	CleanupStack::PopAndDestroy(2, &getData);

	return id;

	}

TItemId MMdSIndexer::ExecuteAndGetIndexL( const TDesC &aSqlClause,

	    								 const RRowData& aRowData )

    {

    CMdSSqLiteConnection& connection = MMdSDbConnectionPool::GetDefaultDBL();

    const TInt queryResult = connection.ExecuteL( aSqlClause, aRowData );

    if (queryResult == 0)

    	{

    	return KNoId;

    	}

   	return MMdSIndexer::GetIndexL();

    }

RSQLIndex::RSQLIndex()

	: iId(MMdSIndexer::GetIndex()), iCommit(EFalse)

	{

	}

const TItemId& RSQLIndex::GetId() const

	{

	return iId;

	}

void RSQLIndex::Commit()

	{

	iCommit = ETrue;

	}

void RSQLIndex::Close()

	{

	if (!iCommit)

		{

		MMdSIndexer::RevertIndex();

		}

	}

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

// -----------------INITIALIZE STATIC DATA------------------------

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

TItemId MMdSIndexer::iId = KNoId;