db.pc.not_sp

linux 上http email 协议分析程序 主要能够处理大数据量的主干网的应用

	{
		EXEC SQL close cur_TR_T_WEBMONRULE;
		m_bcur_TR_T_WEBMONRULE=false;
		return sqlca.sqlcode;	
	}

	memcpy((char *)(void *)prec,(char *)(void *)&rec,sizeof(rec));

	return sqlca.sqlcode;

}

void CTblWebApp::closeCur()
{
	if(m_bcur_TR_T_SUBMITRULE1)
	{
		EXEC SQL close cur_TR_T_SUBMITRULE1;
		m_bcur_TR_T_SUBMITRULE1=false;
	}
	
	if(m_bcur_TR_T_SUBMITRULE)
	{
		EXEC SQL close cur_TR_T_SUBMITRULE;
		m_bcur_TR_T_SUBMITRULE=false;
	}
	if(m_bcur_TR_T_WEBMONRULE)
	{
		EXEC SQL close cur_TR_T_WEBMONRULE;
		m_bcur_TR_T_WEBMONRULE=false;
	}

}

int CTblNet::insRecord(STRU_TR_T_INETACTION *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_INETACTION rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));

	EXEC SQL INSERT INTO TR_T_INETACTION VALUES (:rec);
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_INETACTION [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_INETACTION [%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	
	EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;

}


int CSeqNet::getS_TR_T_INETACTION()
{
	EXEC SQL BEGIN DECLARE SECTION;
		int i_id;
	EXEC SQL END DECLARE SECTION;
	
	EXEC SQL SELECT S_TR_T_INETACTION.NEXTVAL INTO :i_id FROM DUAL ;
	
	m_iS_TR_T_INETACTION=i_id;
	if(checkSqlCode()!=0)
	{
		printf("SELECT S_TR_T_INETACTION.NEXTVAL [%d]\n",sqlca.sqlcode);
		TLog::toErr("SELECT S_TR_T_INETACTION.NEXTVAL [%d]\n",sqlca.sqlcode);
	}
	return (m_iS_TR_T_INETACTION);
}

/*
	remove at 2004.7
int CTblAIMEDMAILADD::totCount()
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;

	EXEC SQL END DECLARE SECTION;

	EXEC SQL select count(*) into :totrec from TR_T_AIMEDMAILADD;
	if(checkSqlCode()!=0)
	{
		printf("select count(*) from TR_T_AIMEDMAILADD [%d]\n",sqlca.sqlcode);
		TLog::toErr("select count(*) from TR_T_AIMEDMAILADD [%d]\n",sqlca.sqlcode);
	}
	if(sqlca.sqlcode<0)
		return (sqlca.sqlcode);
		
	return totrec;
}
	
CTblAIMEDMAILADD::CTblAIMEDMAILADD()
{
	m_bcur_TR_T_AIMEDMAILADD=false;
}

CTblAIMEDMAILADD::~CTblAIMEDMAILADD()
{
	
}
	
	
int CTblAIMEDMAILADD::fetchRecord(STRU_TR_T_AIMEDMAILADD *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSSTRU_TR_T_AIMEDMAILADD rec;	
		
	EXEC SQL END DECLARE SECTION;
	
	if(!m_bcur_TR_T_AIMEDMAILADD)
	{
		EXEC SQL declare cur_TR_T_AIMEDMAILADD cursor for select * from TR_T_AIMEDMAILADD;
		EXEC SQL open cur_TR_T_AIMEDMAILADD;
		m_bcur_TR_T_AIMEDMAILADD=true;
	}
	
	EXEC SQL fetch cur_TR_T_AIMEDMAILADD into :rec;
	if(sqlca.sqlcode==-1405)
		sqlca.sqlcode=0;
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_AIMEDMAILADD  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_AIMEDMAILADD  [%d]\n",sqlca.sqlcode);
	}
	if(checkSqlCode()!=0)
	{
		EXEC SQL close cur_TR_T_AIMEDMAILADD;
		m_bcur_TR_T_AIMEDMAILADD=false;
		return sqlca.sqlcode;	
	}

	memcpy((char *)(void *)prec,(char *)(void *)&rec,sizeof(rec));

	return sqlca.sqlcode;
}
*/

int CTblEvent::insRecord(STRU_TR_T_ALARMEVENT *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_ALARMEVENT rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));

	EXEC SQL INSERT INTO TR_T_ALARMEVENT VALUES (:rec);
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_ALARMEVENT [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_ALARMEVENT [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]\n",rec.ALE_ID) ;
   		TLog::toErr("[%d]\n",rec.AMG_ID)  ;
   		TLog::toErr("[%d]\n",rec.ALE_ALARMTYPE) ;
   		TLog::toErr("[%d]\n",rec.ALE_ALARMSTATUS)  ;
  		TLog::toErr("[%s]\n",rec.ALE_ALARMTITLE);
   		TLog::toErr("[%s]\n",rec.ALE_ALARMCONTENT);
   		TLog::toErr("[%s]\n",rec.ALE_ALARMTIME);
	}
	else
		EXEC SQL COMMIT WORK;
	
	EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;

}

