sl@0: // Copyright (c) 2008-2010 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: #include <s32mem.h>
sl@0: #include "SqlDb.h"
sl@0: #include "SqlAssert.h"
sl@0: #include "SqlDatabaseImpl.h"
sl@0: #include "IPCBuf.h"
sl@0: #include "OstTraceDefinitions.h"
sl@0: #ifdef OST_TRACE_COMPILER_IN_USE
sl@0: #include "SqlBlobTraces.h"
sl@0: #endif
sl@0: #include "SqlTraceDef.h"
sl@0: 
sl@0: // The maximum time (100 milliseconds) that a block of data is allowed to take to be read/written by TSqlBlob.
sl@0: // If the time taken is longer than this value then the next block size used will be less
sl@0: const TInt KTimeThresholdInMicroSecs = 100000; 
sl@0: // The largest block size used by TSqlBlob is 32Kb
sl@0: const TInt KLargestBlockSize = 32 * 1024; 
sl@0: // The client-side buffer will be used instead if the calculated block size is 2Kb or less 
sl@0: const TInt KUseClientBufferThreshold = 2 * 1024; 
sl@0: 
sl@0: // Prepare an IPC buffer containing the parameter values
sl@0: static HBufC8* PrepareIpcParamBufLC(const TDesC& aTableName, const TDesC& aColumnName, TInt64 aRowId, 
sl@0: 								  TBool aReadOnly, const TDesC& aDbName)
sl@0: 	{
sl@0: 	HBufC8* ipcPrmBuf = HBufC8::NewLC(aTableName.Size() + sizeof(TDesC) + 
sl@0: 									  aColumnName.Size() + sizeof(TDesC) +
sl@0: 									  sizeof(aRowId) + sizeof(aReadOnly) + 
sl@0: 									  aDbName.Size() + sizeof(TDesC) + sizeof(TInt32) * 3);
sl@0: 	TPtr8 ipcPrmDes = ipcPrmBuf->Des();
sl@0: 	RDesWriteStream strm(ipcPrmDes);
sl@0: 	
sl@0: 	strm << static_cast <TInt32> (aTableName.Length()) 
sl@0: 	     << aTableName 
sl@0: 	     << static_cast <TInt32> (aColumnName.Length()) 
sl@0: 	     << aColumnName 
sl@0: 	     << aRowId 
sl@0: 	     << static_cast<TInt32>(aReadOnly) 
sl@0: 	     << static_cast <TInt32> (aDbName.Length()) 
sl@0: 	     << aDbName;
sl@0: 	strm.CommitL();
sl@0: 	strm.Close();
sl@0: 	return ipcPrmBuf;
sl@0: 	}
sl@0: 
sl@0: // Create an IPC stream, sending the IPC buffer containing the parameter values
sl@0: static MStreamBuf* CreateIpcStreamL(RSqlDbSession& aDbSession, const TDesC8& aIpcPrmBuf)
sl@0: 	{
sl@0: 	TIpcArgs ipcArgs;
sl@0: 	ipcArgs.Set(0, aIpcPrmBuf.Length());
sl@0: 	ipcArgs.Set(1, &aIpcPrmBuf);
sl@0: 	HIpcBuf* ipcBuf = HIpcBuf::NewL(aDbSession, ::MakeMsgCode(ESqlSrvDbBlobSource, ESqlSrvNoHandle, 0), ipcArgs);
sl@0: 	return ipcBuf;
sl@0: 	}	
sl@0: 	
sl@0: // Used by TSqlBlob to calculate the appropriate block size to use for the next transfer of blob data
sl@0: static TInt CalculateBlockSize(TInt aRemainingDataSize, TInt aPreviousBlockSize, TBool aTimeThresholdBreached)
sl@0: 	{
sl@0: 	TInt blockSize = aPreviousBlockSize;
sl@0: 	if(aTimeThresholdBreached)
sl@0: 		{
sl@0: 		// The time threshold was breached using the previous block size
sl@0: 		// so we will reduce the block size by a factor of 2
sl@0: 		blockSize /= 2;
sl@0: 		if(blockSize <= KUseClientBufferThreshold)
sl@0: 			{
sl@0: 			// Just use the client-side IPC buffer size if things get to this stage
sl@0: 			blockSize = KIpcBufSize; 
sl@0: 			}
sl@0: 		}	
sl@0: 	return aRemainingDataSize <= blockSize ? aRemainingDataSize : blockSize;
sl@0: 	}
sl@0: 		
sl@0: // Retrieve the data in blocks
sl@0: static void DoReadInBlocksL(RSqlBlobReadStream& aStrm, TDes8& aDestBuffer, TInt aBlobSize)
sl@0: 	{
sl@0: 	TInt remainingDataSize = aBlobSize;	
sl@0: 	TBool timeThresholdBreached = EFalse;
sl@0: 	TInt blockSize = KLargestBlockSize;
sl@0: 	TPtr8 ptr((TUint8*)aDestBuffer.Ptr(), aDestBuffer.MaxSize());
sl@0: 	
sl@0: 	while(remainingDataSize > 0)
sl@0: 		{	
sl@0: 		// Calculate the block size to use for this iteration, based on 
sl@0: 		// how much data is remaining and how fast the previous read was
sl@0: 		blockSize = CalculateBlockSize(remainingDataSize, blockSize, timeThresholdBreached);
sl@0: 		
sl@0: 		// Read the block of data, timing how long it takes
sl@0: 		TTime t1, t2;
sl@0: 		t1.HomeTime();
sl@0: 		aStrm.ReadL(ptr, blockSize);
sl@0: 		t2.HomeTime();
sl@0: 		TTimeIntervalMicroSeconds readTime = t2.MicroSecondsFrom(t1);
sl@0: 		timeThresholdBreached = (readTime.Int64() > KTimeThresholdInMicroSecs);
sl@0: 	
sl@0: 		// Update how much data is still to be read, and the buffer pointer
sl@0: 		remainingDataSize -= blockSize;
sl@0: 		__ASSERT_DEBUG(remainingDataSize >= 0, __SQLPANIC2(ESqlPanicInternalError));
sl@0: 		ptr.Set((TUint8*)(ptr.Ptr() + blockSize), 0, remainingDataSize);
sl@0: 		}	
sl@0: 	aDestBuffer.SetLength(aBlobSize);
sl@0: 	}
sl@0: 	
sl@0: // Send the data in blocks
sl@0: static void DoWriteInBlocksL(RSqlBlobWriteStream& aStrm, const TDesC8& aData, TInt aDataSize)
sl@0: 	{
sl@0: 	TInt remainingDataSize = aDataSize;	
sl@0: 	TBool timeThresholdBreached = EFalse;
sl@0: 	TInt blockSize = KLargestBlockSize;
sl@0: 	
sl@0: 	while(remainingDataSize > 0)
sl@0: 		{	
sl@0: 		// Calculate the block size to use for this iteration, based on 
sl@0: 		// how much data is remaining and how fast the previous write was
sl@0: 		blockSize = CalculateBlockSize(remainingDataSize, blockSize, timeThresholdBreached);
sl@0: 
sl@0: 		// Write the block of data, timing how long it takes
sl@0: 		TTime t1, t2;
sl@0: 		t1.HomeTime();
sl@0: 		aStrm.WriteL(aData.Right(remainingDataSize), blockSize);
sl@0: 		t2.HomeTime();
sl@0: 		TTimeIntervalMicroSeconds writeTime = t2.MicroSecondsFrom(t1);
sl@0: 		timeThresholdBreached = (writeTime.Int64() > KTimeThresholdInMicroSecs);
sl@0: 	
sl@0: 		// Update how much data is still to be written
sl@0: 		remainingDataSize -= blockSize;
sl@0: 		__ASSERT_DEBUG(remainingDataSize >= 0, __SQLPANIC2(ESqlPanicInternalError));
sl@0: 		}	
sl@0: 	aStrm.CommitL();	
sl@0: 	}
sl@0: 	
sl@0: // The data is returned in a UTF-8 buffer that is allocated on the heap
sl@0: static HBufC8* ReadLC(RSqlDatabase& aDb, 	
sl@0: 				   	  const TDesC& aTableName, 
sl@0: 				   	  const TDesC& aColumnName, 
sl@0: 				   	  TInt64 aRowId,
sl@0: 				   	  const TDesC& aDbName)	
sl@0: 	{
sl@0: 	RSqlBlobReadStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	strm.OpenL(aDb, aTableName, aColumnName, aRowId, aDbName);		
sl@0: 	TInt blobSize = strm.SizeL(); // size of the blob, in bytes
sl@0: 	HBufC8* buf = HBufC8::NewLC(blobSize);
sl@0: 	TPtr8 ptr = buf->Des();	
sl@0: 	DoReadInBlocksL(strm, ptr, blobSize);
sl@0: 	CleanupStack::Pop(); // buf
sl@0: 	CleanupStack::PopAndDestroy(); // strm
sl@0: 	CleanupStack::PushL(buf);
sl@0: 	return buf;	
sl@0: 	}
sl@0: 
sl@0: // The data is returned in the UTF-8 buffer passed in
sl@0: static void ReadL(RSqlDatabase& aDb, 	
sl@0: 				  const TDesC& aTableName, 
sl@0: 				  const TDesC& aColumnName, 	
sl@0: 				  TDes8& aBuffer,
sl@0: 				  TInt64 aRowId,
sl@0: 				  const TDesC& aDbName)
sl@0: 	{	
sl@0: 	RSqlBlobReadStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	strm.OpenL(aDb, aTableName, aColumnName, aRowId, aDbName);		
sl@0: 	TInt blobSize = strm.SizeL(); // size of the blob, in bytes
sl@0: 	if(blobSize > aBuffer.MaxSize())
sl@0: 		{
sl@0: 		__SQLLEAVE2(KErrOverflow);
sl@0: 		}	
sl@0: 	DoReadInBlocksL(strm, aBuffer, blobSize);
sl@0: 	CleanupStack::PopAndDestroy(); // strm
sl@0: 	}
sl@0: 	
sl@0: // The data in the client-specified UTF-8 buffer is written
sl@0: static void WriteL(RSqlDatabase& aDb, 	
sl@0: 				   const TDesC& aTableName, 
sl@0: 				   const TDesC& aColumnName,
sl@0: 				   const TDesC8& aData,	
sl@0: 				   TInt64 aRowId,
sl@0: 				   const TDesC& aDbName)
sl@0: 	{
sl@0: 	RSqlBlobWriteStream strm;
sl@0: 	CleanupClosePushL(strm);
sl@0: 	strm.OpenL(aDb, aTableName, aColumnName, aRowId, aDbName);
sl@0: 	TInt dataSize = aData.Size(); // size of the data, in bytes
sl@0: 	TInt blobSize = strm.SizeL(); // size of the blob, in bytes
sl@0: 	if(dataSize > blobSize)
sl@0: 		{
sl@0: 		__SQLLEAVE2(KErrEof);
sl@0: 		}	
sl@0: 	if(dataSize > 0)
sl@0: 		{
sl@0: 		DoWriteInBlocksL(strm, aData, dataSize);
sl@0: 		}	
sl@0: 	CleanupStack::PopAndDestroy(); // strm
sl@0: 	}
sl@0: 
sl@0: ////////////////////////////////////////////////////////////////////////////////	
sl@0: 			
sl@0: /**
sl@0: Gives access to a blob as a read-only stream of bytes.
sl@0: 
sl@0: @param aDb        	  A connection to the database that contains the blob
sl@0: @param aTableName     The name of the table that contains the blob
sl@0: @param aColumnName    The name of the column that contains the blob
sl@0: @param aRowId         The ROWID of the record that contains the blob,
sl@0: 					  or KSqlLastInsertedRowId if the last inserted ROWID 
sl@0: 					  of the specified database connection is to be used
sl@0: @param aDbName  	  The name of the attached database if the blob is 
sl@0: 					  contained in an attached database
sl@0: 
sl@0: @leave KSqlErrGeneral, 		 Invalid database connection or table name or column name 
sl@0: 							 or column type or ROWID or database name;							 
sl@0: 	   KErrNoMemory, 		 An out of memory condition occurred;	   
sl@0: 	   KErrArgument, 		 The ROWID is zero or negative or a UTF-16 to UTF-8 string conversion failed;
sl@0:   	   KErrBadName,  		 The table name, column name or database name has an invalid length;
sl@0: 	   KErrPermissionDenied, The client does not have the required security capabilites for this operation; 						 
sl@0:        						 Note that the function may also leave with some other system wide errors or 
sl@0:                      		 database specific errors categorised as ESqlDbError.
sl@0: 	     
sl@0: @panic SqlDb 2 The database object is not yet created
sl@0: @panic SqlDb 3 Server failed to create a handle to the blob
sl@0: @panic SqlDb 4 In _DEBUG mode. Bad parameter value
sl@0: @panic SqlDb 7 In _DEBUG mode. NULL blob handle
sl@0: 
sl@0: @capability None, if the aDb parameter represents a handle which operates on a non-secure database;
sl@0:             RSqlSecurityPolicy::EReadPolicy or 
sl@0:             RSqlSecurityPolicy::ESchemaPolicy database policy type, if the blob belongs to a secure database; 
sl@0: */		
sl@0: EXPORT_C void RSqlBlobReadStream::OpenL(RSqlDatabase& aDb, const TDesC& aTableName, const TDesC& aColumnName, 
sl@0: 										TInt64 aRowId, const TDesC& aDbName)
sl@0: 	{
sl@0: 	SQL_TRACE_BORDER(OstTraceExt5(TRACE_BORDER, RSQLBLOBREADSTREAM_OPENL_ENTRY, "Entry;0;RSqlBlobReadStream::OpenL;aDb=0x%X;aTableName=%S;aColumnName=%S;aDbName=%S;aRowId=%lld", (TUint)&aDb, __SQLPRNSTR(aTableName), __SQLPRNSTR(aColumnName), __SQLPRNSTR(aDbName), aRowId));
sl@0: 	HBufC8* ipcPrmBuf = ::PrepareIpcParamBufLC(aTableName, aColumnName, aRowId, ETrue, aDbName);
sl@0: 	MStreamBuf* strm = ::CreateIpcStreamL(aDb.Impl().Session(), ipcPrmBuf->Des());
sl@0: 	Attach(strm);
sl@0: 	CleanupStack::PopAndDestroy(ipcPrmBuf);	
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLBLOBREADSTREAM_OPENL_EXIT, "Exit;0x%x;RSqlBlobReadStream::OpenL;strm=0x%X", (TUint)this, (TUint)strm));
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: Returns the size of the blob object, in bytes.
sl@0: 
sl@0: @return The size of the blob object, in bytes
sl@0: 
sl@0: @leave One of the system-wide error codes
sl@0: 
sl@0: @panic SqlDb 2 The stream buffer is NULL
sl@0: 	
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C TInt RSqlBlobReadStream::SizeL()
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTrace1(TRACE_BORDER, RSQLBLOBREADSTREAM_SIZEL_ENTRY, "Entry;0x%X;RSqlBlobReadStream::SizeL;", (TUint)this));
sl@0: 	MStreamBuf* src = Source();
sl@0: 	__ASSERT_ALWAYS(src != NULL, __SQLPANIC(ESqlPanicInvalidObj));
sl@0: 	TInt size = src->SizeL();
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLBLOBREADSTREAM_SIZEL_EXIT, "Exit;0x%X;RSqlBlobReadStream::SizeL;size=%d", (TUint)this, size));
sl@0: 	return size;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Gives access to a blob as a writeable stream of bytes.
sl@0: 
sl@0: @param aDb        	  A connection to the database that contains the blob
sl@0: @param aTableName     The name of the table that contains the blob
sl@0: @param aColumnName    The name of the column that contains the blob
sl@0: @param aRowId         The ROWID of the record that contains the blob,
sl@0: 					  or KSqlLastInsertedRowId if the last inserted ROWID 
sl@0: 					  of the specified database connection is to be used
sl@0: @param aDbName  	  The name of the attached database if the blob is 
sl@0: 					  contained in an attached database
sl@0: 
sl@0: @leave KSqlErrGeneral, 		 Invalid database connection or table name or column name or column 
sl@0: 							 type or ROWID or database name, or the specified column is indexed;
sl@0: 	   KErrNoMemory, 		 An out of memory condition occurred;	   
sl@0: 	   KErrArgument, 		 The ROWID is zero or negative or a UTF-16 to UTF-8 string conversion failed;
sl@0:   	   KErrBadName,  		 The table name, column name or database name has an invalid length;
sl@0: 	   KErrPermissionDenied, The client does not have the required security capabilites for this operation; 						 
sl@0:        						 Note that the function may also leave with some other system wide errors or 
sl@0:                      		 database specific errors categorised as ESqlDbError.
sl@0: 	     
sl@0: @panic SqlDb 2 The database object is not yet created
sl@0: @panic SqlDb 3 Server failed to create a handle to the blob
sl@0: @panic SqlDb 4 In _DEBUG mode. Bad parameter value
sl@0: @panic SqlDb 7 In _DEBUG mode. NULL blob handle
sl@0: 
sl@0: @capability None, if the aDb parameter represents a handle which operates on a non-secure database;
sl@0:             RSqlSecurityPolicy::EWritePolicy or 
sl@0:             RSqlSecurityPolicy::ESchemaPolicy database policy type, if the blob belongs to a secure database; 
sl@0: */							
sl@0: EXPORT_C void RSqlBlobWriteStream::OpenL(RSqlDatabase& aDb, const TDesC& aTableName, const TDesC& aColumnName, 
sl@0: 										 TInt64 aRowId, const TDesC& aDbName)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt5(TRACE_BORDER, RSQLBLOBWRITESTREAM_OPENL_ENTRY, "Entry;0;RSqlBlobWriteStream::OpenL;aDb=0x%X;aTableName=%S;aColumnName=%S;aDbName=%S;aRowId=%lld", (TUint)&aDb, __SQLPRNSTR(aTableName), __SQLPRNSTR(aColumnName), __SQLPRNSTR(aDbName), aRowId));
sl@0: 	HBufC8* ipcPrmBuf = ::PrepareIpcParamBufLC(aTableName, aColumnName, aRowId, EFalse, aDbName);
sl@0: 	MStreamBuf* strm = ::CreateIpcStreamL(aDb.Impl().Session(), ipcPrmBuf->Des());
sl@0: 	Attach(strm);
sl@0: 	CleanupStack::PopAndDestroy(ipcPrmBuf);		
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLBLOBWRITESTREAM_OPENL_EXIT, "Exit;0x%x;RSqlBlobWriteStream::OpenL;strm=0x%X", (TUint)this, (TUint)strm));
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Returns the size of the blob object, in bytes.
sl@0: 
sl@0: @return The size of the blob object, in bytes
sl@0: 
sl@0: @leave One of the system-wide error codes
sl@0: 
sl@0: @panic SqlDb 2 The stream buffer is NULL
sl@0: 	
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C TInt RSqlBlobWriteStream::SizeL()
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTrace1(TRACE_BORDER, RSQLBLOBWRITESTREAM_SIZEL_ENTRY, "Entry;0x%X;RSqlBlobWriteStream::SizeL;", (TUint)this));
sl@0: 	MStreamBuf* sink = Sink();
sl@0: 	__ASSERT_ALWAYS(sink != NULL, __SQLPANIC(ESqlPanicInvalidObj));
sl@0: 	TInt size =  sink->SizeL();
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLBLOBWRITESTREAM_SIZEL_EXIT, "Exit;0x%X;RSqlBlobWriteStream::SizeL;size=%d", (TUint)this, size));
sl@0:     return size;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Retrieves the entire content of a blob and returns it to the client 
sl@0: in a heap allocated buffer which has been placed on the cleanup stack. 
sl@0: It is the responsibility of the client to destroy the returned buffer.
sl@0: 
sl@0: @param aDb        	  A connection to the database that contains the blob
sl@0: @param aTableName     The name of the table that contains the blob
sl@0: @param aColumnName    The name of the column that contains the blob
sl@0: @param aRowId         The ROWID of the record that contains the blob,
sl@0: 					  or KSqlLastInsertedRowId if the last inserted ROWID 
sl@0: 					  of the specified database connection is to be used
sl@0: @param aDbName  	  The name of the attached database if the blob is 
sl@0: 					  contained in an attached database
sl@0: 
sl@0: @leave KSqlErrGeneral, 		 Invalid database connection or table name or column name 
sl@0: 							 or column type or ROWID or database name;							 
sl@0: 	   KErrNoMemory, 		 An out of memory condition occurred;	   
sl@0: 	   KErrArgument, 		 The ROWID is zero or negative or a UTF-16 to UTF-8 string conversion failed;
sl@0:   	   KErrBadName,  		 The table name, column name or database name has an invalid length;
sl@0: 	   KErrPermissionDenied, The client does not have the required security capabilites for this operation; 						 
sl@0:        						 Note that the function may also leave with some other system wide errors or 
sl@0:                      		 database specific errors categorised as ESqlDbError.
sl@0: 	     
sl@0: @panic SqlDb 2 The database object is not yet created
sl@0: @panic SqlDb 3 Server failed to create a handle to the blob
sl@0: @panic SqlDb 4 In _DEBUG mode. Bad parameter value
sl@0: @panic SqlDb 7 In _DEBUG mode. NULL blob handle or miscalculation of remaining data to be read
sl@0: 
sl@0: @capability None, if the aDb parameter represents a handle which operates on a non-secure database;
sl@0:             RSqlSecurityPolicy::EReadPolicy or 
sl@0:             RSqlSecurityPolicy::ESchemaPolicy database policy type, if the blob belongs to a secure database; 
sl@0: */
sl@0: EXPORT_C HBufC8* TSqlBlob::GetLC(RSqlDatabase& aDb, 	
sl@0: 					     	     const TDesC& aTableName, 
sl@0: 					     		 const TDesC& aColumnName, 	
sl@0: 					     		 TInt64 aRowId,
sl@0: 					     		 const TDesC& aDbName)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt5(TRACE_BORDER, TSQLBLOB_GETLC_ENTRY, "Entry;0;TSqlBlob::GetLC;aDb=0x%X;aTableName=%S;aColumnName=%S;aDbName=%S;aRowId=%lld", (TUint)&aDb, __SQLPRNSTR(aTableName), __SQLPRNSTR(aColumnName), __SQLPRNSTR(aDbName), aRowId));
sl@0: 	HBufC8* res = ReadLC(aDb, aTableName, aColumnName, aRowId, aDbName);
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, TSQLBLOB_GETLC_EXIT, "Exit;0;TSqlBlob::GetLC;res=0x%X;res->Size()=%d", (TUint)res, res->Des().Size()));
sl@0: 	return res;
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: Retrieves the entire content of a blob into a client specified buffer.
sl@0: 
sl@0: @param aDb        	  A connection to the database that contains the blob
sl@0: @param aTableName     The name of the table that contains the blob
sl@0: @param aColumnName    The name of the column that contains the blob
sl@0: @param aRowId         The ROWID of the record that contains the blob,
sl@0: 					  or KSqlLastInsertedRowId if the last inserted ROWID 
sl@0: 					  of the specified database connection is to be used
sl@0: @param aDbName  	  The name of the attached database if the blob is 
sl@0: 					  contained in an attached database
sl@0: 
sl@0: @return KSqlErrGeneral, 	  Invalid database connection or table name or column name 
sl@0: 							  or column type or ROWID or database name;							 
sl@0: 	    KErrNoMemory, 		  An out of memory condition occurred;	   
sl@0: 	    KErrArgument, 		  The ROWID is zero or negative or a UTF-16 to UTF-8 string conversion failed;
sl@0:  	    KErrOverflow, 		  The specified buffer is not big enough to hold the entire blob;
sl@0:   	    KErrBadName,  		  The table name, column name or database name has an invalid length;
sl@0: 	    KErrPermissionDenied, The client does not have the required security capabilites for this operation; 						 
sl@0:        						  Note that the function may also leave with some other system wide errors or 
sl@0:                      		  database specific errors categorised as ESqlDbError.                    		 
sl@0: 	     
sl@0: @panic SqlDb 2 The database object is not yet created
sl@0: @panic SqlDb 3 Server failed to create a handle to the blob
sl@0: @panic SqlDb 4 In _DEBUG mode. Bad parameter value
sl@0: @panic SqlDb 7 In _DEBUG mode. NULL blob handle or miscalculation of remaining data to be read
sl@0: 
sl@0: @capability None, if the aDb parameter represents a handle which operates on a non-secure database;
sl@0:             RSqlSecurityPolicy::EReadPolicy or 
sl@0:             RSqlSecurityPolicy::ESchemaPolicy database policy type, if the blob belongs to a secure database; 
sl@0: */
sl@0: EXPORT_C TInt TSqlBlob::Get(RSqlDatabase& aDb, 	
sl@0: 					 		const TDesC& aTableName, 
sl@0: 					 	    const TDesC& aColumnName, 	
sl@0: 					 	    TDes8& aBuffer,
sl@0: 					 		TInt64 aRowId,
sl@0: 					 	    const TDesC& aDbName)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt5(TRACE_BORDER, TSQLBLOB_GET_ENTRY, "Entry;0;TSqlBlob::Get;aDb=0x%X;aTableName=%S;aColumnName=%S;aDbName=%S;aRowId=%lld", (TUint)&aDb, __SQLPRNSTR(aTableName), __SQLPRNSTR(aColumnName), __SQLPRNSTR(aDbName), aRowId));
sl@0: 	TRAPD(err, ReadL(aDb, aTableName, aColumnName, aBuffer, aRowId, aDbName));
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, TSQLBLOB_GET_EXIT, "Exit;0;TSqlBlob::Get;aBuffer.Ptr()=0x%X;aBuffer.Size()=%d", (TUint)aBuffer.Ptr(), aBuffer.Size()));
sl@0: 	return err;	
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Writes the data in a client specified buffer to a blob.
sl@0: 
sl@0: @param aDb        	  A connection to the database that contains the blob
sl@0: @param aTableName     The name of the table that contains the blob
sl@0: @param aColumnName    The name of the column that contains the blob
sl@0: @param aRowId         The ROWID of the record that contains the blob,
sl@0: 					  or KSqlLastInsertedRowId if the last inserted ROWID 
sl@0: 					  of the specified database connection is to be used
sl@0: @param aDbName  	  The name of the attached database if the blob is 
sl@0: 					  contained in an attached database
sl@0: 
sl@0: @leave KSqlErrGeneral, 		 Invalid database connection or table name or column name or column 
sl@0: 							 type or ROWID or database name, or the specified column is indexed;
sl@0: 	   KErrNoMemory, 		 An out of memory condition occurred;	   
sl@0: 	   KErrArgument, 		 The ROWID is zero or negative or a UTF-16 to UTF-8 string conversion failed;
sl@0: 	   KErrEof,	     		 The data in the specified buffer is larger in size than the blob object;
sl@0:   	   KErrBadName,  		 The table name, column name or database name has an invalid length;
sl@0: 	   KErrPermissionDenied, The client does not have the required security capabilites for this operation; 						 
sl@0:        						 Note that the function may also leave with some other system wide errors or 
sl@0:                      		 database specific errors categorised as ESqlDbError.
sl@0: 	     
sl@0: @panic SqlDb 2 The database object is not yet created
sl@0: @panic SqlDb 3 Server failed to create a handle to the blob
sl@0: @panic SqlDb 4 In _DEBUG mode. Bad parameter value
sl@0: @panic SqlDb 7 In _DEBUG mode. NULL blob handle or miscalculation of remaining data to be written
sl@0: 
sl@0: @capability None, if the aDb parameter represents a handle which operates on a non-secure database;
sl@0:             RSqlSecurityPolicy::EWritePolicy or 
sl@0:             RSqlSecurityPolicy::ESchemaPolicy database policy type, if the blob belongs to a secure database; 
sl@0: */
sl@0: EXPORT_C void TSqlBlob::SetL(RSqlDatabase& aDb, 	
sl@0: 					  		 const TDesC& aTableName, 
sl@0: 					  		 const TDesC& aColumnName,
sl@0: 					  		 const TDesC8& aData,	
sl@0: 					  		 TInt64 aRowId,
sl@0: 					  		 const TDesC& aDbName)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt5(TRACE_BORDER, TSQLBLOB_SET_ENTRY, "Entry;0;TSqlBlob::Set;aDb=0x%X;aTableName=%S;aColumnName=%S;aDbName=%S;aRowId=%lld", (TUint)&aDb, __SQLPRNSTR(aTableName), __SQLPRNSTR(aColumnName), __SQLPRNSTR(aDbName), aRowId));
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, TSQLBLOB_SET_ENTRYEXT, "EntryExt;0;TSqlBlob::Set;aData.Ptr=0x%X;aData.Size()=%d", (TUint)aData.Ptr(), aData.Size()));
sl@0: 	WriteL(aDb, aTableName, aColumnName, aData,	aRowId, aDbName);
sl@0:     SQL_TRACE_BORDER(OstTrace0(TRACE_BORDER, TSQLBLOB_SET_EXIT, "Exit;0;TSqlBlob::Set"));
sl@0: 	}
sl@0: