cdr.cpp

Mysql的处理

/***********************************************************************
 * Module:  CExceptionADO.h
 * Author:  asus
 * Modified: 2006年4月27日 10:35:46
 * Purpose: Declaration of the class CExceptionADO
 * Comment: 接口基类
 ***********************************************************************/
#include "CDR.h"
#include <stdio.h>
#include <stdlib.h>
#include <time.h>

C_CDR::C_CDR()
{

}

C_CDR::~C_CDR()
{

}
	
bool C_CDR::Connect(const char* szDbUid, const char* szDbPwd, const char* szDbSid)
{
	return DbConnect((char*)szDbUid, (char*)szDbPwd, (char*)szDbSid) == 0;
}

void C_CDR::Disconnect()
{
	DbDisconnect();
}

char* C_CDR::GetSysdate()
{
	//得到YYMMDDHH24MI
	//把时间分成半个小时为一组
	time_t t2 = time(0);
	tm* t = localtime(&t2);
	snprintf(m_szSysdate, 20, "%02d%02d%02d%02d%02d", 
		t->tm_year - 100,
		t->tm_mon + 1,
		t->tm_mday,
		t->tm_hour,
		t->tm_min/30*30);

	return m_szSysdate;
}

char* C_CDR::GetSysdate2()
{
	//得到YYMMDDHH24MI
	//把时间分成半个小时为一组
	time_t t2 = time(0);
	tm* t = localtime(&t2);
	snprintf(m_szSysdate2, 20, "%04d%02d%02d%02d%02d", 
		t->tm_year + 1900,
		t->tm_mon + 1,
		t->tm_mday,
		t->tm_hour,
		t->tm_min);

	return m_szSysdate2;
}

bool C_CDR::Update(const char* pInSzSQL)
{
	return DbUpdateTable((char*)pInSzSQL, &m_Out) == 0;
}


bool C_CDR::Update2(const char* pInSzSQL)
{
	return DbUpdateTable2((char*)pInSzSQL, &m_Out) == 0;
}

void C_CDR::ClearTable(const char* szTable)
{
	char szSql[1024];
	snprintf(szSql, 1024, "DELETE FROM %s%s", szTable, GetSysdate());
	DbUpdateTable((char*)szSql, &m_Out) == 0;
}
	
bool C_CDR::Commit()
{
	return DbCommit() == 0;
}

bool C_CDR::Rollback()
{
	return DbRollback() == 0;
}


/*
void C_CDR::LCLOCInsert(S_LCLOC* pIn)
{

	S_LCLOC *pLoc = NULL;
	int num;
	DbLCLOCSelect("lcloc_og", "22", &pLoc, &num, &Out);
	for(int i=0;i<num;i++)
	{
		printf("\t%s:%s:%s:%s\n", 
				pLoc[i].LocationAreaCode,
				pLoc[i].RoutingAreaCode,
				pLoc[i].CellIdentity,
				pLoc[i].ChangeTime);	
	}
	if(pLoc != NULL)
		free(pLoc);


	S_OSCDR *o = NULL;
//	S_LCLOC *o = NULL;
	int n=0;
	DbOSCDRSelect("oscdr", "seqid=56", &o, &n, &m_Out);
//	DbLCLOCSelect("oscdr", "56", &o, &n, &m_Out);
	free(o);
}*/