testcdr.cpp

Mysql的处理

#include "CDR.h"
#include "oradb.h"
#include<iostream>
using namespace std;
int t_o();
int t_g();
int t_m();
int t_t();
int t_s();
int t_asn();
int t_gtp();
int t_omt();
int t_og();
int t_os();
int t_omo();
int t_om();
int t_asnerror();
int main(char** argv, int argn)
{
	C_CDR cdr;
	if(!cdr.Connect("cgdb", "cgdb", "cgdb"))
	{
		cout << "Connect failed" << endl;
		return -1;
	}
cout<<"let begin \n";

if (!t_o()) cout<<"[               INSERt OMOCDR OK!            ]\n\n";
if (!t_g()) cout<<"[               INSERt  OGCDR OK!             ]\n\n";
if (!t_m()) cout<<"[               INSERt       OMCDR OK!             ]\n\n";
if (!t_t()) cout<<"[                INSERt      INSERt OMTCDR OK!            ]\n\n";
if (!t_s()) cout<<"[               INSERt  OSCDR OK!             ]\n\n";


if (!t_asn()) cout<<"[                INSERt ASNERROR OK!             ]\n\n";
if (!t_asnerror()) cout<<"[                ASNERROR OK!             ]\n\n";

if (!t_omo()) cout<<"[                OMOCdr OK!             ]\n\n";
if (!t_omt()) cout<<"[                OMTCdr OK!             ]\n\n";
if (!t_om()) cout<<"[                OMCdr OK!             ]\n\n";
if (!t_os()) cout<<"[                OSCdr OK!             ]\n\n";
if (!t_og()) cout<<"[                OGCdr OK!             ]\n\n";

	cdr.Disconnect();

	
	return 0;
}
int t_asn()
{

	S_ASNERROR *in;

	S_RESULT out;
	in = (struct S_ASNERROR *) malloc(SIZE_S_ASNERROR);

	memset(in, 0, SIZE_S_ASNERROR);

	char *pWhere="1=1";
	char *pInSzTableName="ASNERROR";
	int nItems=0;
	int i=0;
	/*out=NUll;*/
	strcpy(in->Content,"ASNERROR:");;

	strcpy(in->TableName,"ASNERROR");;

	for(;i<100;i++)
	{
//	printf("OGCDR ====>>Now is  [  %d  ]\n",i);
	if(DbASNERRORInsert(in,&out))return 1;
	/*DbOMTCDRSelect(pInSzTableName,pWhere, &in, &nItems,&out);*/
	}
	
	return 0;
}

int t_asnerror()
{

	S_ASNERROR *in=NULL;

	S_RESULT out;
	
	char *pWhere="1=1";
	char *pInSzTableName="ASNERROR";
	int nItems=0;
	int i=0;
	
	DbASNERRORSelect(pInSzTableName,pWhere, &in, &nItems,&out);
	for(;i<nItems;i++)
	{
	 printf("ASNERROR--->[%d]  [%s]\n",nItems,in->SeqId);                                          
	 printf("ASNERROR--->[%d]   [%s]\n",nItems,in->GtpId);																						
	 printf("ASNERROR--->[%d]   [%s]\n",nItems,in->GtpName);                                     
	 printf("ASNERROR--->[%d]   [%s]\n",nItems,in->Content);                                     

	printf("ASNERROR--->[%d]   [%d]\n",nItems,in->Cause);
	printf("ASNERROR--->[%d]   [%s]\n",nItems,in->DateCreated);                            		                                          	
	printf("ASNERROR--->[%d]   [%s]\n",nItems,in->GsnId);

	}
	
	return 0;
}



int t_gtp()
{

	S_OMTCDR *in=NULL;

	S_RESULT out;
	
//	in = (struct S_GTPL *) malloc(SIZE_S_GTPL);

//	memset(in, 0, SIZE_S_GTPL);

	char *pWhere="1=1";
	char *pInSzTableName="OMTCDR";
	int nItems=0;
	int i=0;


	if(DbOMTCDRSelect(pInSzTableName,pWhere, &in, &nItems,&out)) return 1;;
	
	return 0;
}


