cdrfile.cpp

Mysql的处理

#include "oradb.h"



int C_MYSQL::DbBsFileInsert(struct S_BSFILE* p)
{
	char szMsg[512];
	
	char SeqId[LEN_SEQ+1];
	char *RuleId = p->RuleId;
	char *FileLoc = p->FileLoc;
	char szSQL2[SQLMAX];
	char *TableName = p->TableName;
	int i;

	snprintf(szSQL2, SQLMAX, "INSERT INTO %s("
		//"SEQID,"
		"RULEID,"
		"FILELOC,"
		"DATECREATE) VALUES("
		"'%s','%s',now())",
		TableName,
		RuleId,
		FileLoc);

#ifdef _DEBUG
	logOra(sErrLog, szSQL2);
#endif
	Lock();
	int res = mysql_real_query(myConnect, szSQL2, strlen(szSQL2));
	if(res != 0)
	{
		Unlock();
		onError();
		
		return -1;
	}

	if(GetSeq(p->SeqId) != 0)
	{
		Unlock();
		onError();

		return -2;
	}

	Unlock();
	return 0;
}

int C_MYSQL::DbCdrFileInsert(struct S_CDRFILE* p)
{
	char szMsg[512];

	char *SeqId = p->SeqId;
	char *CDRTable = p->CDRTable;
	char *CDRType = p->CDRType;
	char *FileId = p->FileId;
	char *FileTable = p->FileTable;
	char *TableName = p->TableName;
	int i;
	char szSQL2[SQLMAX];

	TableName = p->TableName;

	snprintf(szSQL2, SQLMAX, "INSERT INTO %s("
"SEQID,"
"CDRTABLE,"
"CDRTYPE,"
"FILEID,"
"FILETABLE,"
"DATECREATE"
") VALUES("
		"'%s','%s','%s','%s','%s',now())",
		TableName,
		SeqId,
		CDRTable,
		CDRType,
		FileId,
		FileTable
		);

#ifdef _DEBUG
	logOra(sErrLog, szSQL2);
#endif
	Lock();
	int res = mysql_real_query(myConnect, szSQL2, strlen(szSQL2));
	if(res != 0)
	{
		Unlock();
		
		onError();
		return -1;
	}

	Unlock();
	return 0;
}

int C_MYSQL::DbLCBCInsert(S_LCBC* p)
{
	char szMsg[512];
	char *SeqId = p->SeqId;

	char *AccessCorrelationld=p->AccessCorrelationld;
	char *UplinkPacketCount=p->UplinkPacketCount;
	char *DownlinkPacketCount=p->DownlinkPacketCount;
	char *UplinkByteCount=p->UplinkByteCount;
	char *DownlinkByteCount=p->DownlinkByteCount;
	char Action=p->Action;
	char *ChargingType=p->ChargingType;
	char *FlowTemplateIdentifier=p->FlowTemplateIdentifier;
	char *ServiceClassIdentifier=p->ServiceClassIdentifier;
	char *FlowChargeIdentifier=p->FlowChargeIdentifier;
	char *ServiceClassDescriptor=p->ServiceClassDescriptor;
	char *FlowDescriptor=p->FlowDescriptor;
	char *TimeDuration=p->TimeDuration;
	char *SrcAddress=p->SrcAddress;
	char *SrcPortStart=p->SrcPortStart;
	char *SrcPortEnd=p->SrcPortEnd;
	char *DestAddress=p->DestAddress;
	char *DestPortStart=p->DestPortStart;
	char *DestPortEnd=p->DestPortEnd;
	char *Protocol=p->Protocol;
	char ContentType=p->ContentType;    
	char *MailHost=p->MailHost;
	char *MimeContentType=p->MimeContentType;
	char *MailFrom=p->MailFrom;
	char *SmtpResponseCode=p->SmtpResponseCode;
	char WspContentType=p->WspContentType;  
	char *Url=p->Url;
	char *WapUserAgent=p->WapUserAgent;  
	char *ReverseChargeIdentifier=p->ReverseChargeIdentifier;
	char *SortId=p->SortId;

	char *TableName = p->TableName;

	int i;
	char szSQL2[SQLMAX];

	snprintf(szSQL2, SQLMAX, "INSERT INTO %s("
"SEQID,"
"ACCESSCORRELATIONLD,"
"UPLINKPACKETCOUNT,"
"DOWNLINKPACKETCOUNT,"
"UPLINKBYTECOUNT,"

"DOWNLINKBYTECOUNT,"
"ACTION,"
"CHARGINGTYPE,"
"FLOWTEMPLATEIDENTIFIER,"
"SERVICECLASSIDENTIFIER,"

"FLOWCHARGEIDENTIFIER,"
"SERVICECLASSDESCRIPTOR,"
"FLOWDESCRIPTOR,"
"TIMEDURATION,"
"SRCADDRESS,"

"SRCPORTSTART,"
"SRCPORTEND,"
"DESTADDRESS,"
"DESTPORTSTART,"
"DESTPORTEND,"

"PROTOCOL,"
"CONTENTTYPE,"
"MAILHOST,"
"MIMECONTENTTYPE,"
"MAILFROM,"

"SMTPRESPONSECODE,"
"WSPCONTENTTYPE,"
"URL,"
"WAPUSERAGENT,"
"REVERSECHARGEIDENTIFIER,"

"SORTID"

") VALUES("
        "%s,%s,%s,%s,%s,"
		"%s,%d,'%s',%s,'%s',"
		"'%s','%s','%s',%s,'%s',"
		"'%s','%s','%s','%s','%s',"
		"%s,%d,'%s','%s','%s',"
		"%s,%d,'%s','%s','%s',"
		"%s)",
		TableName,
		SeqId,
		AccessCorrelationld,
		UplinkPacketCount,
		DownlinkPacketCount,
		UplinkByteCount,

		DownlinkByteCount,
		Action,
		ChargingType,
		FlowTemplateIdentifier,
		ServiceClassIdentifier,

		FlowChargeIdentifier,
		ServiceClassDescriptor,
		FlowDescriptor,
		TimeDuration,
		SrcAddress,

		SrcPortStart,
		SrcPortEnd,
		DestAddress,
		DestPortStart,
		DestPortEnd,

		Protocol,
		ContentType,  
		MailHost,
		MimeContentType,
		MailFrom,

		SmtpResponseCode,
		WspContentType,
		Url,
		WapUserAgent, 
		ReverseChargeIdentifier,

		SortId
		);
#ifdef _DEBUG
	logOra(sErrLog, szSQL2);
#endif
	Lock();
	int res = mysql_real_query(myConnect, szSQL2, strlen(szSQL2));
	if(res != 0)
	{
		Unlock();
		onError();
		
		return -1;
	}
	if(GetSeq(p->SeqId) != 0)
	{
		Unlock();
		onError();
		return -2;
	}

	Unlock();	
	return 0;
}

