sl@0: // Copyright (c) 2006-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 <sqldb.h>					//RSqlColumnReadStream, RSqlParamWriteStream
sl@0: #include "SqlStatementImpl.h"		//CSqlStatementImpl
sl@0: #include "OstTraceDefinitions.h"
sl@0: #ifdef OST_TRACE_COMPILER_IN_USE
sl@0: #include "SqlStreamTraces.h"
sl@0: #endif
sl@0: #include "SqlTraceDef.h"
sl@0: 
sl@0: ////////////////////////////////////////////////////////////////////////////////////////////////////
sl@0: /////////////////////         RSqlColumnReadStream              ////////////////////////////////////
sl@0: ////////////////////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: /**
sl@0: Gives access to column data as a read-only stream of characters,
sl@0: 
sl@0: The function can only be used for text and binary column types.
sl@0: 
sl@0: @param aStmt        The RSqlStatement object to which the referred column belongs.
sl@0: @param aColumnIndex The index value identifying the column; this is 0 for the first column.
sl@0: 
sl@0: @return KErrNone, the text column data stream has been opened successfully;
sl@0:         KErrNoMemory, an out of memory condition occurred;
sl@0:         KErrArgument, the column type is neither text nor binary.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C TInt RSqlColumnReadStream::ColumnText(RSqlStatement& aStmt, TInt aColumnIndex)
sl@0: 	{
sl@0: 	SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNTEXT_ENTRY, "Entry;0x%X;RSqlColumnReadStream::ColumnText;aStmt=0x%X;aColumnIndex=%d", (TUint)this, (TUint)&aStmt, aColumnIndex));
sl@0: 	TRAPD(err, Attach(aStmt.Impl().ColumnSourceL(aColumnIndex)));
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNTEXT_EXIT, "Exit;0x%X;RSqlColumnReadStream::ColumnText;err=%d", (TUint)this, err));
sl@0: 	return err;
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: Gives access to column data as a read-only stream of bytes.
sl@0: 
sl@0: The function can only be used for text and binary column types.
sl@0: 
sl@0: @param aStmt        The RSqlStatement object to which the referred column belongs.
sl@0: @param aColumnIndex The index value identifying the column; this is 0 for the first column.
sl@0: 
sl@0: @return KErrNone, the text column data stream has been opened successfully;
sl@0:         KErrNoMemory, an out of memory condition occurred;
sl@0:         KErrArgument, the column type is neither text nor binary.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C TInt RSqlColumnReadStream::ColumnBinary(RSqlStatement& aStmt, TInt aColumnIndex)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNBINARY_ENTRY, "Entry;0x%X;RSqlColumnReadStream::ColumnBinary;aStmt=0x%X;aColumnIndex=%d", (TUint)this, (TUint)&aStmt, aColumnIndex));
sl@0: 	TRAPD(err, Attach(aStmt.Impl().ColumnSourceL(aColumnIndex)));
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNBINARY_EXIT, "Exit;0x%X;RSqlColumnReadStream::ColumnBinary;err=%d", (TUint)this, err));
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Gives access to column data as a read-only stream of characters,
sl@0: 
sl@0: The function can only be used for text and binary column types.
sl@0: 
sl@0: @param aStmt        The RSqlStatement object to which the referred column belongs.
sl@0: @param aColumnIndex The index value identifying the column; this is 0 for the first column.
sl@0: 
sl@0: @leave  KErrNoMemory, an out of memory condition occurred;
sl@0:         KErrArgument, the column type is neither text nor binary.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C void RSqlColumnReadStream::ColumnTextL(RSqlStatement& aStmt, TInt aColumnIndex)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNTEXTL_ENTRY, "Entry;0x%X;RSqlColumnReadStream::ColumnTextL;aStmt=0x%X;aColumnIndex=%d", (TUint)this, (TUint)&aStmt, aColumnIndex));
sl@0: 	Attach(aStmt.Impl().ColumnSourceL(aColumnIndex));
sl@0:     SQL_TRACE_BORDER(OstTrace1(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNTEXTL_EXIT, "Exit;0x%X;RSqlColumnReadStream::ColumnTextL", (TUint)this));
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: Gives access to column data as a read-only stream of bytes.
sl@0: 
sl@0: The function can only be used for text and binary column types.
sl@0: 
sl@0: @param aStmt        The RSqlStatement object to which the referred column belongs.
sl@0: @param aColumnIndex The index value identifying the column; this is 0 for the first column.
sl@0: 
sl@0: @leave  KErrNoMemory, an out of memory condition occurred;
sl@0:         KErrArgument, the column type is neither text nor binary.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C void RSqlColumnReadStream::ColumnBinaryL(RSqlStatement& aStmt, TInt aColumnIndex)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNBINARYL_ENTRY, "Entry;0x%X;RSqlColumnReadStream::ColumnBinaryL;aStmt=0x%X;aColumnIndex=%d", (TUint)this, (TUint)&aStmt, aColumnIndex));
sl@0: 	Attach(aStmt.Impl().ColumnSourceL(aColumnIndex));
sl@0:     SQL_TRACE_BORDER(OstTrace1(TRACE_BORDER, RSQLCOLUMNREADSTREAM_COLUMNBINARYL_EXIT, "Exit;0x%X;RSqlColumnReadStream::ColumnBinaryL", (TUint)this));
sl@0: 	}
sl@0: 
sl@0: ////////////////////////////////////////////////////////////////////////////////////////////////////
sl@0: /////////////////////         RSqlParamWriteStream              ////////////////////////////////////
sl@0: ////////////////////////////////////////////////////////////////////////////////////////////////////
sl@0: 
sl@0: /**
sl@0: Gives access to parameter data as a stream of characters.
sl@0: 
sl@0: NB You need to close the stream after the execution of the statement operation for
sl@0: which the parameter is set (RSqlStatement::Next() or RSqlStatement::Exec()).
sl@0: 
sl@0: @param aStmt           The RSqlStatement object to which the referred parameter belongs.
sl@0: @param aParameterIndex The index value identifying the parameter; this is 0 for the first parameter.
sl@0: 
sl@0: @return KErrNone, the binary parameter data stream has been opened successfully;
sl@0:         KErrNoMemory, an out of memory condition occurred.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @see RSqlStatement::Next()
sl@0: @see RSqlStatement::Exec()
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C TInt RSqlParamWriteStream::BindText(RSqlStatement& aStmt, TInt aParameterIndex)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDTEXT_ENTRY, "Entry;0x%X;RSqlParamWriteStream::BindText;aStmt=0x%X;aParameterIndex=%d", (TUint)this, (TUint)&aStmt, aParameterIndex));
sl@0: 	TRAPD(err, Attach(aStmt.Impl().ParamSinkL(ESqlSrvStmtTxtParamSink16, aParameterIndex)));
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDTEXT_EXIT, "Exit;0x%X;RSqlParamWriteStream::BindText;err=%d", (TUint)this, err));
sl@0: 	return err;
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: Gives access to parameter data as a stream of bytes.
sl@0: 
sl@0: NB You need to close the stream after the execution of the statement operation for
sl@0: which the parameter is set (RSqlStatement::Next() or RSqlStatement::Exec()).
sl@0: 
sl@0: @param aStmt           The RSqlStatement object to which the referred parameter belongs.
sl@0: @param aParameterIndex The index value identifying the parameter; this is 0 for the first parameter.
sl@0: 
sl@0: @return KErrNone, the binary parameter data stream has been opened successfully;
sl@0:         KErrNoMemory, an out of memory condition occurred.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @see RSqlStatement::Next()
sl@0: @see RSqlStatement::Exec()
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C TInt RSqlParamWriteStream::BindBinary(RSqlStatement& aStmt, TInt aParameterIndex)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDBINARY_ENTRY, "Entry;0x%X;RSqlParamWriteStream::BindBinary;aStmt=0x%X;aParameterIndex=%d", (TUint)this, (TUint)&aStmt, aParameterIndex));
sl@0: 	TRAPD(err, Attach(aStmt.Impl().ParamSinkL(ESqlSrvStmtBinParamSink, aParameterIndex)));
sl@0:     SQL_TRACE_BORDER(OstTraceExt2(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDBINARY_EXIT, "Exit;0x%X;RSqlParamWriteStream::BindBinary;err=%d", (TUint)this, err));
sl@0: 	return err;
sl@0: 	}
sl@0: 
sl@0: /**
sl@0: Gives access to parameter data as a stream of characters.
sl@0: 
sl@0: NB You need to close the stream after the execution of the statement operation for
sl@0: which the parameter is set (RSqlStatement::Next() or RSqlStatement::Exec()).
sl@0: 
sl@0: @param aStmt           The RSqlStatement object to which the referred parameter belongs.
sl@0: @param aParameterIndex The index value identifying the parameter; this is 0 for the first parameter.
sl@0: 
sl@0: @leave KErrNoMemory, an out of memory condition occurred.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @see RSqlStatement::Next()
sl@0: @see RSqlStatement::Exec()
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C void RSqlParamWriteStream::BindTextL(RSqlStatement& aStmt, TInt aParameterIndex)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDTEXTL_ENTRY, "Entry;0x%X;RSqlParamWriteStream::BindTextL;aStmt=0x%X;aParameterIndex=%d", (TUint)this, (TUint)&aStmt, aParameterIndex));
sl@0: 	Attach(aStmt.Impl().ParamSinkL(ESqlSrvStmtTxtParamSink16, aParameterIndex));
sl@0:     SQL_TRACE_BORDER(OstTrace1(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDTEXTL_EXIT, "Exit;0x%X;RSqlParamWriteStream::BindTextL", (TUint)this));
sl@0: 	}
sl@0: 	
sl@0: /**
sl@0: Gives access to parameter data as a stream of bytes.
sl@0: 
sl@0: NB You need to close the stream after the execution of the statement operation for
sl@0: which the parameter is set (RSqlStatement::Next() or RSqlStatement::Exec()).
sl@0: 
sl@0: @param aStmt           The RSqlStatement object to which the referred parameter belongs.
sl@0: @param aParameterIndex The index value identifying the parameter; this is 0 for the first parameter.
sl@0: 
sl@0: @leave KErrNoMemory, an out of memory condition occurred.
sl@0:                       Note that database specific errors categorised as ESqlDbError, and
sl@0:                       other system-wide error codes may also be returned.
sl@0: 
sl@0: @see RSqlStatement::Next()
sl@0: @see RSqlStatement::Exec()
sl@0: 
sl@0: @capability None
sl@0: */
sl@0: EXPORT_C void RSqlParamWriteStream::BindBinaryL(RSqlStatement& aStmt, TInt aParameterIndex)
sl@0: 	{
sl@0:     SQL_TRACE_BORDER(OstTraceExt3(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDBINARYL_ENTRY, "Entry;0x%X;RSqlParamWriteStream::BindBinaryL;aStmt=0x%X;aParameterIndex=%d", (TUint)this, (TUint)&aStmt, aParameterIndex));
sl@0: 	Attach(aStmt.Impl().ParamSinkL(ESqlSrvStmtBinParamSink, aParameterIndex));
sl@0:     SQL_TRACE_BORDER(OstTrace1(TRACE_BORDER, RSQLPARAMWRITESTREAM_BINDBINARYL_EXIT, "Exit;0x%X;RSqlParamWriteStream::BindBinaryL", (TUint)this));
sl@0: 	}
sl@0: