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

//

/**

 @file

*/

#include "database.h"

#include "dbdef.h"

#include "filedump.h"

#include <etelqos.h>

#include <etelmm.h>

#include <etelpckt.h>

#include <faxdefn.h>

#include "T_tabdef.h"

#include "input.h"

#include <networking/panroles.h>

#include <nifvar_internal.h>

#include <e32hashtab.h>

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <commsdattypesv1_1_partner.h>

#include <commsdattypesv1_1_internal.h>

#include <nifvar_internal.h>

#endif

/**

makes logging accessible to all files

*/

extern CFileDump* gMsg;

/**

text for local error codes

@internalComponent

*/

TPtrC errorCode[] = {

	_L("Not all required field data supplied"),							//< E_NOTENOUGHDATA

	_L("Command not possible in this transaction state"),				//< E_INVALIDCOMMAND

	_L("Field data supplied has incorrect data type"),					//< E_INCORRECTTYPE

	_L("Column data is invalid for the last written column's type"),	//< E_INCORRECTCOLNAME

	_L("Object already exists"),										//< E_ALREADYEXISTS

	_L("Enumeration supplied is incorrect for this field"),				//< E_INCORRECTENUM

	_L("Incorrect number of Agent fields supplied"),					//< E_INCORRECTAGENT

	_L("Field count does not match expected amount"),					//< E_BADFIELDCOUNT

	_L("No fields recognised"),											//< E_NOFIELDS

	_L("Not supported"),												//< E_NOTSUPPORTED

	_L("No Global Settings specified"),									//< E_INCORRECTGLOBAL

	_L("Bad escaped character"),										//< E_BADESCAPEDCHAR

	_L("Bad hexadecimal")												//< E_BADHEXADECIMAL

	};

#define KTableLinkSeparator		_S("Link")

DBAccess::DBAccess(const TBool aXML)

:

iSecure(EFalse),

iCommitIndividualRecords(EFalse),

iIsMeshFileProcessing(EFalse),

access(DBUnknown),

iLastError(KErrNone),

LastErrorMessage(_L("")),

FieldCountExpected(0),

iColCount(0),

i2000PacketServiceTable(1),

iInAppendMode(0),

iIsXML(aXML),

iLnkByTagRes(NULL)

	{

	}

DBAccess::~DBAccess()

	{

	Close();

	CloseTable();

	iRecordSetHolder.ResetAndDestroy();

	}

void DBAccess::InitCommsdatL()

	{

	#ifdef __COMMDB_ROHID_SUPPORT__

		iSecure = ETrue;

	#endif

#ifdef SYMBIAN_NON_SEAMLESS_NETWORK_BEARER_MOBILITY

	if (iIsMeshFileProcessing)

		{

		//in this case no mapper is needed.

		iDbSession = CMDBSession::NewL(KCDVersion1_2);

		}

	else

		{

		iDbSession = CMDBSession::NewL(KCDVersion1_1);

		}

#else

	iDbSession = CMDBSession::NewL(KCDVersion1_1);

#endif

	iDbSession->SetAttributeMask(ECDHidden | ECDPrivate | ECDProtectedWrite |ECDNoWriteButDelete );

	}

void DBAccess::MaybeBeginTransactionL()

	{

	if(!iDbSession->IsInTransaction())

		{

		iDbSession->OpenTransactionL();

		}

	}

TInt DBAccess::CommitTransaction()

	{

	TInt ret = KErrNone;

	if(iDbSession && iDbSession->IsInTransaction())

		{

		TRAP(ret, iDbSession->CommitTransactionL());

		iRecordSetHolder.ResetAndDestroy();

		}

	return ret;

	}

void DBAccess::Close()

	{

	if(iDbSession)

		{

		delete iDbSession;

		iDbSession = NULL;

		}

	}

void DBAccess::CloseTable()

/**

Closes the table

*/

	{

	if(iTable)

		{

		iTable->iRecords.ResetAndDestroy();

		iTable->iRecords.Close();

		delete iTable;

		iTable = NULL;

		iTableId = 0;

		}

	}

TInt DBAccess::CommitChanges()

/**

Finalise changes to database

  @return ETrue if successful or EFalse

  */

	{

	TInt ret = KErrNone;

	if(iTable)

		{

		gMsg->Dbg(_L("  Committing record"));

        // ******

        // Modify, don't store as if appending don't know what will already be there.

        // This was introduced with meshpreface file helping migration to new

        // comms framework, but is generally useful idea

		// TRAP(ret, iTable->ModifyL(*iDbSession));

        // ******

		/**

		only for testing...

		CCDConnectionPrefsRecord* elem = NULL;

		TInt elemId = iTable->iRecords[0]->ElementId();

		if ( (elemId & KCDMaskShowRecordType) == KCDTIdConnectionPrefsRecord)

		    {

		    elem = static_cast<CCDConnectionPrefsRecord*>(iTable->iRecords[0]);

		    }

		*/

		TRAP(ret, iTable->StoreL(*iDbSession));

		if(ret == KErrNone && iDbSession->IsInTransaction())

			{

			ret = iRecordSetHolder.Append(iTable);

			}

		else

			{

			delete iTable;

			}

		iTable = NULL;

		}

	return ret;

	}

