omcdr.cpp

Mysql的处理

#include "oradb.h"


/********************************************************
*      filename							:OMCDR.pc
*			 function descrpition	:insert data into database OMCDRxxxxxxxxxx 
*			 input								:struct S_OMCDR *	
*			 output								:SQL_OK ( operation sucess) SQL_RET_ERRO (operation failed)
*			 date									:2006-05-22
**********************************************************/
int DbOMCDRInsert(struct S_OMCDR* pIn, struct S_RESULT* pOut)
{
	short RecordType;
	char *GtpName=(char *)pIn->GtpName;
	char *GtpId=(char *)pIn->GtpId;
	
	int FlagRead = pIn->FlagRead;
	int FlagRepeat=pIn->FlagRepeat;
	int FlagR499=pIn->FlagR499;

	int SystemType=pIn->SystemType;
	char *ServedIMSI=(char *)pIn->ServedIMSI;
	char *ServedIMEI=(char *)pIn->ServedIMEI;
	char *ServedMSISDN=(char *)pIn->ServedMSISDN;
	char *SGSNIPAddress=(char *)pIn->SGSNIPAddress;
	char *MSNetworkCapability=(char *)pIn->MSNetworkCapability;
	char *RoutingAreaCode=(char *)pIn->RoutingAreaCode;
	char *LocationAreaCode=(char *)pIn->LocationAreaCode;
	char *CellIdentity=(char *)pIn->CellIdentity;
	char *NodeId=(char *)pIn->NodeId;/* add by xxh 2006.5.15*/
	char *RecordOpenTime=(char *)pIn->RecordOpenTime;
	char *CallDuration=(char *)pIn->CallDuration;
	int SGSNChange=pIn->SGSNChange;
	char *CauseForRecClosing=(char *)pIn->CauseForRecClosing;
	char *Diagnostics = pIn->Diagnostics;
	char *RecordSequenceNumber=(char *)pIn->RecordSequenceNumber;
	char *LocalRecordSequeceNumnber=(char *)pIn->LocalRecordSequeceNumnber;
	/* CAMEL Information*/
	char *SCFAddress=(char *)pIn->SCFAddress;
	char *ServiceKey=(char *)pIn->ServiceKey;
	/*char */
	int DefaultTransacHandling=pIn->DefaultTransacHandling;
	char *CAMELAPNNI=(char *)pIn->CAMELAPNNI;
	char *CAMELAPNOI=(char *)pIn->CAMELAPNOI;
	char *NumberOfDPEncounter=(char *)pIn->NumberOfDPEncounter;
	char *LevelOfCamelService=(char *)pIn->LevelOfCamelService;
	char *FreeFormatData=(char *)pIn->FreeFormatData;
	/*char */int FFDAppendIndicator=pIn->FFDAppendIndicator;
	/*char*/int DefaultSMSHandling=pIn->DefaultSMSHandling;
	char *CAMELCallingPartyNumber=(char *)pIn->CAMELCallingPartyNumber;
	char *CAMELAccessDestination=(char *)pIn->CAMELAccessDestinationSubNumber;
	char *CAMELSMSAdress=(char *)pIn->CAMELSMSAdress;
	char *SmsReferenceNumber=(char *)pIn->SmsReferenceNumber;

	/*char *DateCreated[LEN_DATETIME + 1]=(char *)pIn->;*/
	char *GsnId=(char *)pIn->GsnId;

	char *TableName=(char *)pIn->TableName;

	char *RecordExtensions = pIn->RecordExtensions;
#ifdef EXT10om
	int ChargingCharacterSelectionMode = pIn->ChargingCharacterSelectionMode;
#endif
	char *ChargingCharacteristics=(char *)pIn->ChargingCharacteristics;

	char szMsg[512];
	char szSQL[SQLMAX];
	char SeqId[LEN_SEQ + 1];
/*	EXEC SQL BEGIN DECLARE SECTION;
	EXEC SQL VAR SeqId IS STRING(LEN_SEQ + 1);
	EXEC SQL END DECLARE SECTION;

	

	EXEC SQL WHENEVER SQLERROR GOTO sql_error; 
	EXEC SQL SELECT SEQ_OMCDR.NEXTVAL 
	INTO :SeqId 
	FROM DUAL;

*/
	/*
snprintf(szSQL,SQLMAX,"INSERT INTO %s("
   "SEQID,GTPID,GTPLTABLE,FLAGR499,"                  
   "SERVEDIMSI,SERVEDIMEI,SERVEDMSISDN,SGSNIPADDRESS,"             
   "MSNNETWORKCAPABILITY,ROUTINGAREACODE,LOCATIONAREACODE,"            
   "CAUSEFORRECCLOSING,DIAGNOSITICS,RECORDSEQUENCENUMBER,NODEID,"                    
   "LOCALRECORDSEQUECENUMBER,SYSTEMTYPE,SCFADDRESS,SERVICEKEY,"                
   "DEFAULTTRANSACHANDLING,CAMELAPNNI,CAMELAPNOI,NUMBEROFDPENCOUNTER,"       
   "LEVELOFCAMELSERVICE,FREEFORMATDATA,FFDAPPENDINDICATOR,DEFAULTSMSHANDLING,"        
   "CAMELCALLINGPARTYNUMBER,CAMELACCESSDESTNO,CAMELSMSADDRESS,SMSREFERENCENUMBER,"        
   "DATECREATED,GSNID,FLAGREAD ) VALUES("
   " '%s','%s','%s',%d,"   
   "  '%s','%s','%s','%s'," 
   "  '%s','%s','%s'," 
   "  '%s',%d,'%s','%s'," 
   "  '%s',%d,'%s','%s',"   
   "  %d,'%s','%s','%s',"
   "  '%s','%s',%d,%d,"   
   "  '%s','%s','%s','%s'," 
   " SYSDATE,'%s',%d)" ,
   TableName,
   SeqId,GtpId,GtpName,FlagR499,
   ServedIMSI,ServedIMEI,ServedMSISDN,SGSNIPAddress,             	         
   MSNetworkCapability,RoutingAreaCode,LocationAreaCode,         
   CauseForRecClosing,Diagnostics,RecordSequenceNumber,NodeId,  
   LocalRecordSequeceNumnber,SystemType,SCFAddress,ServiceKey,            	                   
   DefaultTransacHandling,CAMELAPNNI,CAMELAPNOI,NumberOfDPEncounter,          	           
   LevelOfCamelService,FreeFormatData,FFDAppendIndicator,DefaultSMSHandling,         	           
   CAMELCallingPartyNumber,CAMELAccessDestination,CAMELSMSAdress,SmsReferenceNumber,          	     
    GsnId,FlagRead);     									
*/

snprintf(szSQL,SQLMAX,"INSERT INTO %s("
   "GTPID,GTPLTABLE,FLAGR499,"     
   "FLAGREPEAT,"             
   "SERVEDIMSI,SERVEDIMEI,SERVEDMSISDN,SGSNIPADDRESS,"             
   "MSNNETWORKCAPABILITY,ROUTINGAREACODE,LOCATIONAREACODE,"            
   "CAUSEFORRECCLOSING,DIAGNOSITICS,RECORDSEQUENCENUMBER,NODEID,"                    
   "LOCALRECORDSEQUECENUMBER,SYSTEMTYPE,SCFADDRESS,SERVICEKEY,"                
   "DEFAULTTRANSACHANDLING,CAMELAPNNI,CAMELAPNOI,NUMBEROFDPENCOUNTER,"       
   "LEVELOFCAMELSERVICE,FREEFORMATDATA,FFDAPPENDINDICATOR,DEFAULTSMSHANDLING,"        
   "CAMELCALLINGPARTYnumeric,CAMELACCESSDESTNO,CAMELSMSADDRESS,SMSREFERENCENUMBER,"        
   
   "DATECREATED,GSNID,FLAGREAD,CALLDURATION "
#ifdef EXT10om
",RECORDEXTENSIONS"
",CHARGINGCHARACTERSELECTIONMODE"
",CELLIDENTITY"
//",EVENTSTAMPTIME"
",SGSNCHANGE"
",CHARGINGCHARACTERISTICS"
#endif
   ") VALUES("
   " %s,'%s',%d,"  
   "%d,"
   " '%s','%s','%s','%s'," 
   "  '%s','%s','%s'," 
   "  %s,%s,%s,'%s'," 
   "  %s,%d,'%s',%s,"   
   "  %d,'%s','%s',%s,"
   "  '%s','%s',%d,%d,"   
   "  '%s','%s','%s','%s'," 
   " NOW(),%s,%d,%d"
#ifdef EXT10om
",'%s'"
",%d"
",'%s'"
//",'%s'"
",%d"
",'%s'"
#endif
   ")" ,
   TableName,

   GtpId,GtpName,FlagR499,
   FlagRepeat,
   ServedIMSI,ServedIMEI,ServedMSISDN,SGSNIPAddress,             	         
   MSNetworkCapability,RoutingAreaCode,LocationAreaCode,         
   CauseForRecClosing,Diagnostics,RecordSequenceNumber,NodeId,  
   LocalRecordSequeceNumnber,SystemType,SCFAddress,ServiceKey,            	                   
   DefaultTransacHandling,CAMELAPNNI,CAMELAPNOI,NumberOfDPEncounter,          	           
   LevelOfCamelService,FreeFormatData,FFDAppendIndicator,DefaultSMSHandling,         	           
   CAMELCallingPartyNumber,CAMELAccessDestination,CAMELSMSAdress,SmsReferenceNumber,          	     
   GsnId,FlagRead,CallDuration
   #ifdef EXT10om
   ,RecordExtensions
   ,ChargingCharacterSelectionMode
   ,CellIdentity
//  ,EventStampTime
   ,SGSNChange
   ,ChargingCharacteristics
   #endif
   );     									

#ifdef _DEBUG
	logOra(sErrLog, szSQL);

#endif	

	Lock();
	int res=0;
	res =mysql_real_query(myConnect, szSQL, strlen(szSQL));
	if(res != 0)
	{
		Unlock();
		logOra(sErrLog, "%d %s\n", mysql_errno(myConnect), mysql_error(myConnect));
		return -1;
	}
	Unlock();
/*
	Lock();
	EXEC SQL EXECUTE
		DECLARE
		BEGIN
EXECUTE IMMEDIATE :szSQL using 
   :SeqId,:GtpId,:GtpName,:FlagR499,
:FlagRepeat,                             
   :ServedIMSI,:ServedIMEI,:ServedMSISDN,:SGSNIPAddress,             	         
  :MSNetworkCapability,:RoutingAreaCode,:LocationAreaCode,         
   :CauseForRecClosing,:Diagnostics,:RecordSequenceNumber,:NodeId,  
   :LocalRecordSequeceNumnber,:SystemType,:SCFAddress,:ServiceKey,            	                   
   :DefaultTransacHandling,:CAMELAPNNI,:CAMELAPNOI,:NumberOfDPEncounter,          	           
   :LevelOfCamelService,:FreeFormatData,:FFDAppendIndicator,:DefaultSMSHandling,         	           
   :CAMELCallingPartyNumber,:CAMELAccessDestination,:CAMELSMSAdress,:SmsReferenceNumber,          	     
    :GsnId,:FlagRead,:CallDuration
#ifdef EXT10om
	,:RecordExtensions
	,:ChargingCharacterSelectionMode
	,:CellIdentity
	,:RecordOpenTime
	,:SGSNChange
	,:ChargingCharacteristics
#endif
;     									
	
#ifdef NO_TRANS
			COMMIT;	
#endif
		END;
	END-EXEC;
	Unlock();
	pOut->nFlag = SQL_OK;
	snprintf(pOut->SeqId, LEN_SEQ+1, "%s", SeqId);

	return 0;

sql_error:
	Unlock();
	pOut->nFlag = SQL_RET_ERROR;

#ifdef LOG_ERROR
	snprintf(szMsg, 512, "ORA:DbOMCDRInsert: %.70s", sqlca.sqlerrm.sqlerrmc);
    logOra(sErrLog, szMsg);
#endif

    EXEC SQL WHENEVER SQLERROR CONTINUE; 

	onError();

notfound:	
*/
	return 1;

}


