sybasedb.h

电力与银行通讯的源码 1.应用tuxedo中间件. 2.与银行的前置机通讯. 3.proc*c 的应用

/********************************************************
 * SybaseDB.h: interface for the CDatabase class.
 *
 */
#ifndef SYBASEDB_H__INCLUDED_
#define SYBASEDB_H__INCLUDED_
#define SYBASE
#include "typedef.h"
#include "ctpublic.h"
#include "bkpublic.h"
#define ERROR_BUFFER_LEN 1024
#define	EX_CTLIB_VERSION	CS_VERSION_125
#define	EX_BLK_VERSION		BLK_VERSION_125
#define TYPE_CHAR			"\x20"
#define TYPE_BINARY			"\x01"
#define TYPE_LONGCHAR		"\x02"
#define TYPE_LONGBINARY		"\x03"
#define TYPE_TEXT			"\x04"
#define TYPE_IMAGE			"\x05"
#define TYPE_TINYINT		"\x06"
#define TYPE_SMALLINT		"\x07"
#define TYPE_INT		    "\x08"
#define TYPE_REAL			"\x09"
#define TYPE_FLOAT			"\x0a"
#define TYPE_BIT			"\x0b"
#define TYPE_DATETIME		"\x0c"
#define TYPE_DATETIME4		"\x0d"
#define TYPE_MONEY			"\x0e"
#define TYPE_MONEY4			"\x0f"
#define TYPE_NUMERIC		"\x10"
#define TYPE_DECIMAL		"\x11"
#define TYPE_VARCHAR		"\x12"
#define TYPE_VARBINARY		"\x13"
#define TYPE_LONG			"\x14"
#define TYPE_SENSITIVITY	"\x15"
#define TYPE_BOUNDARY		"\x16"
#define TYPE_VOID			"\x17"
#define TYPE_USHORT			"\x18"
#ifndef MAX
#define MAX(X,Y)	(((X) > (Y)) ? (X) : (Y))
#endif
#ifndef MIN
#define MIN(X,Y)	(((X) < (Y)) ? (X) : (Y))
#endif
typedef struct 
{
	double dValue;
	int nPrecision;
	int nScale;
}CNumeric;
typedef CNumeric CDecimal;
typedef struct 
{
	int nYear;
	int nMonth;
	int nDay;
	int nHour;
	int nMinute;
	int nSecond;
}CDateTime;
typedef struct   
{
	CS_CONTEXT *m_pContext;
	CS_CONNECTION *m_pConnection;
	CS_COMMAND* m_pCommand;
	CS_BLKDESC*	m_pBlkDesc;
	long m_nBlkRowCount;
	int m_nColumnCount;
	int m_nStatus;
	BOOL m_bOpened;
	char m_szErrorBuffer[ERROR_BUFFER_LEN];
}CDatabase;
	void DB_Construct(CDatabase *pDatabase);
	void DB_Destruct(CDatabase *pDatabase);
	
	BOOL DB_Open(CDatabase *pDatabase, char *pServerName, char *pDatabaseName, char *pUserName, char *pPassword);
	BOOL DB_Close(CDatabase *pDatabase, BOOL bForceClose);
	BOOL DB_IsOpen(CDatabase *pDatabase);
	BOOL DB_BeginTransaction(CDatabase *pDatabase);
	BOOL DB_CommitTransaction(CDatabase *pDatabase);
	BOOL DB_RollbackTransaction(CDatabase *pDatabase);
	
	BOOL DB_ExecuteSQL(CDatabase *pDatabase, char *pSQL);
	
	BOOL DB_SQLPrepare(CDatabase *pDatabase, char *pSQL, void *ppBindVar[], int cbVar);
	BOOL DB_SQLFetch(CDatabase *pDatabase);
	BOOL DB_SQLDone(CDatabase *pDatabase);
	
	BOOL DB_ExecuteDynamicSQL(CDatabase *pDatabase, char *pSQL, const unsigned char* pbParamInfo,...);
	
	BOOL DB_DynamicSQLPrepare(CDatabase *pDatabase, char *pSQL);
	BOOL DB_DynamicSQLSendParam(CDatabase *pDatabase, void *pParam, int nType, BOOL bByRef);
	BOOL DB_DynamicSQLExecute(CDatabase *pDatabase);
	BOOL DB_DynamicSQLDone(CDatabase *pDatabase);
	BOOL DB_BlkCopyInPrepare(CDatabase *pDatabase, char *pTableName, int nColumn);
	BOOL DB_BlkCopyInExecute(CDatabase *pDatabase, void *ppVarArray[], long nLenArray[]);
	BOOL DB_BlkCopyInDone(CDatabase *pDatabase);
/*Modify by gjl for Get Result*/	
	BOOL DB_ExecuteStoredProcedureWithResult(CDatabase *pDatabase, char *pRpcName, int *npStatus, 
							void *ppBindVar[], int cbVar,
									   const unsigned char* pbParamInfo,...);
	CS_RETCODE DB_HandleResultsWithResult(CDatabase *pDatabase, CS_COMMAND *pCmd,void *ppBindVar[], int cbVar);
	BOOL DB_ExecuteStoredProcedure(CDatabase *pDatabase, char *pRpcName, int *npStatus, 
									   const unsigned char* pbParamInfo,...);
	void DB_GetLastError(CDatabase *pDatabase, char *pErrorBuffer, int cbErrorBuffer);
	BOOL DB_ConvertNumericToLong(CDatabase *pDatabase, CS_NUMERIC* npSrc, long* lpDest, int nPrecision, int nScale);
	BOOL DB_ConvertNumericToDouble(CDatabase *pDatabase, CS_NUMERIC *npSrc, double* lpDest, int nPrecision, int nScale);
	/*--------------- Callback functions ------------------*/
	/* Client message handler , installed as a callback into Open Client. */
	CS_INT ClientMsgHandler(CS_CONTEXT* pContext,CS_CONNECTION* pConnection, CS_CLIENTMSG* errmsg);
		
	/* Server message handler , installed as a callback into Open Client. */
	CS_INT ServerMsgHandler(CS_CONTEXT* pContext,CS_CONNECTION* pConnection, CS_SERVERMSG* srvmsg);
	/* CS-Library message handler , installed as a callback into Open Client. */
	CS_INT CommonMsgHandler(CS_CONTEXT* pContext, CS_CLIENTMSG* errmsg);
	void DB_SetLastError(CDatabase *pDatabase, char *pErrorMsg);
	CS_RETCODE DB_HandleResults(CDatabase *pDatabase, CS_COMMAND *pCmd);
	CS_INT CS_PUBLIC DB_GetColumnLen(CS_DATAFMT *pColumn);
#endif /* !defined(SYBASEDB_H__INCLUDED_) */