/*

* Copyright (c) 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: 

*

*/

#include "pltables.h"

#include "dbsqlconstants.h"

#include "cntitem.h"

#include <QStringList>

// How many characters from the beginning of the first name and last name are

// stored. This only affects how precisely the results are put in alphabetic order.

const TInt KCharactersFromName = 16;

/**

Destructor

*/

	{

	delete iInsertStmnt;

	delete iDeleteStmnt;

	delete iKeyMap;

	}

/**

@param aItem A contact item whose data are added to the table.

*/

	{

	WriteToDbL(aItem);

	}

/**

Update is done in two steps: delete contact from all predictive search tables,

then insert it into relevant tables.

@param aItem A contact item whose data is updated in the database.

*/

	{

	TBool lowDiskErrorOccurred(EFalse);

	DeleteFromAllTablesL(aItem.Id(), lowDiskErrorOccurred);

	if (lowDiskErrorOccurred)

	    {

        User::Leave(KErrGeneral);

	    }

	WriteToDbL(aItem);

	}

/**

Deletes a contact item from predictive search tables.

@param aItem The contact item to be deleted. It contains contact id, but not

             first name or last name fields.

*/

	{

	DeleteFromAllTablesL(aItem.Id(), aLowDiskErrorOccurred); 

	}

/**

*/

	{

	}

/**

Set up the CCntSqlStatement objects held by the class.

*/

	{

	// Using dummy table names here

	TCntSqlStatementType insertType(EInsert, KSqlContactPredSearchTable0);

	TCntSqlStatementType deleteType(EDelete, KSqlContactPredSearchTable0);

	const TInt KWhereContactIdBufSize(

		KWhereStringEqualsStringFormatText().Size() +

		KPredSearchContactId().Size() +

		KPredSearchContactIdParam().Size() );

	HBufC* whereContactIdClause = HBufC::NewLC(KWhereContactIdBufSize);

	// for WHERE contact_id = [contact id value]

	whereContactIdClause->Des().AppendFormat(KWhereStringEqualsStringFormatText,

		&KPredSearchContactId, &KPredSearchContactIdParam);

	// Delete information of a particular contact item

	// 	DELETE FROM predictivesearchX (X=0..11)

	//	WHERE contact_id = [contact id value];

	iDeleteStmnt = TSqlProvider::GetSqlStatementL(deleteType);

	iDeleteStmnt->SetConditionL(*whereContactIdClause);

	}

/**

Constructor

*/

	{

	}

// Insert a contact to predictive search tables.

// Write contact's all tokens to each associate pred.search table.

