test2.cpp

Mysql的处理

#include "CDR.h"
#include "CDRWriteGTP.h"
#include "CDRWriteASNDecode.h"
#include "CDRReadForBill.h"
#include "CDRReadForCombined.h"
#include "CDRWriteCombined.h"
#include "Date.h"
#include "Dump.h"

#include<stdio.h>
#include<vector>
#include <unistd.h>

#include<iostream>
using namespace std;

int DbOGCDRTest();
int DbASNERRORTest();
int DbCGCDRTest();
int DbCSCDRTest();
int DbLCLOCTest();
int DbLCOMMTest();
int DbLLOTVTest();
int DbGTPTest();
int DbOMCDRTest();
int DbOMOCDRTest();
int DbOMTCDRTest();
int DbOSCDRTest();

bool ReadGtp(C_CDRWriteGTP& gtp)
{
	CDate date("0606120000","0606152330");
	date.Calculate();
	int count = date.GetCount();
	printf(" == ALL ITEMS = %d \n", count);

	int p=0;
	for(int i = 0; i < count; i++)
	{
		char szTableName[31];
		char szDate[21];
		snprintf(szDate, 21, "%s", date.GetAt(i).c_str());
		snprintf(szTableName, LEN_TABLENAME+1, "OGTPL%s", szDate);

		char szSeqId[21]={"0",};
		snprintf(szSeqId, 21, "0");

		int id(0);
		char szContent[4000];
		int nLength;
		int RecordType;
		char szaa[16];
		int nFalgCancel;

		for(;;)
		{
			printf("ID=%d SeqId = '%s'\n", i, szSeqId);
			memset(szContent, 0, 4000);
			nLength = -1;
			if(!gtp.ReadRecord(szTableName, szSeqId, szContent, 
				nLength, RecordType, szSeqId,
				szaa,nFalgCancel
				))
				break;
			if(nLength < 10)
				break;

			char szFileName[1024];
			snprintf(szFileName, 1024, "/space/cgateway/asbcg/src/ogtp/%s.%d", szDate, id++);
			FILE* fp = fopen(szFileName, "wb");
			fwrite(szContent, 1, nLength, fp);
			fclose(fp);

			fp = fopen("data.log", "a");
			fprintf(fp,"i=%d id=%d !%s!\n", i, id, szDate);
			fclose(fp);
		}
	}
	

	return true;
}



