db.pc

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

	
	sprintf(tblname,"%s_%s_%02d","TR_T_SENPAGE",TUTime::YYYYMM(),m_idate/m_idivTR_T_SENPAGE);

	sprintf(stmt,"%s %s %s %d ","UPDATE", tblname, "SET SPG_HASSUBMIT=1 WHERE SPG_ID=",id);

	EXEC SQL EXECUTE IMMIDIATE using :stmt; 
	
	if(checkSqlCode()!=0)
	{
		printf("%s  errcode=[%d] \n",stmt,sqlca.sqlcode);
	
		TLog::toErr("%s  errcode=[%d] \n",stmt,sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	*/

}


void 	CTblWeb::prepare()
{
	char tblname[64];
	int iTR_T_SENPAGE;
	int iTR_T_SUBMITCONTENT;

	EXEC SQL BEGIN DECLARE SECTION;
		char c_sql[256];
	EXEC SQL END DECLARE SECTION;
	
	iTR_T_SENPAGE= readTblDiv("TR_T_SENPAGE",TUTime::YYYYMM());
	if(iTR_T_SENPAGE<=0) iTR_T_SENPAGE=DEFAULT_DIV;
	
	iTR_T_SUBMITCONTENT= readTblDiv("TR_T_SUBMITCONTENT",TUTime::YYYYMM());
	if(iTR_T_SUBMITCONTENT<=0) iTR_T_SUBMITCONTENT=DEFAULT_DIV;
	
	sprintf(tblname,"%s_%s_%02d","TR_T_SENPAGE",TUTime::YYYYMM(),m_idate/iTR_T_SENPAGE);
	sprintf(c_sql,"%s %s %s", "INSERT INTO", tblname, "VALUES (:v1,:v2,:v3,:v4,:v5,:v6,:v7,:v8,:v9,:v10,:v11,:v12,:v13,:v14,:v15)");
	
	EXEC SQL PREPARE ins_TR_T_SENPAGE from :c_sql;  
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
		
	sprintf(tblname,"%s_%s_%02d","TR_T_SUBMITCONTENT",TUTime::YYYYMM(),m_idate/iTR_T_SUBMITCONTENT);
	sprintf(c_sql,"%s %s %s", "INSERT INTO", tblname, "VALUES (:v1,:v2,:v3,:v4)");
	
	EXEC SQL PREPARE ins_TR_T_SUBMITCONTENT from :c_sql;  
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
	sprintf(tblname,"%s_%s_%02d","TR_T_SENPAGE",TUTime::YYYYMM(),m_idate/iTR_T_SENPAGE);
	sprintf(c_sql,"%s %s %s","UPDATE", tblname, "SET SPG_HASSUBMIT=1 WHERE SPG_ID=:v1");
	
	EXEC SQL PREPARE upd_TR_T_SENPAGE from :c_sql;
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
}

void CTblWeb::close()
{
}

void CTblWeb::chkDate()
{
	if(m_idate!=TUTime::date())
	{
		close();
		prepare();
	}
}

int CTblWeb::insRecord(STRU_TR_T_SENPAGE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SENPAGE rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SENPAGE using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SENPAGE [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]", prec->SPG_ID);
		TLog::toErr("[%d]", prec->ACT_ID);
		TLog::toErr("[%d]", prec->WAP_ID);
		TLog::toErr("[%s]", prec->SPG_CLIENTIP);
		TLog::toErr("[%s]", prec->SPG_SERVERIP);
		TLog::toErr("[%s]", prec->SPG_DOMAINNAME);
		TLog::toErr("[%s]", prec->SPG_CAPTIME);
		TLog::toErr("[%d]", prec->SPG_DATAFLOW);
		TLog::toErr("[%s]", prec->SPG_CLNTLOCATION);
		TLog::toErr("[%s]", prec->SPG_CLNTACCOUNT);
		TLog::toErr("[%s]", prec->SPG_CLNTCALLID);
		TLog::toErr("[%s]", prec->SPG_PAGEPOSITION);		
		TLog::toErr("INSERT INTO TR_T_SENPAGE [%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;

}

int CTblWeb::insRecord(STRU_TR_T_SUBMITCONTENT *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SUBMITCONTENT rec;

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


CSpTblWeb::CSpTblWeb()
{
	prepare();
}

CSpTblWeb::~CSpTblWeb()
{
	
}

void CSpTblWeb::updateSPESUBMIT(int id)
{
	EXEC SQL BEGIN DECLARE SECTION;
		
		int ssp_id;
	EXEC SQL END DECLARE SECTION;
	
	ssp_id=id;
	
	EXEC SQL EXECUTE upd_TR_T_SPESENPAGE using :ssp_id; 
	
	if(checkSqlCode()!=0)
	{
		printf("update TR_T_SPESENPAG errcode=[%d] \n",sqlca.sqlcode);
	
		TLog::toErr(" update TR_T_SPESENPAG errcode=[%d] \n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
}

void 	CSpTblWeb::prepare()
{
	char tblname[64];
	
	EXEC SQL BEGIN DECLARE SECTION;
		char c_sql[256];
	EXEC SQL END DECLARE SECTION;
	
		
	sprintf(tblname,"%s","TR_T_SPESENPAGE");
	sprintf(c_sql,"%s %s %s", "INSERT INTO", tblname, "VALUES (:v1,:v2,:v3,:v4,:v5,:v6,:v7,:v8,:v9,:v10,:v11,:v12,:v13)");
	
	EXEC SQL PREPARE ins_TR_T_SPESENPAGE from :c_sql;  
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
		
	sprintf(tblname,"%s","TR_T_SPESUBMITCONTENT");
	sprintf(c_sql,"%s %s %s", "INSERT INTO", tblname, "VALUES (:v1,:v2,:v3,:v4)");
	
	EXEC SQL PREPARE ins_TR_T_SPESUBMITCONTENT from :c_sql;  
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}

	sprintf(tblname,"%s","TR_T_SPESENPAGE");
	sprintf(c_sql,"%s %s %s","UPDATE", tblname, "SET SSP_HASSUBMIT=1 WHERE SSP_ID=:v1");
	
	EXEC SQL PREPARE upd_TR_T_SPESENPAGE from :c_sql;
	if(checkSqlCode()!=0)
	{
		TLog::toErr("prepare [%s] [%d]\n",c_sql,sqlca.sqlcode);
	}
	
}

void CSpTblWeb::close()
{
}

int CSpTblWeb::insRecord(STRU_TR_T_SPESENPAGE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SPESENPAGE rec;

	EXEC SQL END DECLARE SECTION;
			
	memcpy((char *)(void *)&rec,(char *)(void *)prec,sizeof(rec));
	EXEC SQL execute ins_TR_T_SPESENPAGE using :rec;
	if(checkSqlCode()!=0)
	{
		printf("INSERT INTO TR_T_SPESENPAGE [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]", prec->SSP_ID);
		TLog::toErr("[%s]", prec->SSP_CLIENTIP);
		TLog::toErr("[%s]", prec->SSP_SERVERIP);
		TLog::toErr("[%s]", prec->SSP_DOMAINNAME);
		TLog::toErr("[%s]", prec->SSP_CAPTIME);
		TLog::toErr("[%d]", prec->SSP_DATAFLOW);
		TLog::toErr("[%s]", prec->SSP_CLNTLOCATION);
		TLog::toErr("[%s]", prec->SSP_CLNTACCOUNT);
		TLog::toErr("[%s]", prec->SSP_CLNTCALLID);
		TLog::toErr("[%s]", prec->SSP_PAGEPOSITION);		
		TLog::toErr("INSERT INTO TR_T_SPESENPAGE [%d]\n",sqlca.sqlcode);
	}
	else
		EXEC SQL COMMIT WORK;
	return sqlca.sqlcode;

}

int CSpTblWeb::insRecord(STRU_TR_T_SPESUBMITCONTENT *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SPESUBMITCONTENT rec;

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



int CTblWebApp::totCount_TR_T_SUBMITRULE()
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;

	EXEC SQL END DECLARE SECTION;


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

}

int CTblWebApp::totCount_TR_T_SUBMITRULE(int id)
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;
		int wmr_id;		

	EXEC SQL END DECLARE SECTION;
	
	wmr_id=id;

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

int CTblWebApp::totCount_TR_T_WEBMONRULE()
{
	EXEC SQL BEGIN DECLARE SECTION;

		long totrec=0;

	EXEC SQL END DECLARE SECTION;


	EXEC SQL select count(*) into :totrec from TR_T_WEBMONRULE;
	if(checkSqlCode()!=0)
	{
		printf("select count(*)  from TR_T_WEBMONRULE[%d]\n",sqlca.sqlcode);
		TLog::toErr("select count(*)  from TR_T_WEBMONRULE[%d]\n",sqlca.sqlcode);
	}
	if(sqlca.sqlcode<0)
		return (sqlca.sqlcode);
		
	return totrec;
}
	
int CTblWebApp::fetchRecord(STRU_TR_T_SUBMITRULE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SUBMITRULE rec;

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

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

	return sqlca.sqlcode;

}

int CTblWebApp::fetchRecord(STRU_TR_T_SUBMITRULE *prec, int _wmr_id)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_SUBMITRULE rec;
		int wmr_id;

	EXEC SQL END DECLARE SECTION;
	
	wmr_id=_wmr_id;
	if(!m_bcur_TR_T_SUBMITRULE1)
	{
		printf("open cur=%d\n",wmr_id);
		EXEC SQL declare cur_TR_T_SUBMITRULE1 cursor for select * from TR_T_SUBMITRULE WHERE WMR_ID=:wmr_id;
		EXEC SQL open cur_TR_T_SUBMITRULE1;
		m_bcur_TR_T_SUBMITRULE1=true;
	}
	
	EXEC SQL fetch cur_TR_T_SUBMITRULE1 into :rec;
	
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_SUBMITRULE1  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_SUBMITRULE1  [%d]\n",sqlca.sqlcode);
	}
	if(checkSqlCode()!=0)
	{
		EXEC SQL close cur_TR_T_SUBMITRULE1;
		m_bcur_TR_T_SUBMITRULE1=false;
		return sqlca.sqlcode;	
	}

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

	return sqlca.sqlcode;

}



int CTblWebApp::fetchRecord(STRU_TR_T_WEBMONRULE *prec)
{
	EXEC SQL BEGIN DECLARE SECTION;

		DBSTRU_TR_T_WEBMONRULE rec;

	EXEC SQL END DECLARE SECTION;
	
	if(!m_bcur_TR_T_WEBMONRULE)
	{
		EXEC SQL declare cur_TR_T_WEBMONRULE cursor for select * from TR_T_WEBMONRULE;
		EXEC SQL open cur_TR_T_WEBMONRULE;
		m_bcur_TR_T_WEBMONRULE=true;
	}
	
	EXEC SQL fetch cur_TR_T_WEBMONRULE into :rec;
	
	if(checkSqlCode()!=0)
	{
		printf("fetch cur_TR_T_WEBMONRULE  [%d]\n",sqlca.sqlcode);
		TLog::toErr("fetch cur_TR_T_WEBMONRULE  [%d]\n",sqlca.sqlcode);
		TLog::toErr("[%d]\n",rec.WMR_ID);
   	TLog::toErr("[%d]\n",rec.ACT_ID);
   	TLog::toErr("[%d]\n",rec.WAP_ID);
   	TLog::toErr("[%s]\n",rec.WMR_URLFEATURE);
   	TLog::toErr("[%d]\n",rec.WMR_DATAFLOW);
		
	}
	if(checkSqlCode()!=0)
	{
		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;