int CSeqEvent::getS_TR_T_ALARMEVENT()
{
	EXEC SQL BEGIN DECLARE SECTION;
		int i_id;
	EXEC SQL END DECLARE SECTION;
	
	EXEC SQL SELECT S_TR_T_ALARMEVENT.NEXTVAL INTO :i_id FROM DUAL ;
	
	m_iS_TR_T_ALARMEVENT=i_id;
	if(checkSqlCode()!=0)
	{
		printf("SELECT S_TR_T_ALARMEVENT.NEXTVAL [%d]\n",sqlca.sqlcode);
		TLog::toErr("SELECT S_TR_T_ALARMEVENT.NEXTVAL [%d]\n",sqlca.sqlcode);
	}
	return (m_iS_TR_T_ALARMEVENT);
}

/*
CTblAlarmSp::CTblAlarmSp()
{
	m_bcur_TR_T_COMMONMONSITE=false;
}

CTblAlarmSp::~CTblAlarmSp()
{
}

int CTblAlarmSp::tot_COMMONMONSITE()
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;

	EXEC SQL END DECLARE SECTION;

	EXEC SQL select count(*) into :totrec from TR_T_COMMONMONSITE;
	if(checkSqlCode()!=0)
	{
		printf("select count(*) from TR_T_COMMONMONSITE [%d]\n",sqlca.sqlcode);
		TLog::toErr("select count(*) from TR_T_COMMONMONSITE [%d]\n",sqlca.sqlcode);
	}
	if(sqlca.sqlcode<0)
		return (sqlca.sqlcode);
		
	return totrec;
}

int CTblAlarmSp::fetchRecord(STRU_TR_T_COMMONMONSITE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_COMMONMONSITE rec;	
		
	EXEC SQL END DECLARE SECTION;
	
	if(!m_bcur_TR_T_COMMONMONSITE)
	{
		EXEC SQL declare cur_TR_T_COMMONMONSITE cursor for select * from TR_T_COMMONMONSITE;
		EXEC SQL open cur_TR_T_COMMONMONSITE;
		m_bcur_TR_T_COMMONMONSITE=true;
	}
	
	EXEC SQL fetch cur_TR_T_COMMONMONSITE into :rec;
	if(sqlca.sqlcode==-1405)
		sqlca.sqlcode=0;
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_COMMONMONSITE  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_COMMONMONSITE  [%d]\n",sqlca.sqlcode);
	}
	if(checkSqlCode()!=0)
	{
		EXEC SQL close cur_TR_T_COMMONMONSITE;
		m_bcur_TR_T_COMMONMONSITE=false;
		return sqlca.sqlcode;	
	}

	memcpy((char *)(void *)prec,(char *)(void *)&rec,sizeof(rec));

	return sqlca.sqlcode;
}

*/

CTblAimedFeature::CTblAimedFeature()
{
	m_bcur_TR_T_AIMEDFEATURE=false;
}

CTblAimedFeature::~CTblAimedFeature()
{
	
}

int CTblAimedFeature::setFeature(int ifeature)
{
	m_iAFE_TYPE=ifeature;
}

int CTblAimedFeature::totCount_byFeature()
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;
		int	ifeature;

	EXEC SQL END DECLARE SECTION;

	ifeature=m_iAFE_TYPE;
		
	EXEC SQL select count(*) into :totrec from TR_T_AIMEDFEATURE where AFE_TYPE=:ifeature;
	if(checkSqlCode()!=0)
	{
		printf("select count(*) from TR_T_AIMEDFEATURE [%d]\n",sqlca.sqlcode);
		TLog::toErr("select count(*) from TR_T_AIMEDFEATURE [%d]\n",sqlca.sqlcode);
	}
	if(sqlca.sqlcode<0)
		return (sqlca.sqlcode);
		
	return totrec;
}