int t_og()
{

	S_OGCDR *in=NULL;

	S_RESULT out;
	
//	in = (struct S_GTPL *) malloc(SIZE_S_GTPL);

//	memset(in, 0, SIZE_S_GTPL);

	char *pWhere="1=1";
	char *pInSzTableName="OGCDR";
	int nItems=0;
	int i=0;


	if(DbOGCDRSelect(pInSzTableName,pWhere, &in, &nItems,&out)) return 1;;



for(;i<nItems;i++)
{
		 printf("OGCDR ====>>[%s]\n",in->SeqId);                                          	
		 printf("OGCDR ====>>[%s]\n",in->GtpId);																						
		 printf("OGCDR ====>>[%s]\n",in->GtpName);                                	
		 printf("OGCDR ====>>[%s]\n",in->MergeId);                                      	
		 printf("OGCDR ====>>[%s]\n",in->MergeName);                            	
		 printf("OGCDR ====>>[%d]\n",in->FlagRepeat);                                     	         	
		 printf("OGCDR ====>>[%d]\n",in->FlagR499);                                         	         	
		 printf("OGCDR ====>>[%s]\n",in->ServedMSISDN);                                 	
		 printf("OGCDR ====>>[%s]\n",in->SGSNIPAddress);                               	
		 printf("OGCDR ====>>[%d]\n",in->ChargingID);                                     			     	
		 printf("OGCDR ====>>[%s]\n",in->GGSNAddress);               	                  	
		 printf("OGCDR ====>>[%s]\n",in->AccessPointNameNI);                       	
		 printf("OGCDR ====>>[%d]\n",in->APNSelectionMode);                         	         	
		 printf("OGCDR ====>>[%s]\n",in->PDPTypeNumber);                               	
		 printf("OGCDR ====>>[%s]\n",in->ServedPDPAddress);                         	
		 printf("OGCDR ====>>[%s]\n",in->RecordOpenTime);                   	
		 printf("OGCDR ====>>[%d]\n",in->CauseForRecClosing);                     	         	
		 printf("OGCDR ====>>[%s]\n",in->Diagnostics);         	                        	         	
		 printf("OGCDR ====>>[%d]\n",in->RecordSequenceNumber);                 	         	
		 printf("OGCDR ====>>[%s]\n",in->NodeID);                                             	
		 printf("OGCDR ====>>[%d]\n",in->LocalRecordSequeceNumnber);       	
	//	 printf("OGCDR ====>>[%s]\n",in->AccessPointNameOI);       	              	
	//	 printf("OGCDR ====>>[%d]\n",in->UnsentDownlinkVolume);                 	         	
		 printf("OGCDR ====>>[%d]\n",in->ChargingCharacteristics);           	         	
//		 printf("OGCDR ====>>[%s]\n",in->RemotePDPAddress);	                       	
		 printf("OGCDR ====>>[%d]\n",in->DynamicAddressFlag);                     	
	//	 printf("OGCDR ====>>[%d]\n",in->AnonymousAccessIndicator);
 		 printf("OGCDR ====>>[%s]\n",in->GsnId);
}
	return 0;
}


