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

#ifndef __SQLSRVBLOB_H__
#define __SQLSRVBLOB_H__

#include <s32buf.h>

//Forward declarations
struct sqlite3_blob;

/**
Stream buffer class with no intermediate buffering capabilities.

The primary purpose of this class is:
 - to read/write from/to a blob column using sqlite3_blob_read()/sqlite3_blob_write() SQLite functions;
 - to serve as an IPC buffer for streaming the blob content from/to the client side dll;
 
The class overrides the following virtual MStreamBuf functions:
 - DoRelease();
 - DoSynchL();
 - DoReadL();
 - DoWriteL();
 - DoSeekL();

@internalComponent
*/
NONSHARABLE_CLASS(HBlobBuf) : public MStreamBuf
	{
public: 
	enum TMode 
		{
		EReadOnly,
		EReadWrite
		};

public: 
	static HBlobBuf* NewL(sqlite3* aDb, const TDesC8& aDbName, const TDesC8&  aTableName, const TDesC8&  aColumnName, TInt64 aRowId, TMode aMode);
		
private:
	HBlobBuf();
	void ConstructL(sqlite3* aDb, const TDesC8& aDbName, const TDesC8& aTableName, const TDesC8& aColumnName, TInt64 aRowId, TMode aMode);
	
	virtual void DoRelease();
	virtual void DoSynchL();
	virtual TInt DoReadL(TAny* aPtr, TInt aMaxLength);
	virtual void DoWriteL(const TAny* aPtr, TInt aLength);
	virtual TStreamPos DoSeekL(MStreamBuf::TMark aMark, TStreamLocation aLocation, TInt aOffset);

	sqlite3_blob* BlobHandleL();

private:
	sqlite3_blob*	iBlobHandle;
	TInt 			iBlobSize;
	TInt			iWrPos;
	TInt			iRdPos;
	
	};

#endif//__SQLSRVBLOB_H__