int C_MYSQL::DbLLCBCInsert(S_LLCBC* p)
{
	char szMsg[512];
	char *SeqId = p->SeqId;
	char *SortId=p->SortId;

	char *WtpTransactionIdentifier=p->WtpTransactionIdentifier;
	char *MmsTransactionIdentifier=p->MmsTransactionIdentifier;

	char *TableName = p->TableName;

	int i;
	char szSQL2[SQLMAX];

	snprintf(szSQL2, SQLMAX, "INSERT INTO %s("
"SEQID,"
"SORTID,"
"WTPTRANSACTIONIDENTIFIER,"
"MMSTRANSACTIONIDENTIFIER"
") VALUES("
		"%s,%s,%s,'%s')",
		TableName,
		SeqId,
		SortId,
		WtpTransactionIdentifier,
		MmsTransactionIdentifier
		);

#ifdef _DEBUG
	logOra(sErrLog, szSQL2);
#endif
	Lock();
	int res = mysql_real_query(myConnect, szSQL2, strlen(szSQL2));
	if(res != 0)
	{
		Unlock();
		onError();
		
		return -1;
	}
	if(GetSeq(p->SeqId) != 0)
	{
		Unlock();
		onError();
		return -2;
	}
	Unlock();
	
	return 0;
}

void C_MYSQL::LCBCTest()
{
	
	struct S_LCBC lcbc;
	struct S_LCBC *p=&lcbc;
	memset(&lcbc,0,sizeof(lcbc));

	memcpy(p->SeqId,"12",2);
	memcpy(p->AccessCorrelationld,"34",2);
	memcpy(p->UplinkPacketCount,"56",2);
	memcpy(p->DownlinkPacketCount,"78",2);
	memcpy(p->UplinkByteCount,"91",2);
	memcpy(p->DownlinkByteCount,"13",2);
	p->Action=1;//
	memcpy(p->ChargingType,"14",2);
	memcpy(p->FlowTemplateIdentifier,"15",2);
	memcpy(p->ServiceClassIdentifier,"16",2);
	memcpy(p->FlowChargeIdentifier,"17",2);
	memcpy(p->ServiceClassDescriptor,"18",2);
	memcpy(p->FlowDescriptor,"19",2);
	memcpy(p->TimeDuration,"20",2);
	memcpy(p->SrcAddress,"21",2);
	memcpy(p->SrcPortStart,"22",2);
	memcpy(p->SrcPortEnd,"23",2);
	memcpy(p->DestAddress,"24",2);
	memcpy(p->DestPortStart,"25",2);
	memcpy(p->DestPortEnd,"26",2);
	memcpy(p->Protocol,"27",2);
	p->ContentType=2; //   
	memcpy(p->MailHost,"28",2);
	memcpy(p->MimeContentType,"29",2);
	memcpy(p->MailFrom,"14",2);
	memcpy(p->SmtpResponseCode,"30",2);
	p->WspContentType=3;  //
	memcpy(p->Url,"32",2);
	memcpy(p->WapUserAgent,"33",2);  
	memcpy(p->ReverseChargeIdentifier,"34",2);
	memcpy(p->SortId,"35",2);
    
	snprintf(p->TableName,LEN_TABLENAME + 1,"LCBC");

	DbConnect("root", "", "cgdb");
	DbLCBCInsert(p);
	DbCommit();
	DbDisconnect();
}
void C_MYSQL::LLCBCTest()
{
		
	struct S_LLCBC llcbc;
	struct S_LLCBC *p=&llcbc;
	memset(&llcbc,0,sizeof(llcbc));

	memcpy(p->SeqId,"12",2);
    memcpy(p->SortId,"35",2);
    memcpy(p->WtpTransactionIdentifier,"45",2);
    memcpy(p->MmsTransactionIdentifier,"78",2);

	snprintf(p->TableName,LEN_TABLENAME + 1,"LLCBC");

	DbConnect("root", "", "cgdb");
	DbLLCBCInsert(p);
	DbCommit();
	DbDisconnect();
}