int t_omt()
{

	S_OMTCDR *in=NULL;

	S_RESULT out;
	
//	in = (struct S_GTPL *) malloc(SIZE_S_GTPL);

//	memset(in, 0, SIZE_S_GTPL);

	char *pWhere="1=1";
	char *pInSzTableName="OMTCDR";
	int nItems=0;
	int i=0;


	if(DbOMTCDRSelect(pInSzTableName,pWhere, &in, &nItems,&out)) return 1;;
	
	for(;i<nItems;i++)
	{
		
		cout<<"OMTCDR=====>SeqId:["<<(in+i)->SeqId <<"]"<<endl;    
		cout<<"OMTCDR=====>:GtpId:["<<(in+i)->GtpId<<"]"<<endl; 
		cout<<"OMTCDR=====>:GtpName:["<<(in+i)->GtpName<<"]"<<endl; 
		cout<<"OMTCDR=====>:FlagR499:["<<(in+i)->FlagR499 <<"]"<<endl;                                 
		cout<<"OMTCDR=====>:ServedIMSI:["<<(in+i)->ServedIMSI<<"]"<<endl; 
		cout<<"OMTCDR=====>ServedIMEI:["<<(in+i)->ServedIMEI<<"]"<<endl; 
		cout<<"OMTCDR=====>:ServedMSISDN:["<<(in+i)->ServedMSISDN<<"]"<<endl; 
		cout<<"OMTCDR=====>:MSNetworkCapability:["<<(in+i)->MSNetworkCapability<<"]"<<endl;                 
		cout<<"OMTCDR=====>:ServiceCenter:["<<(in+i)->ServiceCenter<<"]"<<endl; 
		cout<<"OMTCDR=====>:RoutingAreaCode:["<<(in+i)->RoutingAreaCode<<"]"<<endl; 
		cout<<"OMTCDR=====>:LocationAreaCode:["<<(in+i)->LocationAreaCode<<"]"<<endl; 
		cout<<"OMTCDR=====>:EventStampTime:["<<(in+i)->EventStampTime<<"]"<<endl; 
		cout<<"OMTCDR=====>:SMSResult:["<<(in+i)->SMSResult<<"]"<<endl; 
		cout<<"OMTCDR=====>:NodeID:["<<(in+i)->NodeID<<"]"<<endl; 
		cout<<"OMTCDR=====>:LocalRecordSequeceNumnber:["<<(in+i)->LocalRecordSequeceNumnber<<"]"<<endl; 
		cout<<"OMTCDR=====>:ChargingCharacteristics:["<<(in+i)->ChargingCharacteristics<<"]"<<endl; 
		cout<<"OMTCDR=====>:SystemType:["<<(in+i)->SystemType<<"]"<<endl; 
		cout<<"OMTCDR=====>:GsnId:["<<(in+i)->GsnId                <<"]"<<endl;              

	}
	
	
	
	return 0;
}
int t_omo()
{

	S_OMOCDR *in=NULL;

	S_RESULT out;
	
//	in = (struct S_GTPL *) malloc(SIZE_S_GTPL);

//	memset(in, 0, SIZE_S_GTPL);

	char *pWhere="1=1";
	char *pInSzTableName="OMOCDR";
	int nItems=0;
	int i=0;


	if(DbOMOCDRSelect(pInSzTableName,pWhere, &in, &nItems,&out)) return 1;;
	
	for(;i<nItems;i++)
	{
		 printf(">>OMOCDR ====>>[%s]\n",in->SeqId);                                                             
		 printf(">>OMOCDR ====>>[%s]\n",in->GtpId);																						     
		 printf(">>OMOCDR ====>>[%s]\n",in->GtpName);                                        
		 printf(">>OMOCDR ====>>[%d]\n",in->FlagR499);                                         	               
		                                                                                 
		 printf(">>OMOCDR ====>>[%s]\n",in->ServedIMSI);                                           
		 printf(">>OMOCDR ====>>[%s]\n",in->ServedIMEI);                                           
		 printf(">>OMOCDR ====>>[%s]\n",in->ServedMSISDN);                                       
		 printf(">>OMOCDR ====>>[%s]\n",in->MSNetworkCapability);                   	     
                                                                                     
		 printf(">>OMOCDR ====>>[%s]\n",in->ServiceCenter);                           	         
		 printf(">>OMOCDR ====>>[%s]\n",in->RoutingAreaCode);                           	     
		 printf(">>OMOCDR ====>>[%s]\n",in->LocationAreaCode);                               
		 printf(">>OMOCDR ====>>[%s]\n",in->EventStampTime);		                     
                                                                                     
                                                                                     
		 printf(">>OMOCDR ====>>[%d]\n",in->SMSResult);                                                        
		 printf(">>OMOCDR ====>>[%s]\n",in->NodeID);                                             		    		 
		 printf(">>OMOCDR ====>>[%d]\n",in->LocalRecordSequeceNumnber);       	            
		 printf(">>OMOCDR ====>>[%d]\n",in->ChargingCharacteristics);                            
		          	                                                                     
		 printf(">>OMOCDR ====>>[%d]\n",in->SystemType);                                                      
		 printf(">>OMOCDR ====>>[%s]\n",in->DestinationNumber);                             
		 printf(">>OMOCDR ====>>[%s]\n",in->SCFAddress);                                           
		 printf(">>OMOCDR ====>>[%d]\n",in->ServiceKey);                                                      
		                                                                                 
		 printf(">>OMOCDR ====>>[%s]\n",in->LevelOfCamelService);