int CTblAimedFeature::fetchRecord_byFeature(STRU_TR_T_AIMEDFEATURE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_AIMEDFEATURE rec;
		int ifeature;

	EXEC SQL END DECLARE SECTION;
	
	if(!m_bcur_TR_T_AIMEDFEATURE)
	{
		ifeature=m_iAFE_TYPE;
		EXEC SQL declare cur_TR_T_AIMEDFEATURE cursor for select * from TR_T_AIMEDFEATURE where AFE_TYPE=:ifeature;
		EXEC SQL open cur_TR_T_AIMEDFEATURE;
		m_bcur_TR_T_AIMEDFEATURE=true;
	}
	
	EXEC SQL fetch cur_TR_T_AIMEDFEATURE into :rec;
	
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_AIMEDFEATURE  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_AIMEDFEATURE  [%d]\n",sqlca.sqlcode);
		EXEC SQL close cur_TR_T_AIMEDFEATURE;
		m_bcur_TR_T_AIMEDFEATURE=false;
		return sqlca.sqlcode;	
	}

	memcpy((char *)(void *)prec,(char *)(void *)&rec,sizeof(rec));

	return sqlca.sqlcode;

}


int CTblPARA::updateValue(char *pszval,int gpr_id)
{
	EXEC SQL BEGIN DECLARE SECTION;

		int igprid;
		char szval[4000+1];	
		
	EXEC SQL END DECLARE SECTION;
	
	igprid=gpr_id;
	
	strcpy(szval,pszval);
	EXEC SQL UPDATE TR_T_GENERALPARA SET GPR_PARAVALUE = :szval WHERE GPR_ID=:igprid;
	if(checkSqlCode()!=0)
	{
		printf("UPDATE TR_T_GENERALPARA [%d]\n",sqlca.sqlcode);
		TLog::toErr("UPDATE TR_T_GENERALPARA [%d]\n",sqlca.sqlcode);
	}
	EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;	
}

int CTblPARA::fetchRecord(STRU_TR_T_GENERALPARA *prec,char *paraname)
{
	EXEC SQL BEGIN DECLARE SECTION;

		char name[64+1];
		DBSTRU_TR_T_GENERALPARA rec;	
		
	EXEC SQL END DECLARE SECTION;
	
	if(!m_bcur_TR_T_GENERALPARA)
	{
		strcpy(name,paraname);
		EXEC SQL declare cur_TR_T_GENERALPARA cursor for select * from TR_T_GENERALPARA where GPR_PARANAME=:name;
		EXEC SQL open cur_TR_T_GENERALPARA;
		m_bcur_TR_T_GENERALPARA=true;
	}
	
	EXEC SQL fetch cur_TR_T_GENERALPARA into :rec;
	
	if(checkSqlCode()!=0)
	{
		int iret=sqlca.sqlcode;
		printf("fetch cur_TR_T_GENERALPARA  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_GENERALPARA  [%d]\n",sqlca.sqlcode);
		EXEC SQL close cur_TR_T_GENERALPARA;
		m_bcur_TR_T_GENERALPARA=false;
		return iret;	
	}

	memcpy((char *)(void *)prec,(char *)(void *)&rec,sizeof(rec));

	return sqlca.sqlcode;

}

CTblPARA::CTblPARA()
{
	m_bcur_TR_T_GENERALPARA=false;
}

CTblPARA::~CTblPARA()
{
	if(m_bcur_TR_T_GENERALPARA)
	{
		EXEC SQL close cur_TR_T_GENERALPARA;
		m_bcur_TR_T_GENERALPARA=false;
	}
}


int CSeqSpWarm::getS_TR_T_OBJECT2INFO()
{
	EXEC SQL BEGIN DECLARE SECTION;
		int i_id;
	EXEC SQL END DECLARE SECTION;
	
	EXEC SQL SELECT S_TR_T_OBJECT2INFO.NEXTVAL INTO :i_id FROM DUAL ;
	
	m_iS_TR_T_OBJECT2INFO=i_id;
	if(checkSqlCode()!=0)
	{
		printf("SELECT S_TR_T_OBJECT2INFO.NEXTVAL [%d]\n",sqlca.sqlcode);
		TLog::toErr("SELECT TR_T_OBJECT2INFO.NEXTVAL [%d]\n",sqlca.sqlcode);
	}
	return (m_iS_TR_T_OBJECT2INFO);
}

