// 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);

	}