ogtpl.cpp

Mysql的处理

#include "oradb.h"
#include "Base64.h"


void C_MYSQL::DbGTPTest()
{
	S_GTPL pIn;
	S_RESULT pOut;
	
	memset(&pIn,0,sizeof(pIn));
	
	pIn.CgType=10;
	memcpy(pIn.Content,"11111111111111111111111111111111111111", 12);
	snprintf(pIn.TableName, LEN_TABLENAME+1, "OGTPL");
	pIn.RecordType=100;
	pIn.ContentLength=20;
	pIn.FlagCancel=1;
	pIn.PeerIp=0xffffffff;
	pIn.PeerSeqId=88333333;
    memcpy(pIn.GsnId,"11111111111111111111111111111111111111", 12);
    memcpy(pIn.GsnId,"3333333", 12);

	DbGTPInsert(&pIn, &pOut);
}

int C_MYSQL::DbGTPInsert(struct S_GTPL* pIn, struct S_RESULT* pOut)
{
	char szMsg[512];
	char szSQL[SQLMAX];
	int i=0;
	char SeqId[LEN_SEQ + 1];
	char TableName2[LEN_TABLENAME + 1];
		
	int 	nRecordType=pIn->RecordType;
	char *szContent=(char *)pIn->Content;
	int 	nContentLength=pIn->ContentLength;
	int 	nFlagCancel=pIn->FlagCancel;
	char *szGsnId=(char *)pIn->GsnId;
	char *TableName=(char *)pIn->TableName;
	unsigned int  PeerIp=pIn->PeerIp;
	unsigned int  PeerSeqId=pIn->PeerSeqId;
	int 	nCgType=pIn->CgType;



	snprintf(szSQL, SQLMAX, "INSERT INTO %s ("
	"RECORDTYPE,CONTENT,CONTENTLENGTH,FLAGCANCEL,"
	"DATECREATE,GSNID,PEERIP,PEERSEQID,CGTYPE) VALUES("
	"%d,'%s',%d,%d,"
	"NOW(),%s,%u,%u,%d)",
	TableName,
	nRecordType,szContent,nContentLength,nFlagCancel,
	szGsnId[0]==0?"NULL":szGsnId,PeerIp,PeerSeqId, nCgType);

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

	return 0;

}



int C_MYSQL::DbGTPSelect(char* pInSzTableName, char* szInSeqId, int* RecordType,
	char* szOutContent, char* szOutSeqId, int* nPeerIp, int *nFlagCancel)
{
	char szMsg[512];
	
	
	char TableName[LEN_TABLENAME + 1];
		
	int		nRecordType;
	int 	nContentLength;
	int 	nFlagCancel2;

	unsigned int nPeeIp2;

	char szSQL[SQLMAX];
	short id;



	snprintf(szSQL, SQLMAX, 
		"SELECT SEQID,CONTENT,RECORDTYPE,PEERIP,FLAGCANCEL "
		"FROM %s WHERE SEQID>'%s'", pInSzTableName, szInSeqId);

	if(myConnect == NULL)
	{
		logOra(sErrLog, "database link break" );
		return -1;
	}

#ifdef _DEBUG
//	logOra(sErrLog, szSQL);
#endif

	int res = mysql_real_query(myConnect, szSQL, strlen(szSQL));
	if(res != 0)
	{
		Unlock();
		onError();

		return -1;
	}
	MYSQL_RES *res_ptr = mysql_store_result(myConnect);
	if (res_ptr == NULL) 
	{
		Unlock();
		onError();

		return -1;
	}
	int num = mysql_num_rows(res_ptr);
	if(num <= 0)
	{
		Unlock();
//		printf("no data\n");
		return -2;
	}


	MYSQL_ROW sqlrow;

	
	sqlrow = mysql_fetch_row(res_ptr);		

	if(sqlrow[0] != NULL)
		memcpy(szOutSeqId, sqlrow[0], LEN_SEQ);
	if(sqlrow[1] != NULL)
		memcpy(szOutContent, sqlrow[1], 4000);
	if(sqlrow[2] != NULL)
		*RecordType = atoi(sqlrow[2]); 
	if(sqlrow[3] != NULL)
		*nPeerIp = atoi(sqlrow[3]);
	if(sqlrow[4] != NULL)
		*nFlagCancel = atoi(sqlrow[4]);

	mysql_free_result(res_ptr);	
	if (mysql_errno(myConnect)) 
	{
		Unlock();
		onError();
		return -1;
	}
	
	Unlock();

	return 0;
}


int C_MYSQL::DbGTPCount(char* pInSzTableName, long inIPeerIp, long inIPeerSeqId, long *nOutCount)
{
	char szSQL[SQLMAX];
	
	snprintf(szSQL, SQLMAX, 
		"SELECT COUNT(*) "
		"FROM %s WHERE PEERIP='%u' AND PEERSEQID='%u'", 
		pInSzTableName, 
		(unsigned long)inIPeerIp, 
		(unsigned long)inIPeerSeqId);

#ifdef _DEBUG
	logOra(sErrLog, szSQL);
#endif
	
	*nOutCount = 0;
	Lock();
	*nOutCount = DbCount(szSQL,myConnect);
	Unlock();

	return 0;
}


int C_MYSQL::DbGTPSelect2(long inIPeerIp, long inIPeerSeqId,
		char *pInSzTableName, 
		int *nRecordType, 
		char *szOutContent,
		char *szOutSeqId)
{
	char szMsg[512];
	
	
	char TableName[LEN_TABLENAME + 1];
		
	int nRecordType2;
	char szOutContent2[4000];
	char szOutSeqId2[LEN_SEQ];

	char szSQL[SQLMAX];
	short id;



	snprintf(szSQL, SQLMAX, 
		"SELECT RECORDTYPE,SEQID,CONTENT "
		"FROM %s WHERE PEERIP='%u' AND PEERSEQID='%u' ORDER BY SEQID DESC", 
		pInSzTableName, 
		(unsigned long)inIPeerIp, 
		(unsigned long)inIPeerSeqId);

#ifdef _DEBUG
//	logOra(sErrLog, szSQL);

#endif


	int res = mysql_real_query(myConnect, szSQL, strlen(szSQL));
	if(res != 0)
	{
		Unlock();
		onError();

		return -1;
	}

	MYSQL_RES *res_ptr = mysql_store_result(myConnect);
	if (res_ptr == NULL) 
	{
		Unlock();
		onError();

		return -1;
	}
	int num = mysql_num_rows(res_ptr);
	if(num <= 0)
	{
		Unlock();
	//	printf("no data\n");
		return -2;
	}

	MYSQL_ROW sqlrow;

	
	sqlrow = mysql_fetch_row(res_ptr);		

	if(sqlrow[0] != NULL)
		*nRecordType = atoi(sqlrow[0]); 
	if(sqlrow[1] != NULL)
		memcpy(szOutSeqId, sqlrow[1], LEN_SEQ);
	if(sqlrow[2] != NULL)
		memcpy(szOutContent, sqlrow[2], 4000);

	mysql_free_result(res_ptr);	
	if (mysql_errno(myConnect)) 
	{
		Unlock();
		onError();
		return -1;
	}
	
	Unlock();

	return 0;
}