Symaptic: os/persistentdata/persistentstorage/sql/SRC/Server/SqlSrvSession.h@260cb5ec6c19

     1 // Copyright (c) 2005-2010 Nokia Corporation and/or its subsidiary(-ies).

     2 // All rights reserved.

     3 // This component and the accompanying materials are made available

     4 // under the terms of "Eclipse Public License v1.0"

     5 // which accompanies this distribution, and is available

     6 // at the URL "http://www.eclipse.org/legal/epl-v10.html".

     7 //

     8 // Initial Contributors:

     9 // Nokia Corporation - initial contribution.

    10 //

    11 // Contributors:

    12 // NTT DOCOMO, INC - Fix for Bug 1915 "SQL server panics when using long column type strings"

    13 //

    14 // Description:

    15 //

    17 #ifndef __SQLSRVSESSION_H__

    18 #define __SQLSRVSESSION_H__

    20 #include <e32base.h>				//CSession2

    21 #include "IPCStream.h"				//HIpcStream

    22 #include "SqlUtil.h"				//TSqlSrvFunction

    23 #include "SqlSrvObjContainer.h"		//RDbObjContainer

    24 #include "SqlSrvDatabase.h"			//CSqlSrvDatabase

    25 #include "SqlSrvResourceProfiler.h"

    27 //Forward declarations

    28 class CSqlServer;

    29 class CSqlSrvStatement;

    30 class MStreamBuf;

    31 class RMessage2;

    32 class CSqlSecurityPolicy;

    34 /**

    35 SQL server side session class.

    37 All client side requests come through a CSqlSrvSession instance which unpacks the client data,

    38 performs the requested operation invoking the appropriate server side objects and functions and

    39 packs and returns back to the client the results from the performed operation.

    41 CSqlSrvSession class owns the following set of data:

    42 - A CSqlSrvDatabase instance - one per session;

    43 - A RDbObjContainer instance - container for statement handles (CSqlSrvStatement class);

    44 - A RDbObjContainer instance - container for IPC stream hadles (large data block transfer operations)

    45                                (HIpcStream class);

    47 CSqlSrvSession instances shall never be created via a direct call of CSqlSrvSession::NewL().

    48 It is always the server, which creates a new session instance as a responce to the creation of a client side

    49 session instance (CSqlServer::NewSessionL() function).

    51 @see CSqlSrvDatabase

    52 @see CSqlSrvStatement

    53 @see RDbObjContainer

    54 @see HIpcStream

    55 @see CSqlServer

    56 @see CSqlServer::NewSessionL()

    57 @see CSession2

    59 @internalComponent

    60 */

    61 NONSHARABLE_CLASS(CSqlSrvSession) : public CSession2

    62 	{

    63 public:

    64 	static CSqlSrvSession* NewL();

    65 	virtual ~CSqlSrvSession();

    66 	inline CSqlServer& Server();

    68 private:

    69 	inline CSqlSrvSession();

    70 	inline void ConstructL();

    71 	//CSession2::ServiceL() implementation and overriden CSession2::ServiceError().

    72 	virtual void ServiceL(const RMessage2& aMessage);

    73 	virtual void ServiceError(const RMessage2& aMessage, TInt aError);

    74 	//Profiler operations

    75 	void ProfilerQueryL(const RMessage2& aMessage);

    76 	//Database operations

    77 	void DbCreateObjectL(const RMessage2& aMessage, TSqlSrvFunction aFunction);

    78 	void DbCreateObjectFromHandleL(const RMessage2& aMessage);

    79 	void DbAttachL(const RMessage2& aMessage);

    80 	void DbAttachFromHandleL(const RMessage2& aMessage);

    81 	void DbDetachL(const RMessage2& aMessage);

    82 	inline void DbDestroyObject();

    83 	void DbCopyFileL(const RMessage2& aMessage);

    84 	void DbDeleteFileL(const RMessage2& aMessage);

    85 	TInt DbLastErrorMessageL(const RMessage2& aMessage);

    86 	void DbLastInsertedRowIdL(const RMessage2& aMessage);

    87 	inline TInt DbExecSql8L(const RMessage2& aMessage);

    88 	inline TInt DbExecSql16L(const RMessage2& aMessage);

    89 	inline void DbSetIsolationLevelL(const RMessage2& aMessage);

    90 	TInt DbGetSecurityPolicyL(const RMessage2& aMessage);

    91 	TInt DbScalarFullSelectL(const RMessage2& aMessage, TBool aIsText16);

    92 	TInt DbBlobSourceL(const RMessage2& aMessage);

    93 	TBool DbInTransaction(const RMessage2& aMessage);

    94 	TInt DbSizeL(const RMessage2& aMessage);

    95 	void DbSize2L(const RMessage2& aMessage);

    96 	TInt DbCompactL(const RMessage2& aMessage);

    97 	void DbReserveDriveSpaceL();

    98 	void DbFreeReservedSpace();

    99 	void DbGetReserveAccessL();

   100 	void DbReleaseReserveAccess();

   101 	//Statement operations

   102 	TInt StmtPrepareL(const RMessage2& aMessage, TBool aIsText16);

   103 	TInt StmtExecL(const RMessage2& aMessage, TInt aStmtHandle, TSqlSrvFunction aFunction);

   104 	TInt StmtNextL(const RMessage2& aMessage, TInt aStmtHandle, TSqlSrvFunction aFunction);

   105 	TInt StmtNamesL(const RMessage2& aMessage, TInt aStmtHandle, TSqlSrvFunction aFunction);

   106 	TInt StmtColumnSourceL(const RMessage2& aMessage, TInt aStmtHandle);

   107 	TInt StmtParamSinkL(const RMessage2& aMessage, TInt aStmtHandle, TSqlSrvFunction aFunction);

   108 	void StmtGetBufFlatL(const RMessage2& aMessage, TInt aStmtHandle);

   109 	void StmtColumnValueL(const RMessage2& aMessage, TInt aStmtHandle);

   110 	void DoStmtBindL(const RMessage2& aMessage, CSqlSrvStatement& aStmt);

   111 	TInt StmtDeclColumnTypesL(const RMessage2& aMessage, TInt aStmtHandle);

   112 	//Helper methods

   113 	TInt NewOutputStreamL(const RMessage2& aMessage, MStreamBuf* aStreamBuf);

   114 	TDes8& ReadString8ZL(const RMessage2& aMessage, TInt aArgNum, TInt aByteLen);

   115 	TDes16& ReadString16ZL(const RMessage2& aMessage, TInt aArgNum, TInt aCharLen);

   116 	TDes16& ReadString16L(const RMessage2& aMessage, TInt aArgNum, TInt aCharLen);

   117 	CSqlSecurityPolicy* CreateSecurityPolicyL(const TDesC8& aSecurotyPolicyData);

   118 	virtual TInt CountResources();

   119 	void Extract(const RMessage2& aMessage, TSqlSrvFunction& aFunction, TInt& aHandle);

   120 	TInt GetColumnValueL(const RMessage2& aMessage, CSqlSrvStatement& aStmt, TSqlColumnType aColType);

   121 	void ExtractNameL(RDesReadStream& aStrm, TDes8& aNameOut, const TDesC& aEmptyNameSubstitute = KNullDesC);

   122 	//Resource allocation testing related

   123 	inline TBool ActivateDbTestMode(TInt aHeapFailureMode, TInt aFailedAllocNumber);

   124 	inline void StopDbTestMode();

   125 	inline void DbResourceMark();

   126 	inline void DbResourceEnd(const RMessage2& aMessage);

   127 	inline void DbSetAllocFail(TInt aHeapFailureMode, TInt aFailedAllocNumber);

   128 	inline void DbSetDelayedAllocFail();

   129 private:

   130 	CSqlSrvDatabase*					iDatabase;				//The database object (one per session)

   131 	RDbObjContainer<CSqlSrvStatement>	iStatements;			//Container for SQL statement handles

   132 	RDbObjContainer<HIpcStream>			iIpcStreams;			//Container for IPC stream hansdles

   133 	TInt								iDbResourceTestMode;	//Non-zero if this session is in test mode (memory leaks simulation/detection)

   134 	TInt								iFailedAllocNumber;		//The failing allocation number - If iDbResourceTestMode is OR-ed with 0x1000

   135 	TBool								iDriveSpaceReserved;	//True if this session reserved drive space

   136 	TBool								iDriveSpaceInUse;		//True if the client has been given an access to the reserved drive space

   137 	TDriveNumber 						iDrive;					//the drive number, where the database file is

   138 	TUint                               iIpcCallCounter;

   139 #ifdef _SQLPROFILER

   140     TSqlSrvIpcTraceData                 iIpcTraceData[KIpcTraceTypeCount];

   141 #endif

   142 	};

   144 #include "SqlSrvSession.inl"

   146 #endif//__SQLSRVSESSION_H__

author	sl
	Tue, 10 Jun 2014 14:32:02 +0200
changeset 1	260cb5ec6c19
permissions	-rw-r--r--