oradb.h

Mysql的处理

	char ServedIMSI[LEN_ServedIMSI+1];
	char ServedIMEI[LEN_ServedIMEI+1];
	char SGSNIPAddress[LEN_IpAddr+1];
	char MSNetworkCapability[LEN_MSNetworkCapability+1];
	char RoutingAreaCode[9];
	char LocationAreaCode[17];
	char CellIdentity[25];
	char ChargingID[11];/*int*/
	char GGSNAddress[LEN_IpAddr+1];
	char AccessPointNameNI[64];
	char PDPTypeNumber[9];
	char ServedPDPAddress[LEN_IpAddr+1];
	char RecordOpenTime[LEN_DATETIME + 1];
	char CallDuration[12+1];
	char Diagnostics[LEN_Diagnostics+1];
	char APNSelectionMode;
	char AccessPointNameOI[38];
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char ChargingCharacteristics[LEN_ChargingCharacteristics+1];
	
	char ConsolidationResult[3];
	char ChargingCharacterSelectionMode;

	/* CAMEL Information*/
	char SCFAddress[LEN_SCFAddress+1];
	char ServiceKey[LEN_ServiceKey+1];
	char DefaultTransacHandling;
	char CAMELAPNNI[64];
	char CAMELAPNOI[38];
	char NumberOfDPEncounter[11];
	char LevelOfCamelService[4];
	char FreeFormatData[161];
	char FFDAppendIndicator;
	char DefaultSMSHandling;
	char CAMELCallingPartyNumber[15];
	char CAMELAccessDestinationSubNumber[44];
	char CAMELSMSAdress[21];
	char SmsReferenceNumber[9];


	/** NOTE: begin **/
	char DynamicAddressFlag;/* both for R99 & R4 */

	char AnonyAccessIndicator; /* only for R4 */
	/** NOTE: end **/
	char APNOperatorIdentifier[37+1];/* both for R99 & R4 */


/*
	vector<char> SystemType;
	vector<string> SGSNIPAddress;
	vector<char> SGSNChange;
	vector<string> CauseForRecClosing;
	vector<string> RecordSequenceNumber;
	vector<string> NodeID;
	deque<string> LocalRecordSequeceNumnber;
	vector<string> UnsentDownlinkVolume;
	vector<string> RecordExtensions;
*/	
	char SystemType;
/*	char SGSNIPAddress[46];*/
	char SGSNChange;/*int*/
	char CauseForRecClosing[3];
	char RecordSequenceNumber[11];
	char NodeID[LEN_NodeID+1];
	char LocalRecordSequeceNumnber[11];
	char UnsentDownlinkVolume[11];
	char RecordExtensions[LEN_RecordExtensions+1];
	
	
	char FlagRead;

	/* PK & FK */
	char SeqId[LEN_SEQ + 1];
	char TableName[LEN_TABLENAME + 1];

	int FlagRepeat;
	int FlagR499;

	/* stamp */
	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

};
#define SIZE_S_CSCDR sizeof(struct S_CSCDR)



	/*12 合并后的GCDR*/
struct S_CGCDR
{
	short		RecordType;
	char NetworkInitiatedPDPContext;
	char ServedIMSI[17];
	char GGSNAddress[LEN_IpAddr+1];
	char ChargingID[11];
	char AccessPointNameNI[64];
	char PDPTypeNumber[9];/*3];/**/
	char ServedPDPAddress[LEN_IpAddr+1];
	char DynamicAddressFlag;

	char RecordOpenTime[LEN_DATETIME + 1];
	char CallDuration[13];
	char Diagnostics[LEN_Diagnostics+1];
	char NodeID[LEN_NodeID+1];
	char APNSelectionMode;
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char		SgsnPlmnIdentifier[LEN_SgsnPlmnIdentifier+1]; /* both for R4 & R99*/

	char ConsolidationResult[3];
	char ChargingCharacterSelectionMode;
	/** NOTE: begin **/
	char ChargingCharacteristics[LEN_ChargingCharacteristics+1];
	char		AnonyAccessIndicator; /* only for R4 */
	char		RemotePdpAddr[LEN_IpAddr+1]; /* only for R4 */


	char FlagRead;
	/* PK & FK */
	char SeqId[LEN_SEQ + 1];
	char TableName[LEN_TABLENAME + 1];


	int FlagRepeat;
	int FlagR499;

	char DateCreated[LEN_DATETIME + 1];
	char GsnId[LEN_GSNID+1];

	
	/* to be remove */
	char SGSNIPAddress[LEN_IpAddr+1];
	char CauseForRecClosing[3];
	char RecordSequenceNumber[11];
	char RecordExtensions[LEN_RecordExtensions+1];
	char LocalRecordSequeceNumnber[11];

	/*char ChargingCharacterSelectionMode[3];*/
};
#define SIZE_S_CGCDR sizeof(struct S_CGCDR)


	/*结果集合*/
struct S_RESULT
{
	int nFlag;
	char SeqId[LEN_SEQ+1];
	char TableName[31];
};


#define SQL_OK 0
#define SQL_RET_ERROR 1
#define SQL_NO_UID 2
#define SQL_NO_PWD 3



#define _DEBUG

#define LOG_ERROR


#define MAXLINE 4096
#define SQLMAX 4096
//extern char sErrLog[1024];

struct S_BSFILE
{
	char SeqId[LEN_SEQ + 1];
	char RuleId	[3];
	char FileLoc[4001];
	char DateCreated[LEN_DATETIME + 1];
	char TableName[LEN_TABLENAME + 1];
};
#define SIZE_S_BSFILE sizeof(struct S_BSFILE)


struct S_CDRFILE
{
	char SeqId[LEN_SEQ + 1];
	char CDRTable[LEN_TABLENAME + 1];
	char CDRType[3];
	char FileId	[LEN_SEQ+1];
	char FileTable[LEN_TABLENAME + 1];
	char DateCreated[LEN_DATETIME + 1];
	char TableName[LEN_TABLENAME + 1];
};
#define SIZE_S_CDRFILE sizeof(struct S_CDRFILE)


//#define NO_TRANS
#undef NO_TRANS

//#define LOG_SELECT
#undef LOG_SELECT

#include <stdio.h>
#include <mysql.h>
#include <pthread.h>
#include <stdlib.h>
#include <string.h>
#include <stdarg.h>
#include <time.h>

struct S_CSCDR_LOAD : public S_CSCDR
{
	int nListOfTrafficVolumn;
	S_LLOTV *pListOfTrafficVolumn;
	
	int nCommon;
	S_LCOMM *pCommon;
};
#define SIZE_S_CSCDR_LOAD sizeof(struct S_CSCDR_LOAD)


struct S_CGCDR_LOAD : public S_CGCDR
{
	int nListOfTrafficVolumn;
	S_LLOTV *pListOfTrafficVolumn;
	
	int nCommon;
	S_LCOMM *pCommon;
};
#define SIZE_S_CGCDR_LOAD sizeof(struct S_CGCDR_LOAD)

struct S_OMCDR_LOAD : public S_OMCDR
{
	int nChangeLocation;
	S_LCLOC *pChangeLocation;
};
#define SIZE_S_OMCDR_LOAD sizeof(struct S_OMCDR_LOAD)


struct S_LLCBC
{
	char SeqId[LEN_SEQ + 1];
	char SortId[LEN_SORT+1];
	
	char WtpTransactionIdentifier[10+1];
	char MmsTransactionIdentifier[9];	
	char TableName[LEN_TABLENAME + 1];
};
#define SIZE_S_LLCBC sizeof(S_LLCBC)

struct S_LCBC
{
	char SeqId[LEN_SEQ + 1];
	char SortId[LEN_SORT+1];
	
	char AccessCorrelationld[10+1];
	char UplinkPacketCount[10+1];
	char DownlinkPacketCount[10+1];
	char UplinkByteCount[10+1];
	char DownlinkByteCount[10+1];
	char Action;
	char ChargingType[5];
	char FlowTemplateIdentifier[10+1];
	char ServiceClassIdentifier[33];
	char FlowChargeIdentifier[21];
	char ServiceClassDescriptor[65];
	char FlowDescriptor[33];
	char TimeDuration[10+1];
	char SrcAddress[46];
	char SrcPortStart[3];
	char SrcPortEnd[3];
	char DestAddress[46];
	char DestPortStart[3];
	char DestPortEnd[3];
	char Protocol[3+1];  //	NUMBER(3)
	char ContentType;    //	NUMBER(1)
	char MailHost[65];
	char MimeContentType[33];
	char MailFrom[65];
	char SmtpResponseCode[10+1];
	char WspContentType;  // NUMBER(1)
	char Url[129];
	char WapUserAgent[65];  //	VARCHAR2 (64)
	char ReverseChargeIdentifier[17];//	VARCHAR2 (16)
	char TableName[LEN_TABLENAME + 1];

	int nLLCBC;
	S_LLCBC* pLLCBC;
};
#define SIZE_S_LCBC sizeof(S_LCBC)

class C_DbConnect
{
public:
	C_DbConnect();
	~C_DbConnect();

	MYSQL* Get() { return myConnect; }

	int Connect(char* szDbUId, char* szDbPwd, char* szDbSid);
	void Disconnect();

	void Lock();
	void Unlock();
	int Initialize();
	void Destroy();

private:
	MYSQL    *  myConnect;    
	pthread_mutex_t sDbLock;
};


class C_MYSQL
{
public:
	C_MYSQL();
	C_MYSQL(C_DbConnect* pDb);
	~C_MYSQL();

	void DbOGCDRTest();
	void DbASNERRORTest();
	void DbCGCDRTest(S_CGCDR & );
	void DbCSCDRTest(S_CSCDR & );
	void DbLCLOCTest();
	void DbLCOMMTest();
	void DbLLOTVTest();
	void DbGTPTest();
	void DbOMCDRTest();
	void DbOMOCDRTest();
	void DbOMTCDRTest();
	void DbOSCDRTest();

	void LCBCTest();
	void LLCBCTest();

protected:
	int DbCount(const char* szSql, MYSQL* pConnect);
	int GetSeq(char* szSeqId);
	
	
	/* 初始 gtp'包*/
	int DbGTPInsert(struct S_GTPL* pIn, struct S_RESULT* pOut);
	int DbGTPCount(char* pInSzTableName, long inIPeerIp, long inIPeerSeqId, long *nOutCount);
	int DbGTPSelect2(long inIPeerIp, long inIPeerSeqId,
		char *pInSzTableName, 
		int *RecordType, 
		char *szOutContent,
		char *szOutSeqId);
	int DbGTPSelect(char* pInSzTableName, char* szInSeqId, int* RecordType,
		char* szOutContent, char* szOutSeqId, int* nPeerIp, int *nFlagCancel);
	int DbReadOgtplTableCount(
		char *p_timeStart,
		int   p_timeAcceptedFree,
		int  *p_bIsFree,
		char *p_timeErrorStart,
		char *p_timeErrorEnd,
		int  *p_nResult);
	int DbGTPInsert2(struct S_GTPL* pIn, struct S_RESULT* pOut);
	
	/* asn.1 解码数据 */
	int DbASNERRORInsert(struct S_ASNERROR* pIn, struct S_RESULT* pOut);
	int DbOSCDRInsert(struct S_OSCDR* pIn, struct S_RESULT* pOut);
	int DbOGCDRInsert(struct S_OGCDR* pIn, struct S_RESULT* pOut);
	int DbOMCDRInsert(struct S_OMCDR* pIn, struct S_RESULT* pOut);
	int DbOMOCDRInsert(struct S_OMOCDR* pIn, struct S_RESULT* pOut);
	int DbOMTCDRInsert(struct S_OMTCDR* pIn, struct S_RESULT* pOut);
	
	/* 辅助列表 */
	int DbLCLOCInsert(struct S_LCLOC* pIn, struct S_RESULT* pOut);
	int DbLLOTVInsert(struct S_LLOTV* pIn, struct S_RESULT* pOut);
	int DbLCOMMInsert(struct S_LCOMM* pIn, struct S_RESULT* pOut);
	
	/* 合并结果*/
	int DbCSCDRInsert(struct S_CSCDR* pIn, struct S_RESULT* pOut);
	int DbCGCDRInsert(struct S_CGCDR* pIn, struct S_RESULT* pOut);
	
	/* 查询*/
	/* 合并及辅助查询 */
	int DbCSCDRSelect(char* pInSzTableName, char* pWhere, struct S_CSCDR_LOAD** pOutCDR, int *nItems, struct S_RESULT* pOut);
	int DbCGCDRSelect(char* pInSzTableName, char* pWhere, struct S_CGCDR_LOAD** pOutCDR, int *nItems, struct S_RESULT* pOut);
	int DbLCLOCSelect(char* pInSzTableName, char* pInSeqId, struct S_LCLOC** pOutLChangeLocation, int * number, struct S_RESULT* pOut);
	int DbLLOTVSelect(char* pInSzTableName, char* pInSeqId, struct S_LLOTV** pOutLChangeLocation, int * number, struct S_RESULT* pOut);
	int DbLCOMMSelect(char* pInSzTableName, char* pInSeqId, struct S_LCOMM** pOutLChangeLocation, int * number, struct S_RESULT* pOut);
	int DbCGCDRSelect2(char* pInSzTableName, char* pWhere, struct S_CGCDR** pOutCDR, int *nItems, struct S_RESULT* pOut);
	
	/* 查询原始 CDR */
	int DbOSCDRSelect(char* pInSzTableName, char* pWhere, struct S_OSCDR** pOutCDR, int *nItems, struct S_RESULT* pOut);
	int DbOGCDRSelect(char* pInSzTableName, char* pWhere, struct S_OGCDR** pOutCDR, int *nItems, struct S_RESULT* pOut);
	int DbOMCDRSelect(char* pInSzTableName, char* pWhere, struct S_OMCDR_LOAD** pOutCDR, int *nItems, struct S_RESULT* pOut);
	int DbOMOCDRSelect(char* pInSzTableName, char* pWhere, struct S_OMOCDR** pOutCDR, int *nItems, struct S_RESULT* pOut);
	int DbOMTCDRSelect(char* pInSzTableName, char* pWhere, struct S_OMTCDR** pOutCDR, int *nItems, struct S_RESULT* pOut);
	
	/* 更新表 */
	int DbUpdateTable(char* pInSzSQL, struct S_RESULT* pOut);
	int DbASNERRORSelect(char* pInSzTableName, char* pWhere, struct S_ASNERROR** pOutCDR, int *nItems, struct S_RESULT* pOut);
	
	int DbCommit();
	int DbRollback();
	
	/*数据库连接维护*/
	/*
	static int DbConnect(char* szDbUId, char* szDbPwd, char* szDbSid);
	static void DbDisconnect();
	
	static void Lock();
	static void Unlock();
	static int Initialize();
	static void Destroy();
	static void logOra(char* szFilename, char* szMessage, ...);
	static void onError();
	*/

	int DbConnect(char* szDbUId, char* szDbPwd, char* szDbSid);
	void DbDisconnect();
	
	void Lock();
	void Unlock();
	int Initialize();
	void Destroy();
	void logOra(char* szFilename, char* szMessage, ...);
	
	void onError();
	void DbSelect(char tablename[10]);
	
	int DbCdrFileInsert(struct S_CDRFILE* pCdr);
	int DbBsFileInsert(struct S_BSFILE* pCdr);
	
	int DbUpdateTable2(char* pInSzSQL, struct S_RESULT* pOut);
	
	int DbLCBCInsert(S_LCBC* p);
	int DbLLCBCInsert(S_LLCBC* p);

protected:
		/*

	static MYSQL    *  myConnect;    

	static char sSid[64];
	static char sUid[64];
	static char sPwd[64];

	static char sErrLog[1024];
	static pthread_mutex_t sDbLock;//=PTHREAD_MUTEX_INITIALIZER;
	*/
	MYSQL    *  myConnect;    

	char sSid[64];
	char sUid[64];
	char sPwd[64];

	char sErrLog[1024];
	C_DbConnect* m_pDb;

	bool m_bCreatedByDb;
};

#endif