sl@0: // Copyright (c) 2008-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: //
sl@0: 
sl@0: #ifndef __SQLSRVBLOB_H__
sl@0: #define __SQLSRVBLOB_H__
sl@0: 
sl@0: #include <s32buf.h>
sl@0: 
sl@0: //Forward declarations
sl@0: struct sqlite3_blob;
sl@0: 
sl@0: /**
sl@0: Stream buffer class with no intermediate buffering capabilities.
sl@0: 
sl@0: The primary purpose of this class is:
sl@0:  - to read/write from/to a blob column using sqlite3_blob_read()/sqlite3_blob_write() SQLite functions;
sl@0:  - to serve as an IPC buffer for streaming the blob content from/to the client side dll;
sl@0:  
sl@0: The class overrides the following virtual MStreamBuf functions:
sl@0:  - DoRelease();
sl@0:  - DoSynchL();
sl@0:  - DoReadL();
sl@0:  - DoWriteL();
sl@0:  - DoSeekL();
sl@0: 
sl@0: @internalComponent
sl@0: */
sl@0: NONSHARABLE_CLASS(HBlobBuf) : public MStreamBuf
sl@0: 	{
sl@0: public: 
sl@0: 	enum TMode 
sl@0: 		{
sl@0: 		EReadOnly,
sl@0: 		EReadWrite
sl@0: 		};
sl@0: 
sl@0: public: 
sl@0: 	static HBlobBuf* NewL(sqlite3* aDb, const TDesC8& aDbName, const TDesC8&  aTableName, const TDesC8&  aColumnName, TInt64 aRowId, TMode aMode);
sl@0: 		
sl@0: private:
sl@0: 	HBlobBuf();
sl@0: 	void ConstructL(sqlite3* aDb, const TDesC8& aDbName, const TDesC8& aTableName, const TDesC8& aColumnName, TInt64 aRowId, TMode aMode);
sl@0: 	
sl@0: 	virtual void DoRelease();
sl@0: 	virtual void DoSynchL();
sl@0: 	virtual TInt DoReadL(TAny* aPtr, TInt aMaxLength);
sl@0: 	virtual void DoWriteL(const TAny* aPtr, TInt aLength);
sl@0: 	virtual TStreamPos DoSeekL(MStreamBuf::TMark aMark, TStreamLocation aLocation, TInt aOffset);
sl@0: 
sl@0: 	sqlite3_blob* BlobHandleL();
sl@0: 
sl@0: private:
sl@0: 	sqlite3_blob*	iBlobHandle;
sl@0: 	TInt 			iBlobSize;
sl@0: 	TInt			iWrPos;
sl@0: 	TInt			iRdPos;
sl@0: 	
sl@0: 	};
sl@0: 
sl@0: #endif//__SQLSRVBLOB_H__