// PRIVATE METHODS

void DBAccess::RemoveCurrentRecord()

	{

	CMDBRecordBase* tempptr = iTable->iRecords[iTable->iRecords.Count()-1];

	delete tempptr;

	iTable->iRecords.Remove(iTable->iRecords.Count()-1);

	if(iRecordId)

		{

		iRecordId = iRecordId - 1;

		}

	}

CMDBRecordBase* DBAccess::GetCurrentRecord()

	{

	return (iTable->iRecords[iTable->iRecords.Count()-1]);

	}

void DBAccess::RecordIsTemplate(TBool aIsTemplate)

	{

	iIsTemplate = aIsTemplate;

	if(iIsTemplate)

		{

		iConfusingTemplateBehaviour = iIsTemplate;

		}

	}

void DBAccess::DoInitAndAddL(CCDRecordBase* aNewRecord,TInt aRecordId)

	{

	iColCount = 0;

	if(iIsTemplate)

		{

		aNewRecord->SetRecordId(KCDDefaultRecord);

		aNewRecord->SetAttributes(ECDHidden);

		}

	else if(iInAppendMode)

	    {

	    if (!iIsXML)

	        {

    		//We are appending and we don't have a clue about what record ids are already in use

    		//So we ask CommsDat to give us an unused one.

    		aNewRecord->SetRecordId(KCDNewRecordRequest);

    		User::LeaveIfError(iTable->iRecords.Append(aNewRecord));

    		return;

	        }

        else

            /**

             * When CED is processing XML files it always has recordIDs.

             */

            aNewRecord->SetRecordId(aRecordId);

	    }

    else if(aRecordId)

		{

		aNewRecord->SetRecordId(aRecordId);

		iRecordId = aRecordId + 1;

		}

	else if(!iTable->iRecords.Count())

		{

		//general case where template records are missing

		aNewRecord->SetRecordId(iRecordId);

		iRecordId = iRecordId + 1;

		}

	else

		{

		if(iConfusingTemplateBehaviour && iRecordId == 1)

			{

			iRecordId = iRecordId + 1;

			}

		aNewRecord->SetRecordId(iRecordId);

		iRecordId = iRecordId + 1;

		}

	// Check whether we've already inserted this record id - if so then we must reject it as a duplicate,

	// lest the database roll back the entire transaction (its behaviour at present)

	TInt newRecordId = aNewRecord->RecordId();

	for(TInt idx = iTable->iRecords.Count() - 1; idx >= 0; --idx)

		{

		if(iTable->iRecords[idx]->RecordId() == newRecordId)

			{

			gMsg->Msg(_L("ERR: record id %d already inserted, skipping (check input file)"), newRecordId);

			delete aNewRecord;

			return;

			}

		}

	User::LeaveIfError(iTable->iRecords.Append(aNewRecord));

	}

void DBAccess::InitAndAddL(CCDRecordBase* aNewRecord,TInt aRecordId)

	{

	CleanupStack::PushL(aNewRecord);

	DoInitAndAddL(aNewRecord,aRecordId);

	CleanupStack::Pop(aNewRecord);

	}

void DBAccess::SaveTableProtection(CMDBRecordSetBase* aRecordSet)

	{

	CloseTable();

	iTable = (CMDBRecordSetBase*)aRecordSet;

	}

void DBAccess::CreateOrInsertRecordL(TCreateType aType,TMDBElementId aRecordElementId, TInt aRecordId)