int main(char** argv, int argn)
{
/*	C_CDRWriteGTP gtp;
	if(!gtp.Connect("root", "", "cgdb"))
	{
		cout << "Connect failed" << endl;
		return -1;
	}
	gtp.Test();


	C_Dump dump;
//	
	
	C_CDRReadForBill bill;
	C_CDRWriteCombined WCombined;

	if(!bill.Connect("root", "", "cgdb"))
	{
		cout << "Connect failed" << endl;
		return -1;
	}
	if(!WCombined.Connect("root", "", "cgdb"))
	{
		cout << "Connect failed" << endl;
		return -1;
	}
*/
/*
	S_CGCDR pIn10;
	memset(&pIn10,0,sizeof(pIn10));

//	bill.DbCSCDRTest();

	bill.DbCGCDRTest(pIn10);

	char pOutSzTableDate[10]={0};
	char pOutSzSeqId[21]={0};

	int nCdrs=1;
	S_LCLOC pChanageLoc;
	int nChangeLoc=0;
	S_LLOTV pLOTV;
	int nLOTV=0;
	S_LCOMM pCommon;
	int nCommon=0;
	int nFlagR4V99=0; // 0- R99; 1 - R4
    int i=0;
	for(i=0;i<5;i++)
	{
	WCombined.InsertGCDR(&pIn10,nCdrs,
		&pChanageLoc,nChangeLoc,
		&pLOTV, nLOTV,
		&pCommon, nCommon,
		nFlagR4V99, // 0- R99; 1 - R4
		pOutSzTableDate,
		pOutSzSeqId);
	}

	WCombined.Disconnect();

	char *szTableDate=bill.GetSysdate2();
	char *szTableDate2="";
	char *szSQLWhere="1=1";
	S_CGCDR_LOAD * ppCDR=NULL;
	int nOutNumber=0;
	char *szSeqId="";

	printf("time=%s\n", szTableDate);
	int m=bill.SelectGCDR(
		szTableDate,
		szTableDate2,
		szSQLWhere,
		szSeqId,
		&ppCDR, &nOutNumber);

	printf("\n%d\n",m);

	if (ppCDR != NULL)
	{	
//		S_CGCDR_LOAD * pp=ppCDR;
		for(i=0;i<nOutNumber;i++)
			dump.DumpCGCDR("gcdr.log",&ppCDR[i],0);
	}
	else 
	{
		printf("\n DB NULL \n");
	}


	bill.Disconnect();
*/
/*
	S_CSCDR pIn11;
	memset(&pIn11,0,sizeof(pIn11));

//	bill.DbCSCDRTest();

	bill.DbCSCDRTest(pIn11);

	char pOutSzTableDate[10]={0};
	char pOutSzSeqId[21]={0};

	int nCdrs=1;
	S_LCLOC pChanageLoc;
	int nChangeLoc=0;
	S_LLOTV pLOTV;
	int nLOTV=0;
	S_LCOMM pCommon;
	int nCommon=0;
	int nFlagR4V99=0; // 0- R99; 1 - R4
    int i=0;
	for(i=0;i<5;i++)
	{
	WCombined.InsertSCDR(&pIn11,nCdrs,
		&pChanageLoc,nChangeLoc,
		&pLOTV, nLOTV,
		&pCommon, nCommon,
		nFlagR4V99, // 0- R99; 1 - R4
		pOutSzTableDate,
		pOutSzSeqId);
	}

	WCombined.Disconnect();

	char *szTableDate=bill.GetSysdate2();
	char *szTableDate2="";
	char *szSQLWhere="1=1";
	S_CSCDR_LOAD * ppCDR1=NULL;
	int nOutNumber=0;
	char *szSeqId="";

	printf("time=%s\n", szTableDate);
	int m=bill.SelectSCDR(
		szTableDate,
		szTableDate2,
		szSQLWhere,
		szSeqId,
		&ppCDR1, &nOutNumber);

	printf("\n%d\n",m);

	if (ppCDR1 != NULL)
	{	
//		S_CGCDR_LOAD * pp=ppCDR;
		for(i=0;i<nOutNumber;i++)
			dump.DumpCSCDR("scdr.log",&ppCDR1[i],0);
	}
	else 
	{
		printf("\n DB NULL \n");
	}


	bill.Disconnect();
*/
//OMCDR Begin
/*	char* szTableDate=bill.GetSysdate();
	char *szTableDate2="";
	
	
		
	int nOutChangeLoc=0;
	S_LLOTV *ppLOTV=NULL;
	int nLOTV=0;
	S_LCOMM *ppCommon=NULL;
	int nCommon=0;
	int i;
	S_LCLOC *ppChanageLoc=NULL;
*/
/*
	S_OMCDR *ppCDR=NULL;
	bill.SelectMCDR(szTableDate,
					szTableDate2,
					szSQLWhere,
					&ppCDR, &nOutNumber, 
					&ppChanageLoc,&nOutChangeLoc,
					&ppLOTV, &nLOTV,
					&ppCommon, &nCommon);	
	S_OMCDR *pp=ppCDR;
	if (ppCDR != NULL)
	{	
		for(i=0;i<nOutNumber+1;i++,pp++)
			dump.DumpOMCDR("OutOMCDR",pp,0);
	}
	else 
	{
		printf("\n DB NULL \n");
	}
*/
//OMCDR End

//OMOCDR Begin
/*
nOutNumber=0;
S_OMOCDR * ppCDR1=NULL;
S_OMOCDR * pp1=NULL;
bill.SelectMOCDR(
					szTableDate,
					szTableDate2,
					szSQLWhere,
					&ppCDR1, &nOutNumber, 
					&ppChanageLoc,&nOutChangeLoc,
					&ppLOTV, &nLOTV,
					&ppCommon, &nCommon);


if (ppCDR1 != NULL)
	{	
		pp1=ppCDR1;
		for(i=0;i<nOutNumber+1;i++,pp1++)
			dump.DumpOMOCDR("OutOMOCDR",pp1,0);
	}
	else 
	{
		printf("\n DB NULL \n");
	}
*/
//OMOCDR End

//OMTCDR Begin
/*
nOutNumber=0;
S_OMTCDR * ppCDR2=NULL;
S_OMTCDR * pp2=NULL;
bill.SelectMTCDR(
					szTableDate,
					szTableDate2,
					szSQLWhere,
					&ppCDR2, &nOutNumber, 
					&ppChanageLoc,&nOutChangeLoc,
					&ppLOTV, &nLOTV,
					&ppCommon, &nCommon);


if (ppCDR2 != NULL)
	{	
		pp2=ppCDR2;
		for(i=0;i<nOutNumber+1;i++,pp2++)
			dump.DumpOMTCDR("OutOMTCDR",pp2,0);
	}
	else 
	{
		printf("\n DB NULL \n");
	}
*/
//OMTCDR End

//C_CDRReadForCombined Combined;

//OSCDR Begin
/*
nOutNumber=0;
S_OSCDR * ppCDR3=NULL;
S_OSCDR * pp3=NULL;

Combined.SelectSCDR(
					szTableDate,
					szTableDate2,
					szSQLWhere,
					&ppCDR3, &nOutNumber, 
					&ppChanageLoc,&nOutChangeLoc,
					&ppLOTV, &nLOTV,
					&ppCommon, &nCommon);


	if (ppCDR3 != NULL)
	{	
		pp3=ppCDR3;
		for(i=0;i<nOutNumber+1;i++,pp3++)
			dump.DumpOSCDR("OutOSCDR",pp3,0);
	}
	else 
	{
		printf("\n DB NULL \n");
	}
*/
//OSCDR End


//OGCDR Begin
/*
nOutNumber=0;
S_OGCDR * ppCDR4=NULL;
S_OGCDR * pp4=NULL;
Combined.SelectGCDR(
					szTableDate,
					szTableDate2,
					szSQLWhere,
					&ppCDR4, &nOutNumber, 
					&ppChanageLoc,&nOutChangeLoc,
					&ppLOTV, &nLOTV,
					&ppCommon, &nCommon);


if (ppCDR4 != NULL)
	{	
		pp4=ppCDR4;
		for(i=0;i<nOutNumber+1;i++,pp4++)
			dump.DumpOGCDR("OutOGCDR",pp4,0);
	}
	else 
	{
		printf("\n DB NULL \n");
	}
*/
//OGCDR End

//test

//DbOGCDRTest();
//DbASNERRORTest();
//DbCGCDRTest();
//DbCSCDRTest();
//DbLCLOCTest();
//DbLCOMMTest();
//DbLLOTVTest();
//DbGTPTest();
//DbOMCDRTest();
//DbOMOCDRTest();
//DbOMTCDRTest();
//DbOSCDRTest();
/*
DbCommit();	
//test select begin

C_Dump dump;
char pInSzTableName[]="LCLOC"; 
char pInSzSeqId[]="0"; 
S_LCLOC *pOutLChangeLocation=NULL; 
int number=0; 
S_RESULT pOut101;


DbLCLOCSelect(pInSzTableName, pInSzSeqId, &pOutLChangeLocation, &number, &pOut101);
int i;

for(i=0;i<number;i++)
{
//	printf("%s %s %s %s %s %s\n",pOutLChangeLocation[i].SeqId,pOutLChangeLocation[i].LocationAreaCode,pOutLChangeLocation[i].RoutingAreaCode,pOutLChangeLocation[i].CellIdentity,pOutLChangeLocation[i].ChangeTime,pOutLChangeLocation[i].SortId);
}

char pInSzTableName1[]="OGCDR";
char pWhere[]="SEQID<5";
S_OGCDR *pOutCDR=NULL;
S_RESULT pOut102;

//DbOGCDRSelect(pInSzTableName1,pWhere,&pOutCDR,&number,&pOut102);

for(i=0;i<number;i++)
{
//	printf("%d\n",pOutCDR[i].FlagR499);
}

//dump.DumpOGCDR("out.txt",pOutCDR,1);

char pInSzTableName2[]="OMCDR";
S_OMCDR *pOutCDR2=NULL; 
S_RESULT pOut103;
//DbOMCDRSelect(pInSzTableName2,pWhere, &pOutCDR2, &number, &pOut103);

for(i=0;i<number;i++)
{
//	printf("%s %s \n",pOutCDR2[i].SeqId,pOutCDR2[i].RecordOpenTime);
}

//dump.DumpOMCDR("out.txt",pOutCDR2,1);

char pInSzTableName3[]="OMOCDR";
S_OMOCDR *pOutCDR3=NULL;
S_RESULT pOut104;

//DbOMOCDRSelect(pInSzTableName3,pWhere,&pOutCDR3,&number,&pOut104);

for(i=0;i<number;i++)
{
//	printf("%s %s \n",pOutCDR3[i].SeqId,pOutCDR3[i].ServedMSISDN);
}

//dump.DumpOMOCDR("out.txt",pOutCDR3,1);

char pInSzTableName4[]="OMTCDR";
S_OMTCDR *pOutCDR4=NULL;
S_RESULT pOut105;
//DbOMTCDRSelect(pInSzTableName4,pWhere,&pOutCDR4,&number,&pOut105);
for(i=0;i<number;i++)
{
//	printf("%s  %s\n",pOutCDR4[i].SeqId,pOutCDR4[i].GsnIpAddr);
}

//dump.DumpOMTCDR("out",pOutCDR4,1);

char pInSzTableName5[]="OSCDR";
S_OSCDR *pOutCDR5;
S_RESULT pOut106;

//DbOSCDRSelect(pInSzTableName5,pWhere,&pOutCDR5, &number,&pOut106);
for(i=0;i<number;i++)
{
 // printf("%s  %s\n",pOutCDR5[i].SeqId,pOutCDR5[i].DateCreated);
}

//dump.DumpOSCDR("out.txt",pOutCDR5,1);


char pInSzTableName6[]="CSCDR";
S_CSCDR *pOutCDR6=NULL;
S_RESULT pOut107;
//DbCSCDRSelect(pInSzTableName6,pWhere,&pOutCDR6,&number, &pOut107);
for(i=0;i<number;i++)
{
  //printf("%s  %s\n",pOutCDR6[i].SeqId,pOutCDR6[i].DateCreated);
}
	
char pInSzTableName7[]="CGCDR";
S_CGCDR *pOutCDR7; 
S_RESULT pOut108;

//DbCGCDRSelect(pInSzTableName7,pWhere,&pOutCDR7,&number,&pOut108);

for(i=0;i<number;i++)
{
 // printf("%s  %s\n",pOutCDR7[i].SeqId,pOutCDR7[i].DateCreated);
}
//test select end 

//	ReadGtp(gtp);

//	gtp.Test();

  /*	C_CDRWriteASNDecode asn;
	asn.Test();
//	asn.Test2();*/
/*	C_CDRReadForCombined readCom;
	readCom.Test();

	/*
	C_CDRWriteCombined writeCom;
	writeCom.Test();
*/


//	C_CDRReadForBill bill;
//	bill.Test();

/*	C_CDRReadForCombined readCom;
	readCom.Test();
/*

//	gtp.Disconnect();
	cout<<"Good Bye to TEST2\n";
/*
	for(int i=0;i<10000;i++)
	{
		char* a = gtp.GetSysdate();
		CDate date(a, a);
		date.Calculate();
		printf("%d %d\n", i, date.GetCount());
		printf("%d %s\n", i ,date.GetAt(i).c_str());
	}
*/


//test LCBC & LLCBC 
C_MYSQL test;
test.LCBCTest();
test.LLCBCTest();

//test LCBC & LLCBC end
}