int CTblSpWarm::insRecord(STRU_TR_T_OBJECT2INFO *prec)
{

	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_OBJECT2INFO rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));

	EXEC SQL INSERT INTO TR_T_OBJECT2INFO VALUES (:rec);
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_OBJECT2INFO [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_OBJECT2INFO [%d]\n",sqlca.sqlcode);
		
	}
	else
		EXEC SQL COMMIT WORK;
	
	EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;

}

CTblSsl::CTblSsl()
{
	prepare();
}

CTblSsl::~CTblSsl()
{
}

void CTblSsl::prepare()
{
	EXEC SQL BEGIN DECLARE SECTION;
		char c_sql[512];
	EXEC SQL END DECLARE SECTION;

	strcpy(c_sql, "INSERT INTO TR_T_SSLWEBPAGE( SWP_ID, SWP_SERVERIP, SWP_CLIENTIP,SWP_CAPTIME,SWP_CLNTLOCATION, SWP_CLNTACCOUNT, SWP_CLNTCALLID) VALUES (:v1,:v2,:v3,:v4,:v5,:v6,:v7)");
	EXEC SQL PREPARE ins_TR_T_SSLWEBPAGE from :c_sql;  
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
}

int CTblSsl::insRecord(STRU_TR_T_SSLWEBPAGE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SSLWEBPAGE rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SSLWEBPAGE using :rec;
	//EXEC SQL INSERT INTO TR_T_SSLWEBPAGE VALUES (:rec);
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SSLWEBPAGE [%d]\n",sqlca.sqlcode);
		TLog::toErr("INSERT INTO TR_T_SSLWEBPAGE [%d]\n",sqlca.sqlcode);
		
	}
	else
		EXEC SQL COMMIT WORK;
	
	EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;

}

int CSeqSsl::getS_TR_T_SSLWEBPAGE()
{
	EXEC SQL BEGIN DECLARE SECTION;
		int i_id;
	EXEC SQL END DECLARE SECTION;
	
	EXEC SQL SELECT S_TR_T_SSLWEBPAGE.NEXTVAL INTO :i_id FROM DUAL ;
	
	m_iS_TR_T_SSLWEBPAGE=i_id;
	if(checkSqlCode()!=0)
	{
		printf("SELECT S_TR_T_SSLWEBPAGE.NEXTVAL [%d]\n",sqlca.sqlcode);
		TLog::toErr("SELECT S_TR_T_SSLWEBPAGE.NEXTVAL [%d]\n",sqlca.sqlcode);
	}
	return (m_iS_TR_T_SSLWEBPAGE);
}

int CSeqSsl::getS_TR_T_SSLSITE()
{
	EXEC SQL BEGIN DECLARE SECTION;
		int i_id;
	EXEC SQL END DECLARE SECTION;
	
	EXEC SQL SELECT S_TR_T_SSLSITE.NEXTVAL INTO :i_id FROM DUAL ;
	
	m_iS_TR_T_SSLSITE=i_id;
	if(checkSqlCode()!=0)
	{
		printf("SELECT S_TR_T_SSLSITE.NEXTVAL [%d]\n",sqlca.sqlcode);
		TLog::toErr("SELECT S_TR_T_SSLSITE.NEXTVAL [%d]\n",sqlca.sqlcode);
	}
	return (m_iS_TR_T_SSLSITE);
}

int CSeqSsl::getS_TR_T_DYNAMICIP()
{
	EXEC SQL BEGIN DECLARE SECTION;
		int i_id;
	EXEC SQL END DECLARE SECTION;
	
	EXEC SQL SELECT TR_T_DYNAMICIP.NEXTVAL INTO :i_id FROM DUAL ;
	
	m_iS_TR_T_DYNAMICIP=i_id;
	if(checkSqlCode()!=0)
	{
		printf("SELECT S_TR_T_DYNAMICIP.NEXTVAL [%d]\n",sqlca.sqlcode);
		TLog::toErr("SELECT S_TR_T_DYNAMICIP.NEXTVAL [%d]\n",sqlca.sqlcode);
	}
	return (m_iS_TR_T_SSLSITE);
}