// E.g. if FN="11 22" LN="2 333", write "11","22","2" and "333" to tables 1, 2 and 3.

	{

	HBufC* firstNameAsNbr(NULL); // owned

    HBufC* lastNameAsNbr(NULL);  // owned

	HBufC* firstName(NULL); // owned

    HBufC* lastName(NULL);  // owned

	GetFieldsLC(aItem, &firstNameAsNbr, &lastNameAsNbr, &firstName, &lastName);

	QT_TRYCATCH_LEAVING({

	HBufC* tableName(NULL);

	while ((tableName = GetNextTableNameL(tables)) != NULL)

		{

		// Takes ownership. Clears also earlier SQL statement.

		iInsertStmnt->SetTableName(tableName);

		RSqlStatement stmnt;

		CleanupClosePushL( stmnt ); 

		stmnt.PrepareL(iDatabase, iInsertStmnt->SqlStringL());

		User::LeaveIfError(stmnt.BindInt(

			User::LeaveIfError(stmnt.ParameterIndex(KPredSearchContactIdParam)),

			aItem.Id()));

		if (firstName)

			{

			User::LeaveIfError(stmnt.BindText(

				User::LeaveIfError(stmnt.ParameterIndex(KPredSearchFirstNameParam)),

				*firstName));

			}

		if (lastName)

			{

			User::LeaveIfError(stmnt.BindText(

				User::LeaveIfError(stmnt.ParameterIndex(KPredSearchLastNameParam)),

				*lastName));

			}

		// Execute the SQL statement

		User::LeaveIfError(stmnt.Exec());

		CleanupStack::PopAndDestroy(&stmnt);

		}

	CleanupStack::PopAndDestroy(lastNameAsNbr);

	CleanupStack::PopAndDestroy(lastName);

	CleanupStack::PopAndDestroy(firstNameAsNbr);

	CleanupStack::PopAndDestroy(firstName);

	}

	{

	__ASSERT_ALWAYS(aFirstNameAsNbr != NULL && *aFirstNameAsNbr == NULL,

				    User::Leave(KErrArgument));

	__ASSERT_ALWAYS(aLastNameAsNbr != NULL && *aLastNameAsNbr == NULL,

				    User::Leave(KErrArgument));

	__ASSERT_ALWAYS(aFirstName != NULL && *aFirstName == NULL,

					User::Leave(KErrArgument));

	__ASSERT_ALWAYS(aLastName != NULL && *aLastName == NULL,

					User::Leave(KErrArgument));

	CContactItemFieldSet& fieldset = aItem.CardFields();

    TInt pos = fieldset.Find(KUidContactFieldGivenName);

    if (pos != KErrNotFound)

        {

        CContactTextField* textfield = fieldset[pos].TextStorage();

        if (textfield)

            {

            TPtrC firstName = textfield->Text();

			*aFirstName = firstName.Left(KCharactersFromName).AllocLC();

            }

        }

	// If aFirstName was not pushed to cleanupstack above, do it now

	if (*aFirstName == NULL)

		{

		CleanupStack::PushL(*aFirstName);

		}

	CleanupStack::PushL(*aFirstNameAsNbr);

    pos = fieldset.Find(KUidContactFieldFamilyName);

    if (pos != KErrNotFound)

        {

        CContactTextField* textfield = fieldset[pos].TextStorage();

        if (textfield)

            {

            TPtrC lastName = textfield->Text();

			*aLastName = lastName.Left(KCharactersFromName).AllocLC();

            }

        }

	// If aLastName was not pushed to cleanupstack above, do it now

	if (*aLastName == NULL)

		{

		}

	CleanupStack::PushL(*aLastNameAsNbr);

		aItem.Id(),

	    *aFirstNameAsNbr ? *aFirstNameAsNbr : &KNullDesC,

	    *aLastNameAsNbr ? *aLastNameAsNbr : &KNullDesC,

		*aFirstName ? *aFirstName : &KNullDesC,

	    *aLastName ? *aLastName: &KNullDesC);

	}

// 1. get first token of LN

// 2. get first token of FN

// 3. get second token of LN

// 4. get second token of FN

// :

// :

// keep getting tokens from the other field.

	{

	QStringList firstNameTokens;

	QStringList lastNameTokens;

	AddTokens(aFirstName, firstNameTokens);

	AddTokens(aLastName, lastNameTokens);

		   (!firstNameTokens.isEmpty() || !lastNameTokens.isEmpty()))

		{

		GetNextToken(lastNameTokens, tokens);

		GetNextToken(firstNameTokens, tokens);

		}

	return tokens;

	}

// Ignore tokens beginning with invalid (unknown) character.

// Keep duplicate tokens to support e.g. search "202" when both FN and LN are "23".

void

	{

	if (aString)

		{

		QString s((QChar*)aString->Ptr(), aString->Length());

#if defined(USE_ORBIT_KEYMAP)

		QStringList tokens = s.split(iKeyMap->Separator(), QString::SkipEmptyParts);

#else

		QStringList tokens = s.split(' ', QString::SkipEmptyParts);

#endif

		// Select tokens in the same order they are in original aString

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

			{

			if (IsValidChar(tokens[i][0]))

				{

				aTokens.append(tokens[i]);

				}

			}

		}

	}

	{

		{

		aDestination.append(padded);

		aSource.removeFirst();

		}

	}

void

	{

	QT_TRYCATCH_LEAVING(tables = FillAllTables());

	HBufC* tableName(NULL);

	while ((tableName = GetNextTableNameL(tables)) != NULL)

		{

		iDeleteStmnt->SetTableName(tableName); // Clears also earlier SQL statement

		RSqlStatement stmnt;

		CleanupClosePushL(stmnt);

		stmnt.PrepareL(iDatabase, iDeleteStmnt->SqlStringL());

		// Contact id was not added with iDeleteStmnt->SetParamL() so it can not be

		// accessed with iDeleteStmnt->ParameterIndex().

		// It is the first and only parameter in query

		const TInt KContactIdParamIndex(KFirstIndex);

		User::LeaveIfError(stmnt.BindInt(KContactIdParamIndex, aContactId));

		// Returns the amount of affected rows. As contact is not present each

		// table, some operations return 0, it is not an error.

		TInt status = stmnt.Exec();

		CleanupStack::PopAndDestroy(&stmnt);

		if (status == KErrDiskFull)

			{

			aLowDiskErrorOccurred = ETrue;

			}

		else

			{

			User::LeaveIfError(status);

			}

		}

	}