// Copyright (c) 1998-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:
// DBMS server proxy database
// 
//

#include "SD_STD.H"

// Class CDbsDatabase


/**
SYMBIAN_REMOVE_TRIVIAL_ENCRYPTION version of the method.
Standard phase-one factory method for creation of CDbsDatabase instances.
@param aDbs A reference to the client side DBMS session object
@param aDatabase Database file path
@param aFormat Database format string
@return A pointer to teh created CDbsDatabase instance.
@leave System-wide error code, including KErrNoMemory
*/
CDbsDatabase* CDbsDatabase::NewL(const RDbs& aDbs, const TDesC& aDatabase, const TDesC& aFormat)
	{
	CDbsDatabase* self=new(ELeave) CDbsDatabase;
	CleanupStack::PushL(self);
	
	TIpcArgs args(&aDatabase,&aFormat,TIpcArgs::ENothing,NULL);
	self->ConstructL(aDbs,args);	// two phase construction
	CleanupStack::Pop();			// self
	return self;
	}

/**
SYMBIAN_REMOVE_TRIVIAL_ENCRYPTION version of the method.
Standard phase-two construction method for creation of CDbsDatabase instances.
@param aDbs A reference to the client side DBMS session object
@param aArgs A reference to the packed parameters needed for the database instance creation.
@leave System-wide error code, including KErrNoMemory
*/
void CDbsDatabase::ConstructL(const RDbs& aDbs, TIpcArgs& aArgs)
	{
	iObject.OpenL(aDbs,EDbsOpenDatabase,aArgs);
	}
	

CDbsDatabase::~CDbsDatabase()
	{
	iObject.Close();
	}

TInt CDbsDatabase::Destroy()
	{
	return iObject.SendReceive(EDbsDatabaseDestroy);
	}

TInt CDbsDatabase::Begin()
	{
	return iObject.SendReceive(EDbsDatabaseBegin);
	}

TInt CDbsDatabase::Commit()
	{
	return iObject.SendReceive(EDbsDatabaseCommit);
	}

void CDbsDatabase::Rollback()
	{
	iObject.SendReceive(EDbsDatabaseRollback);
	}

TInt CDbsDatabase::Property(CDbDatabase::TProperty aProperty)
	{
	return iObject.SendReceive(EDbsDatabaseProperty,TIpcArgs(aProperty));
	}

void CDbsDatabase::CreateTableL(const TDesC& aName,const CDbColSet& aColSet,const CDbKey* aPrimaryKey)
	{
	TPtrC8 colset(TDbsParam::PrepareLC(aColSet));
	TIpcArgs m(&aName,&colset,0);
	TPtrC8 primary;
	if (aPrimaryKey)
		{
		primary.Set(TDbsParam::PrepareLC(*aPrimaryKey));
		m.Set(2,&primary);
		}
	iObject.SendReceiveL(EDbsDatabaseCreateTable,m);
	if (aPrimaryKey)
		CleanupStack::PopAndDestroy();	// primary
	CleanupStack::PopAndDestroy();	// colset
	}

void CDbsDatabase::TablesL(CDbTableNames& aNames)
	{
	TIpcArgs m;
	RReadStream in(HDbsBuf::NewLC(iObject,EDbsDatabaseTables,m));
	in>>aNames;
	CleanupStack::PopAndDestroy();	// dbsbuf
	}

void CDbsDatabase::ColumnsL(CDbColSet& aColSet,const TDesC& aName)
	{
	TIpcArgs m(&aName);
	RReadStream in(HDbsBuf::NewLC(iObject,EDbsDatabaseColumns,m));
	in>>aColSet;
	CleanupStack::PopAndDestroy();
	}

void CDbsDatabase::IndexesL(CDbIndexNames& aNames,const TDesC& aTable)
	{
	TIpcArgs m(&aTable);
	RReadStream in(HDbsBuf::NewLC(iObject,EDbsDatabaseIndexes,m));
	in>>aNames;
	CleanupStack::PopAndDestroy();	// dbsbuf
	}

void CDbsDatabase::KeysL(CDbKey& aKey,const TDesC& aName,const TDesC& aTable)
	{
	TIpcArgs args(&aName,&aTable);
	RReadStream in(HDbsBuf::NewLC(iObject,EDbsDatabaseKeys,args));
	in>>aKey;
	CleanupStack::PopAndDestroy();	// dbsbuf
	}

CDbNotifier* CDbsDatabase::OpenNotifierL()
	{
	return CDbsNotifier::NewL(iObject);
	}

CDbIncremental* CDbsDatabase::OpenUtilityL(CDbDatabase::TUtility aType,TInt& aStep)
	{
	TIpcArgs args(aType);
	return CDbsIncremental::NewL(iObject,EDbsDatabaseOpenUtility,args,aStep);
	}

CDbIncremental* CDbsDatabase::OpenDropTableL(const TDesC& aTable,TInt& aStep)
	{
	TIpcArgs args(&aTable);
	return CDbsIncremental::NewL(iObject,EDbsDatabaseOpenDropTable,args,aStep);
	}

CDbIncremental* CDbsDatabase::OpenAlterTableL(const TDesC& aTable,const CDbColSet& aNewDef,TInt& aStep)
	{
	TPtrC8 colset(TDbsParam::PrepareLC(aNewDef));
	TIpcArgs args(&aTable,&colset);
	CDbIncremental* inc=CDbsIncremental::NewL(iObject,EDbsDatabaseOpenAlterTable,args,aStep);
	CleanupStack::PopAndDestroy();	// colset
	return inc;
	}

CDbIncremental* CDbsDatabase::OpenCreateIndexL(const TDesC& aName,const TDesC& aTable,const CDbKey& aKey,TInt& aStep)
	{
	TPtrC8 key(TDbsParam::PrepareLC(aKey));
	TIpcArgs args(&aName,&aTable,&key);
	CDbIncremental* inc=CDbsIncremental::NewL(iObject,EDbsDatabaseOpenCreateIndex,args,aStep);
	CleanupStack::PopAndDestroy();	// key
	return inc;
	}

CDbIncremental* CDbsDatabase::OpenDropIndexL(const TDesC& aName,const TDesC& aTable,TInt& aStep)
	{
	TIpcArgs args(&aName,&aTable);
	return CDbsIncremental::NewL(iObject,EDbsDatabaseOpenDropIndex,args,aStep);
	}

CDbIncremental* CDbsDatabase::OpenExecuteL(const TDesC& aSql,TDbTextComparison aComparison,TInt& aInit)
	{
	TIpcArgs args(&aSql,aComparison);
	return CDbsIncremental::NewL(iObject,EDbsDatabaseExecute,args,aInit);
	}

CDbCursor* CDbsDatabase::PrepareViewL(const TDbQuery& aQuery,const TDbWindow& aWindow,RDbRowSet::TAccess aAccess)
	{
	const TDesC& des = aQuery.Query();
	TPckgC<TDbWindow> pckg(aWindow);
	TIpcArgs args(&des,aQuery.Comparison()|(aAccess<<8),&pckg);
	return CDbsCursor::NewL(iObject,EDbsDatabasePrepareView,args);
	}

CDbCursor* CDbsDatabase::OpenTableL(const TDesC& aName,RDbRowSet::TAccess aAccess)
	{
	TIpcArgs args(&aName,aAccess);
	return CDbsCursor::NewL(iObject,EDbsDatabaseOpenTable,args);
	}