#include "oradb.h"/*********************************************************      filename							:OMOCDR.pc*			 function descrpition	:insert data into database OMOCDRxxxxxxxxxx *			 input								:struct S_OMOCDR *	*			 output								:SQL_OK ( operation sucess) SQL_RET_ERRO (operation failed)*			 date									:2006-05-22**********************************************************/int DbOMOCDRInsert(struct S_OMOCDR* pIn, struct S_RESULT* pOut){/*        get info           */	/* PK & FK */	short RecordType=pIn->RecordType;	char *GtpName=(char *)pIn->GtpName;	char *GtpId=(char *)pIn->GtpId;		int FlagRead = pIn->FlagRead;	int FlagRepeat=pIn->FlagRepeat;	int FlagR499=pIn->FlagR499;	char *ServedIMSI=(char *)pIn->ServedIMSI;	char *ServedIMEI=(char *)pIn->ServedIMEI;	char *ServedMSISDN=(char *)pIn->ServedMSISDN;	char *MSNetworkCapability=(char *)pIn->MSNetworkCapability;	char *RoutingAreaCode=(char *)pIn->RoutingAreaCode;	char *LocationAreaCode=(char *)pIn->LocationAreaCode;	char *CellIdentity=(char *)pIn->CellIdentity;/*	int ChargingID=pIn->ChargingID;*/	char *ServiceCenter=(char *)pIn->ServiceCenter;	char *RecordingEntity	= (char*)pIn->RecordingEntity;	char *EventStampTime=(char *)pIn->EventStampTime;	/*char*/int SystemType=pIn->SystemType;	char* MessageReference = pIn->MessageReference;	/*char*/int SMSResult=pIn->SystemType;	char *NodeID=(char *)pIn->NodeID;	char *ChargingCharacteristics=(char *)pIn->ChargingCharacteristics;	char *LocalRecordSequeceNumnber=(char *)pIn->LocalRecordSequeceNumnber;	char *DestinationNumber=(char *)pIn->DestinationNumber;	/* 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 EXT10mo	int ChargingCharacterSelectionMode = pIn->ChargingCharacterSelectionMode;#endif	/* peer ip */	char *GsnIpAddr = pIn->GsnIpAddr;	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_OMOCDR.NEXTVAL 	INTO :SeqId 	FROM DUAL;	/*     PART 2 INSERT STATEMENT           *//*#ifdef _DEBUGsnprintf(szSQL,SQLMAX,"INSERT INTO %s (""SEQID,GTPID,GTPLTABLE,FLAGR499,"                    "SERVEDIMSI,SERVEDIMEI,SERVEDMSISDN,MSNNETWORKCAPABILITY,"        "SERVICECENTER,ROUTINGAREACODE,LOCATIONAREACODE,EVENTSTAMPTIME,"              "SMSRESULT,NODEID,LOCALRECORDSEQUECENUMBER,CHARGINGCHARACTERISTICS,""SYSTEMTYPE,DESTINATIONNUNMBER,SCFADDRESS,SERVICEKEY,"                  "DEFAULTTRANSACHANDLING,CAMELAPNNI,CAMELAPNOI,NUMBEROFDPENCOUNTER, "        "LEVELOFCAMELSERVICE,FREEFORMATDATA,FFDAPPENDINDICATOR,DEFAULTSMSHANDLING,"          "CAMELCALLINGPARTYNUMBER,CAMELACCESSDESTNO,CAMELSMSADDRESS,SMSREFERENCENUMBER,"          "DATECREATED,GSNID,FLAGREAD,RECORDINGENTITY,MESSAGEREFRENCE) VALUES("    "'%s','%s','%s',%d,"    "'%s','%s','%s','%s',"  "'%s','%s','%s',TO_DATE('%s','YYYYMMDDHH24MISS'), " "%d ,'%s','%s','%s', "   "%d,'%s','%s','%s',"     "%d,'%s','%s','%s',"   "'%s','%s',%d,%d,"   "'%s','%s','%s','%s',"  "SYSDATE,'%s',%d," "'%s','%s')", TableName,  SeqId,  GtpId,GtpName,FlagR499,  ServedIMSI,ServedIMEI,ServedMSISDN,MSNetworkCapability,  ServiceCenter,RoutingAreaCode,LocationAreaCode,EventStampTime,  SMSResult,NodeID,LocalRecordSequeceNumnber,  ChargingCharacteristics,  SystemType,DestinationNumber,SCFAddress,ServiceKey,  DefaultTransacHandling,CAMELAPNNI,CAMELAPNOI,NumberOfDPEncounter,  LevelOfCamelService,FreeFormatData,FFDAppendIndicator,DefaultSMSHandling,  CAMELCallingPartyNumber,CAMELAccessDestination,CAMELSMSAdress,SmsReferenceNumber,  GsnId,FlagRead,  RecordingEntity,MessageReference); 										logOra(sErrLog, szSQL);#endif*/snprintf(szSQL,SQLMAX,"INSERT INTO %s (""GTPID,GTPLTABLE,FLAGR499,"  "FLAGREPEAT,"                  "SERVEDIMSI,SERVEDIMEI,SERVEDMSISDN,MSNNETWORKCAPABILITY,"        "SERVICECENTER,ROUTINGAREACODE,LOCATIONAREACODE,EVENTSTAMPTIME,"  /*13*/            "SMSRESULT,NODEID,LOCALRECORDSEQUECEnumeric,CHARGINGCHARACTERISTICS,""SYSTEMTYPE,DESTINATIONNUNMBER,SCFADDRESS,SERVICEKEY,"                  "DEFAULTTRANSACHANDLING,CAMELAPNNI,CAMELAPNOI,NUMBEROFDPENCOUNTER, "        "LEVELOFCAMELSERVICE,FREEFORMATDATA,FFDAPPENDINDICATOR,DEFAULTSMSHANDLING,"          "CAMELCALLINGPARTYNUMBER,CAMELACCESSDESTNO,CAMELSMSADDRESS,SMSREFERENCENUMBER,"          "DATECREATED,GSNID,FLAGREAD,RECORDINGENTITY,MESSAGEREFRENCE"#ifdef EXT10mo",RECORDEXTENSIONS"",CHARGINGCHARACTERSELECTIONMODE"",CELLIDENTITY"#endif",GSNIPADDR"") VALUES("    "%s,'%s',%d," "%d,"   "'%s','%s','%s','%s',"  "'%s','%s','%s','%s', " "%d ,'%s',%s,'%s', "   "%d,'%s','%s',%s,"     "%d,'%s','%s',%s,"   "'%s','%s',%d,%d,"   "'%s','%s','%s','%s',"  "NOW(),%s,%d,'%s','%s'"#ifdef EXT10mo",'%s'"",%d"",'%s'"#endif",'%s'"")", TableName,  GtpId,GtpName,FlagR499,  FlagRepeat,  ServedIMSI,ServedIMEI,ServedMSISDN,MSNetworkCapability,  ServiceCenter,RoutingAreaCode,LocationAreaCode,EventStampTime,  SMSResult,NodeID,LocalRecordSequeceNumnber,  ChargingCharacteristics,  SystemType,DestinationNumber,SCFAddress,ServiceKey,  DefaultTransacHandling,CAMELAPNNI,CAMELAPNOI,NumberOfDPEncounter,  LevelOfCamelService,FreeFormatData,FFDAppendIndicator,DefaultSMSHandling,  CAMELCallingPartyNumber,CAMELAccessDestination,CAMELSMSAdress,SmsReferenceNumber,  GsnId,FlagRead,RecordingEntity,MessageReference#ifdef EXT10mo,RecordExtensions,ChargingCharacterSelectionMode,CellIdentity#endif,GsnIpAddr );								#ifdef _DEBUG	logOra(sErrLog, szSQL);#endif	Lock();	int 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,:MSNetworkCapability,  :ServiceCenter,:RoutingAreaCode,:LocationAreaCode,:EventStampTime,  :SMSResult,:NodeID,:LocalRecordSequeceNumnber,:ChargingCharacteristics,  :SystemType,:DestinationNumber,:SCFAddress,:ServiceKey,  :DefaultTransacHandling,:CAMELAPNNI,:CAMELAPNOI,:NumberOfDPEncounter,  :LevelOfCamelService,:FreeFormatData,:FFDAppendIndicator,:DefaultSMSHandling,  :CAMELCallingPartyNumber,:CAMELAccessDestination,:CAMELSMSAdress,  :SmsReferenceNumber,  :GsnId,:FlagRead,  :RecordingEntity,:MessageReference#ifdef EXT10mo	,:RecordExtensions	,:ChargingCharacterSelectionMode	,:CellIdentity#endif,:GsnIpAddr;     									 												COMMIT;			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:DbOMOCDRInsert: %.70s", sqlca.sqlerrm.sqlerrmc);    logOra(sErrLog, szMsg);#endif    EXEC SQL WHENEVER SQLERROR CONTINUE; 	onError();notfound:	*/	return 1;}/************************************************************************      filename							:OMOCDR.pc*			 function descrpition	:get records from database OMCDRxxxxxxxxxx *			 input								:Tablename,Condition;	*			 output								:S_OMOCDR 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 DbOMOCDRSelect(char* pInSzTableName, char* pWhere, struct S_OMOCDR** 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 ServedIMSI[17];	char ServedIMEI[17];	char ServedMSISDN[LEN_ServedMSISDN+1];	char MSNetworkCapability[LEN_MSNetworkCapability+1];	char RoutingAreaCode[9];	char LocationAreaCode[17];	char CellIdentity[25];	/*int ChargingID;*/	char ServiceCenter[21];	char RecordingEntity[21];	char EventStampTime[LEN_DATETIME + 1];	char SystemType;	char MessageReference[256];	char SMSResult;