ioledbthread.h

网络游戏龙族服务器端管理工具 rmtool 源代码

#pragma once
#include <initguid.h>
#include "dbstruct.h"

// {896940DB-7E35-4e4f-8D90-AF5E78A10B3B}
DEFINE_GUID(CLSID_OLEDBTHREAD, 
0x896940db, 0x7e35, 0x4e4f, 0x8d, 0x90, 0xaf, 0x5e, 0x78, 0xa1, 0xb, 0x3b);

// {E8BDB6F8-679D-40bf-83A3-B647E797FB1B}
DEFINE_GUID(IID_OLEDBTHREAD, 
0xe8bdb6f8, 0x679d, 0x40bf, 0x83, 0xa3, 0xb6, 0x47, 0xe7, 0x97, 0xfb, 0x1b);


interface IOleDBThread : IUnknown
{			
	virtual	int		__stdcall CreateDBConnection() = 0;
	virtual	int		__stdcall Initialize(WCHAR* szDataSource, WCHAR* szDefaultDb, WCHAR* szUserId, WCHAR* szPassword, BYTE bConnectionIndex = 0) = 0;
	virtual	BOOL	__stdcall ReleaseDBConnection(BYTE bConnectionIndex) = 0;	


	virtual	int			__stdcall ExecuteSQL(WCHAR* szQuerySQL, BYTE bConnectionIndex = 0) = 0;
	virtual	int			__stdcall ExecuteSQLByParam(WCHAR* szQuerySQL, DBBINDING* pBinding, void* pParamValue, BYTE bParamNum, BYTE bConnectionIndex = 0) = 0;
	virtual	DBBINDING*  __stdcall CreateParamInfo(WORD wParamNum, BYTE bConnectionIndex = 0) = 0;
	virtual	BOOL		__stdcall ReleaseParamInfo(DBBINDING* pBinding, BYTE bConnectionIndex = 0) = 0;
		
		
	virtual	int				__stdcall OpenRecord(WCHAR* szQuerySQL, void* pRecordSet, DWORD dwMaxNumRows = DEFAULT_RETURNED_MAX_ROWS, BYTE bConnectionIndex = 0) = 0;
	virtual	DBRECEIVEDATA*  __stdcall OpenRecordEx(WCHAR* szQuerySQL, DWORD dwMaxNumRows = DEFAULT_RETURNED_MAX_ROWS, DWORD dwRowPerRead = DEFAULT_ROWS_PER_READ, BYTE bConnectionIndex = 0) = 0;
	virtual	BOOL			__stdcall GetData(void* pReceiveData, DBRECEIVEDATA* pResultData, DWORD dwRowNum, WORD wColumnNum, BYTE bConnectionIndex = 0) = 0;	//dwRowNum客 wColumnNum 篮 zero based Index捞促..
	virtual	BOOL			__stdcall ReleaseRecordset(DBRECEIVEDATA* pResultData, BYTE bConnectionIndex = 0) = 0;

		
	virtual	int		__stdcall GetBLOBData(WCHAR* szTableName, WCHAR* szColumnName, WCHAR* szFilter, void* pReadBuffer, DWORD dwReadSize, BYTE bConnectionIndex = 0) = 0;
	virtual	int		__stdcall SetBLOBData(WCHAR* szTableName, WCHAR* szColumnName, WCHAR* szFilter, void* pWriteData,  DWORD dwWriteSize, BYTE bConnectionIndex = 0) = 0;
	//by File
	virtual int __stdcall GetBLOBData(WCHAR* szTableName, WCHAR* szColumnName, WCHAR* szFilter, 
								WCHAR* szFilePath, DWORD dwReadSize, BYTE bConnectionIndex = 0) = 0;
	virtual int __stdcall SetBLOBData(WCHAR* szTableName, WCHAR* szColumnName, WCHAR* szFilter, 
								WCHAR* szFilePath, BYTE bConnectionIndex = 0) = 0;


	virtual	BOOL	__stdcall ChangeDB(WCHAR* szDbName, BYTE bConnectionIndex) = 0;
	virtual	BOOL	__stdcall SetDefaultDBIndex(BYTE bConnectionIndex) = 0;
	virtual	BYTE	__stdcall GetDefaultDBIndex() = 0;

	//Multibyte 茄臂 -> 蜡聪内靛 茄臂 屈栏肺 函券
	virtual BOOL	__stdcall KSCToUnicode(char *pKsc, WCHAR *pUni) = 0;
	//蜡聪内靛屈 茄臂 -> Multibyte茄臂肺 函券 
	virtual BOOL	__stdcall UnicodeToKSC(WCHAR *pUni, char *pKsc) = 0;

	//Added 020109	; SQLServer狼 葛电 Database 疙馆券 
	virtual int		__stdcall QueryDBCatalog(DBSCHEMA* pSchemaBuf, DWORD dwMaxNumRows, BYTE bConnectionIndex = 0) = 0;
	virtual int		__stdcall QueryDBTable(DBSCHEMA* pSchemaBuf, DWORD dwMaxNumRows, BYTE bConnectionIndex = 0) = 0;
	//Added by 020109
	

};