/*

This method returns the pointer to recordset type depending on record Id

*/

	{

	if(aType == EInsert && iTable->iRecords.Count() >= KCDMaxRecords)

		{

		User::Leave(KErrTooBig); //actually KErrTooManyRecords

		}

	if(aType != EInsert)

		{

		if(aType == ECreateNew)

			{

			iRecordId =	1;

			}

		iTableId = aRecordElementId;

		}

	iNameSet = EFalse;

	switch(iTableId)

		{

		case KCDTIdConnectionPrefsRecord:

			{

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDConnectionPrefsRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDConnectionPrefsRecord>(KCDTIdConnectionPrefsRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDConnectionPrefsRecord* ptrNewRecord = (CCDConnectionPrefsRecord*)CCDRecordBase::RecordFactoryL(KCDTIdConnectionPrefsRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			}

			break;

		case KCDTIdIAPRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDIAPRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDIAPRecord>(KCDTIdIAPRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDIAPRecord* ptrNewRecord = (CCDIAPRecord*)CCDRecordBase::RecordFactoryL(KCDTIdIAPRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdNetworkRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDNetworkRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDNetworkRecord>(KCDTIdNetworkRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDNetworkRecord* ptrNewRecord = (CCDNetworkRecord*)CCDRecordBase::RecordFactoryL(KCDTIdNetworkRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdLocationRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDLocationRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDLocationRecord>(KCDTIdLocationRecord | 1);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDLocationRecord* ptrNewRecord = (CCDLocationRecord*)CCDRecordBase::RecordFactoryL(KCDTIdLocationRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdGlobalSettingsRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDGlobalSettingsRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDGlobalSettingsRecord>(KCDTIdGlobalSettingsRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDGlobalSettingsRecord* ptrNewRecord = (CCDGlobalSettingsRecord*)CCDRecordBase::RecordFactoryL(KCDTIdGlobalSettingsRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdWAPAccessPointRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDWAPAccessPointRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDWAPAccessPointRecord>(KCDTIdWAPAccessPointRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDWAPAccessPointRecord* ptrNewRecord = (CCDWAPAccessPointRecord*)CCDRecordBase::RecordFactoryL(KCDTIdWAPAccessPointRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdDialOutISPRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDDialOutISPRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDDialOutISPRecord>(KCDTIdDialOutISPRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDDialOutISPRecord* ptrNewRecord = (CCDDialOutISPRecord*)CCDRecordBase::RecordFactoryL(KCDTIdDialOutISPRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdDialInISPRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDDialInISPRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDDialInISPRecord>(KCDTIdDialInISPRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDDialInISPRecord* ptrNewRecord = (CCDDialInISPRecord*)CCDRecordBase::RecordFactoryL(KCDTIdDialInISPRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdLANServiceRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDLANServiceRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDLANServiceRecord>(KCDTIdLANServiceRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDLANServiceRecord* ptrNewRecord = (CCDLANServiceRecord*)CCDRecordBase::RecordFactoryL(KCDTIdLANServiceRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdWLANServiceExtRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDWLANServiceExtRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDWLANServiceExtRecord>(KCDTIdWLANServiceExtRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDWLANServiceExtRecord* ptrNewRecord = (CCDWLANServiceExtRecord*)CCDRecordBase::RecordFactoryL(KCDTIdWLANServiceExtRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdVPNServiceRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDVPNServiceRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDVPNServiceRecord>(KCDTIdVPNServiceRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDVPNServiceRecord* ptrNewRecord = (CCDVPNServiceRecord*)CCDRecordBase::RecordFactoryL(KCDTIdVPNServiceRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdPANServiceExtRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDPANServiceExtRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDPANServiceExtRecord>(KCDTIdPANServiceExtRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDPANServiceExtRecord* ptrNewRecord = (CCDPANServiceExtRecord*)CCDRecordBase::RecordFactoryL(KCDTIdPANServiceExtRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdWCDMAPacketServiceRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDWCDMAPacketServiceRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDWCDMAPacketServiceRecord>(KCDTIdWCDMAPacketServiceRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				iRecordId = i2000PacketServiceTable;

				}

			else

				{

				CCDWCDMAPacketServiceRecord* ptrNewRecord = (CCDWCDMAPacketServiceRecord*)CCDRecordBase::RecordFactoryL(KCDTIdWCDMAPacketServiceRecord);

				if(i2000PacketServiceTable == 1)

					{

					InitAndAddL(ptrNewRecord,aRecordId);

					}

				else

					{

					InitAndAddL(ptrNewRecord,i2000PacketServiceTable);

					}

				i2000PacketServiceTable = iRecordId;

				}

			break;

		case KCDTIdOutgoingGprsRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDOutgoingGprsRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDOutgoingGprsRecord>(KCDTIdOutgoingGprsRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);

				}

			else

				{

				CCDOutgoingGprsRecord* ptrNewRecord = (CCDOutgoingGprsRecord*)CCDRecordBase::RecordFactoryL(KCDTIdOutgoingGprsRecord);

				InitAndAddL(ptrNewRecord,aRecordId);

				}

			break;

		case KCDTIdIncomingGprsRecord:

			if(aType != EInsert)

				{

				CMDBRecordSet<CCDIncomingGprsRecord>* ptrRecordSet = new (ELeave)CMDBRecordSet<CCDIncomingGprsRecord>(KCDTIdIncomingGprsRecord);

				SaveTableProtection((CMDBRecordSetBase*)ptrRecordSet);