/***********************************************************************
*      filename							:OMCDR.pc
*			 function descrpition	:get records from database OMCDRxxxxxxxxxx 
*			 input								:Tablename,Condition;	
*			 output								:S_OMCDR is record set to store what we want,
														nItems is counter of those record set,S_RESULT
													  is flag to tell us about operation is sucessful or not;
*			 date									:2006-05-22
*************************************************************************************/


int DbOMCDRSelect(char* pInSzTableName, char* pWhere, struct S_OMCDR** pOutCDR, int *nItems, struct S_RESULT* pOut)
{

	short ind[55];
	short id[2];
	short RecordType;
	char SeqId[LEN_SEQ + 1];
	char GtpName[LEN_TABLENAME + 1];
	char GtpId[LEN_SEQ + 1];
	
	int FlagRead;
	int FlagRepeat;
	int FlagR499;
	
	char SystemType;
	char ServedIMSI[17];
	char ServedIMEI[17];
	char ServedMSISDN[LEN_ServedMSISDN+1];
	char SGSNIPAddress[46];
	char MSNetworkCapability[LEN_MSNetworkCapability+1];
	char RoutingAreaCode[9];
	char LocationAreaCode[17];
	char CellIdentity[25];
	/*int ChargingID;*/

	char RecordOpenTime[LEN_DATETIME + 1];
	char CallDuration[13];
	char SGSNChange;
	char CauseForRecClosing[3];
	char Diagnostics[LEN_Diagnostics+1];
	char RecordSequenceNumber[11];
	char LocalRecordSequeceNumnber[11];

	/* CAMEL Information*/
	char SCFAddress[LEN_SCFAddress+1];
	char ServiceKey[LEN_ServiceKey+1];